clusterapply

package
v0.0.0-...-9460cd5 Latest Latest
Warning

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

 Go to latest Published: Aug 7, 2019 License: Apache-2.0 Imports: 18 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, error)

type AddOrUpdateChangeOpts 

type AddOrUpdateChangeOpts struct {
	DefaultUpdateStrategy string
}

type ApplyingChanges 

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

func NewApplyingChanges 

func NewApplyingChanges(numTotal int, clusterChangeFactory ClusterChangeFactory, ui UI) *ApplyingChanges

func (*ApplyingChanges) Apply 

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

func (*ApplyingChanges) Complete 

func (c *ApplyingChanges) Complete() error

type ChangeSetView 

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

func NewChangeSetView 

func NewChangeSetView(changeViews []ChangeView, opts ChangeSetViewOpts) *ChangeSetView

func (*ChangeSetView) Print 

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

func (*ChangeSetView) Summary 

func (v *ChangeSetView) Summary() string

type ChangeSetViewOpts 

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

type ChangeView 

type ChangeView interface {
	Resource() ctlres.Resource
	ApplyOp() ClusterChangeApplyOp
	WaitOp() ClusterChangeWaitOp
	TextDiff() ctldiff.TextDiff
	IsIgnored() bool
	IgnoredReason() string
}

func ClusterChangesAsChangeViews 

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

type ChangesCountsView 

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

func NewChangesCountsView 

func NewChangesCountsView() *ChangesCountsView

func (*ChangesCountsView) Add 

func (v *ChangesCountsView) Add(applyOp ClusterChangeApplyOp, waitOp ClusterChangeWaitOp)

func (*ChangesCountsView) String 

func (v *ChangesCountsView) String() string

func (*ChangesCountsView) Strings 

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

type ChangesView 

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

func (*ChangesView) Print 

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

func (*ChangesView) Summary 

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

func (*ClusterChange) Apply 

func (c *ClusterChange) Apply() error

func (*ClusterChange) ApplyDescription 

func (c *ClusterChange) ApplyDescription() string

func (*ClusterChange) ApplyOp 

func (c *ClusterChange) ApplyOp() ClusterChangeApplyOp

func (*ClusterChange) IgnoredReason 

func (c *ClusterChange) IgnoredReason() string

func (*ClusterChange) IsDoneApplying 

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

func (*ClusterChange) IsIgnored 

func (c *ClusterChange) IsIgnored() bool

func (*ClusterChange) MarkNeedsWaiting 

func (c *ClusterChange) MarkNeedsWaiting()

func (*ClusterChange) Resource 

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

func (*ClusterChange) TextDiff 

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

func (*ClusterChange) WaitDescription 

func (c *ClusterChange) WaitDescription() string

func (*ClusterChange) WaitOp 

func (c *ClusterChange) WaitOp() ClusterChangeWaitOp

type ClusterChangeApplyOp 

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,
	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 

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

type ClusterChangeSetOpts 

type ClusterChangeSetOpts struct {
	WaitTimeout       time.Duration
	WaitCheckInterval time.Duration
}

type ClusterChangeWaitOp 

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

type ConvergedResource 

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

func NewConvergedResource 

func NewConvergedResource(res ctlres.Resource, associatedRs []ctlres.Resource) ConvergedResource

func (ConvergedResource) IsDoneApplying 

func (c ConvergedResource) IsDoneApplying(ui UI) (ctlresm.DoneApplyState, error)

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

type SpecificResource 

type SpecificResource interface {
	IsDoneApplying() ctlresm.DoneApplyState
}

type UI 

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

type WaitingChange 

type WaitingChange struct {
	Graph   *ctldgraph.Change
	Cluster *ClusterChange
}

type WaitingChanges 

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

func NewWaitingChanges 

func NewWaitingChanges(numTotal int, opts ClusterChangeSetOpts, ui UI) *WaitingChanges

func (*WaitingChanges) Complete 

func (c *WaitingChanges) Complete() error

func (*WaitingChanges) IsEmpty 

func (c *WaitingChanges) IsEmpty() bool

func (*WaitingChanges) Track 

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

func (*WaitingChanges) WaitForAny 

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

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.