base

Documentation

Index

• func CreateGenericChannelObject(dynamicClient dynamic.Interface, obj *resources.MetaResource) (schema.GroupVersionResource, error)
• func GetAddressableURI(dynamicClient dynamic.Interface, obj *resources.MetaResource) (url.URL, error)
• func GetGenericObject(dynamicClient dynamic.Interface, obj *resources.MetaResource, ...) (runtime.Object, error)
• func GetGenericObjectList(dynamicClient dynamic.Interface, objList *resources.MetaResourceList, ...) ([]runtime.Object, error)
• func GetServiceHostname(svc *corev1.Service) string
• func WaitForResourceReady(dynamicClient dynamic.Interface, obj *resources.MetaResource) error
• func WaitForResourcesReady(dynamicClient dynamic.Interface, objList *resources.MetaResourceList) error

Functions

func CreateGenericChannelObject

func CreateGenericChannelObject(
	dynamicClient dynamic.Interface,
	obj *resources.MetaResource,
) (schema.GroupVersionResource, error)

CreateGenericChannelObject create a generic channel object with the dynamic client and channel's meta data.

func GetAddressableURI

func GetAddressableURI(dynamicClient dynamic.Interface, obj *resources.MetaResource) (url.URL, error)

GetAddressableURI returns the uri for the given resource that implements Addressable duck-type.

func GetGenericObject

func GetGenericObject(
	dynamicClient dynamic.Interface,
	obj *resources.MetaResource,
	rtype apis.Listable,
) (runtime.Object, error)

GetGenericObject returns a generic object representing a Kubernetes resource. Callers can cast this returned object to other objects that implement the corresponding duck-type.

func GetGenericObjectList

func GetGenericObjectList(
	dynamicClient dynamic.Interface,
	objList *resources.MetaResourceList,
	rtype apis.Listable,
) ([]runtime.Object, error)

GetGenericObjectList returns a generic object list representing a list of Kubernetes resource.

func GetServiceHostname

func GetServiceHostname(svc *corev1.Service) string

func WaitForResourceReady

func WaitForResourceReady(dynamicClient dynamic.Interface, obj *resources.MetaResource) error

WaitForResourceReady polls the status of the MetaResource from client every interval until isResourceReady returns `true` indicating it is done, returns an error or timeout. desc will be used to name the metric that is emitted to track how long it took for the resource to get into the state checked by isResourceReady.

func WaitForResourcesReady

func WaitForResourcesReady(dynamicClient dynamic.Interface, objList *resources.MetaResourceList) error

WaitForResourcesReady waits until all the specified resources in the given namespace are ready.