testutil

Documentation

Index

• type TestAOECluster
  • func NewTestAOECluster(t *testing.T, cfgCreator func(node int) *config.Config, ...) *TestAOECluster
  • func (c *TestAOECluster) Restart()
  • func (c *TestAOECluster) RestartNode(n int)
  • func (c *TestAOECluster) Start()
  • func (c *TestAOECluster) Stop()
  • func (c *TestAOECluster) StopNode(n int)
• type TestAOEClusterOption
  • func WithTestAOEClusterAOEStorageFunc(value func(path string, feature storage.Feature) (*aoe2.Storage, error)) TestAOEClusterOption
  • func WithTestAOEClusterKVDataStorageFunc(value func(path string) (storage.DataStorage, error)) TestAOEClusterOption
  • func WithTestAOEClusterRaftClusterOptions(values ...raftstore.TestClusterOption) TestAOEClusterOption
  • func WithTestAOEClusterUsePebble() TestAOEClusterOption
• type TestCluster
  • func (c *TestCluster) Stop()

Types

type TestAOECluster

type TestAOECluster struct {
	RaftCluster  raftstore.TestRaftCluster
	CubeDrivers  []driver.CubeDriver
	AOEStorages  []*aoe2.Storage
	DataStorages []storage.DataStorage
	// contains filtered or unexported fields
}

TestAOECluster is a test cluster for testing.

func NewTestAOECluster

func NewTestAOECluster(t *testing.T, cfgCreator func(node int) *config.Config, opts ...TestAOEClusterOption) *TestAOECluster

func (*TestAOECluster) Restart

func (c *TestAOECluster) Restart()

func (*TestAOECluster) RestartNode

func (c *TestAOECluster) RestartNode(n int)

func (*TestAOECluster) Start

func (c *TestAOECluster) Start()

func (*TestAOECluster) Stop

func (c *TestAOECluster) Stop()

func (*TestAOECluster) StopNode

func (c *TestAOECluster) StopNode(n int)

type TestAOEClusterOption

type TestAOEClusterOption func(opts *testAOEClusterOptions)

TestAOEClusterOption the option for create TestAOECluster

func WithTestAOEClusterAOEStorageFunc

func WithTestAOEClusterAOEStorageFunc(value func(path string, feature storage.Feature) (*aoe2.Storage, error)) TestAOEClusterOption

WithTestAOEClusterAOEStorageFunc set aoe storage func

func WithTestAOEClusterKVDataStorageFunc

func WithTestAOEClusterKVDataStorageFunc(value func(path string) (storage.DataStorage, error)) TestAOEClusterOption

WithTestAOEClusterKVDataStorageFunc set kv data storage func

func WithTestAOEClusterRaftClusterOptions

func WithTestAOEClusterRaftClusterOptions(values ...raftstore.TestClusterOption) TestAOEClusterOption

WithTestAOEClusterRaftClusterOptions set raftstore test cluster options

func WithTestAOEClusterUsePebble

func WithTestAOEClusterUsePebble() TestAOEClusterOption

WithTestAOEClusterUsePebble set use pebble

type TestCluster

type TestCluster struct {
	T            *testing.T
	Applications []driver.CubeDriver
	AOEDBs       []*aoe2.Storage
}

func (*TestCluster) Stop

func (c *TestCluster) Stop()