diff --git a/pkg/lockers/k8s_locker/k8s_locker.go b/pkg/lockers/k8s_locker/k8s_locker.go index 073fedc32..6e7bb4893 100644 --- a/pkg/lockers/k8s_locker/k8s_locker.go +++ b/pkg/lockers/k8s_locker/k8s_locker.go @@ -67,6 +67,8 @@ type config struct { RenewPeriod time.Duration `mapstructure:"renew-period,omitempty" json:"renew-period,omitempty"` RetryTimer time.Duration `mapstructure:"retry-timer,omitempty" json:"retry-timer,omitempty"` Debug bool `mapstructure:"debug,omitempty" json:"debug,omitempty"` + QPS float32 `mapstructure:"qps,omitempty" json:"qps,omitempty"` + Burst int `mapstructure:"burst,omitempty" json:"burst,omitempty"` } type lock struct { @@ -91,6 +93,13 @@ func (k *k8sLocker) Init(ctx context.Context, cfg map[string]interface{}, opts . return err } + if k.Cfg.QPS > 0 { + inClusterConfig.QPS = k.Cfg.QPS + } + if k.Cfg.Burst > 0 { + inClusterConfig.Burst = k.Cfg.Burst + } + k.clientset, err = kubernetes.NewForConfig(inClusterConfig) if err != nil { return err