test

Jul 7, 2023

Changes in this version

+ const DefaultProcedureExecutingBatchSize

May 29, 2023

Changes in this version

+ func InitPrepareCluster(ctx context.Context, t *testing.T) *cluster.Cluster

+ type MockIDAllocator struct

+ func (m MockIDAllocator) Alloc(_ context.Context) (uint64, error)

+ func (m MockIDAllocator) Collect(_ context.Context, _ uint64) error

May 6, 2023

Changes in this version

+ const DefaultSchedulerOperator

+ const DefaultTopologyType

+ func InitEmptyCluster(ctx context.Context, t *testing.T) *cluster.Cluster

+ func InitStableCluster(ctx context.Context, t *testing.T) *cluster.Cluster

Feb 22, 2023

Changes in this version

+ const ClusterName

+ const DefaultIDAllocatorStep

+ const DefaultNodeCount

+ const DefaultPartitionTableProportionOfNodes

+ const DefaultReplicationFactor

+ const DefaultShardTotal

+ const NodeName0

+ const NodeName1

+ const TestRootPath

+ const TestSchemaName

+ const TestTableName0

+ const TestTableName1

+ func NewTestStorage(_ *testing.T) procedure.Storage

+ type MockDispatch struct

+ func (m MockDispatch) CloseShard(_ context.Context, _ string, _ eventdispatch.CloseShardRequest) error

+ func (m MockDispatch) CloseTableOnShard(_ context.Context, _ string, _ eventdispatch.CloseTableOnShardRequest) error

+ func (m MockDispatch) CreateTableOnShard(_ context.Context, _ string, _ eventdispatch.CreateTableOnShardRequest) error

+ func (m MockDispatch) DropTableOnShard(_ context.Context, _ string, _ eventdispatch.DropTableOnShardRequest) error

+ func (m MockDispatch) OpenShard(_ context.Context, _ string, _ eventdispatch.OpenShardRequest) error

+ func (m MockDispatch) OpenTableOnShard(_ context.Context, _ string, _ eventdispatch.OpenTableOnShardRequest) error

+ type MockStorage struct

+ func (m MockStorage) CreateOrUpdate(_ context.Context, _ procedure.Meta) error

+ func (m MockStorage) List(_ context.Context, _ int) ([]*procedure.Meta, error)

+ func (m MockStorage) MarkDeleted(_ context.Context, _ uint64) error