Versions in this module Expand all Collapse all v0 v0.3.0 Mar 9, 2022 v0.2.0 Jan 5, 2022 Changes in this version + var ErrNoSavedLog = errors.New("no saved log") + var ErrNoSnapshot = errors.New("no snapshot") + var ErrNotFound = errors.New("not found") + func IsEmptyRaftReady(rd raft.Ready) bool + type KVLogDB struct + func NewKVLogDB(ms storage.KVMetadataStore, logger *zap.Logger) *KVLogDB + func (l *KVLogDB) Close() error + func (l *KVLogDB) GetAllSnapshots(shardID uint64) ([]raftpb.Snapshot, error) + func (l *KVLogDB) GetSnapshot(shardID uint64) (raftpb.Snapshot, error) + func (l *KVLogDB) IterateEntries(ents []raftpb.Entry, size uint64, shardID uint64, replicaID uint64, low uint64, ...) ([]raftpb.Entry, uint64, error) + func (l *KVLogDB) Name() string + func (l *KVLogDB) NewWorkerContext() *WorkerContext + func (l *KVLogDB) ReadRaftState(shardID uint64, replicaID uint64, snapshotIndex uint64) (RaftState, error) + func (l *KVLogDB) RemoveEntriesTo(shardID uint64, replicaID uint64, index uint64) error + func (l *KVLogDB) RemoveReplicaData(shardID uint64) error + func (l *KVLogDB) RemoveSnapshot(shardID uint64, index uint64) error + func (l *KVLogDB) SaveRaftState(shardID uint64, replicaID uint64, rd raft.Ready, ctx *WorkerContext) error + type LogDB interface + Close func() error + GetAllSnapshots func(shardID uint64) ([]raftpb.Snapshot, error) + GetSnapshot func(shardID uint64) (raftpb.Snapshot, error) + IterateEntries func(ents []raftpb.Entry, size uint64, shardID uint64, replicaID uint64, low uint64, ...) ([]raftpb.Entry, uint64, error) + Name func() string + NewWorkerContext func() *WorkerContext + ReadRaftState func(shardID uint64, replicaID uint64, snapshotIndex uint64) (RaftState, error) + RemoveEntriesTo func(shardID uint64, replicaID uint64, index uint64) error + RemoveReplicaData func(shardID uint64) error + RemoveSnapshot func(shardID uint64, index uint64) error + SaveRaftState func(shardID uint64, replicaID uint64, rd raft.Ready, ctx *WorkerContext) error + type RaftState struct + EntryCount uint64 + FirstIndex uint64 + State raftpb.HardState + type WorkerContext struct + func (w *WorkerContext) Close() + func (w *WorkerContext) Reset()
Go to main page