test

Documentation

Index

• Constants
• 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 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"
	NodeName0                              = "node0"
	NodeName1                              = "node1"
	TestRootPath                           = "/rootPath"
	DefaultIDAllocatorStep                 = 20
	ClusterName                            = "ceresdbCluster1"
	DefaultNodeCount                       = 2
	DefaultReplicationFactor               = 1
	DefaultPartitionTableProportionOfNodes = 0.5
	DefaultShardTotal                      = 4
)

Functions

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 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