Merge pull request #4158 from yanfeng1992/scheduler-add-leaderelectco…

…nfig

Introduced leaderElection options including: `--leader-elect-lease-duration`, `--leader-elect-renew-deadline`, `--leader-elect-retry-period`

cmd/scheduler/app/options/options.go

@@ -98,6 +98,19 @@ func (o *Options) AddFlags(fs *pflag.FlagSet) {
  fs.BoolVar(&o.LeaderElection.LeaderElect, "leader-elect", true, "Enable leader election, which must be true when running multi instances.")
  fs.StringVar(&o.LeaderElection.ResourceName, "leader-elect-resource-name", "karmada-scheduler", "The name of resource object that is used for locking during leader election.")
  fs.StringVar(&o.LeaderElection.ResourceNamespace, "leader-elect-resource-namespace", util.NamespaceKarmadaSystem, "The namespace of resource object that is used for locking during leader election.")
+ fs.DurationVar(&o.LeaderElection.LeaseDuration.Duration, "leader-elect-lease-duration", defaultElectionLeaseDuration.Duration, ""+
+ "The duration that non-leader candidates will wait after observing a leadership "+
+ "renewal until attempting to acquire leadership of a led but unrenewed leader "+
+ "slot. This is effectively the maximum duration that a leader can be stopped "+
+ "before it is replaced by another candidate. This is only applicable if leader "+
+ "election is enabled.")
+ fs.DurationVar(&o.LeaderElection.RenewDeadline.Duration, "leader-elect-renew-deadline", defaultElectionRenewDeadline.Duration, ""+
+ "The interval between attempts by the acting master to renew a leadership slot "+
+ "before it stops leading. This must be less than or equal to the lease duration. "+
+ "This is only applicable if leader election is enabled.")
+ fs.DurationVar(&o.LeaderElection.RetryPeriod.Duration, "leader-elect-retry-period", defaultElectionRetryPeriod.Duration, ""+
+ "The duration the clients should wait between attempting acquisition and renewal "+
+ "of a leadership. This is only applicable if leader election is enabled.")
  fs.StringVar(&o.KubeConfig, "kubeconfig", o.KubeConfig, "Path to karmada control plane kubeconfig file.")
  fs.StringVar(&o.Master, "master", o.Master, "The address of the Kubernetes API server. Overrides any value in KubeConfig. Only required if out-of-cluster.")
  fs.StringVar(&o.BindAddress, "bind-address", defaultBindAddress, "The IP address on which to listen for the --secure-port port.")