resources

Documentation

Index

• Constants
• func AssertKEOperatorCRReadyStatus(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func AssertKSOperatorCRReadyStatus(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func AssertKnativeDeploymentStatus(t *testing.T, clients *test.Clients, namespace string, version string, ...)
• func AssertKnativeObsoleteResource(t *testing.T, clients *test.Clients, namespace string, ...)
• func DeleteAndVerifyDeployments(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func DeleteAndVerifyEventingDeployments(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func EnsureKnativeEventingExists(clients eventingv1beta1.KnativeEventingInterface, names test.ResourceNames) (*v1beta1.KnativeEventing, error)
• func EnsureKnativeServingExists(clients servingv1beta1.KnativeServingInterface, names test.ResourceNames) (*v1beta1.KnativeServing, error)
• func GetExpectedDeployments(manifest mf.Manifest) []string
• func IsDeploymentAvailable(d *v1.Deployment) (bool, error)
• func IsKnativeDeploymentReady(dpList *v1.DeploymentList, expectedDeployments []string, version string, ...) (bool, error)
• func IsKnativeEventingReady(s *v1beta1.KnativeEventing, err error) (bool, error)
• func IsKnativeObsoleteResourceGone(clients *test.Clients, namespace string, ...) (bool, error)
• func IsKnativeServingReady(s *v1beta1.KnativeServing, err error) (bool, error)
• func KEOperatorCRDelete(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func KSOperatorCRDelete(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func KSOperatorCRVerifyConfiguration(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func SetKodataDir()
• func VerifyHADeployments(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func WaitForConfigMap(name string, client kubernetes.Interface, fn func(map[string]string) bool) error
• func WaitForKnativeDeploymentState(clients *test.Clients, namespace string, version string, ...) error
• func WaitForKnativeEventingState(clients eventingv1beta1.KnativeEventingInterface, name string, ...) (*v1beta1.KnativeEventing, error)
• func WaitForKnativeResourceState(clients *test.Clients, namespace string, ...) error
• func WaitForKnativeServingState(clients servingv1beta1.KnativeServingInterface, name string, ...) (*v1beta1.KnativeServing, 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
	// LoggingConfigKey specifies specifies the key name of the logging config map.
	LoggingConfigKey = "logging"
	// DefaultsConfigKey specifies the key name of the default config map.
	DefaultsConfigKey = "defaults"
)

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 AssertKSOperatorCRReadyStatus

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

AssertKSOperatorCRReadyStatus verifies if the KnativeServing reaches the READY status.

func AssertKnativeDeploymentStatus

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

AssertKnativeDeploymentStatus verifies if the Knative deployments reach the READY status.

func AssertKnativeObsoleteResource

func AssertKnativeObsoleteResource(t *testing.T, clients *test.Clients, namespace string, obsResources []unstructured.Unstructured)

AssertKnativeObsoleteResource verifies if all obsolete resources disappear in the cluster

func DeleteAndVerifyDeployments

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

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

func DeleteAndVerifyEventingDeployments

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

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

func EnsureKnativeEventingExists

func EnsureKnativeEventingExists(clients eventingv1beta1.KnativeEventingInterface, names test.ResourceNames) (*v1beta1.KnativeEventing, error)

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

func EnsureKnativeServingExists

func EnsureKnativeServingExists(clients servingv1beta1.KnativeServingInterface, names test.ResourceNames) (*v1beta1.KnativeServing, error)

EnsureKnativeServingExists creates a KnativeServing with the name names.KnativeServing under the namespace names.Namespace, if it does not exist.

func GetExpectedDeployments

func GetExpectedDeployments(manifest mf.Manifest) []string

GetExpectedDeployments will return an array of deployment resources based on the version for the knative component.

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 IsKnativeDeploymentReady

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

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

func IsKnativeEventingReady

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

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

func IsKnativeObsoleteResourceGone

func IsKnativeObsoleteResourceGone(clients *test.Clients, namespace string, obsResources []unstructured.Unstructured,
	logf logging.FormatLogger) (bool, error)

IsKnativeObsoleteResourceGone check the status conditions of the resources and return true if the obsolete resources are removed.

func IsKnativeServingReady

func IsKnativeServingReady(s *v1beta1.KnativeServing, err error) (bool, error)

IsKnativeServingReady will check the status conditions of the KnativeServing and return true if the KnativeServing 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 KSOperatorCRDelete

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

KSOperatorCRDelete deletes tha KnativeServing to see if all resources will be deleted

func KSOperatorCRVerifyConfiguration

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

KSOperatorCRVerifyConfiguration verifies that KnativeServing config is set properly

func SetKodataDir

func SetKodataDir()

SetKodataDir will set the env var KO_DATA_PATH into the path of the kodata of this repository.

func VerifyHADeployments

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

VerifyHADeployments verify whether all the deployments has scaled up.

func WaitForConfigMap

func WaitForConfigMap(name string, client kubernetes.Interface, fn func(map[string]string) bool) error

WaitForConfigMap takes a condition function that evaluates ConfigMap data

func WaitForKnativeDeploymentState

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

WaitForKnativeDeploymentState 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 eventingv1beta1.KnativeEventingInterface, name string,
	inState func(s *v1beta1.KnativeEventing, err error) (bool, error)) (*v1beta1.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.

func WaitForKnativeResourceState

func WaitForKnativeResourceState(clients *test.Clients, namespace string,
	obsResources []unstructured.Unstructured, logf logging.FormatLogger, inState func(clients *test.Clients,
		namespace string, obsResources []unstructured.Unstructured, logf logging.FormatLogger) (bool, error)) error

WaitForKnativeResourceState returns the status of whether all obsolete resources are removed

func WaitForKnativeServingState

func WaitForKnativeServingState(clients servingv1beta1.KnativeServingInterface, name string,
	inState func(s *v1beta1.KnativeServing, err error) (bool, error)) (*v1beta1.KnativeServing, error)

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