tee

Documentation

Index

• 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) DeleteSnapshot(clusterID uint64, nodeID uint64, index uint64) error
  • func (t *LogDB) GetBootstrapInfo(clusterID uint64, nodeID uint64) (pb.Bootstrap, 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) ListSnapshots(clusterID uint64, nodeID uint64, index uint64) ([]pb.Snapshot, 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

Functions

func NewTeeLogDB

func NewTeeLogDB(nhConfig config.NodeHostConfig,
	cb config.LogDBCallback, dirs []string, wals []string,
	fs vfs.IFS) (raftio.ILogDB, error)

NewTeeLogDB creates a new LogDB instance.

Types

type LogDB

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

LogDB is a special LogDB module used for testing purposes.

func (*LogDB) BinaryFormat

func (t *LogDB) BinaryFormat() uint32

BinaryFormat ...

func (*LogDB) Close

func (t *LogDB) Close() error

Close ...

func (*LogDB) CompactEntriesTo

func (t *LogDB) CompactEntriesTo(clusterID uint64,
	nodeID uint64, index uint64) (<-chan struct{}, error)

CompactEntriesTo ...

func (*LogDB) DeleteSnapshot

func (t *LogDB) DeleteSnapshot(clusterID uint64,
	nodeID uint64, index uint64) error

DeleteSnapshot ...

func (*LogDB) GetBootstrapInfo

func (t *LogDB) GetBootstrapInfo(clusterID uint64,
	nodeID uint64) (pb.Bootstrap, error)

GetBootstrapInfo ...

func (*LogDB) ImportSnapshot

func (t *LogDB) ImportSnapshot(ss pb.Snapshot, nodeID uint64) error

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

func (t *LogDB) ListNodeInfo() ([]raftio.NodeInfo, error)

ListNodeInfo ...

func (*LogDB) ListSnapshots

func (t *LogDB) ListSnapshots(clusterID uint64,
	nodeID uint64, index uint64) ([]pb.Snapshot, error)

ListSnapshots ...

func (*LogDB) Name

func (t *LogDB) Name() string

Name ...

func (*LogDB) ReadRaftState

func (t *LogDB) ReadRaftState(clusterID uint64,
	nodeID uint64, lastIndex uint64) (raftio.RaftState, error)

ReadRaftState ...

func (*LogDB) RemoveEntriesTo

func (t *LogDB) RemoveEntriesTo(clusterID uint64,
	nodeID uint64, index uint64) error

RemoveEntriesTo ...

func (*LogDB) RemoveNodeData

func (t *LogDB) RemoveNodeData(clusterID uint64, nodeID uint64) error

RemoveNodeData ...

func (*LogDB) SaveBootstrapInfo

func (t *LogDB) SaveBootstrapInfo(clusterID uint64,
	nodeID uint64, bootstrap pb.Bootstrap) error

SaveBootstrapInfo ...

func (*LogDB) SaveRaftState

func (t *LogDB) SaveRaftState(updates []pb.Update, shardID uint64) error

SaveRaftState ...

func (*LogDB) SaveSnapshots

func (t *LogDB) SaveSnapshots(updates []pb.Update) error

SaveSnapshots ...