client

Documentation

Index

• func ClusterMetadata(c client.Reader) (*kmapi.ClusterMetadata, error)
• func ClusterUID(c client.Reader) (string, error)
• func CreateOrPatch(ctx context.Context, c client.Client, obj client.Object, ...) (kutil.VerbType, error)
• func GetForGVK(ctx context.Context, c client.Client, gvk schema.GroupVersionKind, ...) (client.Object, error)
• func GetForGVR(ctx context.Context, c client.Client, gvr schema.GroupVersionResource, ...) (client.Object, error)
• func NewClient(cache cache.Cache, config *restclient.Config, options client.Options, ...) (client.Client, error)
• func NewDelegatingClient(in NewDelegatingClientInput) (client.Client, error)
• func NewUncachedClient(cfg *rest.Config, funcs ...func(*runtime.Scheme) error) (client.Client, error)
• func PatchStatus(ctx context.Context, c client.Client, obj client.Object, ...) (kutil.VerbType, error)
• type NewDelegatingClientInput
• type TransformFunc
• type TransformStatusFunc

Functions

func ClusterMetadata

func ClusterMetadata(c client.Reader) (*kmapi.ClusterMetadata, error)

func ClusterUID

func ClusterUID(c client.Reader) (string, error)

func CreateOrPatch

func CreateOrPatch(ctx context.Context, c client.Client, obj client.Object, transform TransformFunc, opts ...client.PatchOption) (kutil.VerbType, error)

func GetForGVK

func GetForGVK(ctx context.Context, c client.Client, gvk schema.GroupVersionKind, ref types.NamespacedName) (client.Object, error)

func GetForGVR

func GetForGVR(ctx context.Context, c client.Client, gvr schema.GroupVersionResource, ref types.NamespacedName) (client.Object, error)

func NewClient

func NewClient(cache cache.Cache, config *restclient.Config, options client.Options, uncachedObjects ...client.Object) (client.Client, error)

func NewDelegatingClient

func NewDelegatingClient(in NewDelegatingClientInput) (client.Client, error)

NewDelegatingClient creates a new delegating client.

A delegating client forms a Client by composing separate reader, writer and statusclient interfaces. This way, you can have an Client that reads from a cache and writes to the API server.

func NewUncachedClient

func NewUncachedClient(cfg *rest.Config, funcs ...func(*runtime.Scheme) error) (client.Client, error)

func PatchStatus

func PatchStatus(ctx context.Context, c client.Client, obj client.Object, transform TransformStatusFunc, opts ...client.PatchOption) (kutil.VerbType, error)

Types

type NewDelegatingClientInput

type NewDelegatingClientInput struct {
	CacheReader       client.Reader
	Client            client.Client
	UncachedObjects   []client.Object
	CacheUnstructured bool
	Cachable          apiutil2.Cachable
}

NewDelegatingClientInput encapsulates the input parameters to create a new delegating client.

type TransformFunc

type TransformFunc func(obj client.Object, createOp bool) client.Object

type TransformStatusFunc

type TransformStatusFunc func(obj client.Object) client.Object