raft

type AppendEntriesArg struct {
	Term         Term
	LeaderID     NodeIndex
	PrevLogIndex LogEntryIndex
	PrevLogTerm  LogEntryIndex
	Entries      []LogEntry
	LeaderCommit LogEntryIndex
}

type AppendEntriesReply struct {
	CurrentTerm Term
	Success     bool
	// return conflict info to leader
	ConflictTerm  Term
	ConflictIndex LogEntryIndex
}

type ApplyMsg struct {
	Index   LogEntryIndex
	Command interface{}

	UseSnapshot bool   // ignore for lab2; only used in lab3
	Snapshot    []byte // ignore for lab2; only used in lab3
}

type ApplyReceipt struct {
	Term  Term
	Index LogEntryIndex
	Err   error
}

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

type Config struct {
	ElectionTimeout  time.Duration
	HeartbeatTimeout time.Duration
}

type ConnectInfo struct {
	Addrs []string
	Index int
}

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

type InstallSnapshotArg struct {
	Term              Term
	LeaderID          NodeIndex
	LastIncludedIndex LogEntryIndex
	LastIncludedTerm  Term
	Snapshot          []byte
}

type InstallSnapshotReply struct {
	CurrentTerm Term
}

type KV struct {
	Raft *Raft
	// contains filtered or unexported fields
}

type Log struct {
	Logs []LogEntry

	CommitIndex LogEntryIndex
	LastApplied LogEntryIndex
	Snapshot    LogSnapshot
	// contains filtered or unexported fields
}

type LogEntry struct {
	Term    int
	Command interface{}
}

type LogEntryIndex = int

type LogSnapshot struct {
	LastIncludedIndex LogEntryIndex
	LastIncludedTerm  Term
}

type NodeIndex = int

type Peer interface {
	Call(method string, arg interface{}, reply interface{}) error
}

type RPCDelegate struct {
	Raft *Raft
}

type Raft struct {
	Config

	StableStore

	Id          NodeIndex
	Role        Role
	CurrentTerm Term

	Log
	// contains filtered or unexported fields
}

type RequestVoteArg struct {
	Term         Term
	CandidateID  NodeIndex
	LastLogIndex LogEntryIndex
	LastLogTerm  Term
}

type RequestVoteReply struct {
	CurrentTerm Term
	VoteGranted bool
}

type Role = int

type StableStore interface {
	LoadStatus() ([]byte, error)
	LoadSnapshot() ([]byte, error)
	StoreStatus([]byte) error
	StoreSnapshot([]byte) error
	StateSize() int
}

type Term = int