virtual-kubelet: github.com/virtual-kubelet/virtual-kubelet/internal/test/e2e/framework Index | Files

package framework

import "github.com/virtual-kubelet/virtual-kubelet/internal/test/e2e/framework"

Index

Package Files

env.go framework.go node.go pod.go stats.go

type Framework Uses

type Framework struct {
    KubeClient   kubernetes.Interface
    Namespace    string
    NodeName     string
    WatchTimeout time.Duration
}

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

func NewTestingFramework Uses

func NewTestingFramework(kubeconfig, namespace, nodeName string, watchTimeout time.Duration) *Framework

NewTestingFramework returns a new instance of the testing framework.

func (*Framework) CreateDummyPodObjectWithPrefix Uses

func (f *Framework) CreateDummyPodObjectWithPrefix(testName string, 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 Uses

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

CreatePod creates the specified pod in the Kubernetes API.

func (*Framework) CreatePodObjectWithEnv Uses

func (f *Framework) CreatePodObjectWithEnv(testName string, 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 Uses

func (f *Framework) CreatePodObjectWithMandatoryConfigMapKey(testName string) *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 Uses

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

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

func (*Framework) CreatePodObjectWithOptionalConfigMapKey Uses

func (f *Framework) CreatePodObjectWithOptionalConfigMapKey(testName string) *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 Uses

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

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

func (*Framework) DeleteNode Uses

func (f *Framework) DeleteNode() error

DeleteNode deletes the vk node used by the framework

func (*Framework) DeletePod Uses

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 Uses

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) GetNode Uses

func (f *Framework) GetNode() (*corev1.Node, error)

GetNode gets the vk nodeused by the framework

func (*Framework) GetRunningPodsFromKubernetes Uses

func (f *Framework) GetRunningPodsFromKubernetes() (*corev1.PodList, error)

GetRunningPodsFromProvider gets the running pods from the provider of the virtual kubelet

func (*Framework) GetRunningPodsFromProvider Uses

func (f *Framework) GetRunningPodsFromProvider() (*corev1.PodList, error)

GetRunningPodsFromProvider gets the running pods from the provider of the virtual kubelet

func (*Framework) GetStatsSummary Uses

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) WaitUntilNodeCondition Uses

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 Uses

func (f *Framework) WaitUntilPodCondition(namespace, name string, fn watch.ConditionFunc) (*corev1.Pod, 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 Uses

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

WaitUntilPodDeleted blocks until the pod with the specified name and namespace is deleted from apiserver.

func (*Framework) WaitUntilPodEventWithReason Uses

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) WaitUntilPodInPhase Uses

func (f *Framework) WaitUntilPodInPhase(namespace, name string, phases ...corev1.PodPhase) (*corev1.Pod, error)

WaitUntilPodInPhase blocks until the pod with the specified name and namespace is in one of the specified phases

func (*Framework) WaitUntilPodReady Uses

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

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

Package framework imports 19 packages (graph) and is imported by 1 packages. Updated 2020-04-05. Refresh now. Tools for package owners.