duck

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.

func WaitForResourcesReady

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

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