From 17e79ac238b635718544bb388bc62b5a09a37c87 Mon Sep 17 00:00:00 2001 From: shahra Date: Wed, 29 Jul 2020 14:01:11 -0700 Subject: [PATCH] Use separate client for leader election --- cmd/csi-snapshotter/main.go | 8 +++++++- cmd/snapshot-controller/main.go | 8 +++++++- 2 files changed, 14 insertions(+), 2 deletions(-) diff --git a/cmd/csi-snapshotter/main.go b/cmd/csi-snapshotter/main.go index 4fa94f92..d2beaf7e 100644 --- a/cmd/csi-snapshotter/main.go +++ b/cmd/csi-snapshotter/main.go @@ -193,7 +193,13 @@ func main() { run(context.TODO()) } else { lockName := fmt.Sprintf("%s-%s", prefix, strings.Replace(driverName, "/", "-", -1)) - le := leaderelection.NewLeaderElection(kubeClient, lockName, run) + // Create a new clientset for leader election to prevent throttling + // due to snapshot sidecar + leClientset, err := kubernetes.NewForConfig(config) + if err != nil { + klog.Fatalf("failed to create leaderelection client: %v", err) + } + le := leaderelection.NewLeaderElection(leClientset, lockName, run) if *leaderElectionNamespace != "" { le.WithNamespace(*leaderElectionNamespace) } diff --git a/cmd/snapshot-controller/main.go b/cmd/snapshot-controller/main.go index cc557c29..1c8cfee1 100644 --- a/cmd/snapshot-controller/main.go +++ b/cmd/snapshot-controller/main.go @@ -120,7 +120,13 @@ func main() { run(context.TODO()) } else { lockName := "snapshot-controller-leader" - le := leaderelection.NewLeaderElection(kubeClient, lockName, run) + // Create a new clientset for leader election to prevent throttling + // due to snapshot controller + leClientset, err := kubernetes.NewForConfig(config) + if err != nil { + klog.Fatalf("failed to create leaderelection client: %v", err) + } + le := leaderelection.NewLeaderElection(leClientset, lockName, run) if *leaderElectionNamespace != "" { le.WithNamespace(*leaderElectionNamespace) }