Versions in this module Expand all Collapse all v3 v3.3.102 Mar 9, 2021 v3.3.101 Mar 3, 2021 Changes in this version + const DefaultKVStoreTypeName + func NewDefaultBatchedLogDB(config config.NodeHostConfig, callback config.LogDBCallback, dirs []string, ...) (raftio.ILogDB, error) + func NewDefaultLogDB(config config.NodeHostConfig, callback config.LogDBCallback, dirs []string, ...) (raftio.ILogDB, error) + func NewLogDB(config config.NodeHostConfig, callback config.LogDBCallback, dirs []string, ...) (raftio.ILogDB, error) + type DefaultFactory struct + func NewDefaultFactory(fs vfs.IFS) *DefaultFactory + func (f *DefaultFactory) Create(cfg config.NodeHostConfig, cb config.LogDBCallback, dirs []string, ...) (raftio.ILogDB, error) + func (f *DefaultFactory) Name() string + type IContext interface + Destroy func() + GetEntryBatch func() pb.EntryBatch + GetKey func() IReusableKey + GetLastEntryBatch func() pb.EntryBatch + GetValueBuffer func(sz uint64) []byte + GetWriteBatch func() interface{} + Reset func() + SetWriteBatch func(wb interface{}) + type IReusableKey interface + Key func() []byte + Release func() + SetEntryBatchKey func(clusterID uint64, nodeID uint64, index uint64) + SetEntryKey func(clusterID uint64, nodeID uint64, index uint64) + SetMaxIndexKey func(clusterID uint64, nodeID uint64) + SetStateKey func(clusterID uint64, nodeID uint64) + type Key struct + func NewKey(sz uint64, pool *sync.Pool) *Key + func (k *Key) Key() []byte + func (k *Key) Release() + func (k *Key) SetEntryBatchKey(clusterID uint64, nodeID uint64, batchID uint64) + func (k *Key) SetEntryKey(clusterID uint64, nodeID uint64, index uint64) + func (k *Key) SetMaxIndexKey(clusterID uint64, nodeID uint64) + func (k *Key) SetMaximumKey() + func (k *Key) SetMinimumKey() + func (k *Key) SetStateKey(clusterID uint64, nodeID uint64) + type LogReader struct + func NewLogReader(clusterID uint64, nodeID uint64, logdb raftio.ILogDB) *LogReader + func (lr *LogReader) Append(entries []pb.Entry) error + func (lr *LogReader) ApplySnapshot(snapshot pb.Snapshot) error + func (lr *LogReader) Compact(index uint64) error + func (lr *LogReader) CreateSnapshot(snapshot pb.Snapshot) error + func (lr *LogReader) Entries(low uint64, high uint64, maxSize uint64) ([]pb.Entry, error) + func (lr *LogReader) GetRange() (uint64, uint64) + func (lr *LogReader) NodeState() (pb.State, pb.Membership) + func (lr *LogReader) SetRange(firstIndex uint64, length uint64) + func (lr *LogReader) SetState(s pb.State) + func (lr *LogReader) Snapshot() pb.Snapshot + func (lr *LogReader) Term(index uint64) (uint64, error) + type ShardedDB struct + func OpenShardedDB(config config.NodeHostConfig, cb config.LogDBCallback, dirs []string, ...) (*ShardedDB, error) + func (s *ShardedDB) BinaryFormat() uint32 + func (s *ShardedDB) Close() + func (s *ShardedDB) CompactEntriesTo(clusterID uint64, nodeID uint64, index uint64) (<-chan struct{}, error) + func (s *ShardedDB) DeleteSnapshot(clusterID uint64, nodeID uint64, snapshotIndex uint64) error + func (s *ShardedDB) GetBootstrapInfo(clusterID uint64, nodeID uint64) (pb.Bootstrap, error) + func (s *ShardedDB) GetLogDBThreadContext() IContext + func (s *ShardedDB) ImportSnapshot(ss pb.Snapshot, nodeID uint64) error + func (s *ShardedDB) IterateEntries(ents []pb.Entry, size uint64, clusterID uint64, nodeID uint64, low uint64, ...) ([]pb.Entry, uint64, error) + func (s *ShardedDB) ListNodeInfo() ([]raftio.NodeInfo, error) + func (s *ShardedDB) ListSnapshots(clusterID uint64, nodeID uint64, index uint64) ([]pb.Snapshot, error) + func (s *ShardedDB) Name() string + func (s *ShardedDB) ReadRaftState(clusterID uint64, nodeID uint64, lastIndex uint64) (raftio.RaftState, error) + func (s *ShardedDB) RemoveEntriesTo(clusterID uint64, nodeID uint64, index uint64) error + func (s *ShardedDB) RemoveNodeData(clusterID uint64, nodeID uint64) error + func (s *ShardedDB) SaveBootstrapInfo(clusterID uint64, nodeID uint64, bootstrap pb.Bootstrap) error + func (s *ShardedDB) SaveRaftState(updates []pb.Update, shardID uint64) error + func (s *ShardedDB) SaveRaftStateCtx(updates []pb.Update, ctx IContext) error + func (s *ShardedDB) SaveSnapshots(updates []pb.Update) error + func (s *ShardedDB) SelfCheckFailed() (bool, error) Other modules containing this package github.com/vyevenko/dragonboat