integration

Documentation

Index

• Constants
• func StartEnvTest(projectRootDir string, celValidationEnabled bool) (*envtest.Environment, *rest.Config, error)
• type TestEnvironment
  • func NewTestEnvironment(projectRootDir string, celValidationEnabled bool, ...) (*TestEnvironment, error)
  • func (env TestEnvironment) CreateK8sResource(obj client.Object) error
  • func (env TestEnvironment) CreateUnstructuredK8sResource(obj *unstructured.Unstructured) error
  • func (env TestEnvironment) DeleteConfigMapFromK8s(name, namespace string) error
  • func (env TestEnvironment) DeleteDestinationRuleFromK8s(name, namespace string) error
  • func (env TestEnvironment) DeletePodDisruptionBudgetFromK8s(name, namespace string) error
  • func (env TestEnvironment) DeleteSecretFromK8s(name, namespace string) error
  • func (env TestEnvironment) DeleteServiceFromK8s(name, namespace string) error
  • func (env TestEnvironment) DeleteStatefulSetFromK8s(name, namespace string) error
  • func (env TestEnvironment) EnsureK8sConfigMapExists(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sConfigMapNotFound(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sDestinationRuleExists(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sDestinationRuleNotFound(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sNATSNotFound(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sPVCExists(t *testing.T, label, namespace string)
  • func (env TestEnvironment) EnsureK8sPVCNotFound(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sPodDisruptionBudgetExists(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sResourceCreated(t *testing.T, obj client.Object)
  • func (env TestEnvironment) EnsureK8sResourceDeleted(t *testing.T, obj client.Object)
  • func (env TestEnvironment) EnsureK8sResourceUpdated(t *testing.T, obj client.Object)
  • func (env TestEnvironment) EnsureK8sSecretExists(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sSecretNotFound(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sServiceExists(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sServiceNotFound(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sStatefulSetExists(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sStatefulSetHasAnnotations(t *testing.T, name, namespace string, annotations map[string]string)
  • func (env TestEnvironment) EnsureK8sStatefulSetHasLabels(t *testing.T, name, namespace string, labels map[string]string)
  • func (env TestEnvironment) EnsureK8sStatefulSetNotFound(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sUnStructResourceCreated(t *testing.T, obj *unstructured.Unstructured)
  • func (env TestEnvironment) EnsureNATSSpecClusterSizeReflected(t *testing.T, nats natsv1alpha1.NATS)
  • func (env TestEnvironment) EnsureNATSSpecDebugTraceReflected(t *testing.T, nats natsv1alpha1.NATS)
  • func (env TestEnvironment) EnsureNATSSpecFileStorageReflected(t *testing.T, nats natsv1alpha1.NATS)
  • func (env TestEnvironment) EnsureNATSSpecMemStorageReflected(t *testing.T, nats natsv1alpha1.NATS)
  • func (env TestEnvironment) EnsureNATSSpecResourcesReflected(t *testing.T, nats natsv1alpha1.NATS)
  • func (env TestEnvironment) EnsureNamespaceCreation(t *testing.T, namespace string)
  • func (env TestEnvironment) GetConfigMapFromK8s(name, namespace string) (*corev1.ConfigMap, error)
  • func (env TestEnvironment) GetDestinationRuleFromK8s(name, namespace string) (*unstructured.Unstructured, error)
  • func (env TestEnvironment) GetK8sEventsAssert(g *gomega.GomegaWithT, nats *natsv1alpha1.NATS) gomega.AsyncAssertion
  • func (env TestEnvironment) GetNATSAssert(g *gomega.GomegaWithT, nats *natsv1alpha1.NATS) gomega.AsyncAssertion
  • func (env TestEnvironment) GetNATSFromK8s(name, namespace string) (natsv1alpha1.NATS, error)
  • func (env TestEnvironment) GetPVCFromK8s(label, namespace string) (*corev1.PersistentVolumeClaim, error)
  • func (env TestEnvironment) GetPodDisruptionBudgetFromK8s(name, namespace string) (*policyv1.PodDisruptionBudget, error)
  • func (env TestEnvironment) GetSecretFromK8s(name, namespace string) (*corev1.Secret, error)
  • func (env TestEnvironment) GetServiceFromK8s(name, namespace string) (*corev1.Service, error)
  • func (env TestEnvironment) GetStatefulSetFromK8s(name, namespace string) (*appsv1.StatefulSet, error)
  • func (env TestEnvironment) TearDown() error
  • func (env TestEnvironment) UpdateStatefulSetStatusOnK8s(sts appsv1.StatefulSet) error
  • func (env TestEnvironment) UpdatedNATSInK8s(nats *natsv1alpha1.NATS, options ...testutils.NATSOption) error

Constants

const (
	NATSChartDir = "resources/nats"

	TwoMinTimeOut        = 120 * time.Second
	BigPollingInterval   = 3 * time.Second
	BigTimeOut           = 40 * time.Second
	SmallTimeOut         = 5 * time.Second
	SmallPollingInterval = 1 * time.Second

	NATSContainerName  = "nats"
	NATSConfigFileName = "nats.conf"
)

Functions

func StartEnvTest

func StartEnvTest(projectRootDir string, celValidationEnabled bool) (*envtest.Environment, *rest.Config, error)

Types

type TestEnvironment

type TestEnvironment struct {
	Context         context.Context
	EnvTestInstance *envtest.Environment

	K8sDynamicClient *dynamic.DynamicClient
	KubeClient       *k8s.Client
	ChartRenderer    *chart.Renderer
	NATSManager      *manager.Manager
	Reconciler       *natscontroller.Reconciler
	Logger           *zap.SugaredLogger
	Recorder         *record.EventRecorder
	TestCancelFn     context.CancelFunc
	// contains filtered or unexported fields
}

TestEnvironment provides mocked resources for integration tests.

func NewTestEnvironment

func NewTestEnvironment(projectRootDir string, celValidationEnabled bool,
	allowedNATSCR *natsv1alpha1.NATS) (*TestEnvironment, error)

func (TestEnvironment) CreateK8sResource

func (env TestEnvironment) CreateK8sResource(obj client.Object) error

func (TestEnvironment) CreateUnstructuredK8sResource

func (env TestEnvironment) CreateUnstructuredK8sResource(obj *unstructured.Unstructured) error

func (TestEnvironment) DeleteConfigMapFromK8s

func (env TestEnvironment) DeleteConfigMapFromK8s(name, namespace string) error

func (TestEnvironment) DeleteDestinationRuleFromK8s

func (env TestEnvironment) DeleteDestinationRuleFromK8s(name, namespace string) error

func (TestEnvironment) DeletePodDisruptionBudgetFromK8s

func (env TestEnvironment) DeletePodDisruptionBudgetFromK8s(name, namespace string) error

func (TestEnvironment) DeleteSecretFromK8s

func (env TestEnvironment) DeleteSecretFromK8s(name, namespace string) error

func (TestEnvironment) DeleteServiceFromK8s

func (env TestEnvironment) DeleteServiceFromK8s(name, namespace string) error

func (TestEnvironment) DeleteStatefulSetFromK8s

func (env TestEnvironment) DeleteStatefulSetFromK8s(name, namespace string) error

func (TestEnvironment) EnsureK8sConfigMapExists

func (env TestEnvironment) EnsureK8sConfigMapExists(t *testing.T, name, namespace string)

func (TestEnvironment) EnsureK8sConfigMapNotFound

func (env TestEnvironment) EnsureK8sConfigMapNotFound(t *testing.T, name, namespace string)

func (TestEnvironment) EnsureK8sDestinationRuleExists

func (env TestEnvironment) EnsureK8sDestinationRuleExists(t *testing.T, name, namespace string)

func (TestEnvironment) EnsureK8sDestinationRuleNotFound

func (env TestEnvironment) EnsureK8sDestinationRuleNotFound(t *testing.T, name, namespace string)

func (TestEnvironment) EnsureK8sNATSNotFound

func (env TestEnvironment) EnsureK8sNATSNotFound(t *testing.T, name, namespace string)

func (TestEnvironment) EnsureK8sPVCExists

func (env TestEnvironment) EnsureK8sPVCExists(t *testing.T, label, namespace string)

func (TestEnvironment) EnsureK8sPVCNotFound

func (env TestEnvironment) EnsureK8sPVCNotFound(t *testing.T, name, namespace string)

func (TestEnvironment) EnsureK8sPodDisruptionBudgetExists

func (env TestEnvironment) EnsureK8sPodDisruptionBudgetExists(t *testing.T, name, namespace string)

func (TestEnvironment) EnsureK8sResourceCreated

func (env TestEnvironment) EnsureK8sResourceCreated(t *testing.T, obj client.Object)

func (TestEnvironment) EnsureK8sResourceDeleted

func (env TestEnvironment) EnsureK8sResourceDeleted(t *testing.T, obj client.Object)

func (TestEnvironment) EnsureK8sResourceUpdated

func (env TestEnvironment) EnsureK8sResourceUpdated(t *testing.T, obj client.Object)

func (TestEnvironment) EnsureK8sSecretExists

func (env TestEnvironment) EnsureK8sSecretExists(t *testing.T, name, namespace string)

func (TestEnvironment) EnsureK8sSecretNotFound

func (env TestEnvironment) EnsureK8sSecretNotFound(t *testing.T, name, namespace string)

func (TestEnvironment) EnsureK8sServiceExists

func (env TestEnvironment) EnsureK8sServiceExists(t *testing.T, name, namespace string)

func (TestEnvironment) EnsureK8sServiceNotFound

func (env TestEnvironment) EnsureK8sServiceNotFound(t *testing.T, name, namespace string)

func (TestEnvironment) EnsureK8sStatefulSetExists

func (env TestEnvironment) EnsureK8sStatefulSetExists(t *testing.T, name, namespace string)

func (TestEnvironment) EnsureK8sStatefulSetHasAnnotations

func (env TestEnvironment) EnsureK8sStatefulSetHasAnnotations(t *testing.T, name, namespace string,
	annotations map[string]string)

func (TestEnvironment) EnsureK8sStatefulSetHasLabels

func (env TestEnvironment) EnsureK8sStatefulSetHasLabels(t *testing.T, name, namespace string,
	labels map[string]string)

func (TestEnvironment) EnsureK8sStatefulSetNotFound

func (env TestEnvironment) EnsureK8sStatefulSetNotFound(t *testing.T, name, namespace string)

func (TestEnvironment) EnsureK8sUnStructResourceCreated

func (env TestEnvironment) EnsureK8sUnStructResourceCreated(t *testing.T, obj *unstructured.Unstructured)

func (TestEnvironment) EnsureNATSSpecClusterSizeReflected

func (env TestEnvironment) EnsureNATSSpecClusterSizeReflected(t *testing.T, nats natsv1alpha1.NATS)

EnsureNATSSpecClusterSizeReflected ensures that NATS CR Spec.cluster.size is reflected in relevant k8s objects.

func (TestEnvironment) EnsureNATSSpecDebugTraceReflected

func (env TestEnvironment) EnsureNATSSpecDebugTraceReflected(t *testing.T, nats natsv1alpha1.NATS)

EnsureNATSSpecDebugTraceReflected ensures that NATS CR Spec.trace and Spec.debug is reflected in relevant k8s objects.

func (TestEnvironment) EnsureNATSSpecFileStorageReflected

func (env TestEnvironment) EnsureNATSSpecFileStorageReflected(t *testing.T, nats natsv1alpha1.NATS)

EnsureNATSSpecFileStorageReflected ensures that NATS CR Spec.jetStream.fileStorage is reflected in relevant k8s objects.

func (TestEnvironment) EnsureNATSSpecMemStorageReflected

func (env TestEnvironment) EnsureNATSSpecMemStorageReflected(t *testing.T, nats natsv1alpha1.NATS)

EnsureNATSSpecMemStorageReflected ensures that NATS CR Spec.jetStream.memStorage is reflected in relevant k8s objects.

func (TestEnvironment) EnsureNATSSpecResourcesReflected

func (env TestEnvironment) EnsureNATSSpecResourcesReflected(t *testing.T, nats natsv1alpha1.NATS)

EnsureNATSSpecResourcesReflected ensures that NATS CR Spec.resources is reflected in relevant k8s objects.

func (TestEnvironment) EnsureNamespaceCreation

func (env TestEnvironment) EnsureNamespaceCreation(t *testing.T, namespace string)

func (TestEnvironment) GetConfigMapFromK8s

func (env TestEnvironment) GetConfigMapFromK8s(name, namespace string) (*corev1.ConfigMap, error)

func (TestEnvironment) GetDestinationRuleFromK8s

func (env TestEnvironment) GetDestinationRuleFromK8s(name, namespace string) (*unstructured.Unstructured, error)

func (TestEnvironment) GetK8sEventsAssert

func (env TestEnvironment) GetK8sEventsAssert(g *gomega.GomegaWithT, nats *natsv1alpha1.NATS) gomega.AsyncAssertion

func (TestEnvironment) GetNATSAssert

func (env TestEnvironment) GetNATSAssert(g *gomega.GomegaWithT,
	nats *natsv1alpha1.NATS) gomega.AsyncAssertion

GetNATSAssert fetches a NATS from k8s and allows making assertions on it.

func (TestEnvironment) GetNATSFromK8s

func (env TestEnvironment) GetNATSFromK8s(name, namespace string) (natsv1alpha1.NATS, error)

func (TestEnvironment) GetPVCFromK8s

func (env TestEnvironment) GetPVCFromK8s(label, namespace string) (*corev1.PersistentVolumeClaim, error)

func (TestEnvironment) GetPodDisruptionBudgetFromK8s

func (env TestEnvironment) GetPodDisruptionBudgetFromK8s(name,
	namespace string) (*policyv1.PodDisruptionBudget, error)

func (TestEnvironment) GetSecretFromK8s

func (env TestEnvironment) GetSecretFromK8s(name, namespace string) (*corev1.Secret, error)

func (TestEnvironment) GetServiceFromK8s

func (env TestEnvironment) GetServiceFromK8s(name, namespace string) (*corev1.Service, error)

func (TestEnvironment) GetStatefulSetFromK8s

func (env TestEnvironment) GetStatefulSetFromK8s(name, namespace string) (*appsv1.StatefulSet, error)

func (TestEnvironment) TearDown

func (env TestEnvironment) TearDown() error

func (TestEnvironment) UpdateStatefulSetStatusOnK8s

func (env TestEnvironment) UpdateStatefulSetStatusOnK8s(sts appsv1.StatefulSet) error

func (TestEnvironment) UpdatedNATSInK8s

func (env TestEnvironment) UpdatedNATSInK8s(nats *natsv1alpha1.NATS, options ...testutils.NATSOption) error