election

Jul 11, 2019

Changes in this version

type RunnerConfig

+ MasterHoldJitter time.Duration

+ func (cfg *RunnerConfig) ResignDelay() time.Duration

Jun 22, 2018

Changes in this version

+ const MinMasterCheckInterval

+ const MinMasterHoldInterval

+ const MinPreElectionPause

+ var ErrNoMaster = errors.New("no master")

+ func HeldInfo(held []int64, ids []int64) string

+ type Factory interface

+ NewElection func(ctx context.Context, treeID int64) (MasterElection, error)

+ type MasterElection interface

+ Close func(context.Context) error

+ GetCurrentMaster func(context.Context) (string, error)

+ IsMaster func(context.Context) (bool, error)

+ Resign func(context.Context) error

+ Start func(context.Context) error

+ WaitForMastership func(context.Context) error

+ type MasterTracker struct

+ func NewMasterTracker(ids []int64, notify func(id int64, isMaster bool)) *MasterTracker

+ func (mt *MasterTracker) Count() int

+ func (mt *MasterTracker) Held() []int64

+ func (mt *MasterTracker) IDs() []int64

+ func (mt *MasterTracker) Set(id int64, val bool)

+ func (mt *MasterTracker) String() string

+ type NoopElection struct

+ func (ne *NoopElection) Close(ctx context.Context) error

+ func (ne *NoopElection) GetCurrentMaster(ctx context.Context) (string, error)

+ func (ne *NoopElection) IsMaster(ctx context.Context) (bool, error)

+ func (ne *NoopElection) Resign(ctx context.Context) error

+ func (ne *NoopElection) Start(ctx context.Context) error

+ func (ne *NoopElection) WaitForMastership(ctx context.Context) error

+ type NoopFactory struct

+ InstanceID string

+ func (nf NoopFactory) NewElection(ctx context.Context, treeID int64) (MasterElection, error)

+ type Resignation struct

+ ID int64

+ func (r *Resignation) Execute(ctx context.Context)

+ type Runner struct

+ Cancel context.CancelFunc

+ func NewRunner(id int64, cfg *RunnerConfig, tracker *MasterTracker, cancel context.CancelFunc, ...) *Runner

+ func (er *Runner) Run(ctx context.Context, pending chan<- Resignation)

+ func (er *Runner) ShouldResign(masterSince time.Time) bool

+ type RunnerConfig struct

+ MasterCheckInterval time.Duration

+ MasterHoldInterval time.Duration

+ PreElectionPause time.Duration

+ ResignOdds int

+ TimeSource util.TimeSource