raft

type BufferReader interface {
	ReadAt(readIndex uint64) (*rafthashi.Log, uint64, error)
	LastIndex() uint64
}

type BuildOp func(*Config)

type ClientFetcher interface {
	Fetch(target string) intra.NodeRaftClient
}

type Config struct {
	*rafthashi.Config
	// contains filtered or unexported fields
}

type ConsumerFetcher interface {
	Fetch(bufferName string) <-chan rafthashi.RPC
	Addr() string
}

type Node interface {
	AddPeer(peer string) rafthashi.Future
	RemovePeer(peer string) rafthashi.Future
}

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

type PeerStore interface {
	rafthashi.PeerStore
}

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