clusterapply

package
v0.17.0 Latest Latest
Warning

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

 Go to latest Published: Jan 3, 2020 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddOrUpdateChange 

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

func (AddOrUpdateChange) Apply 

func (c AddOrUpdateChange) Apply() error

func (AddOrUpdateChange) IsDoneApplying 

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

type AddOrUpdateChangeOpts 

type AddOrUpdateChangeOpts struct {
	DefaultUpdateStrategy string
}

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) *ApplyingChanges

func (*ApplyingChanges) Apply added in v0.10.0 

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

func (*ApplyingChanges) Complete added in v0.10.0 

func (c *ApplyingChanges) Complete() error

type ApplyingChangesOpts added in v0.12.0 

type ApplyingChangesOpts struct {
	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, 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
	ctldiff.TextDiffViewOpts
}

type ChangeView added in v0.10.0 

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

	ApplyOp() ClusterChangeApplyOp
	WaitOp() ClusterChangeWaitOp
	TextDiff() ctldiff.TextDiff
}

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 (v *ChangesCountsView) Add(applyOp ClusterChangeApplyOp, waitOp ClusterChangeWaitOp)

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) *ClusterChange

func (*ClusterChange) Apply added in v0.10.0 

func (c *ClusterChange) Apply() error

func (*ClusterChange) ApplyDescription 

func (c *ClusterChange) ApplyDescription() string

func (*ClusterChange) ApplyOp 

func (c *ClusterChange) ApplyOp() ClusterChangeApplyOp

func (*ClusterChange) ExistingResource added in v0.12.0 

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

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) TextDiff added in v0.10.0 

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

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"
)

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,
) 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, ui UI) ClusterChangeSet

func (ClusterChangeSet) Apply 

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

func (ClusterChangeSet) Calculate added in v0.10.0 

func (c ClusterChangeSet) Calculate() ([]*ClusterChange, *ctldgraph.ChangeGraph, error)

type ClusterChangeSetOpts added in v0.8.0 

type ClusterChangeSetOpts struct {
	ApplyingChangesOpts
	WaitingChangesOpts
}

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, associatedRs []ctlres.Resource,
	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(
	opts ConvergedResourceFactoryOpts) ConvergedResourceFactory

func (ConvergedResourceFactory) New added in v0.17.0 

func (f ConvergedResourceFactory) New(res ctlres.Resource,
	associatedRs []ctlres.Resource) ConvergedResource

type ConvergedResourceFactoryOpts added in v0.17.0 

type ConvergedResourceFactoryOpts struct {
	IgnoreFailingAPIServices bool
}

type DeleteChange 

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

func (DeleteChange) Apply 

func (c DeleteChange) Apply() error

func (DeleteChange) IsDoneApplying 

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

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 SpecificResFactory added in v0.17.0 

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

type SpecificResource 

type SpecificResource interface {
	IsDoneApplying() ctlresm.DoneApplyState
}

type UI 

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

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
}

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) *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, error)

type WaitingChangesOpts added in v0.12.0 

type WaitingChangesOpts struct {
	Timeout       time.Duration
	CheckInterval time.Duration
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.