alexlebens/external-snapshotter
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixed the bug introduced by PR 621 and exposed the kube-api-qps cmd option properly

Browse Source
This commit is contained in:
Lintong Jiang
2021-12-10 12:51:32 -08:00
parent 070312031a
commit 9d1492a945
4 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
cmd/snapshot-controller/main.go
View File

@@ -27,7 +27,6 @@ import (
"sync"
"time"
"github.com/spf13/pflag"
"k8s.io/client-go/kubernetes"
"k8s.io/client-go/kubernetes/scheme"
"k8s.io/client-go/rest"
@@ -62,7 +61,7 @@ var (
leaderElectionRenewDeadline = flag.Duration("leader-election-renew-deadline", 10*time.Second, "Duration, in seconds, that the acting leader will retry refreshing leadership before giving up. Defaults to 10 seconds.")
leaderElectionRetryPeriod = flag.Duration("leader-election-retry-period", 5*time.Second, "Duration, in seconds, the LeaderElector clients should wait between tries of actions. Defaults to 5 seconds.")
kubeAPIQPS = pflag.Float32("kube-api-qps", 5, "QPS to use while communicating with the kubernetes apiserver. Defaults to 5.0.")
kubeAPIQPS = flag.Float64("kube-api-qps", 5, "QPS to use while communicating with the kubernetes apiserver. Defaults to 5.0.")
kubeAPIBurst = flag.Int("kube-api-burst", 10, "Burst to use while communicating with the kubernetes apiserver. Defaults to 10.")
httpEndpoint = flag.String("http-endpoint", "", "The TCP network address where the HTTP server for diagnostics, including metrics, will listen (example: :8080). The default is empty string, which means the server is disabled.")
@@ -131,7 +130,7 @@ func main() {
os.Exit(1)
}
config.QPS = *kubeAPIQPS
config.QPS = (float32)(*kubeAPIQPS)
config.Burst = *kubeAPIBurst
kubeClient, err := kubernetes.NewForConfig(config)