reconciler

Documentation

Index

• type CommonOptions
• type InstanceOwnershipConflict
• type InstanceOwnershipConflictErr
  • func (e *InstanceOwnershipConflictErr) Error() string
• type InteractiveOptions
• type InteractiveReconciler
  • func NewInteractiveReconciler(log logr.Logger, copts *CommonOptions, iopts *InteractiveOptions, ...) *InteractiveReconciler
  • func (r *InteractiveReconciler) ApplyInstance(ctx context.Context, log logr.Logger, builder *engine.ModuleBuilder, ...) error
  • func (r *InteractiveReconciler) DryRunDiff(ctx context.Context, namespaceExists bool) error
  • func (r *InteractiveReconciler) Wait(ctx context.Context, log logr.Logger, cs *ssa.ChangeSet, ...) error
  • func (r *InteractiveReconciler) WaitForTermination(ctx context.Context, log logr.Logger, cs *ssa.ChangeSet, _ *engine.ResourceSet) error
• type Reconciler
  • func NewReconciler(log logr.Logger, opts *CommonOptions, timeout time.Duration) *Reconciler
  • func (r *Reconciler) ApplyAllSets(ctx context.Context, log logr.Logger, withChangeSet withChangeSetFunc) error
  • func (r *Reconciler) ApplyAllStaged(ctx context.Context, set engine.ResourceSet) (*ssa.ChangeSet, error)
  • func (r *Reconciler) ApplyInstance(ctx context.Context, log logr.Logger, builder *engine.ModuleBuilder, ...) error
  • func (r *Reconciler) Init(ctx context.Context, builder *engine.ModuleBuilder, buildResult cue.Value, ...) error
  • func (r *Reconciler) Name() string
  • func (r *Reconciler) Namespace() string
  • func (r *Reconciler) NamespaceExists(ctx context.Context) (bool, error)
  • func (r *Reconciler) PostApplyPruneStaleObjects(ctx context.Context, log logr.Logger, withChangeSet withChangeSetFunc) error
  • func (r *Reconciler) PostApplyUpdateInventory(ctx context.Context, builder *engine.ModuleBuilder, buildResult cue.Value) error
  • func (r *Reconciler) UpdateImages(builder *engine.ModuleBuilder, buildResult cue.Value)
  • func (r *Reconciler) UpdateStoredInstance(ctx context.Context) error
  • func (r *Reconciler) Wait(ctx context.Context, log logr.Logger, _ *ssa.ChangeSet, rs *engine.ResourceSet) error
  • func (r *Reconciler) WaitForTermination(ctx context.Context, log logr.Logger, cs *ssa.ChangeSet, _ *engine.ResourceSet) error

Types

type CommonOptions

type CommonOptions struct {
	Dir                string
	Wait               bool
	Force              bool
	OverwriteOwnership bool
}

type InstanceOwnershipConflict

type InstanceOwnershipConflict struct{ InstanceName, CurrentOwnerBundle string }

type InstanceOwnershipConflictErr

type InstanceOwnershipConflictErr []InstanceOwnershipConflict

func (*InstanceOwnershipConflictErr) Error

func (e *InstanceOwnershipConflictErr) Error() string

type InteractiveOptions

type InteractiveOptions struct {
	DryRun     bool
	Diff       bool
	DiffOutput io.Writer

	ProgressStart func(string) interface{ Stop() }
}

type InteractiveReconciler

type InteractiveReconciler struct {
	*Reconciler
	*InteractiveOptions
}

func NewInteractiveReconciler

func NewInteractiveReconciler(log logr.Logger, copts *CommonOptions, iopts *InteractiveOptions, timeout time.Duration) *InteractiveReconciler

func (*InteractiveReconciler) ApplyInstance

func (r *InteractiveReconciler) ApplyInstance(ctx context.Context, log logr.Logger, builder *engine.ModuleBuilder, buildResult cue.Value) error

func (*InteractiveReconciler) DryRunDiff

func (r *InteractiveReconciler) DryRunDiff(ctx context.Context, namespaceExists bool) error

func (*InteractiveReconciler) Wait

func (r *InteractiveReconciler) Wait(ctx context.Context, log logr.Logger, cs *ssa.ChangeSet, rs *engine.ResourceSet) error

func (*InteractiveReconciler) WaitForTermination

func (r *InteractiveReconciler) WaitForTermination(ctx context.Context, log logr.Logger, cs *ssa.ChangeSet, _ *engine.ResourceSet) error

type Reconciler

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

func NewReconciler

func NewReconciler(log logr.Logger, opts *CommonOptions, timeout time.Duration) *Reconciler

func (*Reconciler) ApplyAllSets

func (r *Reconciler) ApplyAllSets(ctx context.Context, log logr.Logger, withChangeSet withChangeSetFunc) error

func (*Reconciler) ApplyAllStaged

func (r *Reconciler) ApplyAllStaged(ctx context.Context, set engine.ResourceSet) (*ssa.ChangeSet, error)

func (*Reconciler) ApplyInstance

func (r *Reconciler) ApplyInstance(ctx context.Context, log logr.Logger, builder *engine.ModuleBuilder, buildResult cue.Value) error

func (*Reconciler) Init

func (r *Reconciler) Init(ctx context.Context, builder *engine.ModuleBuilder, buildResult cue.Value, instance *apiv1.BundleInstance, rcg genericclioptions.RESTClientGetter) error

func (*Reconciler) Name

func (r *Reconciler) Name() string

func (*Reconciler) Namespace

func (r *Reconciler) Namespace() string

func (*Reconciler) NamespaceExists

func (r *Reconciler) NamespaceExists(ctx context.Context) (bool, error)

func (*Reconciler) PostApplyPruneStaleObjects

func (r *Reconciler) PostApplyPruneStaleObjects(ctx context.Context, log logr.Logger, withChangeSet withChangeSetFunc) error

func (*Reconciler) PostApplyUpdateInventory

func (r *Reconciler) PostApplyUpdateInventory(ctx context.Context, builder *engine.ModuleBuilder, buildResult cue.Value) error

func (*Reconciler) UpdateImages

func (r *Reconciler) UpdateImages(builder *engine.ModuleBuilder, buildResult cue.Value)

func (*Reconciler) UpdateStoredInstance

func (r *Reconciler) UpdateStoredInstance(ctx context.Context) error

func (*Reconciler) Wait

func (r *Reconciler) Wait(ctx context.Context, log logr.Logger, _ *ssa.ChangeSet, rs *engine.ResourceSet) error

func (*Reconciler) WaitForTermination

func (r *Reconciler) WaitForTermination(ctx context.Context, log logr.Logger, cs *ssa.ChangeSet, _ *engine.ResourceSet) error