clusterapply

package
v0.62.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 16, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddOrFallbackOnUpdateOrNoopStrategy added in v0.62.0

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

func (AddOrFallbackOnUpdateOrNoopStrategy) Apply added in v0.62.0

func (AddOrFallbackOnUpdateOrNoopStrategy) Op added in v0.62.0

type AddOrFallbackOnUpdateStrategy added in v0.62.0

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

func (AddOrFallbackOnUpdateStrategy) Apply added in v0.62.0

func (AddOrFallbackOnUpdateStrategy) Op added in v0.62.0

type AddOrUpdateChange

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

func (AddOrUpdateChange) ApplyStrategy added in v0.62.0

func (c AddOrUpdateChange) ApplyStrategy() (ApplyStrategy, error)

type AddOrUpdateChangeOpts

type AddOrUpdateChangeOpts struct {
	DefaultUpdateStrategy string
}

type AddPlainStrategy added in v0.62.0

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

func (AddPlainStrategy) Apply added in v0.62.0

func (c AddPlainStrategy) Apply() error

func (AddPlainStrategy) Op added in v0.62.0

type ApplyStrategy added in v0.62.0

type ApplyStrategy interface {
	Op() ClusterChangeApplyStrategyOp
	Apply() error
}

type ApplyingChanges added in v0.10.0

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

func NewApplyingChanges added in v0.10.0

func NewApplyingChanges(numTotal int, opts ApplyingChangesOpts, clusterChangeFactory ClusterChangeFactory, ui UI, exitOnError bool) *ApplyingChanges

func (*ApplyingChanges) Apply added in v0.10.0

func (c *ApplyingChanges) Apply(allChanges []*ctldgraph.Change) ([]WaitingChange, []string, error)

func (*ApplyingChanges) Complete added in v0.10.0

func (c *ApplyingChanges) Complete() error

type ApplyingChangesOpts added in v0.12.0

type ApplyingChangesOpts struct {
	Timeout       time.Duration
	CheckInterval time.Duration
	Concurrency   int
}

type ChangeSetView added in v0.10.0

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

func NewChangeSetView added in v0.10.0

func NewChangeSetView(changeViews []ChangeView,
	maskRules []ctlconf.DiffMaskRule, opts ChangeSetViewOpts) *ChangeSetView

func (*ChangeSetView) Print added in v0.10.0

func (v *ChangeSetView) Print(ui ui.UI)

func (*ChangeSetView) Summary added in v0.10.0

func (v *ChangeSetView) Summary() string

type ChangeSetViewOpts added in v0.10.0

type ChangeSetViewOpts struct {
	Summary     bool
	Changes     bool
	ChangesYAML bool
	ctldiff.TextDiffViewOpts
}

type ChangeView added in v0.10.0

type ChangeView interface {
	Resource() ctlres.Resource
	ClusterOriginalResource() ctlres.Resource

	ApplyOp() ClusterChangeApplyOp
	ApplyStrategyOp() (ClusterChangeApplyStrategyOp, error)
	WaitOp() ClusterChangeWaitOp
	ConfigurableTextDiff() *ctldiff.ConfigurableTextDiff
}

func ClusterChangesAsChangeViews added in v0.10.0

func ClusterChangesAsChangeViews(changes []*ClusterChange) []ChangeView

type ChangesCountsView added in v0.10.0

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

func NewChangesCountsView added in v0.10.0

func NewChangesCountsView() *ChangesCountsView

func (*ChangesCountsView) Add added in v0.10.0

func (*ChangesCountsView) String added in v0.10.0

func (v *ChangesCountsView) String() string

func (*ChangesCountsView) Strings added in v0.10.0

func (v *ChangesCountsView) Strings(table bool) []string

type ChangesView added in v0.10.0

type ChangesView struct {
	ChangeViews []ChangeView
	Sort        bool
	// contains filtered or unexported fields
}

func (*ChangesView) Print added in v0.10.0

func (v *ChangesView) Print(ui ui.UI)

func (*ChangesView) Summary added in v0.10.0

func (v *ChangesView) Summary() string

type ClusterChange

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

func NewClusterChange

func NewClusterChange(change ctldiff.Change, opts ClusterChangeOpts,
	identifiedResources ctlres.IdentifiedResources,
	changeFactory ctldiff.ChangeFactory,
	changeSetFactory ctldiff.ChangeSetFactory,
	convergedResFactory ConvergedResourceFactory, ui UI,
	diffMaskRules []ctlconf.DiffMaskRule) *ClusterChange

func (*ClusterChange) Apply added in v0.10.0

func (c *ClusterChange) Apply() (bool, []string, error)

func (*ClusterChange) ApplyDescription

func (c *ClusterChange) ApplyDescription() string

func (*ClusterChange) ApplyOp

func (c *ClusterChange) ApplyOp() ClusterChangeApplyOp

func (*ClusterChange) ApplyStrategyOp added in v0.62.0

