github/open-cluster-management
1
0
Fork 0
mirror of https://github.com/open-cluster-management-io/ocm.git synced 2026-05-21 16:43:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

increse controller workers for available and cleanup (#200)

Browse Source 
Signed-off-by: Wei Liu <liuweixa@redhat.com>
This commit is contained in:
Wei Liu
2023-04-25 15:07:10 +08:00
committed by GitHub
parent 656a7e9866
commit 10037a429d
1 changed files with 15 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
pkg/spoke/spokeagent.go
View File

@@ -26,6 +26,18 @@ import (
"sigs.k8s.io/controller-runtime/pkg/client/apiutil"
)
const (
// If a controller queue size is too large (>500), the processing speed of the controller will drop significantly
// with one worker, increasing the work numbers can imporve the processing speed.
// We compared the two situations where the worker is set to 1 and 10, when the worker is 10, the resource
// utilization of the kubeapi-server and work agent do not increase significantly.
//
// TODO expose a flag to set the worker for each controller
appliedManifestWorkFinalizeControllerWorkers = 10
manifestWorkFinalizeControllerWorkers = 10
availableStatusControllerWorkers = 10
)
// WorkloadAgentOptions defines the flags for workload agent
type WorkloadAgentOptions struct {
HubKubeconfigFile string
@@ -192,12 +204,12 @@ func (o *WorkloadAgentOptions) RunWorkloadAgent(ctx context.Context, controllerC
go workInformerFactory.Start(ctx.Done())
go spokeWorkInformerFactory.Start(ctx.Done())
go addFinalizerController.Run(ctx, 1)
go appliedManifestWorkFinalizeController.Run(ctx, 1)
go appliedManifestWorkFinalizeController.Run(ctx, appliedManifestWorkFinalizeControllerWorkers)
go unmanagedAppliedManifestWorkController.Run(ctx, 1)
go appliedManifestWorkController.Run(ctx, 1)
go manifestWorkController.Run(ctx, 1)
go manifestWorkFinalizeController.Run(ctx, 1)
go availableStatusController.Run(ctx, 1)
go manifestWorkFinalizeController.Run(ctx, manifestWorkFinalizeControllerWorkers)
go availableStatusController.Run(ctx, availableStatusControllerWorkers)
<-ctx.Done()
return nil
}