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

Use separate client for leader election

Browse Source
This commit is contained in:
shahra
2020-07-29 14:01:11 -07:00
parent d24d2b9820
commit 17e79ac238
2 changed files with 14 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
cmd/csi-snapshotter/main.go
View File

@@ -193,7 +193,13 @@ func main() {
run(context.TODO()) run(context.TODO())
} else { } else {
lockName := fmt.Sprintf("%s-%s", prefix, strings.Replace(driverName, "/", "-", -1)) 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 != "" { if *leaderElectionNamespace != "" {
le.WithNamespace(*leaderElectionNamespace) le.WithNamespace(*leaderElectionNamespace)
} }

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

@@ -120,7 +120,13 @@ func main() {
run(context.TODO()) run(context.TODO())
} else { } else {
lockName := "snapshot-controller-leader" 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 != "" { if *leaderElectionNamespace != "" {
le.WithNamespace(*leaderElectionNamespace) le.WithNamespace(*leaderElectionNamespace)
} }