shipwreck

type GrpcNodeServer[T nodeMessage] struct {
	proto.UnsafeNodeServer
	// contains filtered or unexported fields
}

type LogReply struct {
	CommitOffset int64
	Success      bool
}

type LogRequest[T nodeMessage] struct {
	CommitOffset int64
	StartOffset  int64
	Entries      []T
}

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

type Message[T msg] struct {
	SourceID string
	TargetID string
	Msg      T
}

type NodeMode int64

type ProxyPush[T nodeMessage] struct {
	Value T
}

type ProxyPushReply struct {
	Ok bool
}

type RaftNode[T nodeMessage] interface {
	ID() string
	String() string
	Mode() NodeMode
	Push(v T) error
	AddPeer(conn conn[T])
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	// contains filtered or unexported methods
}

type Storage[T any] interface {
	Append(command ...T) (int64, error)
	Get(start int64, end int64) ([]T, error)
	// Commits the logs to the offset and returns the commited logs
	Commit(offset int64) ([]T, error)
	Discard(start int64, end int64) error

	Length() int64
	Commited() int64
}

type VoteReply struct {
	Granted bool
}

type VoteRequest struct {
	Term         int64
	CommitOffset int64
}