lib

type ConfChange interface {
	// ID returns configuration change ID
	ID() uint64
	// Type returns configuration change type
	Type() ConfChangeType
	// NodeID returns node id concerned
	NodeID() uint64
	// Context returs some associated data
	Context() []byte
	// Unmarshal deserializes the structure
	Unmarshal([]byte) error
}

type ConfChangeType int32

type ConfState interface {
	// Nodes returns cluster nodes
	Nodes() []uint64
	// Learners returns non-voting nodes
	Learners() []uint64
}

type Config interface {
	// ID returns node ID in a cluster
	ID() uint64
	// ElectionTick is the number of Node.Tick invocations that must pass between elections
	ElectionTick() int
	// HeartbeatTick is the number of Node.Tick invocations that must pass between heartbeats
	HeartbeatTick() int
	// Storage returns storage object
	Storage() Storage
	// MaxSizePerMsg limits the max size of each append message
	MaxSizePerMsg() uint64
	// MaxInflightMsgs limits the max number of in-flight append messages during optimistic replication phase
	MaxInflightMsgs() int
}

type Entry interface {
	// Term returns entry term
	Term() uint64
	// Index returns entry index
	Index() uint64
	// Type returns entry type
	Type() EntryType
	// Data returns entry payload
	Data() []byte
}

type EntryType int32

type HardState interface {
	// Term returns term
	Term() uint64
	// Vote returns vote
	Vote() uint64
	// Commit returns commit
	Commit() uint64
}

type Lib interface {
	// StartNode starts a node
	StartNode(Config, []Peer) Node
	// NewConfig creates a configuration
	NewConfig(uint64, int, int, Storage, uint64, int) Config
	// NewPeer creates a peer
	NewPeer(uint64, []byte) Peer
	// NewConfChange creates a config change
	NewConfChange(uint64, ConfChangeType, uint64, []byte) ConfChange
	// NewMemoryStorage creates a memory storage
	NewMemoryStorage() Storage
}

type Message interface {
	// To return destination ID
	To() uint64
	// Data returns message payload
	Data() []byte
}

type Node interface {
	// ProposeConfChange proposes configuration change
	ProposeConfChange(context.Context, ConfChange) error
	// Propose proposes some data
	Propose(context.Context, []byte) error
	// Tick is a clock event
	Tick()
	// Advace advances state machine
	Advance()
	// Step tells state machine to process a message
	Step(context.Context, []byte) error
	// Stop stops a node
	Stop()
	// ApplyConfChange applies configuration change
	ApplyConfChange(ConfChange)
	// Ready returns a channel with events
	Ready() <-chan Ready
}

type Peer interface {
	// ID returns peer ID
	ID() uint64
	// Context returns peer information, such as address
	Context() []byte
}

type Ready interface {
	// Messages returns the slice of messages
	Messages() []Message
	// Entries returns the slice of entries
	Entries() []Entry
	// CommittedEntries returns the slice of committed entries
	CommittedEntries() []Entry
}

type Snapshot interface {
	// Data represents a serialized snapshot
	Data() []byte
	// Metadata brings additional information about the snapshot
	Metadata() SnapshotMetadata
}

type SnapshotMetadata interface {
	// ConfState returns configuration state
	ConfState() ConfState
	// Index returns index
	Index() uint64
	// Term returns term
	Term() uint64
}

type Storage interface {
	// Append adds entries to a storage
	Append([]Entry) error
	// InitialState returns initial state
	InitialState() (HardState, ConfState, error)
	// Entries returns entries in a given range
	Entries(uint64, uint64, uint64) ([]Entry, error)
	// Term returns current term
	Term(i uint64) (uint64, error)
	// LastIndex returns last index
	LastIndex() (uint64, error)
	// FirstIndex returns first index
	FirstIndex() (uint64, error)
	// Snapshot returns snapshot
	Snapshot() (Snapshot, error)
}