resources

Documentation

Index

• Constants
• func AssertKEOperatorCRReadyStatus(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func AssertKEOperatorDeploymentStatus(t *testing.T, clients *test.Clients, namespace string, ...)
• func DeleteAndVerifyDeployments(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func EnsureKnativeEventingExists(clients eventingv1alpha1.KnativeEventingInterface, names test.ResourceNames) (*v1alpha1.KnativeEventing, error)
• func IsDeploymentAvailable(d *v1.Deployment) (bool, error)
• func IsKnativeEventingDeploymentReady(dpList *v1.DeploymentList, expectedDeployments []string, err error, ...) (bool, error)
• func IsKnativeEventingReady(s *v1alpha1.KnativeEventing, err error) (bool, error)
• func KEOperatorCRDelete(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func Setup(t *testing.T) *test.Clients
• func WaitForKnativeEventingDeploymentState(clients *test.Clients, namespace string, expectedDeployments []string, ...) error
• func WaitForKnativeEventingState(clients eventingv1alpha1.KnativeEventingInterface, name string, ...) (*v1alpha1.KnativeEventing, error)

Constants

const (
	// Interval specifies the time between two polls.
	Interval = 10 * time.Second
	// Timeout specifies the timeout for the function PollImmediate to reach a certain status.
	Timeout = 5 * time.Minute
)

Functions

func AssertKEOperatorCRReadyStatus

func AssertKEOperatorCRReadyStatus(t *testing.T, clients *test.Clients, names test.ResourceNames)

AssertKEOperatorCRReadyStatus verifies if the KnativeEventing can reach the READY status.

func AssertKEOperatorDeploymentStatus

func AssertKEOperatorDeploymentStatus(t *testing.T, clients *test.Clients, namespace string, expectedDeployments []string)

AssertKEOperatorDeploymentStatus verifies if the Knative deployments reach the READY status.

func DeleteAndVerifyDeployments

func DeleteAndVerifyDeployments(t *testing.T, clients *test.Clients, names test.ResourceNames)

DeleteAndVerifyDeployments verify whether all the deployments for knative eventing are able to recreate, when they are deleted.

func EnsureKnativeEventingExists

func EnsureKnativeEventingExists(clients eventingv1alpha1.KnativeEventingInterface, names test.ResourceNames) (*v1alpha1.KnativeEventing, error)

EnsureKnativeEventingExists creates a KnativeEventingServing with the name names.KnativeEventing under the namespace names.Namespace.

func IsDeploymentAvailable

func IsDeploymentAvailable(d *v1.Deployment) (bool, error)

IsDeploymentAvailable will check the status conditions of the deployment and return true if the deployment is available.

func IsKnativeEventingDeploymentReady

func IsKnativeEventingDeploymentReady(dpList *v1.DeploymentList, expectedDeployments []string, err error,
	logf logging.FormatLogger) (bool, error)

IsKnativeEventingDeploymentReady will check the status conditions of the deployments and return true if the deployments meet the desired status.

func IsKnativeEventingReady

func IsKnativeEventingReady(s *v1alpha1.KnativeEventing, err error) (bool, error)

IsKnativeEventingReady will check the status conditions of the KnativeEventing and return true if the KnativeEventing is ready.

func KEOperatorCRDelete

func KEOperatorCRDelete(t *testing.T, clients *test.Clients, names test.ResourceNames)

KEOperatorCRDelete deletes tha KnativeEventing to see if all resources will be deleted

func Setup

func Setup(t *testing.T) *test.Clients

Setup creates the client objects needed in the e2e tests.

func WaitForKnativeEventingDeploymentState

func WaitForKnativeEventingDeploymentState(clients *test.Clients, namespace string, expectedDeployments []string, logf logging.FormatLogger,
	inState func(deps *v1.DeploymentList, expectedDeployments []string, err error, logf logging.FormatLogger) (bool, error)) error

WaitForKnativeEventingDeploymentState polls the status of the Knative deployments every `interval` until `inState` returns `true` indicating the deployments match the desired deployments.

func WaitForKnativeEventingState

func WaitForKnativeEventingState(clients eventingv1alpha1.KnativeEventingInterface, name string,
	inState func(s *v1alpha1.KnativeEventing, err error) (bool, error)) (*v1alpha1.KnativeEventing, error)

WaitForKnativeEventingState polls the status of the KnativeEventing called name from client every `interval` until `inState` returns `true` indicating it is done, returns an error or timeout.