election

Documentation

Index

• type Elector
  • func NewElector(opts ...Option) (Elector, error)
• type Option
  • func WithEtcd(value *clientv3.Client) Option
  • func WithLeaderLeaseSec(value int64) Option
  • func WithLeaderPath(value string) Option
  • func WithLockPath(value string) Option

Types

type Elector

type Elector interface {
	// Stop stop elector
	Stop(frag uint64)

	// CurrentLeader returns current leader
	CurrentLeader(frag uint64) (uint64, error)

	// ElectionLoop run leader election loop
	ElectionLoop(ctx context.Context, frag, currentPeerID uint64, nodeChecker func(uint64) bool, becomeLeader, becomeFollower func())

	// ChangeLeaderTo change leader to
	ChangeLeaderTo(frag uint64, oldLeader, newLeader uint64) error
}

Elector leader election

func NewElector

func NewElector(opts ...Option) (Elector, error)

NewElector create a elector by options

type Option

type Option func(*options)

Option option for election

func WithEtcd

func WithEtcd(value *clientv3.Client) Option

WithEtcd set etcd client

func WithLeaderLeaseSec

func WithLeaderLeaseSec(value int64) Option

WithLeaderLeaseSec set leader lease time in seconds

func WithLeaderPath

func WithLeaderPath(value string) Option

WithLeaderPath set leader path

func WithLockPath

func WithLockPath(value string) Option

WithLockPath set lock path