test

Documentation

Index

• Constants
• func InitEmptyCluster(ctx context.Context, t *testing.T) *cluster.Cluster
• func InitPrepareCluster(ctx context.Context, t *testing.T) *cluster.Cluster
• func InitStableCluster(ctx context.Context, t *testing.T) *cluster.Cluster
• func NewTestStorage(_ *testing.T) procedure.Storage
• type MockDispatch
  • 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 MockIDAllocator
  • func (m MockIDAllocator) Alloc(_ context.Context) (uint64, error)
  • func (m MockIDAllocator) Collect(_ context.Context, _ uint64) error
• type MockStorage
  • 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

Constants

const (
	TestTableName0           = "table0"
	TestTableName1           = "table1"
	TestSchemaName           = "TestSchemaName"
	TestRootPath             = "/rootPath"
	DefaultIDAllocatorStep   = 20
	ClusterName              = "ceresdbCluster1"
	DefaultNodeCount         = 2
	DefaultShardTotal        = 4
	DefaultSchedulerOperator = true
	DefaultTopologyType      = "static"
)

Functions

func InitEmptyCluster

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

InitEmptyCluster will return a cluster that has created shards and nodes, but it does not have any shard node mapping.

func InitPrepareCluster

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

InitPrepareCluster will return a cluster that has created shards and nodes, and cluster state is prepare.

func InitStableCluster

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

InitStableCluster will return a cluster that has created shards and nodes, and shards have been assigned to existing nodes.

func NewTestStorage

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

Types

type MockDispatch

type MockDispatch struct{}

func (MockDispatch) CloseShard

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

func (MockDispatch) CloseTableOnShard

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

func (MockDispatch) CreateTableOnShard

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

func (MockDispatch) DropTableOnShard

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

func (MockDispatch) OpenShard

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

func (MockDispatch) OpenTableOnShard

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

type MockIDAllocator

type MockIDAllocator struct{}

func (MockIDAllocator) Alloc

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

func (MockIDAllocator) Collect

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

type MockStorage

type MockStorage struct{}

func (MockStorage) CreateOrUpdate

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

func (MockStorage) List

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

func (MockStorage) MarkDeleted

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