clientutil

Documentation

Index

• func AddAnnotation(o client.Object, key, value string)
• func AddLabel(o client.Object, key, value string)
• func ClusterNameIndexer(obj client.Object) []string
• func DeleteYaml(ctx context.Context, c client.Client, yaml []byte) error
• func ObjectsToClientObjects[T client.Object](objs []T) []client.Object
• func YamlToClientObjects(yamlObjects []byte) ([]client.Object, error)
• type KubeClient
  • func NewKubeClient(client client.Client) *KubeClient
  • func (c *KubeClient) Create(ctx context.Context, obj kubernetes.Object) error
  • func (c *KubeClient) Delete(ctx context.Context, obj kubernetes.Object) error
  • func (c *KubeClient) DeleteAllOf(ctx context.Context, obj kubernetes.Object, ...) error
  • func (c *KubeClient) Get(ctx context.Context, name, namespace string, obj kubernetes.Object) error
  • func (c *KubeClient) List(ctx context.Context, list kubernetes.ObjectList) error
  • func (c *KubeClient) Update(ctx context.Context, obj kubernetes.Object) error

Functions

func AddAnnotation

func AddAnnotation(o client.Object, key, value string)

AddAnnotation adds an annotation to the given object. If the annotation already exists, it overwrites its value.

func AddLabel

func AddLabel(o client.Object, key, value string)

AddLabel adds a label to the given object. If the label already exists, it overwrites its value.

func ClusterNameIndexer

func ClusterNameIndexer(obj client.Object) []string

ClusterNameIndexer is an indexer for controller to list Cluster objects based on name.

func DeleteYaml

func DeleteYaml(ctx context.Context, c client.Client, yaml []byte) error

func ObjectsToClientObjects

func ObjectsToClientObjects[T client.Object](objs []T) []client.Object

func YamlToClientObjects

func YamlToClientObjects(yamlObjects []byte) ([]client.Object, error)

Types

type KubeClient

type KubeClient struct {
	// contains filtered or unexported fields
}

Kubeclient implements kubernetes.Client interface using a client.Client as the underlying implementation.

func NewKubeClient

func NewKubeClient(client client.Client) *KubeClient

func (*KubeClient) Create

func (c *KubeClient) Create(ctx context.Context, obj kubernetes.Object) error

Create saves the object obj in the Kubernetes cluster.

func (*KubeClient) Delete

func (c *KubeClient) Delete(ctx context.Context, obj kubernetes.Object) error

Delete deletes the given obj from Kubernetes cluster.

func (*KubeClient) DeleteAllOf

func (c *KubeClient) DeleteAllOf(ctx context.Context, obj kubernetes.Object, opts ...kubernetes.DeleteAllOfOption) error

DeleteAllOf deletes all objects of the given type matching the given options.

func (*KubeClient) Get

func (c *KubeClient) Get(ctx context.Context, name, namespace string, obj kubernetes.Object) error

Get retrieves an obj for the given name and namespace from the Kubernetes Cluster.

func (*KubeClient) List

func (c *KubeClient) List(ctx context.Context, list kubernetes.ObjectList) error

List retrieves list of objects. On a successful call, Items field in the list will be populated with the result returned from the server.

func (*KubeClient) Update

func (c *KubeClient) Update(ctx context.Context, obj kubernetes.Object) error

Update updates the given obj in the Kubernetes cluster.