raft

type Command struct {
	Ctx     context.Context
	Payload []byte
	ErrCh   chan error
}

type Commit struct {
	Index   uint64
	Payload []byte
}

type CommitApplier func(context.Context, Commit) error

type Config struct {
	NodeID          uint64
	NodeAddress     string
	ClusterID       string
	DataDir         string
	GetSnapshot     func() ([]byte, error)
	CommitApplier   CommitApplier
	SnapshotApplier SnapshotApplier
}

type LeaderFunc func(context.Context) error

type Membership interface {
	Call(id uint64, f func(*grpc.ClientConn) error) error
	Members() []*clusterpb.Member
}

type NodeConfig struct {
	AppliedIndex              uint64
	DisableProposalForwarding bool
	LeaderFunc                LeaderFunc
}

type Peer struct {
	ID      uint64
	Address string
}

type Peers []Peer

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

type SnapshotApplier func(context.Context, uint64, *snap.Snapshotter) error

type StableStorage interface {
	io.Closer
	ReadAll() (metadata []byte, state raftpb.HardState, ents []raftpb.Entry, err error)
	ReleaseLockTo(index uint64) error
	Save(st raftpb.HardState, ents []raftpb.Entry) error
	Sync() error
	SaveSnapshot(e walpb.Snapshot) error
}

type StatsProvider interface {
	Histogram(name string) *prometheus.Histogram
}

type StatsProviderGetter func() StatsProvider