election

Documentation

Index

• type K8sLeaderElectionMgr
  • func NewK8sLeaderElectionMgr(electionNamespace string, expectedMaxSkewMS, renewDeadlineMS time.Duration, ...) (*K8sLeaderElectionMgr, error)
  • func (le *K8sLeaderElectionMgr) Campaign(ctx context.Context) error

Types

type K8sLeaderElectionMgr

type K8sLeaderElectionMgr struct {
	// contains filtered or unexported fields
}

K8sLeaderElectionMgr manages leader election among cloud connectors by talking to the leader election side car.

func NewK8sLeaderElectionMgr

func NewK8sLeaderElectionMgr(electionNamespace string, expectedMaxSkewMS, renewDeadlineMS time.Duration, electionName string) (*K8sLeaderElectionMgr, error)

NewK8sLeaderElectionMgr creates a K8sLeaderElectionMgr.

func (*K8sLeaderElectionMgr) Campaign

func (le *K8sLeaderElectionMgr) Campaign(ctx context.Context) error

Campaign blocks until this node is the leader.