The highest tagged major version is v2.

election

package

v1.1.2-beta Latest Latest Go to latest Published: Dec 2, 2023 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Election for leader node election

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

New returns a new Election

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

Run start election process

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

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

Manager is election cycle manager

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

NewManager returns a new manager

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

RoleCh return role chan

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

Run election cycle

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

type Option func(e *Election)

Option is function of set election

func OptionNode(node *node.Node) Option

OptionNode sets election node

func OptionTTL(ttl int) Option

OptionTTL sets election ttl