Skip to content

Commit 2f2b347

Browse files
authored
feat(core): add priority queue for controller (#1642)
Description Using priority queue for slightly improving performance for each controller. --------- Signed-off-by: Daniil Antoshin <daniil.antoshin@flant.com>
1 parent d01ce36 commit 2f2b347

File tree

18 files changed

+18
-0
lines changed

18 files changed

+18
-0
lines changed

images/virtualization-artifact/pkg/controller/cvi/cvi_controller.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,7 @@ func NewController(
8585
RecoverPanic: ptr.To(true),
8686
LogConstructor: logger.NewConstructor(log),
8787
CacheSyncTimeout: 10 * time.Minute,
88+
UsePriorityQueue: ptr.To(true),
8889
})
8990
if err != nil {
9091
return nil, err

images/virtualization-artifact/pkg/controller/evacuation/evacuation_controller.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@ func SetupController(
5252
RecoverPanic: ptr.To(true),
5353
LogConstructor: logger.NewConstructor(log),
5454
CacheSyncTimeout: 10 * time.Minute,
55+
UsePriorityQueue: ptr.To(true),
5556
})
5657
if err != nil {
5758
return err

images/virtualization-artifact/pkg/controller/livemigration/live_migration_controller.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ func SetupController(
5050
RecoverPanic: ptr.To(true),
5151
LogConstructor: logger.NewConstructor(log),
5252
CacheSyncTimeout: 10 * time.Minute,
53+
UsePriorityQueue: ptr.To(true),
5354
})
5455
if err != nil {
5556
return err

images/virtualization-artifact/pkg/controller/vd/vd_controller.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -98,6 +98,7 @@ func NewController(
9898
RecoverPanic: ptr.To(true),
9999
LogConstructor: logger.NewConstructor(log),
100100
CacheSyncTimeout: 10 * time.Minute,
101+
UsePriorityQueue: ptr.To(true),
101102
})
102103
if err != nil {
103104
return nil, err

images/virtualization-artifact/pkg/controller/vdsnapshot/vdsnapshot_controller.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,7 @@ func NewController(
5858
RecoverPanic: ptr.To(true),
5959
LogConstructor: logger.NewConstructor(log),
6060
CacheSyncTimeout: 10 * time.Minute,
61+
UsePriorityQueue: ptr.To(true),
6162
})
6263
if err != nil {
6364
return nil, err

images/virtualization-artifact/pkg/controller/vi/vi_controller.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -91,6 +91,7 @@ func NewController(
9191
RecoverPanic: ptr.To(true),
9292
LogConstructor: logger.NewConstructor(log),
9393
CacheSyncTimeout: 10 * time.Minute,
94+
UsePriorityQueue: ptr.To(true),
9495
})
9596
if err != nil {
9697
return nil, err

images/virtualization-artifact/pkg/controller/vm/vm_controller.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -88,6 +88,7 @@ func SetupController(
8888
RecoverPanic: ptr.To(true),
8989
LogConstructor: logger.NewConstructor(log),
9090
CacheSyncTimeout: 10 * time.Minute,
91+
UsePriorityQueue: ptr.To(true),
9192
})
9293
if err != nil {
9394
return err

images/virtualization-artifact/pkg/controller/vmbda/vmbda_controller.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ func NewController(
6161
RecoverPanic: ptr.To(true),
6262
LogConstructor: logger.NewConstructor(lg),
6363
CacheSyncTimeout: 10 * time.Minute,
64+
UsePriorityQueue: ptr.To(true),
6465
})
6566
if err != nil {
6667
return nil, err

images/virtualization-artifact/pkg/controller/vmclass/vmclass_controller.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,7 @@ func NewController(
5858
RecoverPanic: ptr.To(true),
5959
LogConstructor: logger.NewConstructor(log),
6060
CacheSyncTimeout: 10 * time.Minute,
61+
UsePriorityQueue: ptr.To(true),
6162
})
6263
if err != nil {
6364
return nil, err

images/virtualization-artifact/pkg/controller/vmip/vmip_controller.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,7 @@ func NewController(
6868
RecoverPanic: ptr.To(true),
6969
LogConstructor: logger.NewConstructor(log),
7070
CacheSyncTimeout: 10 * time.Minute,
71+
UsePriorityQueue: ptr.To(true),
7172
})
7273
if err != nil {
7374
return nil, err

0 commit comments

Comments
 (0)