resources

Documentation

Index

• Constants
• func AssertKSOperatorCRReadyStatus(t *testing.T, clients *test.Clients, names test.ResourceNames)
• func AssertKSOperatorDeploymentStatus(t *testing.T, clients *test.Clients, namespace string, ...)
• 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 IsKnativeServingDeploymentReady(dpList *v1.DeploymentList, expectedDeployments []string, err error, ...) (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 WaitForKnativeServingDeploymentState(clients *test.Clients, namespace string, expectedDeployments []string, ...) 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 AssertKSOperatorDeploymentStatus

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

AssertKSOperatorDeploymentStatus 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 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 IsKnativeServingDeploymentReady

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

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

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 WaitForKnativeServingDeploymentState

func WaitForKnativeServingDeploymentState(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

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

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.