local

package

v0.24.0 Latest Latest Go to latest Published: Feb 3, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Cluster struct {
	// contains filtered or unexported fields
}

func New(t *testing.T, opts ...Option) *Cluster

func (c *Cluster) AdminServerAddress(context.Context, *testing.T) string

func (c *Cluster) Close(ctx context.Context, t *testing.T)

func (c *Cluster) Controller() *controller.Controller

func (c *Cluster) GetStorageNodeByNodeName(t *testing.T, nodeName string) *storagenode.Node

func (c *Cluster) MetadataRepositoryAddress(_ context.Context, t *testing.T) string

func (c *Cluster) SetNumMetadataRepositories(_ context.Context, t *testing.T, desired int)

func (c *Cluster) Setup(_ context.Context, t *testing.T)

func (c *Cluster) StartAdminServer(_ context.Context, t *testing.T)

func (c *Cluster) StartMetadataRepositoryNodes(ctx context.Context, t *testing.T, desired int)

func (c *Cluster) StartStorageNode(_ context.Context, t *testing.T, nodeName string) bool

func (c *Cluster) StartStorageNodes(_ context.Context, t *testing.T, desired int)

func (c *Cluster) StopAdminServer(_ context.Context, t *testing.T)

func (c *Cluster) StopMetadataRepositoryNodes(ctx context.Context, t *testing.T)

func (c *Cluster) StopStorageNode(_ context.Context, t *testing.T, snid types.StorageNodeID) (nodeName string)

func (c *Cluster) StopStorageNodes(_ context.Context, t *testing.T)

func (c *Cluster) String() string

type Option interface {
	// contains filtered or unexported methods
}

func WithAdminExecutable(executable string) Option

func WithCommonConfig(commonConfig cluster.Config) Option

func WithGRPCHealthProbeExecutable(executable string) Option

func WithMetadataRepositoryExecutable(executable string) Option

func WithStorageNodeExecutable(executable string) Option