Documentation
¶
Index ¶
- func IsPodReady(pod *corev1.Pod) bool
- type Framework
- func (f *Framework) CreateDummyPodObjectWithPrefix(testName string, prefix string, images ...string) *corev1.Pod
- func (f *Framework) CreatePod(ctx context.Context, pod *corev1.Pod) (*corev1.Pod, error)
- func (f *Framework) CreatePodObjectWithEnv(testName string, env []corev1.EnvVar) *corev1.Pod
- func (f *Framework) CreatePodObjectWithMandatoryConfigMapKey(testName string) *corev1.Pod
- func (f *Framework) CreatePodObjectWithMandatorySecretKey(testName string) *corev1.Pod
- func (f *Framework) CreatePodObjectWithOptionalConfigMapKey(testName string) *corev1.Pod
- func (f *Framework) CreatePodObjectWithOptionalSecretKey(testName string) *corev1.Pod
- func (f *Framework) DeleteNode(ctx context.Context) error
- func (f *Framework) DeletePod(ctx context.Context, namespace, name string) error
- func (f *Framework) DeletePodImmediately(ctx context.Context, namespace, name string) error
- func (f *Framework) GetMetricsResource(ctx context.Context) ([]byte, error)
- func (f *Framework) GetNode(ctx context.Context) (*corev1.Node, error)
- func (f *Framework) GetRunningPodsFromKubernetes(ctx context.Context) (*corev1.PodList, error)
- func (f *Framework) GetRunningPodsFromProvider(ctx context.Context) (*corev1.PodList, error)
- func (f *Framework) GetStatsSummary(ctx context.Context) (*stats.Summary, error)
- func (f *Framework) WaitUntilNodeCondition(fn watch.ConditionFunc) error
- func (f *Framework) WaitUntilPodCondition(namespace, name string, fn watch.ConditionFunc) (*corev1.Pod, error)
- func (f *Framework) WaitUntilPodDeleted(namespace, name string) (*corev1.Pod, error)
- func (f *Framework) WaitUntilPodEventWithReason(pod *corev1.Pod, reason string) error
- func (f *Framework) WaitUntilPodInPhase(namespace, name string, phases ...corev1.PodPhase) (*corev1.Pod, error)
- func (f *Framework) WaitUntilPodReady(namespace, name string) (*corev1.Pod, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Framework ¶
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 ¶
func NewTestingFramework(kubeconfig, namespace, nodeName string, watchTimeout time.Duration) *Framework
NewTestingFramework returns a new instance of the testing framework.
func (*Framework) CreateDummyPodObjectWithPrefix ¶
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) CreatePodObjectWithEnv ¶
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 ¶
CreatePodObjectWithMandatoryConfigMapKey creates a pod object that references the "key_0" key from the "config-map-0" config map as mandatory.
func (*Framework) CreatePodObjectWithMandatorySecretKey ¶
CreatePodObjectWithMandatorySecretKey creates a pod object that references the "key_0" key from the "secret-0" config map as mandatory.
func (*Framework) CreatePodObjectWithOptionalConfigMapKey ¶
CreatePodObjectWithOptionalConfigMapKey creates a pod object that references the "key_0" key from the "config-map-0" config map as optional.
func (*Framework) CreatePodObjectWithOptionalSecretKey ¶
CreatePodObjectWithOptionalSecretKey creates a pod object that references the "key_0" key from the "secret-0" config map as optional.
func (*Framework) DeleteNode ¶
DeleteNode deletes the vk node used by the framework
func (*Framework) DeletePod ¶
DeletePod deletes the pod with the specified name and namespace in the Kubernetes API using the default grace period.
func (*Framework) DeletePodImmediately ¶
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) GetMetricsResource ¶
GetStatsSummary queries the /metrics/resource endpoint of the virtual-kubelet and returns the Summary object obtained as a response.
func (*Framework) GetRunningPodsFromKubernetes ¶
GetRunningPodsFromKubernetes gets the running pods from the provider of the virtual kubelet
func (*Framework) GetRunningPodsFromProvider ¶
GetRunningPodsFromProvider gets the running pods from the provider of the virtual kubelet
func (*Framework) GetStatsSummary ¶
GetStatsSummary queries the /stats/summary endpoint of the virtual-kubelet and returns the Summary object obtained as a response.
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) (*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 ¶
WaitUntilPodDeleted blocks until the pod with the specified name and namespace is deleted from apiserver.
func (*Framework) WaitUntilPodEventWithReason ¶
WaitUntilPodEventWithReason establishes a watch on events involving the specified pod. Then, it waits for an event with the specified reason to be created/updated.
Source Files