apply

Documentation

Index

• type Applier
• type Appliers
  • func NewAppliers(dynamicClient dynamic.Interface, kubeclient kubernetes.Interface, ...) *Appliers
  • func (a *Appliers) GetApplier(strategy workapiv1.UpdateStrategyType) Applier
• type CreateOnlyApply
  • func NewCreateOnlyApply(client dynamic.Interface) *CreateOnlyApply
  • func (c *CreateOnlyApply) Apply(ctx context.Context, gvr schema.GroupVersionResource, ...) (runtime.Object, error)
• type ReadOnlyApply
  • func NewReadOnlyApply() *ReadOnlyApply
  • func (c *ReadOnlyApply) Apply(ctx context.Context, _ schema.GroupVersionResource, ...) (runtime.Object, error)
• type ServerSideApply
  • func NewServerSideApply(client dynamic.Interface) *ServerSideApply
  • func (c *ServerSideApply) Apply(ctx context.Context, gvr schema.GroupVersionResource, ...) (runtime.Object, error)
• type ServerSideApplyConflictError
  • func (e *ServerSideApplyConflictError) Error() string
• type UpdateApply
  • func NewUpdateApply(dynamicClient dynamic.Interface, kubeclient kubernetes.Interface, ...) *UpdateApply
  • func (c *UpdateApply) Apply(ctx context.Context, gvr schema.GroupVersionResource, ...) (runtime.Object, error)

Types

type Applier

type Applier interface {
	Apply(ctx context.Context,
		gvr schema.GroupVersionResource,
		required *unstructured.Unstructured,
		owner metav1.OwnerReference,
		applyOption *workapiv1.ManifestConfigOption,
		recorder events.Recorder) (runtime.Object, error)
}

type Appliers

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

func NewAppliers

func NewAppliers(dynamicClient dynamic.Interface, kubeclient kubernetes.Interface, apiExtensionClient apiextensionsclient.Interface) *Appliers

func (*Appliers) GetApplier

func (a *Appliers) GetApplier(strategy workapiv1.UpdateStrategyType) Applier

type CreateOnlyApply

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

func NewCreateOnlyApply

func NewCreateOnlyApply(client dynamic.Interface) *CreateOnlyApply

func (*CreateOnlyApply) Apply

func (c *CreateOnlyApply) Apply(ctx context.Context,
	gvr schema.GroupVersionResource,
	required *unstructured.Unstructured,
	owner metav1.OwnerReference,
	_ *workapiv1.ManifestConfigOption,
	recorder events.Recorder) (runtime.Object, error)

type ReadOnlyApply

type ReadOnlyApply struct{}

func NewReadOnlyApply

func NewReadOnlyApply() *ReadOnlyApply

func (*ReadOnlyApply) Apply

func (c *ReadOnlyApply) Apply(ctx context.Context,
	_ schema.GroupVersionResource,
	required *unstructured.Unstructured,
	_ metav1.OwnerReference,
	_ *workapiv1.ManifestConfigOption,
	recorder events.Recorder) (runtime.Object, error)

type ServerSideApply

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

func NewServerSideApply

func NewServerSideApply(client dynamic.Interface) *ServerSideApply

func (*ServerSideApply) Apply

func (c *ServerSideApply) Apply(
	ctx context.Context,
	gvr schema.GroupVersionResource,
	required *unstructured.Unstructured,
	owner metav1.OwnerReference,
	applyOption *workapiv1.ManifestConfigOption,
	recorder events.Recorder) (runtime.Object, error)

type ServerSideApplyConflictError

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

func (*ServerSideApplyConflictError) Error

func (e *ServerSideApplyConflictError) Error() string

type UpdateApply

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

func NewUpdateApply

func NewUpdateApply(dynamicClient dynamic.Interface, kubeclient kubernetes.Interface, apiExtensionClient apiextensionsclient.Interface) *UpdateApply

func (*UpdateApply) Apply

func (c *UpdateApply) Apply(
	ctx context.Context,
	gvr schema.GroupVersionResource,
	required *unstructured.Unstructured,
	owner metav1.OwnerReference,
	_ *workapiv1.ManifestConfigOption,
	recorder events.Recorder) (runtime.Object, error)