election

Documentation

Index

• type Elector
  • func NewElector(opts Opts) (leader *Elector, onPromote <-chan time.Time, onDemote <-chan time.Time, ...)
  • func (i *Elector) IsLeader(context.Context) error
  • func (i *Elector) Start()
  • func (i *Elector) Stop() error
• type Opts

Types

type Elector

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

func NewElector

func NewElector(opts Opts) (leader *Elector, onPromote <-chan time.Time, onDemote <-chan time.Time, onError <-chan error)

func (*Elector) IsLeader

func (i *Elector) IsLeader(context.Context) error

func (*Elector) Start

func (i *Elector) Start()

func (*Elector) Stop

func (i *Elector) Stop() error

type Opts

type Opts struct {
	Redis    redis.Scripter
	TTL      time.Duration
	Wait     time.Duration
	JitterMS int
	Key      string
}