func (c *ClusterChange) ApplyStrategyOp() (ClusterChangeApplyStrategyOp, error)

func (*ClusterChange) ClusterOriginalResource added in v0.62.0

func (c *ClusterChange) ClusterOriginalResource() ctlres.Resource

func (*ClusterChange) ConfigurableTextDiff added in v0.62.0

func (c *ClusterChange) ConfigurableTextDiff() *ctldiff.ConfigurableTextDiff

func (*ClusterChange) IsDoneApplying added in v0.10.0

func (c *ClusterChange) IsDoneApplying() (ctlresm.DoneApplyState, []string, error)

func (*ClusterChange) MarkNeedsWaiting added in v0.10.0

func (c *ClusterChange) MarkNeedsWaiting()

func (*ClusterChange) Resource added in v0.10.0

func (c *ClusterChange) Resource() ctlres.Resource

func (*ClusterChange) WaitDescription

func (c *ClusterChange) WaitDescription() string

func (*ClusterChange) WaitOp added in v0.10.0

func (c *ClusterChange) WaitOp() ClusterChangeWaitOp

type ClusterChangeApplyOp added in v0.10.0

type ClusterChangeApplyOp string
const (
	ClusterChangeApplyOpAdd    ClusterChangeApplyOp = "add"
	ClusterChangeApplyOpDelete ClusterChangeApplyOp = "delete"
	ClusterChangeApplyOpUpdate ClusterChangeApplyOp = "update"
	ClusterChangeApplyOpNoop   ClusterChangeApplyOp = "noop"
	ClusterChangeApplyOpExists ClusterChangeApplyOp = "exists"
)

type ClusterChangeApplyStrategyOp added in v0.62.0

type ClusterChangeApplyStrategyOp string
const (
	UnknownStrategyOp ClusterChangeApplyStrategyOp = "unknown"
)

type ClusterChangeFactory

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

func NewClusterChangeFactory

func NewClusterChangeFactory(
	opts ClusterChangeOpts,
	identifiedResources ctlres.IdentifiedResources,
	changeFactory ctldiff.ChangeFactory,
	changeSetFactory ctldiff.ChangeSetFactory,
	convergedResFactory ConvergedResourceFactory,
	ui UI, diffMaskRules []ctlconf.DiffMaskRule,
) ClusterChangeFactory

func (ClusterChangeFactory) NewClusterChange

func (f ClusterChangeFactory) NewClusterChange(change ctldiff.Change) *ClusterChange

type ClusterChangeOpts

type ClusterChangeOpts struct {
	ApplyIgnored bool
	Wait         bool
	WaitIgnored  bool

	AddOrUpdateChangeOpts
}

type ClusterChangeSet

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

func NewClusterChangeSet

func NewClusterChangeSet(changes []ctldiff.Change, opts ClusterChangeSetOpts,
	clusterChangeFactory ClusterChangeFactory, changeGroupBindings []ctlconf.ChangeGroupBinding,
	changeRuleBindings []ctlconf.ChangeRuleBinding, ui UI, logger logger.Logger) ClusterChangeSet

func (ClusterChangeSet) Apply

func (c ClusterChangeSet) Apply(changesGraph *ctldgraph.ChangeGraph) error

func (ClusterChangeSet) Calculate added in v0.10.0

type ClusterChangeSetOpts added in v0.8.0

type ClusterChangeSetOpts struct {
	ApplyingChangesOpts
	WaitingChangesOpts

	ExitEarlyOnApplyError bool
	ExitEarlyOnWaitError  bool
}

type ClusterChangeWaitOp added in v0.10.0

type ClusterChangeWaitOp string
const (
	ClusterChangeWaitOpOK     ClusterChangeWaitOp = "ok"
	ClusterChangeWaitOpDelete ClusterChangeWaitOp = "delete"
	ClusterChangeWaitOpNoop   ClusterChangeWaitOp = "noop"
)

type ConvergedResource added in v0.10.0

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

func NewConvergedResource added in v0.10.0

func NewConvergedResource(res ctlres.Resource,
	associatedRsFunc func(ctlres.Resource, []ctlres.ResourceRef) ([]ctlres.Resource, error),
	specificResFactories []SpecificResFactory) ConvergedResource

func (ConvergedResource) IsDoneApplying added in v0.10.0

func (c ConvergedResource) IsDoneApplying() (ctlresm.DoneApplyState, []string, error)

type ConvergedResourceFactory added in v0.17.0

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

func NewConvergedResourceFactory added in v0.17.0

func NewConvergedResourceFactory(waitRules []ctlconf.WaitRule,
	opts ConvergedResourceFactoryOpts) ConvergedResourceFactory

func (ConvergedResourceFactory) New added in v0.17.0

type ConvergedResourceFactoryOpts added in v0.17.0

type ConvergedResourceFactoryOpts struct {
	IgnoreFailingAPIServices bool
}

