Documentation ¶
Index ¶
- Constants
- func StartEnvTest(projectRootDir string, celValidationEnabled bool) (*envtest.Environment, *rest.Config, error)
- type TestEnvironment
- 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 ¶
Variables ¶
This section is empty.
Functions ¶
func StartEnvTest ¶
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 ¶ added in v0.1.0
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 ¶ added in v0.1.0
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 (TestEnvironment) EnsureK8sStatefulSetHasLabels ¶
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 ¶ added in v0.1.0
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 ¶ added in v0.1.0
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