elector

Documentation

Index

• type LeaderCallbacks
• type LeaderElector
  • func NewLeaderElector(config componentbaseconfig.LeaderElectionConfiguration, ...) (LeaderElector, error)

Types

type LeaderCallbacks

type LeaderCallbacks struct {
	// OnStartedLeading is called when a LeaderElector client starts leading
	OnStartedLeading func(shardId int)
	// OnStoppedLeading is called when a LeaderElector client stops leading
	OnStoppedLeading func(shardId int)
}

type LeaderElector

type LeaderElector interface {
	Run(ctx context.Context)
	IsLeader(shardId int) bool
	GetLeaders() map[int]proxyv1alpha1.EndpointInfo
	SetCallbacks(LeaderCallbacks)
}

func NewLeaderElector

func NewLeaderElector(config componentbaseconfig.LeaderElectionConfiguration, client clientset.Interface, identity string, ShardingCount int) (LeaderElector, error)