apply

Documentation

Index

• type Applier
  • func (a *Applier) Run(ctx context.Context, invInfo inventory.Info, objects object.UnstructuredSet, ...) <-chan event.Event
• type ApplierBuilder
  • func NewApplierBuilder() *ApplierBuilder
  • func (b *ApplierBuilder) Build() (*Applier, error)
  • func (b *ApplierBuilder) WithDiscoveryClient(discoClient discovery.CachedDiscoveryInterface) *ApplierBuilder
  • func (b *ApplierBuilder) WithDynamicClient(client dynamic.Interface) *ApplierBuilder
  • func (b *ApplierBuilder) WithFactory(factory util.Factory) *ApplierBuilder
  • func (b *ApplierBuilder) WithInventoryClient(invClient inventory.Client) *ApplierBuilder
  • func (b *ApplierBuilder) WithRestConfig(restConfig *rest.Config) *ApplierBuilder
  • func (b *ApplierBuilder) WithRestMapper(mapper meta.RESTMapper) *ApplierBuilder
  • func (b *ApplierBuilder) WithStatusWatcher(statusWatcher watcher.StatusWatcher) *ApplierBuilder
  • func (b *ApplierBuilder) WithUnstructuredClientForMapping(...) *ApplierBuilder
• type ApplierOptions
• type Destroyer
  • func NewDestroyer(factory cmdutil.Factory, invClient inventory.Client) (*Destroyer, error)
  • func (d *Destroyer) Run(ctx context.Context, invInfo inventory.Info, options DestroyerOptions) <-chan event.Event
• type DestroyerOptions

Types

type Applier

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

Applier performs the step of applying a set of resources into a cluster, conditionally waits for all of them to be fully reconciled and finally performs prune to clean up any resources that has been deleted. The applier performs its function by executing a list queue of tasks, each of which is one of the steps in the process of applying a set of resources to the cluster. The actual execution of these tasks are handled by a StatusRunner. So the taskqueue is effectively a specification that is executed by the StatusRunner. Based on input parameters and/or the set of resources that needs to be applied to the cluster, different sets of tasks might be needed.

func (*Applier) Run

func (a *Applier) Run(ctx context.Context, invInfo inventory.Info, objects object.UnstructuredSet, options ApplierOptions) <-chan event.Event

Run performs the Apply step. This happens asynchronously with updates on progress and any errors reported back on the event channel. Cancelling the operation or setting timeout on how long to Wait for it complete can be done with the passed in context. Note: There isn't currently any way to interrupt the operation before all the given resources have been applied to the cluster. Any cancellation or timeout will only affect how long we Wait for the resources to become current.

type ApplierBuilder

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

func NewApplierBuilder

func NewApplierBuilder() *ApplierBuilder

NewApplierBuilder returns a new ApplierBuilder.

func (*ApplierBuilder) Build

func (b *ApplierBuilder) Build() (*Applier, error)

func (*ApplierBuilder) WithDiscoveryClient

func (b *ApplierBuilder) WithDiscoveryClient(discoClient discovery.CachedDiscoveryInterface) *ApplierBuilder

func (*ApplierBuilder) WithDynamicClient

func (b *ApplierBuilder) WithDynamicClient(client dynamic.Interface) *ApplierBuilder

func (*ApplierBuilder) WithFactory

func (b *ApplierBuilder) WithFactory(factory util.Factory) *ApplierBuilder

func (*ApplierBuilder) WithInventoryClient

func (b *ApplierBuilder) WithInventoryClient(invClient inventory.Client) *ApplierBuilder

func (*ApplierBuilder) WithRestConfig

func (b *ApplierBuilder) WithRestConfig(restConfig *rest.Config) *ApplierBuilder

func (*ApplierBuilder) WithRestMapper

func (b *ApplierBuilder) WithRestMapper(mapper meta.RESTMapper) *ApplierBuilder

func (*ApplierBuilder) WithStatusWatcher

func (b *ApplierBuilder) WithStatusWatcher(statusWatcher watcher.StatusWatcher) *ApplierBuilder

func (*ApplierBuilder) WithUnstructuredClientForMapping

func (b *ApplierBuilder) WithUnstructuredClientForMapping(unstructuredClientForMapping func(*meta.RESTMapping) (resource.RESTClient, error)) *ApplierBuilder

type ApplierOptions

type ApplierOptions struct {
	// Encapsulates the fields for server-side apply.
	ServerSideOptions common.ServerSideOptions

	// ReconcileTimeout defines whether the applier should wait
	// until all applied resources have been reconciled, and if so,
	// how long to wait.
	ReconcileTimeout time.Duration

	// EmitStatusEvents defines whether status events should be
	// emitted on the eventChannel to the caller.
	EmitStatusEvents bool

	// NoPrune defines whether pruning of previously applied
	// objects should happen after apply.
	NoPrune bool

	// DryRunStrategy defines whether changes should actually be performed,
	// or if it is just talk and no action.
	DryRunStrategy common.DryRunStrategy

	// PrunePropagationPolicy defines the deletion propagation policy
	// that should be used for pruning. If this is not provided, the
	// default is to use the Background policy.
	PrunePropagationPolicy metav1.DeletionPropagation

	// PruneTimeout defines whether we should wait for all resources
	// to be fully deleted after pruning, and if so, how long we should
	// wait.
	PruneTimeout time.Duration

	// InventoryPolicy defines the inventory policy of apply.
	InventoryPolicy inventory.Policy

	// ValidationPolicy defines how to handle invalid objects.
	ValidationPolicy validation.Policy
}

type Destroyer

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

Destroyer performs the step of grabbing all the previous inventory objects and prune them. This also deletes all the previous inventory objects

func NewDestroyer

func NewDestroyer(factory cmdutil.Factory, invClient inventory.Client) (*Destroyer, error)

NewDestroyer returns a new destroyer. It will set up the ApplyOptions and PruneOptions which are responsible for capturing any command line flags. It currently requires IOStreams, but this is a legacy from when the ApplyOptions were responsible for printing progress. This is now handled by a separate printer with the KubectlPrinterAdapter bridging between the two.

func (*Destroyer) Run

func (d *Destroyer) Run(ctx context.Context, invInfo inventory.Info, options DestroyerOptions) <-chan event.Event

Run performs the destroy step. Passes the inventory object. This happens asynchronously on progress and any errors are reported back on the event channel.

type DestroyerOptions

type DestroyerOptions struct {
	// InventoryPolicy defines the inventory policy of apply.
	InventoryPolicy inventory.Policy

	// DryRunStrategy defines whether changes should actually be performed,
	// or if it is just talk and no action.
	DryRunStrategy common.DryRunStrategy

	// DeleteTimeout defines how long we should wait for resources
	// to be fully deleted.
	DeleteTimeout time.Duration

	// DeletePropagationPolicy defines the deletion propagation policy
	// that should be used. If this is not provided, the default is to
	// use the Background policy.
	DeletePropagationPolicy metav1.DeletionPropagation

	// EmitStatusEvents defines whether status events should be
	// emitted on the eventChannel to the caller.
	EmitStatusEvents bool

	// ValidationPolicy defines how to handle invalid objects.
	ValidationPolicy validation.Policy
}