handler

Documentation

Index

• type DeleteOptions
• type KubernetesClient
• type KubernetesHandler
  • func NewKubernetesHandler(c KubernetesClient) *KubernetesHandler
  • func (k *KubernetesHandler) Append(obj client.Object)
  • func (k *KubernetesHandler) ApplyAll(ctx context.Context) ([]types.NamespacedName, error)
  • func (k *KubernetesHandler) CreateAll(ctx context.Context) error
  • func (k *KubernetesHandler) DeleteAll(ctx context.Context) ([]types.NamespacedName, error)
• type StatusClient
• type StatusHandler
  • func NewStatusHandler(c StatusClient) *StatusHandler
  • func (s *StatusHandler) Patch(ctx context.Context, obj client.Object) error

Types

type DeleteOptions

type DeleteOptions struct {
	// DeletionPropagation decides how the garbage collector will handle the propagation.
	DeletionPropagation metav1.DeletionPropagation

	// Inclusions determines which in-cluster objects are subject to deletion
	// based on the labels.
	// A nil Inclusions map means all objects are subject to deletion
	Inclusions map[string]string
}

DeleteOptions contains options for delete requests.

type KubernetesClient

type KubernetesClient interface {
	Apply(ctx context.Context, obj client.Object) error
	Create(ctx context.Context, obj client.Object) error
	Get(ctx context.Context, obj client.Object) (*unstructured.Unstructured, error)
	Delete(ctx context.Context, obj client.Object, opts DeleteOptions) error
}

type KubernetesHandler

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

func NewKubernetesHandler

func NewKubernetesHandler(c KubernetesClient) *KubernetesHandler

func (*KubernetesHandler) Append

func (k *KubernetesHandler) Append(obj client.Object)

func (*KubernetesHandler) ApplyAll

func (k *KubernetesHandler) ApplyAll(ctx context.Context) ([]types.NamespacedName, error)

func (*KubernetesHandler) CreateAll

func (k *KubernetesHandler) CreateAll(ctx context.Context) error

CreateAll creates the given objects (AlreadyExists errors are ignored)

func (*KubernetesHandler) DeleteAll

func (k *KubernetesHandler) DeleteAll(ctx context.Context) ([]types.NamespacedName, error)

type StatusClient

type StatusClient interface {
	PatchStatus(ctx context.Context, obj client.Object) error
}

type StatusHandler

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

func NewStatusHandler

func NewStatusHandler(c StatusClient) *StatusHandler

func (*StatusHandler) Patch

func (s *StatusHandler) Patch(ctx context.Context, obj client.Object) error