type DeleteChange

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

func (DeleteChange) ApplyStrategy added in v0.62.0

func (c DeleteChange) ApplyStrategy() (ApplyStrategy, error)

func (DeleteChange) IsDoneApplying

func (c DeleteChange) IsDoneApplying() (ctlresm.DoneApplyState, []string, error)

type DeleteOrphanStrategy added in v0.62.0

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

func (DeleteOrphanStrategy) Apply added in v0.62.0

func (c DeleteOrphanStrategy) Apply() error

func (DeleteOrphanStrategy) Op added in v0.62.0

type DeletePlainStrategy added in v0.62.0

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

func (DeletePlainStrategy) Apply added in v0.62.0

func (c DeletePlainStrategy) Apply() error

func (DeletePlainStrategy) Op added in v0.62.0

type DoneApplyStateUI added in v0.11.0

type DoneApplyStateUI struct {
	State   string
	Message string
	Error   bool
}

func NewDoneApplyStateUI added in v0.11.0

func NewDoneApplyStateUI(state ctlresm.DoneApplyState, err error) DoneApplyStateUI

type ExistsChange added in v0.62.0

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

func (ExistsChange) ApplyStrategy added in v0.62.0

func (c ExistsChange) ApplyStrategy() (ApplyStrategy, error)

type ExistsChangeError added in v0.62.0

type ExistsChangeError struct{}

func (ExistsChangeError) Error added in v0.62.0

func (e ExistsChangeError) Error() string

type ExistsStrategy added in v0.62.0

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

func (ExistsStrategy) Apply added in v0.62.0

func (e ExistsStrategy) Apply() error

func (ExistsStrategy) Op added in v0.62.0

type NoopStrategy added in v0.62.0

type NoopStrategy struct{}

func (NoopStrategy) Apply added in v0.62.0

func (s NoopStrategy) Apply() error

func (NoopStrategy) Op added in v0.62.0

type ReconcilingChange added in v0.62.0

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

func (ReconcilingChange) IsDoneApplying added in v0.62.0

func (c ReconcilingChange) IsDoneApplying() (ctlresm.DoneApplyState, []string, error)

type SpecificResFactory added in v0.17.0

type SpecificResFactory func(ctlres.Resource, []ctlres.Resource) (SpecificResource, []ctlres.ResourceRef)

type SpecificResource

type SpecificResource interface {
	IsDoneApplying() ctlresm.DoneApplyState
}

type UI

type UI interface {
	NotifySection(msg string, args ...interface{})
	Notify(msgs []string)
}

type UpdateAlwaysReplaceStrategy added in v0.62.0

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

func (UpdateAlwaysReplaceStrategy) Apply added in v0.62.0

func (UpdateAlwaysReplaceStrategy) Op added in v0.62.0

type UpdateOrFallbackOnReplaceStrategy added in v0.62.0

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

func (UpdateOrFallbackOnReplaceStrategy) Apply added in v0.62.0

func (UpdateOrFallbackOnReplaceStrategy) Op added in v0.62.0

type UpdatePlainStrategy added in v0.62.0

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

func (UpdatePlainStrategy) Apply added in v0.62.0

func (c UpdatePlainStrategy) Apply() error

func (UpdatePlainStrategy) Op added in v0.62.0

type UpdateSkipStrategy added in v0.62.0

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

func (UpdateSkipStrategy) Apply added in v0.62.0

func (c UpdateSkipStrategy) Apply() error

func (UpdateSkipStrategy) Op added in v0.62.0

type ValueResourceConverged added in v0.12.0

type ValueResourceConverged struct {
	StateVal  uitable.Value
	ReasonVal uitable.Value
}

func NewValueResourceConverged added in v0.12.0

func NewValueResourceConverged(resource ctlres.Resource) ValueResourceConverged

type WaitingChange added in v0.10.0

type WaitingChange struct {
	Graph   *ctldgraph.Change
	Cluster *ClusterChange
	// contains filtered or unexported fields
}

type WaitingChanges added in v0.10.0

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

func NewWaitingChanges added in v0.10.0

func NewWaitingChanges(numTotal int, opts WaitingChangesOpts, ui UI, exitOnError bool) *WaitingChanges

func (*WaitingChanges) Complete added in v0.10.0

func (c *WaitingChanges) Complete() error

func (*WaitingChanges) IsEmpty added in v0.10.0

func (c *WaitingChanges) IsEmpty() bool

func (*WaitingChanges) Track added in v0.10.0

func (c *WaitingChanges) Track(changes []WaitingChange)

func (*WaitingChanges) WaitForAny added in v0.10.0

func (c *WaitingChanges) WaitForAny() ([]WaitingChange, []string, error)

type WaitingChangesOpts added in v0.12.0

type WaitingChangesOpts struct {
	Timeout         time.Duration
	ResourceTimeout time.Duration
	CheckInterval   time.Duration
	Concurrency     int
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL