raft

Documentation

Index

• func NewRaftServer(store *dovii.KVStore) (*raft.Raft, error)
• type BitcaskFSM
  • func (fsm *BitcaskFSM) Apply(raftLog *raft.Log) interface{}
  • func (fsm *BitcaskFSM) Restore(rc io.ReadCloser) error
  • func (fsm *BitcaskFSM) Snapshot() (raft.FSMSnapshot, error)
• type LogMessage

Functions

func NewRaftServer

func NewRaftServer(store *dovii.KVStore) (*raft.Raft, error)

Types

type BitcaskFSM

type BitcaskFSM struct {
	Store *dovii.KVStore
}

func (*BitcaskFSM) Apply

func (fsm *BitcaskFSM) Apply(raftLog *raft.Log) interface{}

func (*BitcaskFSM) Restore

func (fsm *BitcaskFSM) Restore(rc io.ReadCloser) error

func (*BitcaskFSM) Snapshot

func (fsm *BitcaskFSM) Snapshot() (raft.FSMSnapshot, error)

type LogMessage

type LogMessage struct {
	Key   string
	Value string
}