client

Documentation

Overview

Package client provides helper functions for API clients used by the helm operator.

Index

• func NewLabelInjectingClient(base kube.Interface, labels map[string]string) kube.Interface
• func NewOwnerRefInjectingClient(base kube.Interface, restMapper meta.RESTMapper, obj client.Object) (kube.Interface, error)
• type ActionConfigGetter
  • func NewActionConfigGetter(cfg *rest.Config, rm meta.RESTMapper, log logr.Logger) (ActionConfigGetter, error)
• type WatchedSecrets
  • func NewWatchedSecrets(clientSet kubernetes.Interface, namespace string) *WatchedSecrets
  • func (w *WatchedSecrets) Apply(ctx context.Context, secret *applyconfv1.SecretApplyConfiguration, ...) (result *corev1.Secret, err error)
  • func (w *WatchedSecrets) Create(ctx context.Context, secret *corev1.Secret, opts metav1.CreateOptions) (*corev1.Secret, error)
  • func (w *WatchedSecrets) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error
  • func (w *WatchedSecrets) DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error
  • func (w *WatchedSecrets) Get(ctx context.Context, name string, opts metav1.GetOptions) (*corev1.Secret, error)
  • func (w *WatchedSecrets) List(ctx context.Context, opts metav1.ListOptions) (*corev1.SecretList, error)
  • func (w *WatchedSecrets) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, ...) (result *corev1.Secret, err error)
  • func (w *WatchedSecrets) Run()
  • func (w *WatchedSecrets) Update(ctx context.Context, secret *corev1.Secret, opts metav1.UpdateOptions) (*corev1.Secret, error)
  • func (w *WatchedSecrets) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)

Functions

func NewLabelInjectingClient

func NewLabelInjectingClient(base kube.Interface, labels map[string]string) kube.Interface

func NewOwnerRefInjectingClient

func NewOwnerRefInjectingClient(base kube.Interface, restMapper meta.RESTMapper,
	obj client.Object) (kube.Interface, error)

Types

type ActionConfigGetter

type ActionConfigGetter interface {
	ActionConfigFor(obj client.Object) (*action.Configuration, error)
}

func NewActionConfigGetter

func NewActionConfigGetter(cfg *rest.Config, rm meta.RESTMapper, log logr.Logger) (ActionConfigGetter, error)

type WatchedSecrets

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

Wraps the kubernetes SecretInterface Helm queries its own secrets multiple times per reconciliation. To reduce the number of lists going to the apiserver we instead use an informer to watch the changes on secrets.

func NewWatchedSecrets

func NewWatchedSecrets(clientSet kubernetes.Interface, namespace string) *WatchedSecrets

func (*WatchedSecrets) Apply

func (w *WatchedSecrets) Apply(ctx context.Context, secret *applyconfv1.SecretApplyConfiguration, opts metav1.ApplyOptions) (result *corev1.Secret, err error)

func (*WatchedSecrets) Create

func (w *WatchedSecrets) Create(ctx context.Context, secret *corev1.Secret, opts metav1.CreateOptions) (*corev1.Secret, error)

func (*WatchedSecrets) Delete

func (w *WatchedSecrets) Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error

func (*WatchedSecrets) DeleteCollection

func (w *WatchedSecrets) DeleteCollection(ctx context.Context, opts metav1.DeleteOptions, listOpts metav1.ListOptions) error

func (*WatchedSecrets) Get

func (w *WatchedSecrets) Get(ctx context.Context, name string, opts metav1.GetOptions) (*corev1.Secret, error)

func (*WatchedSecrets) List

func (w *WatchedSecrets) List(ctx context.Context, opts metav1.ListOptions) (*corev1.SecretList, error)

func (*WatchedSecrets) Patch

func (w *WatchedSecrets) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, opts metav1.PatchOptions, _ ...string) (result *corev1.Secret, err error)

func (*WatchedSecrets) Run

func (w *WatchedSecrets) Run()

func (*WatchedSecrets) Update

func (w *WatchedSecrets) Update(ctx context.Context, secret *corev1.Secret, opts metav1.UpdateOptions) (*corev1.Secret, error)

func (*WatchedSecrets) Watch

func (w *WatchedSecrets) Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)