leaderelector

Oct 24, 2022

Changes in this version

+ func IsDisabled() bool

Oct 4, 2022

Changes in this version

type Identity

+ Elected func() <-chan struct{}

+ type LeaderStartupAction struct

+ func NewLeaderStartupAction(identity Identity) *LeaderStartupAction

+ func (a *LeaderStartupAction) GetAction() func() error

+ func (a *LeaderStartupAction) SetAction(action func() error)

+ func (a *LeaderStartupAction) WatchElectionResults(ctx context.Context)

Aug 26, 2022

Changes in this version

+ func NewIdentity(leaderValue *atomic.Bool) *identityImpl

+ type ElectionConfig struct

+ Id string

+ Namespace string

+ OnNewLeader func(leaderId string)

+ OnStartedLeading func(c context.Context)

+ OnStoppedLeading func()

+ type ElectionFactory interface

+ StartElection func(ctx context.Context, config *ElectionConfig) (Identity, error)

+ type Identity interface

+ IsLeader func() bool