application

Documentation

Overview

Package kubernetes implements an Application backend that uses a Kubernetes informer to keep track of resources, and an appclientset to manipulate Application resources on the cluster.

Index

• type KubernetesBackend
  • func NewKubernetesBackend(appClient appclientset.Interface, namespace string, ...) *KubernetesBackend
  • func (be *KubernetesBackend) Create(ctx context.Context, app *v1alpha1.Application) (*v1alpha1.Application, error)
  • func (be *KubernetesBackend) Delete(ctx context.Context, name string, namespace string, ...) error
  • func (be *KubernetesBackend) EnsureSynced(timeout time.Duration) error
  • func (be *KubernetesBackend) Get(ctx context.Context, name string, namespace string) (*v1alpha1.Application, error)
  • func (be *KubernetesBackend) List(ctx context.Context, selector backend.ApplicationSelector) ([]v1alpha1.Application, error)
  • func (be *KubernetesBackend) Patch(ctx context.Context, name string, namespace string, patch []byte) (*v1alpha1.Application, error)
  • func (be *KubernetesBackend) StartInformer(ctx context.Context) error
  • func (be *KubernetesBackend) SupportsPatch() bool
  • func (be *KubernetesBackend) Update(ctx context.Context, app *v1alpha1.Application) (*v1alpha1.Application, error)

Types

type KubernetesBackend

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

KubernetesBackend is an implementation of the backend.Application interface, which is used by ApplicationManager to track/update the state of Argo CD Applications. KubernetesBackend stores/retrieves all data from Argo CD Application CRs on the cluster that is local to the agent/principal.

KubernetesBackend is used by both the principal and agent components.

func NewKubernetesBackend

func NewKubernetesBackend(appClient appclientset.Interface, namespace string, appInformer informer.InformerInterface, usePatch bool) *KubernetesBackend

func (*KubernetesBackend) Create

func (be *KubernetesBackend) Create(ctx context.Context, app *v1alpha1.Application) (*v1alpha1.Application, error)

func (*KubernetesBackend) Delete

func (be *KubernetesBackend) Delete(ctx context.Context, name string, namespace string, deletionPropagation *backend.DeletionPropagation) error

func (*KubernetesBackend) EnsureSynced

func (be *KubernetesBackend) EnsureSynced(timeout time.Duration) error

func (*KubernetesBackend) Get

func (be *KubernetesBackend) Get(ctx context.Context, name string, namespace string) (*v1alpha1.Application, error)

func (*KubernetesBackend) List

func (be *KubernetesBackend) List(ctx context.Context, selector backend.ApplicationSelector) ([]v1alpha1.Application, error)

func (*KubernetesBackend) Patch

func (be *KubernetesBackend) Patch(ctx context.Context, name string, namespace string, patch []byte) (*v1alpha1.Application, error)

func (*KubernetesBackend) StartInformer

func (be *KubernetesBackend) StartInformer(ctx context.Context) error

func (*KubernetesBackend) SupportsPatch

func (be *KubernetesBackend) SupportsPatch() bool

func (*KubernetesBackend) Update

func (be *KubernetesBackend) Update(ctx context.Context, app *v1alpha1.Application) (*v1alpha1.Application, error)