package resource

import "k8s.io/kubernetes/test/e2e/framework/resource"

Index ¶

• func DeleteResourceAndWaitForGC(c clientset.Interface, kind schema.GroupKind, ns, name string) error
• func GetReplicasFromRuntimeObject(obj runtime.Object) (int32, error)
• func GetRuntimeObjectForKind(c clientset.Interface, kind schema.GroupKind, ns, name string) (runtime.Object, error)
• func GetSelectorFromRuntimeObject(obj runtime.Object) (labels.Selector, error)
• func ScaleResource( clientset clientset.Interface, scalesGetter scaleclient.ScalesGetter, ns, name string, size uint, wait bool, kind schema.GroupKind, gvr schema.GroupVersionResource, ) error
• func WaitForControlledPods(c clientset.Interface, ns, name string, kind schema.GroupKind) (pods *v1.PodList, err error)
• func WaitForControlledPodsRunning(c clientset.Interface, ns, name string, kind schema.GroupKind) error

Functions ¶

func DeleteResourceAndWaitForGC ¶

func DeleteResourceAndWaitForGC(c clientset.Interface, kind schema.GroupKind, ns, name string) error

DeleteResourceAndWaitForGC deletes only given resource and waits for GC to delete the pods.

func GetReplicasFromRuntimeObject ¶

func GetReplicasFromRuntimeObject(obj runtime.Object) (int32, error)

GetReplicasFromRuntimeObject returns the number of replicas for the given object.

func GetRuntimeObjectForKind ¶

func GetRuntimeObjectForKind(c clientset.Interface, kind schema.GroupKind, ns, name string) (runtime.Object, error)

GetRuntimeObjectForKind returns a runtime.Object based on its GroupKind, namespace and name.

func GetSelectorFromRuntimeObject ¶

func GetSelectorFromRuntimeObject(obj runtime.Object) (labels.Selector, error)

GetSelectorFromRuntimeObject returns the labels for the given object.

func ScaleResource ¶

func ScaleResource(
	clientset clientset.Interface,
	scalesGetter scaleclient.ScalesGetter,
	ns, name string,
	size uint,
	wait bool,
	kind schema.GroupKind,
	gvr schema.GroupVersionResource,
) error

ScaleResource scales resource to the given size.

func WaitForControlledPods ¶

func WaitForControlledPods(c clientset.Interface, ns, name string, kind schema.GroupKind) (pods *v1.PodList, err error)

WaitForControlledPods waits up to podListTimeout for getting pods of the specified controller name and return them.

func WaitForControlledPodsRunning ¶

func WaitForControlledPodsRunning(c clientset.Interface, ns, name string, kind schema.GroupKind) error

WaitForControlledPodsRunning waits up to 10 minutes for pods to become Running.

Source Files ¶

resources.go runtimeobj.go