Documentation ¶
Index ¶
- type FakeCluster
- func (f *FakeCluster) AddToDeleteBatch(batch *cluster.ToDeleteBatch) error
- func (f *FakeCluster) CreateSnapshot() (cluster.Snapshot, error)
- func (f *FakeCluster) DeleteAllDataInRangeForAllShardsLocally(startPrefix []byte, endPrefix []byte) error
- func (f *FakeCluster) DeleteAllDataInRangeForShardLocally(shardID uint64, startPrefix []byte, endPrefix []byte) error
- func (f *FakeCluster) Dump() string
- func (f *FakeCluster) ExecuteForwardBatch(shardID uint64, batch []byte) error
- func (f *FakeCluster) ExecuteRemotePullQuery(queryInfo *cluster.QueryExecutionInfo, rowsFactory *common.RowsFactory) (*common.Rows, error)
- func (f *FakeCluster) GenerateClusterSequence(sequenceName string) (uint64, error)
- func (f *FakeCluster) GetAllShardIDs() []uint64
- func (f *FakeCluster) GetLeadersMap() (map[uint64]uint64, error)
- func (f *FakeCluster) GetLocalShardIDs() []uint64
- func (f *FakeCluster) GetLock(prefix string) (bool, error)
- func (f *FakeCluster) GetNodeID() int
- func (f *FakeCluster) LinearizableGet(_ uint64, key []byte) ([]byte, error)
- func (f *FakeCluster) LocalGet(key []byte) ([]byte, error)
- func (f *FakeCluster) LocalScan(startKeyPrefix []byte, endKeyPrefix []byte, limit int) ([]cluster.KVPair, error)
- func (f *FakeCluster) LocalScanWithSnapshot(sn cluster.Snapshot, startKeyPrefix []byte, endKeyPrefix []byte, limit int) ([]cluster.KVPair, error)
- func (f *FakeCluster) PostStartChecks(queryExec common.SimpleQueryExec) error
- func (f *FakeCluster) RegisterEndFill()
- func (f *FakeCluster) RegisterShardListenerFactory(factory cluster.ShardListenerFactory)
- func (f *FakeCluster) RegisterStartFill(expectedLeaders map[uint64]uint64, interruptor *interruptor.Interruptor) error
- func (f *FakeCluster) ReleaseLock(prefix string) (bool, error)
- func (f *FakeCluster) RemoveToDeleteBatch(batch *cluster.ToDeleteBatch) error
- func (f *FakeCluster) SetRemoteQueryExecutionCallback(callback cluster.RemoteQueryExecutionCallback)
- func (f *FakeCluster) Start() error
- func (f *FakeCluster) Stop() error
- func (f *FakeCluster) SyncStore() error
- func (f *FakeCluster) WriteBatch(batch *cluster.WriteBatch, _ bool) error
- func (f *FakeCluster) WriteBatchLocally(batch *cluster.WriteBatch) error
- func (f *FakeCluster) WriteForwardBatch(batch *cluster.WriteBatch, localOnly bool) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeCluster ¶
type FakeCluster struct {
// contains filtered or unexported fields
}
func NewFakeCluster ¶
func NewFakeCluster(nodeID int, numShards int) *FakeCluster
func (*FakeCluster) AddToDeleteBatch ¶
func (f *FakeCluster) AddToDeleteBatch(batch *cluster.ToDeleteBatch) error
func (*FakeCluster) CreateSnapshot ¶
func (f *FakeCluster) CreateSnapshot() (cluster.Snapshot, error)
func (*FakeCluster) DeleteAllDataInRangeForAllShardsLocally ¶
func (f *FakeCluster) DeleteAllDataInRangeForAllShardsLocally(startPrefix []byte, endPrefix []byte) error
func (*FakeCluster) DeleteAllDataInRangeForShardLocally ¶
func (f *FakeCluster) DeleteAllDataInRangeForShardLocally(shardID uint64, startPrefix []byte, endPrefix []byte) error
func (*FakeCluster) Dump ¶
func (f *FakeCluster) Dump() string
func (*FakeCluster) ExecuteForwardBatch ¶ added in v0.1.6
func (f *FakeCluster) ExecuteForwardBatch(shardID uint64, batch []byte) error
func (*FakeCluster) ExecuteRemotePullQuery ¶
func (f *FakeCluster) ExecuteRemotePullQuery(queryInfo *cluster.QueryExecutionInfo, rowsFactory *common.RowsFactory) (*common.Rows, error)
func (*FakeCluster) GenerateClusterSequence ¶
func (f *FakeCluster) GenerateClusterSequence(sequenceName string) (uint64, error)
func (*FakeCluster) GetAllShardIDs ¶
func (f *FakeCluster) GetAllShardIDs() []uint64
func (*FakeCluster) GetLeadersMap ¶ added in v0.1.6
func (f *FakeCluster) GetLeadersMap() (map[uint64]uint64, error)
func (*FakeCluster) GetLocalShardIDs ¶
func (f *FakeCluster) GetLocalShardIDs() []uint64
func (*FakeCluster) GetNodeID ¶
func (f *FakeCluster) GetNodeID() int
func (*FakeCluster) LinearizableGet ¶ added in v0.1.6
func (f *FakeCluster) LinearizableGet(_ uint64, key []byte) ([]byte, error)
func (*FakeCluster) LocalScanWithSnapshot ¶
func (*FakeCluster) PostStartChecks ¶
func (f *FakeCluster) PostStartChecks(queryExec common.SimpleQueryExec) error
func (*FakeCluster) RegisterEndFill ¶ added in v0.1.6
func (f *FakeCluster) RegisterEndFill()
func (*FakeCluster) RegisterShardListenerFactory ¶
func (f *FakeCluster) RegisterShardListenerFactory(factory cluster.ShardListenerFactory)
func (*FakeCluster) RegisterStartFill ¶ added in v0.1.6
func (f *FakeCluster) RegisterStartFill(expectedLeaders map[uint64]uint64, interruptor *interruptor.Interruptor) error
func (*FakeCluster) ReleaseLock ¶
func (f *FakeCluster) ReleaseLock(prefix string) (bool, error)
func (*FakeCluster) RemoveToDeleteBatch ¶
func (f *FakeCluster) RemoveToDeleteBatch(batch *cluster.ToDeleteBatch) error
func (*FakeCluster) SetRemoteQueryExecutionCallback ¶
func (f *FakeCluster) SetRemoteQueryExecutionCallback(callback cluster.RemoteQueryExecutionCallback)
func (*FakeCluster) Start ¶
func (f *FakeCluster) Start() error
func (*FakeCluster) Stop ¶
func (f *FakeCluster) Stop() error
Stop resets all ephemeral state for a cluster, allowing it to be used with a new server but keeping all persisted data.
func (*FakeCluster) SyncStore ¶ added in v0.1.6
func (f *FakeCluster) SyncStore() error
func (*FakeCluster) WriteBatch ¶
func (f *FakeCluster) WriteBatch(batch *cluster.WriteBatch, _ bool) error
func (*FakeCluster) WriteBatchLocally ¶
func (f *FakeCluster) WriteBatchLocally(batch *cluster.WriteBatch) error
func (*FakeCluster) WriteForwardBatch ¶
func (f *FakeCluster) WriteForwardBatch(batch *cluster.WriteBatch, localOnly bool) error
Click to show internal directories.
Click to hide internal directories.