kubernetes/test/e2e/apimachinery/crd_watch.go

var _ …

func watchCRWithName(ctx context.Context, crdResourceClient dynamic.ResourceInterface, name string) (watch.Interface, error) { … }

func instantiateCustomResource(ctx context.Context, instanceToCreate *unstructured.Unstructured, client dynamic.ResourceInterface, definition *apiextensionsv1.CustomResourceDefinition) (*unstructured.Unstructured, error) { … }

func patchCustomResource(ctx context.Context, client dynamic.ResourceInterface, name string) error { … }

func deleteCustomResource(ctx context.Context, client dynamic.ResourceInterface, name string) error { … }

func newNamespacedCustomResourceClient(ns string, client dynamic.Interface, crd *apiextensionsv1.CustomResourceDefinition) (dynamic.ResourceInterface, error) { … }