election

Documentation

Index

• type Election
  • func New(opts ...Option) (e *Election)
  • func (e *Election) Run(ctx context.Context)
  • func (e *Election) Stopped() chan struct{}
• type Manager
  • func NewManager(optNode *node.Node) (m *Manager)
  • func (m *Manager) RoleCh() chan role.Role
  • func (m *Manager) Run(ctx context.Context)
  • func (m *Manager) Stopped() chan struct{}
• type Option
  • func OptionNode(node *node.Node) Option
  • func OptionTTL(ttl int) Option

Types

type Election

type Election struct {
	RoleCh chan role.Role
	// contains filtered or unexported fields
}

Election for leader node election

func New

func New(opts ...Option) (e *Election)

New returns a new Election

func (*Election) Run

func (e *Election) Run(ctx context.Context)

Run start election process

func (*Election) Stopped

func (e *Election) Stopped() chan struct{}

type Manager

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

Manager is election cycle manager

func NewManager

func NewManager(optNode *node.Node) (m *Manager)

NewManager returns a new manager

func (*Manager) RoleCh

func (m *Manager) RoleCh() chan role.Role

RoleCh return role chan

func (*Manager) Run

func (m *Manager) Run(ctx context.Context)

Run election cycle

func (*Manager) Stopped

func (m *Manager) Stopped() chan struct{}

type Option

type Option func(e *Election)

Option is function of set election

func OptionNode

func OptionNode(node *node.Node) Option

OptionNode sets election node

func OptionTTL

func OptionTTL(ttl int) Option

OptionTTL sets election ttl