raft

type Commit struct {
	Index   uint64
	Payload []byte
}

type CommitApplier func(context.Context, Commit) error

type ConfChangeApplier func(context.Context, uint64, raftpb.ConfChangeI) error

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

type LeaderFunc func(context.Context, RaftStatusProvider) error

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

type NodeConfig struct {
	AppliedIndex              uint64
	DisableProposalForwarding bool
	CheckQuorum               bool
	LeaderFunc                LeaderFunc
}

type Peer struct {
	ID      uint64
	Address string
}

type Peers []Peer

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

type RaftStatusProvider interface {
	Status() raft.Status
}

type Recorder interface {
	NotifyRaftConfChange(cluster string, cc raftpb.ConfChangeI)
}

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