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 NewCreateFailingFakeClient() client.Client
• func NewFakeClient(initRuntimeObjs ...runtime.Object) (client.Client, error)
• func NewFakeClientWRestMapper() client.Client
• func NewK8ssandraCluster(name string, namespace string) k8ssandraapi.K8ssandraCluster
• func NewMedusaRestore(namespace string, localRestoreName string, remoteBackupName string, dc string, ...) *medusaapi.MedusaRestoreJob
• func NewReaper(name string, namespace string) reaperapi.Reaper
• func NewStargate(name string, namespace string) stargateapi.Stargate
• func TestSetup(t *testing.T) context.Context
• type ControllerTest
• type CreateFailingFakeClient
  • func (c CreateFailingFakeClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
• 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) SetAdapter(a ManagementApiFactoryAdapter)
  • func (f *FakeManagementApiFactory) SetT(t *testing.T)
  • func (f *FakeManagementApiFactory) UseDefaultAdapter()
• 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) GetDataPlaneEnvTests() []*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)
• type Testable

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 NewCreateFailingFakeClient

func NewCreateFailingFakeClient() client.Client

func NewFakeClient

func NewFakeClient(initRuntimeObjs ...runtime.Object) (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 NewMedusaRestore

func NewMedusaRestore(namespace string, localRestoreName string, remoteBackupName string, dc string, clusterName string) *medusaapi.MedusaRestoreJob

func NewReaper

func NewReaper(name string, namespace string) reaperapi.Reaper

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 CreateFailingFakeClient

type CreateFailingFakeClient struct {
	client.Client
}

CreateFailingFakeClient is a fake client. Calls to .Create on this client will fail after `createFailsAfter` invocations.

func (CreateFailingFakeClient) Create

func (c CreateFailingFakeClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

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

func (f *FakeManagementApiFactory) SetAdapter(a ManagementApiFactoryAdapter)

func (*FakeManagementApiFactory) SetT

func (f *FakeManagementApiFactory) SetT(t *testing.T)

func (*FakeManagementApiFactory) UseDefaultAdapter

func (f *FakeManagementApiFactory) UseDefaultAdapter()

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

	// NumDataPlanes is the number of data planes to create.
	NumDataPlanes int

	BeforeTest func(t *testing.T)
	// 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) GetDataPlaneEnvTests

func (e *MultiClusterTestEnv) GetDataPlaneEnvTests() []*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)

type Testable

type Testable interface {
	Test(t mock.TestingT)
}