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 RetryWebhookErrors(updater func(int) error) error
• func WaitForKServiceReady(client resources.ServingClient, name, namespace string) error
• func WaitForKServiceScales(ctx context.Context, client resources.ServingClient, name, namespace string, ...) error
• 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 runtime.Object,
) (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 runtime.Object,
) ([]runtime.Object, error)

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

func GetServiceHostname

func GetServiceHostname(svc *corev1.Service) string

func RetryWebhookErrors

func RetryWebhookErrors(updater func(int) error) error

func WaitForKServiceReady

func WaitForKServiceReady(client resources.ServingClient, name, namespace string) error

WaitForKServiceReady will wait until ksvc reports that's ready

func WaitForKServiceScales

func WaitForKServiceScales(ctx context.Context, client resources.ServingClient, name, namespace string, satisfyScale func(int) bool) error

WaitForKServiceScales will wait until ksvc scale is satisfied

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.