election

type Elector interface {
	IsLeader() bool
	GetLeader() string
	MyIdentity() string
	Run(ctx context.Context)
}

type Option func(*Options)

type Options struct {
	Identity      string
	LockType      string
	KubeClient    kubernetes.Interface
	EventRecorder record.EventRecorder
	Namespace     string
	Name          string
	LeaseDuration time.Duration
	RenewDuration time.Duration
	RetryPeriod   time.Duration
	HealthChecker *leaderelection.HealthzAdaptor

	// OnStartedLeading is called when a LeaderElector client starts leading
	OnStartedLeading func(context.Context)
	// OnStoppedLeading is called when a LeaderElector client stops leading
	OnStoppedLeading func()
	// OnNewLeader is called when the client observes a leader that is
	// not the previously observed leader. This includes the first observed
	// leader when the client starts.
	OnNewLeader func(identity string)
}