resources

Documentation

Index

• Constants
• func AssertKSOperatorCRReadyStatus(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func DeleteAndVerifyDeployments(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func EnsureKnativeServingExists(clients servingv1alpha1.KnativeServingInterface, names test.ResourceNames) (*v1alpha1.KnativeServing, error)
• func IsDeploymentAvailable(d *v1.Deployment) (bool, error)
• func IsKnativeServingReady(s *v1alpha1.KnativeServing, err error) (bool, error)
• func KSOperatorCRDelete(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func KSOperatorCRVerifyConfiguration(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func WaitForConfigMap(name string, client *kubernetes.Clientset, fn func(map[string]string) bool) error
• func WaitForKnativeServingState(clients servingv1alpha1.KnativeServingInterface, name string, ...) (*v1alpha1.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 AssertKSOperatorCRReadyStatus

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

AssertKSOperatorCRReadyStatus verifies if the KnativeServing reaches the READY status.

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 EnsureKnativeServingExists

func EnsureKnativeServingExists(clients servingv1alpha1.KnativeServingInterface, names test.ResourceNames) (*v1alpha1.KnativeServing, error)

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

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 IsKnativeServingReady

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

IsKnativeServingReady will check the status conditions of the KnativeServing and return true if the KnativeServing is ready.

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 WaitForConfigMap

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

WaitForConfigMap takes a condition function that evaluates ConfigMap data

func WaitForKnativeServingState

func WaitForKnativeServingState(clients servingv1alpha1.KnativeServingInterface, name string,
	inState func(s *v1alpha1.KnativeServing, err error) (bool, error)) (*v1alpha1.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.