election

package

v0.0.0-...-7b93ac1 Latest Latest Go to latest Published: Oct 22, 2019 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var (
	// ErrNotLeader is returned when a node attempts to execute a leader-only
	// operation.
	ErrNotLeader = errors.New("not leader")
)

This section is empty.

type Config struct {
	Bind    string `json:"bind"`
	DataDir string `json:"data_dir"`
	Peers   string `json:"peers"`
}

Config ?

type Election struct {
	NodeStatCh  chan NodeState
	OperationCh chan OperationType
	// contains filtered or unexported fields
}

Election leader election with raft

func New(raftBindAddr utils.NetAddr, raftDataDir string, raftPeers utils.NetAddrList, enableSingle bool) *Election

New return an Election instance

func (p *Election) Join(id, addr string) error

Join let peers join into cluster

func (p *Election) RecvOperation(op OperationType) error

func (p *Election) RemovePeer(id string) error

func (p *Election) RemoveSvr(id string) error

func (p *Election) Start() error

Start start and maintain leader election and monitor

func (p *Election) TransferLeaderShip(id, address string) error

type NodeState int

NodeState follower, candidate, leader

const (
	//Follower value zero
	Follower NodeState = iota
	//Candidate value 1
	Candidate
	//Leader value 2
	Leader
)

func (e NodeState) String() string

type Operation interface {
	TransferLeaderShip(id, address string) error
	Join(id, address string) error
	RemoveSvr(id string) error
}

type OperationType int

OperationType for raft peers

const (
	// Remove remove raft peer
	Remove OperationType = iota
)