Skip to content

Commit 24b3390

Browse files
authored
improve performance while processing the virtual servers with host group (#3952)
1 parent 50f2dbc commit 24b3390

File tree

1 file changed

+30
-0
lines changed

1 file changed

+30
-0
lines changed

pkg/controller/worker.go

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -403,6 +403,16 @@ func (ctlr *Controller) processResources() bool {
403403
break
404404
}
405405
for _, virtual := range virtuals {
406+
if rKey.event == Create {
407+
rscKey := resourceRef{
408+
kind: VirtualServer,
409+
name: virtual.Name,
410+
namespace: virtual.Namespace,
411+
}
412+
if _, ok := ctlr.resources.processedNativeResources[rscKey]; ok {
413+
continue
414+
}
415+
}
406416
err := ctlr.processVirtualServers(virtual, false)
407417
if err != nil {
408418
// TODO
@@ -461,6 +471,16 @@ func (ctlr *Controller) processResources() bool {
461471
break
462472
}
463473
for _, virtual := range virtuals {
474+
if rKey.event == Create {
475+
rscKey := resourceRef{
476+
kind: VirtualServer,
477+
name: virtual.Name,
478+
namespace: virtual.Namespace,
479+
}
480+
if _, ok := ctlr.resources.processedNativeResources[rscKey]; ok {
481+
continue
482+
}
483+
}
464484
err := ctlr.processVirtualServers(virtual, false)
465485
if err != nil {
466486
// TODO
@@ -560,6 +580,16 @@ func (ctlr *Controller) processResources() bool {
560580
virtuals := ctlr.getVirtualsForCustomPolicy(cp)
561581
//Sync Custompolicy for Virtual Servers
562582
for _, virtual := range virtuals {
583+
if rKey.event == Create {
584+
rscKey := resourceRef{
585+
kind: VirtualServer,
586+
name: virtual.Name,
587+
namespace: virtual.Namespace,
588+
}
589+
if _, ok := ctlr.resources.processedNativeResources[rscKey]; ok {
590+
continue
591+
}
592+
}
563593
err := ctlr.processVirtualServers(virtual, false)
564594
if err != nil {
565595
// TODO

0 commit comments

Comments
 (0)