fake

Documentation

Index

• type FakeCluster
  • func NewFakeCluster(nodeID int, numShards int) *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

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

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

func (f *FakeCluster) GetLeadersMap() (map[uint64]uint64, error)

func (*FakeCluster) GetLocalShardIDs

func (f *FakeCluster) GetLocalShardIDs() []uint64

func (*FakeCluster) GetLock

func (f *FakeCluster) GetLock(prefix string) (bool, error)

func (*FakeCluster) GetNodeID

func (f *FakeCluster) GetNodeID() int

func (*FakeCluster) LinearizableGet

func (f *FakeCluster) LinearizableGet(_ uint64, key []byte) ([]byte, error)

func (*FakeCluster) LocalGet

func (f *FakeCluster) LocalGet(key []byte) ([]byte, error)

func (*FakeCluster) LocalScan

func (f *FakeCluster) LocalScan(startKeyPrefix []byte, endKeyPrefix []byte, limit int) ([]cluster.KVPair, error)

func (*FakeCluster) LocalScanWithSnapshot

func (f *FakeCluster) LocalScanWithSnapshot(sn cluster.Snapshot, startKeyPrefix []byte, endKeyPrefix []byte, limit int) ([]cluster.KVPair, error)

func (*FakeCluster) PostStartChecks

func (f *FakeCluster) PostStartChecks(queryExec common.SimpleQueryExec) error

func (*FakeCluster) RegisterEndFill

func (f *FakeCluster) RegisterEndFill()

func (*FakeCluster) RegisterShardListenerFactory

func (f *FakeCluster) RegisterShardListenerFactory(factory cluster.ShardListenerFactory)

func (*FakeCluster) RegisterStartFill

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

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