raft

type APIExtension interface {
	Setup(s *Server, r *mux.Router) error
}

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

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

type BoltStore struct {
	LogStore
	StateStore
}

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

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

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

type Command []byte

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

type Future[T any] interface {
	Result() (T, error)
	// contains filtered or unexported methods
}

type FutureTask[FUTURE any, TASK any] interface {
	Future[FUTURE]
	Task() TASK
}

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

type HandyEncoding string

type HandyRespWriter struct {
	http.ResponseWriter
	// contains filtered or unexported fields
}

type InstallSnapshotRequest struct {
	Metadata *pb.InstallSnapshotRequestMeta
	Reader   io.ReadCloser
}

type LogStore interface {
	// AppendLogs is used to append logs to the LogStore.
	// It's recommended to use techniques like transaction processing to
	// avoid data inconsistency due to an error or interruption.
	AppendLogs(logs []*pb.Log) error

	// TrimPrefix is used to trim the logs by evicting UNPACKED logs forwards from
	// the first log until the log with the index is reached. Index is exclusive.
	TrimPrefix(index uint64) error

	// TrimSuffix is used to trim the logs by evicting UNPACKED logs backwards from
	// the last log until the log with the index is reached. Index is exclusive.
	TrimSuffix(index uint64) error

	FirstIndex() (uint64, error)
	LastIndex() (uint64, error)

	Entry(index uint64) (*pb.Log, error)

	// LastEntry is used to find the last log entry.
	// If t is not zero, a log type filter should be applied.
	LastEntry(t pb.LogType) (*pb.Log, error)
}

type MetricsExporter interface {
	Record(time time.Time, name string, value interface{})
}

type ObjectID [12]byte

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

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

type ServerCoreOptions struct {
	Id             string
	InitialCluster []*pb.Peer
	StableStore    StableStore
	StateMachine   StateMachine
	SnapshotStore  SnapshatStore
	Transport      Transport
}

type ServerInfo struct {
	ID       string `json:"id"`
	Endpoint string `json:"endpoint"`
}

type ServerOption func(options *serverOptions)

type ServerRole uint32

type ServerStates struct {
	ID                string   `json:"id"`
	Endpoint          string   `json:"endpoint"`
	Leader            *pb.Peer `json:"leader"`
	Role              string   `json:"role"`
	CurrentTerm       uint64   `json:"current_term"`
	LastLogIndex      uint64   `json:"last_log_index"`
	LastVoteTerm      uint64   `json:"last_vote_term"`
	LastVoteCandidate string   `json:"last_vote_candidate"`
	CommitIndex       uint64   `json:"commit_index"`
}

type SingleFlight[T any] struct {
	// contains filtered or unexported fields
}

type SnapshatStore interface {
	Create(index, term uint64, c *pb.Configuration, cIndex uint64) (SnapshotSink, error)
	List() ([]SnapshotMeta, error)
	Open(id string) (Snapshot, error)
	DecodeMeta(b []byte) (SnapshotMeta, error)
	Trim() error
}

type Snapshot interface {
	Meta() (SnapshotMeta, error)
	Reader() (io.Reader, error)

	// Close is used to close the snapshot's underlying file descriptors or handles.
	Close() error
}

type SnapshotMeta interface {
	Id() string
	Index() uint64
	Term() uint64
	Configuration() *pb.Configuration
	ConfigurationIndex() uint64
	Encode() ([]byte, error)
}

type SnapshotPolicy struct {
	Applies  int
	Interval time.Duration
}

type SnapshotSink interface {
	io.WriteCloser
	Meta() SnapshotMeta
	Cancel() error
}

type StableStore interface {
	LogStore
	StateStore
}

type StateMachine interface {
	Apply(command Command)
	Snapshot() (StateMachineSnapshot, error)
	Restore(snapshot Snapshot) error
}

type StateMachineSnapshot interface {
	Write(sink SnapshotSink) error
}

type StateStore interface {
	CurrentTerm() (uint64, error)
	SetCurrentTerm(term uint64) error
	LastVote() (voteSummary, error)
	SetLastVote(summary voteSummary) error
}

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

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

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

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

type Transport interface {
	// Endpoint returns the endpoint used by current Transport instance
	Endpoint() string

	AppendEntries(ctx context.Context, peer *pb.Peer, request *pb.AppendEntriesRequest) (*pb.AppendEntriesResponse, error)
	RequestVote(ctx context.Context, peer *pb.Peer, request *pb.RequestVoteRequest) (*pb.RequestVoteResponse, error)
	InstallSnapshot(ctx context.Context, peer *pb.Peer, requestMeta *pb.InstallSnapshotRequestMeta, reader io.Reader) (*pb.InstallSnapshotResponse, error)
	ApplyLog(ctx context.Context, peer *pb.Peer, request *pb.ApplyLogRequest) (*pb.ApplyLogResponse, error)

	RPC() <-chan *RPC
}

type TransportCloser interface {
	Close() error
}

type TransportConnecter interface {
	Connect(peer *pb.Peer) error
	Disconnect(peer *pb.Peer)
	DisconnectAll()
}

type TransportServer interface {
	Serve() error
}