mgr

package

v0.1.0 Latest Latest Go to latest Published: Jan 7, 2022 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func NewDefaultTicker(d time.Duration) *defaultTicker

type Config struct {
	TickIntervalMilliSec int64
	ElectionTimeoutMin   int64
	ElectionTimeoutMax   int64
	DebugMode            bool
}

type ConfigChange struct {
	Op     ConfigOp
	Server core.Address
}

type ConfigOp int

const (
	Add ConfigOp = iota
	Remove
)

type RaftManager struct {
	Dispatcher dispatcher
	// contains filtered or unexported fields
}

func NewRaftMgr(cls core.Cluster, cfg Config, sm core.StateMachine, inputCh chan *Rpc) *RaftManager

func NewRaftMgrWithTicker(cls core.Cluster, cfg Config, sm core.StateMachine, inputCh chan *Rpc, ticker Ticker) *RaftManager

func (m *RaftManager) GetAllEntries() []core.Entry

func (m *RaftManager) GetOthers() []core.Address

func (m *RaftManager) IsCandidate() bool

func (m *RaftManager) IsFollower() bool

func (m *RaftManager) IsLeader() bool

func (m *RaftManager) Run()

func (m *RaftManager) Stop()

type Rpc struct {
	Ctx     context.Context
	Addr    core.Address
	Payload interface{}
}

type Ticker interface {
	GetTickCh() <-chan time.Time
	Start()
	Stop()
}