Documentation
¶
Index ¶
- func MakeTeeLogDB(odb raftio.ILogDB, ndb raftio.ILogDB) raftio.ILogDB
- func NewPebbleLogDB(nhConfig config.NodeHostConfig, cb config.LogDBCallback, dirs []string, ...) (raftio.ILogDB, error)
- func NewRocksDBLogDB(nhConfig config.NodeHostConfig, cb config.LogDBCallback, dirs []string, ...) (raftio.ILogDB, error)
- func NewTeeLogDB(nhConfig config.NodeHostConfig, cb config.LogDBCallback, dirs []string, ...) (raftio.ILogDB, error)
- type LogDB
- func (t *LogDB) BinaryFormat() uint32
- func (t *LogDB) Close() error
- func (t *LogDB) CompactEntriesTo(clusterID uint64, nodeID uint64, index uint64) (<-chan struct{}, error)
- func (t *LogDB) GetBootstrapInfo(clusterID uint64, nodeID uint64) (pb.Bootstrap, error)
- func (t *LogDB) GetSnapshot(clusterID uint64, nodeID uint64) (pb.Snapshot, error)
- func (t *LogDB) ImportSnapshot(ss pb.Snapshot, nodeID uint64) error
- func (t *LogDB) IterateEntries(ents []pb.Entry, size uint64, clusterID uint64, nodeID uint64, low uint64, ...) ([]pb.Entry, uint64, error)
- func (t *LogDB) ListNodeInfo() ([]raftio.NodeInfo, error)
- func (t *LogDB) Name() string
- func (t *LogDB) ReadRaftState(clusterID uint64, nodeID uint64, lastIndex uint64) (raftio.RaftState, error)
- func (t *LogDB) RemoveEntriesTo(clusterID uint64, nodeID uint64, index uint64) error
- func (t *LogDB) RemoveNodeData(clusterID uint64, nodeID uint64) error
- func (t *LogDB) SaveBootstrapInfo(clusterID uint64, nodeID uint64, bootstrap pb.Bootstrap) error
- func (t *LogDB) SaveRaftState(updates []pb.Update, shardID uint64) error
- func (t *LogDB) SaveSnapshots(updates []pb.Update) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeTeeLogDB ¶
MakeTeeLogDB returns a LogDB instance combined from the specified odb and ndb instances.
func NewPebbleLogDB ¶
func NewPebbleLogDB(nhConfig config.NodeHostConfig, cb config.LogDBCallback, dirs []string, wals []string) (raftio.ILogDB, error)
NewPebbleLogDB creates a new LogDB instance.
func NewRocksDBLogDB ¶
func NewRocksDBLogDB(nhConfig config.NodeHostConfig, cb config.LogDBCallback, dirs []string, wals []string) (raftio.ILogDB, error)
NewRocksDBLogDB creates a new RocksDB based LogDB instance
func NewTeeLogDB ¶
func NewTeeLogDB(nhConfig config.NodeHostConfig, cb config.LogDBCallback, dirs []string, wals []string) (raftio.ILogDB, error)
NewTeeLogDB creates a new LogDB instance backed by a pebble and a rocksdb based ILogDB.
Types ¶
type LogDB ¶
type LogDB struct {
// contains filtered or unexported fields
}
LogDB is a special LogDB module used for testing purposes.
func (*LogDB) CompactEntriesTo ¶
func (t *LogDB) CompactEntriesTo(clusterID uint64, nodeID uint64, index uint64) (<-chan struct{}, error)
CompactEntriesTo ...
func (*LogDB) GetBootstrapInfo ¶
GetBootstrapInfo ...
func (*LogDB) GetSnapshot ¶
GetSnapshot ...
func (*LogDB) ImportSnapshot ¶
ImportSnapshot ...
func (*LogDB) IterateEntries ¶
func (t *LogDB) IterateEntries(ents []pb.Entry, size uint64, clusterID uint64, nodeID uint64, low uint64, high uint64, maxSize uint64) ([]pb.Entry, uint64, error)
IterateEntries ...
func (*LogDB) ListNodeInfo ¶
ListNodeInfo ...
func (*LogDB) ReadRaftState ¶
func (t *LogDB) ReadRaftState(clusterID uint64, nodeID uint64, lastIndex uint64) (raftio.RaftState, error)
ReadRaftState ...
func (*LogDB) RemoveEntriesTo ¶
RemoveEntriesTo ...
func (*LogDB) RemoveNodeData ¶
RemoveNodeData ...
func (*LogDB) SaveBootstrapInfo ¶
SaveBootstrapInfo ...
func (*LogDB) SaveRaftState ¶
SaveRaftState ...
Source Files
Click to show internal directories.
Click to hide internal directories.