test

Documentation

Overview

Package test: this file contains minimum viable configurations for various objects in k8ssandra-operator to facilitate testing.

Index

• Constants
• func NewCassandraDatacenter(name string, namespace string) cassdcapi.CassandraDatacenter
• func NewFakeClient() (client.Client, error)
• func NewFakeClientWRestMapper() client.Client
• func NewK8ssandraCluster(name string, namespace string) k8ssandraapi.K8ssandraCluster
• func NewStargate(name string, namespace string) stargateapi.Stargate
• func TestSetup(t *testing.T) context.Context
• type ControllerTest
• type FakeManagementApiFacade
  • func NewFakeManagementApiFacade() *FakeManagementApiFacade
  • func (f *FakeManagementApiFacade) GetFirstCall(method ManagementApiMethod, args ...interface{}) int
  • func (f *FakeManagementApiFacade) GetLastCall(method ManagementApiMethod, args ...interface{}) int
• type FakeManagementApiFactory
  • func (f *FakeManagementApiFactory) NewManagementApiFacade(ctx context.Context, dc *cassdcapi.CassandraDatacenter, client client.Client, ...) (cassandra.ManagementApiFacade, error)
  • func (f *FakeManagementApiFactory) Reset()
  • func (f *FakeManagementApiFactory) SetAdapter(a ManagementApiFactoryAdapter)
• type ManagementApiFactoryAdapter
• type ManagementApiMethod
• type MultiClusterTestEnv
  • func (e *MultiClusterTestEnv) ControllerTest(ctx context.Context, test ControllerTest) func(*testing.T)
  • func (e *MultiClusterTestEnv) GetControlPlaneEnvTest() *envtest.Environment
  • func (e *MultiClusterTestEnv) Start(ctx context.Context, t *testing.T, ...) error
  • func (e *MultiClusterTestEnv) Stop(t *testing.T)
• type TestEnv
  • func (e *TestEnv) Start(ctx context.Context, t *testing.T, ...) error
  • func (e *TestEnv) Stop(t *testing.T)

Constants

const (
	EnsureKeyspaceReplication = "EnsureKeyspaceReplication"
	GetKeyspaceReplication    = "GetKeyspaceReplication"
	CreateKeyspaceIfNotExists = "CreateKeyspaceIfNotExists"
	AlterKeyspace             = "AlterKeyspace"
	ListKeyspaces             = "ListKeyspaces"
	CreateTable               = "CreateTable"
	ListTables                = "ListTables"
	GetSchemaVersions         = "GetSchemaVersions"
)

Functions

func NewCassandraDatacenter

func NewCassandraDatacenter(name string, namespace string) cassdcapi.CassandraDatacenter

func NewFakeClient

func NewFakeClient() (client.Client, error)

NewFakeClient gets a fake client loaded up with a scheme that contains all the APIs used in this project.

func NewFakeClientWRestMapper

func NewFakeClientWRestMapper() client.Client

func NewK8ssandraCluster

func NewK8ssandraCluster(name string, namespace string) k8ssandraapi.K8ssandraCluster

NewK8ssandraCluster returns a minimum viable k8ssandra cluster.

func NewStargate

func NewStargate(name string, namespace string) stargateapi.Stargate

func TestSetup

func TestSetup(t *testing.T) context.Context

Types

type ControllerTest

type ControllerTest func(*testing.T, context.Context, *framework.Framework, string)

type FakeManagementApiFacade

type FakeManagementApiFacade struct {
	*mocks.ManagementApiFacade
}

func NewFakeManagementApiFacade

func NewFakeManagementApiFacade() *FakeManagementApiFacade

func (*FakeManagementApiFacade) GetFirstCall

func (f *FakeManagementApiFacade) GetFirstCall(method ManagementApiMethod, args ...interface{}) int

func (*FakeManagementApiFacade) GetLastCall

func (f *FakeManagementApiFacade) GetLastCall(method ManagementApiMethod, args ...interface{}) int

type FakeManagementApiFactory

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

func (*FakeManagementApiFactory) NewManagementApiFacade

func (f *FakeManagementApiFactory) NewManagementApiFacade(
	ctx context.Context,
	dc *cassdcapi.CassandraDatacenter,
	client client.Client,
	logger logr.Logger) (cassandra.ManagementApiFacade, error)

func (*FakeManagementApiFactory) Reset

func (f *FakeManagementApiFactory) Reset()

func (*FakeManagementApiFactory) SetAdapter

func (f *FakeManagementApiFactory) SetAdapter(a ManagementApiFactoryAdapter)

type ManagementApiFactoryAdapter

type ManagementApiFactoryAdapter func(
	ctx context.Context,
	datacenter *cassdcapi.CassandraDatacenter,
	client client.Client,
	logger logr.Logger) (cassandra.ManagementApiFacade, error)

type ManagementApiMethod

type ManagementApiMethod string

type MultiClusterTestEnv

type MultiClusterTestEnv struct {
	// Clients is a mapping of cluster (or k8s context) names to Client objects. Note that
	// these are no-cache clients  as they are intended for use by the tests.
	Clients map[string]client.Client

	BeforeTest func()
	// contains filtered or unexported fields
}

func (*MultiClusterTestEnv) ControllerTest

func (e *MultiClusterTestEnv) ControllerTest(ctx context.Context, test ControllerTest) func(*testing.T)

func (*MultiClusterTestEnv) GetControlPlaneEnvTest

func (e *MultiClusterTestEnv) GetControlPlaneEnvTest() *envtest.Environment

func (*MultiClusterTestEnv) Start

func (e *MultiClusterTestEnv) Start(ctx context.Context, t *testing.T, initReconcilers func(mgr manager.Manager, clientCache *clientcache.ClientCache, clusters []cluster.Cluster) error) error

func (*MultiClusterTestEnv) Stop

func (e *MultiClusterTestEnv) Stop(t *testing.T)

type TestEnv

type TestEnv struct {
	*envtest.Environment

	TestClient client.Client
}

func (*TestEnv) Start

func (e *TestEnv) Start(ctx context.Context, t *testing.T, initReconcilers func(mgr manager.Manager) error) error

func (*TestEnv) Stop

func (e *TestEnv) Stop(t *testing.T)