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

increase qps and burst

Browse Source
This commit is contained in:
liuwei
2020-11-13 13:54:00 +08:00
parent 979f3b6e77
commit 03b02f2cf2
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/hub/manager.go
View File

@@ -18,21 +18,31 @@ import (
"github.com/open-cluster-management/registration/pkg/hub/rbacfinalizerdeletion"
kubeinformers "k8s.io/client-go/informers"
"k8s.io/client-go/rest"
)
// RunControllerManager starts the controllers on hub to manage spoke cluster registration.
func RunControllerManager(ctx context.Context, controllerContext *controllercmd.ControllerContext) error {
kubeClient, err := kubernetes.NewForConfig(controllerContext.KubeConfig)
// If qps in kubconfig is not set, increase the qps and burst to enhance the ability of kube client to handle
// requests in concurrent
// TODO: Use ClientConnectionOverrides flags to change qps/burst when library-go exposes them in the future
kubeConfig := rest.CopyConfig(controllerContext.KubeConfig)
if kubeConfig.QPS == 0.0 {
kubeConfig.QPS = 100.0
kubeConfig.Burst = 200
}
kubeClient, err := kubernetes.NewForConfig(kubeConfig)
if err != nil {
return err
}
clusterClient, err := clusterv1client.NewForConfig(controllerContext.KubeConfig)
clusterClient, err := clusterv1client.NewForConfig(kubeConfig)
if err != nil {
return err
}
workClient, err := workv1client.NewForConfig(controllerContext.KubeConfig)
workClient, err := workv1client.NewForConfig(kubeConfig)
if err != nil {
return err
}