integration

Documentation

Index

• Constants
• func SetupAndStartEnvTest(config TestEnvironmentConfig) (*envtest.Environment, *rest.Config, error)
• func StartEnvTestWithRetry(testEnv *envtest.Environment) (*rest.Config, error)
• type TestEnvironment
  • func NewTestEnvironment(config TestEnvironmentConfig, connMock *natsconnectionmocks.Connection) (*TestEnvironment, error)
  • func (env TestEnvironment) CreateK8sResource(obj client.Object) error
  • func (env TestEnvironment) CreateUnstructuredK8sResource(obj *unstructured.Unstructured) error
  • func (env TestEnvironment) DeleteClusterRoleBindingFromK8s(name, namespace string) error
  • func (env TestEnvironment) DeleteClusterRoleFromK8s(name, namespace string) error
  • func (env TestEnvironment) DeleteEventingFromK8s(name, namespace string) error
  • func (env TestEnvironment) DeleteHPAFromK8s(name, namespace string) error
  • func (env TestEnvironment) DeleteSecretFromK8s(name, namespace string) error
  • func (env TestEnvironment) DeleteServiceAccountFromK8s(name, namespace string) error
  • func (env TestEnvironment) DeleteServiceFromK8s(name, namespace string) error
  • func (env TestEnvironment) EnsureCRDCreated(t *testing.T, crd *kapiextensionsv1.CustomResourceDefinition)
  • func (env TestEnvironment) EnsureDeploymentDeletion(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureDeploymentExists(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureDeploymentNotFound(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureDeploymentOwnerReferenceSet(t *testing.T, eventingCR *v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEPPClusterRoleBindingCorrect(t *testing.T, eventingCR v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEPPClusterRoleBindingOwnerReferenceSet(t *testing.T, eventingCR v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEPPClusterRoleCorrect(t *testing.T, eventingCR v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEPPClusterRoleOwnerReferenceSet(t *testing.T, eventingCR v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEPPHealthServiceCorrect(t *testing.T, eppDeployment *kappsv1.Deployment, eventingCR v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEPPHealthServiceOwnerReferenceSet(t *testing.T, eventingCR v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEPPK8sResourcesExists(t *testing.T, eventingCR v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEPPK8sResourcesHaveOwnerReference(t *testing.T, eventingCR v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEPPMetricsServiceCorrect(t *testing.T, eppDeployment *kappsv1.Deployment, eventingCR v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEPPMetricsServiceOwnerReferenceSet(t *testing.T, eventingCR v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEPPPublishServiceCorrect(t *testing.T, eppDeployment *kappsv1.Deployment, eventingCR v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEPPPublishServiceOwnerReferenceSet(t *testing.T, eventingCR v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEPPServiceAccountOwnerReferenceSet(t *testing.T, eventingCR v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEventMeshSecretCreated(t *testing.T, eventing *v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEventMeshSecretDeleted(t *testing.T, eventing *v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEventingReplicasReflected(t *testing.T, eventingCR *v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureEventingResourceDeletion(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureEventingResourceDeletionStateError(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureEventingSpecPublisherReflected(t *testing.T, eventingCR *v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureHPADeletion(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureHPAExists(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureHPANotFound(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sClusterRoleBindingExists(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sClusterRoleBindingNotFound(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sClusterRoleExists(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sClusterRoleNotFound(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) EnsureK8sServiceAccountExists(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureK8sServiceAccountNotFound(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) EnsureK8sUnStructResourceCreated(t *testing.T, obj *unstructured.Unstructured)
  • func (env TestEnvironment) EnsureNATSCRDDeleted(t *testing.T)
  • func (env TestEnvironment) EnsureNATSResourceState(t *testing.T, nats *natsv1alpha1.NATS, status string)
  • func (env TestEnvironment) EnsureNATSResourceStateError(t *testing.T, nats *natsv1alpha1.NATS)
  • func (env TestEnvironment) EnsureNATSResourceStateReady(t *testing.T, nats *natsv1alpha1.NATS)
  • func (env TestEnvironment) EnsureNamespaceCreation(t *testing.T, namespace string)
  • func (env TestEnvironment) EnsureNamespaceDeleted(t *testing.T, namespace string)
  • func (env TestEnvironment) EnsureOAuthSecretCreated(t *testing.T, eventing *v1alpha1.Eventing)
  • func (env TestEnvironment) EnsurePublishServiceInEventingStatus(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsurePublisherDeploymentENVSet(t *testing.T, eventingCR *v1alpha1.Eventing)
  • func (env TestEnvironment) EnsureSubscriptionExists(t *testing.T, name, namespace string)
  • func (env TestEnvironment) EnsureSubscriptionResourceDeletion(t *testing.T, name, namespace string)
  • func (env TestEnvironment) GetClusterRoleBindingFromK8s(name, namespace string) (*krbacv1.ClusterRoleBinding, error)
  • func (env TestEnvironment) GetClusterRoleFromK8s(name, namespace string) (*krbacv1.ClusterRole, error)
  • func (env TestEnvironment) GetDeploymentFromK8s(name, namespace string) (*kappsv1.Deployment, error)
  • func (env TestEnvironment) GetEventingAssert(g *gomega.GomegaWithT, eventing *v1alpha1.Eventing) gomega.AsyncAssertion
  • func (env TestEnvironment) GetEventingFromK8s(name, namespace string) (*v1alpha1.Eventing, error)
  • func (env TestEnvironment) GetHPAFromK8s(name, namespace string) (*kautoscalingv1.HorizontalPodAutoscaler, error)
  • func (env TestEnvironment) GetNATSFromK8s(name, namespace string) (*natsv1alpha1.NATS, error)
  • func (env TestEnvironment) GetSecretFromK8s(name, namespace string) (*kcorev1.Secret, error)
  • func (env TestEnvironment) GetServiceAccountFromK8s(name, namespace string) (*kcorev1.ServiceAccount, error)
  • func (env TestEnvironment) GetServiceFromK8s(name, namespace string) (*kcorev1.Service, error)
  • func (env TestEnvironment) GetSubscriptionFromK8s(name, namespace string) (*eventingv1alpha2.Subscription, error)
  • func (env TestEnvironment) TearDown() error
  • func (env TestEnvironment) UpdateEventingStatus(eventing *v1alpha1.Eventing) error
  • func (env TestEnvironment) UpdateNATSStatus(nats *natsv1alpha1.NATS) error
  • func (env TestEnvironment) UpdateUnstructuredK8sResource(obj *unstructured.Unstructured) error
• type TestEnvironmentConfig

Constants

const (
	BigPollingInterval   = 3 * time.Second
	BigTimeOut           = 120 * time.Second
	SmallTimeOut         = 60 * time.Second
	SmallPollingInterval = 1 * time.Second
)

Functions

func SetupAndStartEnvTest

func SetupAndStartEnvTest(config TestEnvironmentConfig) (*envtest.Environment, *rest.Config, error)

func StartEnvTestWithRetry

func StartEnvTestWithRetry(testEnv *envtest.Environment) (*rest.Config, error)

Types

type TestEnvironment

type TestEnvironment struct {
	EnvTestInstance *envtest.Environment

	KubeClient          k8s.Client
	K8sDynamicClient    *dynamic.DynamicClient
	Reconciler          *eventingcontroller.Reconciler
	Logger              *logger.Logger
	Recorder            *record.EventRecorder
	TestCancelFn        context.CancelFunc
	SubManagerFactory   subscriptionmanager.ManagerFactory
	JetStreamSubManager manager.Manager
	// contains filtered or unexported fields
}

TestEnvironment provides mocked resources for integration tests.

func NewTestEnvironment

func NewTestEnvironment(config TestEnvironmentConfig, connMock *natsconnectionmocks.Connection) (*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) DeleteClusterRoleBindingFromK8s

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

func (TestEnvironment) DeleteClusterRoleFromK8s

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

func (TestEnvironment) DeleteEventingFromK8s

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

func (TestEnvironment) DeleteHPAFromK8s

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

func (TestEnvironment) DeleteSecretFromK8s

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

func (TestEnvironment) DeleteServiceAccountFromK8s

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

func (TestEnvironment) DeleteServiceFromK8s

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

func (TestEnvironment) EnsureCRDCreated

func (env TestEnvironment) EnsureCRDCreated(t *testing.T, crd *kapiextensionsv1.CustomResourceDefinition)

func (TestEnvironment) EnsureDeploymentDeletion

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

func (TestEnvironment) EnsureDeploymentExists

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

func (TestEnvironment) EnsureDeploymentNotFound

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

func (TestEnvironment) EnsureDeploymentOwnerReferenceSet

func (env TestEnvironment) EnsureDeploymentOwnerReferenceSet(t *testing.T, eventingCR *v1alpha1.Eventing)

func (TestEnvironment) EnsureEPPClusterRoleBindingCorrect

func (env TestEnvironment) EnsureEPPClusterRoleBindingCorrect(t *testing.T, eventingCR v1alpha1.Eventing)

func (TestEnvironment) EnsureEPPClusterRoleBindingOwnerReferenceSet

func (env TestEnvironment) EnsureEPPClusterRoleBindingOwnerReferenceSet(t *testing.T, eventingCR v1alpha1.Eventing)

func (TestEnvironment) EnsureEPPClusterRoleCorrect

func (env TestEnvironment) EnsureEPPClusterRoleCorrect(t *testing.T, eventingCR v1alpha1.Eventing)

func (TestEnvironment) EnsureEPPClusterRoleOwnerReferenceSet

func (env TestEnvironment) EnsureEPPClusterRoleOwnerReferenceSet(t *testing.T, eventingCR v1alpha1.Eventing)

func (TestEnvironment) EnsureEPPHealthServiceCorrect

func (env TestEnvironment) EnsureEPPHealthServiceCorrect(t *testing.T, eppDeployment *kappsv1.Deployment, eventingCR v1alpha1.Eventing)

func (TestEnvironment) EnsureEPPHealthServiceOwnerReferenceSet

func (env TestEnvironment) EnsureEPPHealthServiceOwnerReferenceSet(t *testing.T, eventingCR v1alpha1.Eventing)

func (TestEnvironment) EnsureEPPK8sResourcesExists

func (env TestEnvironment) EnsureEPPK8sResourcesExists(t *testing.T, eventingCR v1alpha1.Eventing)

func (TestEnvironment) EnsureEPPK8sResourcesHaveOwnerReference

func (env TestEnvironment) EnsureEPPK8sResourcesHaveOwnerReference(t *testing.T, eventingCR v1alpha1.Eventing)

func (TestEnvironment) EnsureEPPMetricsServiceCorrect

func (env TestEnvironment) EnsureEPPMetricsServiceCorrect(t *testing.T, eppDeployment *kappsv1.Deployment, eventingCR v1alpha1.Eventing)

func (TestEnvironment) EnsureEPPMetricsServiceOwnerReferenceSet

func (env TestEnvironment) EnsureEPPMetricsServiceOwnerReferenceSet(t *testing.T, eventingCR v1alpha1.Eventing)

func (TestEnvironment) EnsureEPPPublishServiceCorrect

func (env TestEnvironment) EnsureEPPPublishServiceCorrect(t *testing.T, eppDeployment *kappsv1.Deployment, eventingCR v1alpha1.Eventing)

func (TestEnvironment) EnsureEPPPublishServiceOwnerReferenceSet

func (env TestEnvironment) EnsureEPPPublishServiceOwnerReferenceSet(t *testing.T, eventingCR v1alpha1.Eventing)

func (TestEnvironment) EnsureEPPServiceAccountOwnerReferenceSet

func (env TestEnvironment) EnsureEPPServiceAccountOwnerReferenceSet(t *testing.T, eventingCR v1alpha1.Eventing)

func (TestEnvironment) EnsureEventMeshSecretCreated

func (env TestEnvironment) EnsureEventMeshSecretCreated(t *testing.T, eventing *v1alpha1.Eventing)

func (TestEnvironment) EnsureEventMeshSecretDeleted

func (env TestEnvironment) EnsureEventMeshSecretDeleted(t *testing.T, eventing *v1alpha1.Eventing)

func (TestEnvironment) EnsureEventingReplicasReflected

func (env TestEnvironment) EnsureEventingReplicasReflected(t *testing.T, eventingCR *v1alpha1.Eventing)

func (TestEnvironment) EnsureEventingResourceDeletion

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

func (TestEnvironment) EnsureEventingResourceDeletionStateError

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

func (TestEnvironment) EnsureEventingSpecPublisherReflected

func (env TestEnvironment) EnsureEventingSpecPublisherReflected(t *testing.T, eventingCR *v1alpha1.Eventing)

func (TestEnvironment) EnsureHPADeletion

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

func (TestEnvironment) EnsureHPAExists

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

func (TestEnvironment) EnsureHPANotFound

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

func (TestEnvironment) EnsureK8sClusterRoleBindingExists

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

func (TestEnvironment) EnsureK8sClusterRoleBindingNotFound

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

func (TestEnvironment) EnsureK8sClusterRoleExists

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

func (TestEnvironment) EnsureK8sClusterRoleNotFound

func (env TestEnvironment) EnsureK8sClusterRoleNotFound(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) EnsureK8sServiceAccountExists

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

func (TestEnvironment) EnsureK8sServiceAccountNotFound

func (env TestEnvironment) EnsureK8sServiceAccountNotFound(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) EnsureK8sUnStructResourceCreated

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

func (TestEnvironment) EnsureNATSCRDDeleted

func (env TestEnvironment) EnsureNATSCRDDeleted(t *testing.T)

func (TestEnvironment) EnsureNATSResourceState

func (env TestEnvironment) EnsureNATSResourceState(t *testing.T, nats *natsv1alpha1.NATS, status string)

func (TestEnvironment) EnsureNATSResourceStateError

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

func (TestEnvironment) EnsureNATSResourceStateReady

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

func (TestEnvironment) EnsureNamespaceCreation

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

func (TestEnvironment) EnsureNamespaceDeleted

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

func (TestEnvironment) EnsureOAuthSecretCreated

func (env TestEnvironment) EnsureOAuthSecretCreated(t *testing.T, eventing *v1alpha1.Eventing)

func (TestEnvironment) EnsurePublishServiceInEventingStatus

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

func (TestEnvironment) EnsurePublisherDeploymentENVSet

func (env TestEnvironment) EnsurePublisherDeploymentENVSet(t *testing.T, eventingCR *v1alpha1.Eventing)

func (TestEnvironment) EnsureSubscriptionExists

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

func (TestEnvironment) EnsureSubscriptionResourceDeletion

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

func (TestEnvironment) GetClusterRoleBindingFromK8s

func (env TestEnvironment) GetClusterRoleBindingFromK8s(name, namespace string) (*krbacv1.ClusterRoleBinding, error)

func (TestEnvironment) GetClusterRoleFromK8s

func (env TestEnvironment) GetClusterRoleFromK8s(name, namespace string) (*krbacv1.ClusterRole, error)

func (TestEnvironment) GetDeploymentFromK8s

func (env TestEnvironment) GetDeploymentFromK8s(name, namespace string) (*kappsv1.Deployment, error)

func (TestEnvironment) GetEventingAssert

func (env TestEnvironment) GetEventingAssert(g *gomega.GomegaWithT,
	eventing *v1alpha1.Eventing,
) gomega.AsyncAssertion

GetEventingAssert fetches Eventing from k8s and allows making assertions on it.

func (TestEnvironment) GetEventingFromK8s

func (env TestEnvironment) GetEventingFromK8s(name, namespace string) (*v1alpha1.Eventing, error)

func (TestEnvironment) GetHPAFromK8s

func (env TestEnvironment) GetHPAFromK8s(name, namespace string) (*kautoscalingv1.HorizontalPodAutoscaler, error)

func (TestEnvironment) GetNATSFromK8s

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

func (TestEnvironment) GetSecretFromK8s

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

func (TestEnvironment) GetServiceAccountFromK8s

func (env TestEnvironment) GetServiceAccountFromK8s(name, namespace string) (*kcorev1.ServiceAccount, error)

func (TestEnvironment) GetServiceFromK8s

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

func (TestEnvironment) GetSubscriptionFromK8s

func (env TestEnvironment) GetSubscriptionFromK8s(name, namespace string) (*eventingv1alpha2.Subscription, error)

func (TestEnvironment) TearDown

func (env TestEnvironment) TearDown() error

func (TestEnvironment) UpdateEventingStatus

func (env TestEnvironment) UpdateEventingStatus(eventing *v1alpha1.Eventing) error

func (TestEnvironment) UpdateNATSStatus

func (env TestEnvironment) UpdateNATSStatus(nats *natsv1alpha1.NATS) error

func (TestEnvironment) UpdateUnstructuredK8sResource

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

type TestEnvironmentConfig

type TestEnvironmentConfig struct {
	ProjectRootDir            string
	CELValidationEnabled      bool
	APIRuleCRDEnabled         bool
	ApplicationRuleCRDEnabled bool
	NATSCRDEnabled            bool
	AllowedEventingCR         *v1alpha1.Eventing
}