framework

Documentation

Index

• type Framework
  • func NewTestingFramework(kubeconfig, namespace, nodeName, taintKey, taintValue, taintEffect string) *Framework
  • func (f *Framework) CreateDummyPodObjectWithPrefix(prefix string, images ...string) *corev1.Pod
  • func (f *Framework) CreatePod(pod *corev1.Pod) (*corev1.Pod, error)
  • func (f *Framework) CreatePodObjectWithEnv(env []corev1.EnvVar) *corev1.Pod
  • func (f *Framework) CreatePodObjectWithMandatoryConfigMapKey() *corev1.Pod
  • func (f *Framework) CreatePodObjectWithMandatorySecretKey() *corev1.Pod
  • func (f *Framework) CreatePodObjectWithOptionalConfigMapKey() *corev1.Pod
  • func (f *Framework) CreatePodObjectWithOptionalSecretKey() *corev1.Pod
  • func (f *Framework) DeleteNode() error
  • func (f *Framework) DeletePod(namespace, name string) error
  • func (f *Framework) DeletePodImmediately(namespace, name string) error
  • func (f *Framework) GetStatsSummary() (*stats.Summary, error)
  • func (f *Framework) WaitUntilNodeAdded(event watchapi.Event) (bool, error)
  • func (f *Framework) WaitUntilNodeCondition(fn watch.ConditionFunc) error
  • func (f *Framework) WaitUntilPodCondition(namespace, name string, fn watch.ConditionFunc) error
  • func (f *Framework) WaitUntilPodDeleted(namespace, name string) error
  • func (f *Framework) WaitUntilPodEventWithReason(pod *corev1.Pod, reason string) error
  • func (f *Framework) WaitUntilPodReady(namespace, name string) error

Types

type Framework

type Framework struct {
	KubeClient  kubernetes.Interface
	Namespace   string
	NodeName    string
	TaintKey    string
	TaintValue  string
	TaintEffect string
}

Framework encapsulates the configuration for the current run, and provides helper methods to be used during testing.

func NewTestingFramework

func NewTestingFramework(kubeconfig, namespace, nodeName, taintKey, taintValue, taintEffect string) *Framework

NewTestingFramework returns a new instance of the testing framework.

func (*Framework) CreateDummyPodObjectWithPrefix

func (f *Framework) CreateDummyPodObjectWithPrefix(prefix string, images ...string) *corev1.Pod

CreateDummyPodObjectWithPrefix creates a dujmmy pod object using the specified prefix as the value of .metadata.generateName. A variable number of strings can be provided. For each one of these strings, a container that uses the string as its image will be appended to the pod. This method DOES NOT create the pod in the Kubernetes API.

func (*Framework) CreatePod

func (f *Framework) CreatePod(pod *corev1.Pod) (*corev1.Pod, error)

CreatePod creates the specified pod in the Kubernetes API.

func (*Framework) CreatePodObjectWithEnv

func (f *Framework) CreatePodObjectWithEnv(env []corev1.EnvVar) *corev1.Pod

CreatePodObjectWithEnv creates a pod object whose name starts with "env-test-" and that uses the specified environment configuration for its first container.

func (*Framework) CreatePodObjectWithMandatoryConfigMapKey

func (f *Framework) CreatePodObjectWithMandatoryConfigMapKey() *corev1.Pod

CreatePodObjectWithMandatoryConfigMapKey creates a pod object that references the "key_0" key from the "config-map-0" config map as mandatory.

func (*Framework) CreatePodObjectWithMandatorySecretKey

func (f *Framework) CreatePodObjectWithMandatorySecretKey() *corev1.Pod

CreatePodObjectWithMandatorySecretKey creates a pod object that references the "key_0" key from the "secret-0" config map as mandatory.

func (*Framework) CreatePodObjectWithOptionalConfigMapKey

func (f *Framework) CreatePodObjectWithOptionalConfigMapKey() *corev1.Pod

CreatePodObjectWithOptionalConfigMapKey creates a pod object that references the "key_0" key from the "config-map-0" config map as optional.

func (*Framework) CreatePodObjectWithOptionalSecretKey

func (f *Framework) CreatePodObjectWithOptionalSecretKey() *corev1.Pod

CreatePodObjectWithOptionalSecretKey creates a pod object that references the "key_0" key from the "secret-0" config map as optional.

func (*Framework) DeleteNode

func (f *Framework) DeleteNode() error

DeleteNode deletes the vk node used by the framework

func (*Framework) DeletePod

func (f *Framework) DeletePod(namespace, name string) error

DeletePod deletes the pod with the specified name and namespace in the Kubernetes API using the default grace period.

func (*Framework) DeletePodImmediately

func (f *Framework) DeletePodImmediately(namespace, name string) error

DeletePodImmediately forcibly deletes the pod with the specified name and namespace in the Kubernetes API. This is equivalent to running "kubectl delete --force --grace-period 0 --namespace <namespace> pod <name>".

func (*Framework) GetStatsSummary

func (f *Framework) GetStatsSummary() (*stats.Summary, error)

GetStatsSummary queries the /stats/summary endpoint of the virtual-kubelet and returns the Summary object obtained as a response.

func (*Framework) WaitUntilNodeAdded

func (f *Framework) WaitUntilNodeAdded(event watchapi.Event) (bool, error)

WaitUntilNodeAdded is a watch condition which waits until the VK node object is added.

func (*Framework) WaitUntilNodeCondition

func (f *Framework) WaitUntilNodeCondition(fn watch.ConditionFunc) error

WaitUntilNodeCondition establishes a watch on the vk node. Then, it waits for the specified condition function to be verified.

func (*Framework) WaitUntilPodCondition

func (f *Framework) WaitUntilPodCondition(namespace, name string, fn watch.ConditionFunc) error

WaitUntilPodCondition establishes a watch on the pod with the specified name and namespace. Then, it waits for the specified condition function to be verified.

func (*Framework) WaitUntilPodDeleted

func (f *Framework) WaitUntilPodDeleted(namespace, name string) error

WaitUntilPodDeleted blocks until the pod with the specified name and namespace is marked for deletion (or, alternatively, effectively deleted).

func (*Framework) WaitUntilPodEventWithReason

func (f *Framework) WaitUntilPodEventWithReason(pod *corev1.Pod, reason string) error

WaitUntilPodEventWithReason establishes a watch on events involving the specified pod. Then, it waits for an event with the specified reason to be created/updated.

func (*Framework) WaitUntilPodReady

func (f *Framework) WaitUntilPodReady(namespace, name string) error

WaitUntilPodReady blocks until the pod with the specified name and namespace is reported to be running and ready.