utils

package
v1.28.2-0...-a792dfb Latest Latest
Warning

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

 Go to latest Published: Apr 19, 2022 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DeleteObjects 

func DeleteObjects(k *k8s.K8sCluster, refs []k8s2.ObjectRef, doWait bool) (*types.CommandResult, error)

func DownscaleObject 

func DownscaleObject(remote *uo.UnstructuredObject, local *uo.UnstructuredObject) (*uo.UnstructuredObject, error)

func FindObjectsForDelete 

func FindObjectsForDelete(k *k8s.K8sCluster, allClusterObjects []*uo.UnstructuredObject, inclusionHasTags bool, excludedObjects []k8s2.ObjectRef) ([]k8s2.ObjectRef, error)

func IsDownscaleDelete 

func IsDownscaleDelete(o *uo.UnstructuredObject) bool

func NewDiffUtil 

func NewDiffUtil(dew *DeploymentErrorsAndWarnings, deployments []*deployment.DeploymentItem, ru *RemoteObjectUtils, appliedObjects map[k8s2.ObjectRef]*uo.UnstructuredObject) *diffUtil

func NewProgressCtx 

func NewProgressCtx(p *mpb.Progress, name string, maxNameWidth int) *progressCtx

Types

type ApplyDeploymentsUtil 

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

func NewApplyDeploymentsUtil 

func NewApplyDeploymentsUtil(dew *DeploymentErrorsAndWarnings, deployments []*deployment.DeploymentItem, ru *RemoteObjectUtils, k *k8s.K8sCluster, o *ApplyUtilOptions) *ApplyDeploymentsUtil

func (*ApplyDeploymentsUtil) ApplyDeployments 

func (a *ApplyDeploymentsUtil) ApplyDeployments()

func (*ApplyDeploymentsUtil) GetAppliedHookObjects 

func (ad *ApplyDeploymentsUtil) GetAppliedHookObjects() []*types.RefAndObject

func (*ApplyDeploymentsUtil) GetAppliedObjects 

func (ad *ApplyDeploymentsUtil) GetAppliedObjects() []*types.RefAndObject

func (*ApplyDeploymentsUtil) GetAppliedObjectsMap 

func (ad *ApplyDeploymentsUtil) GetAppliedObjectsMap() map[k8s2.ObjectRef]*uo.UnstructuredObject

func (*ApplyDeploymentsUtil) GetDeletedObjects 

func (ad *ApplyDeploymentsUtil) GetDeletedObjects() []k8s2.ObjectRef

func (*ApplyDeploymentsUtil) NewApplyUtil 

func (ad *ApplyDeploymentsUtil) NewApplyUtil(pctx *progressCtx) *ApplyUtil

type ApplyUtil 

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

func (*ApplyUtil) ApplyObject 

func (a *ApplyUtil) ApplyObject(x *uo.UnstructuredObject, replaced bool, hook bool)

func (*ApplyUtil) DeleteObject 

func (a *ApplyUtil) DeleteObject(ref k8s2.ObjectRef, hook bool) bool

func (*ApplyUtil) HadError 

func (a *ApplyUtil) HadError(ref k8s2.ObjectRef) bool

func (*ApplyUtil) HandleError 

func (a *ApplyUtil) HandleError(ref k8s2.ObjectRef, err error)

func (*ApplyUtil) HandleWarning 

func (a *ApplyUtil) HandleWarning(ref k8s2.ObjectRef, warning error)

func (*ApplyUtil) ReplaceObject 

func (a *ApplyUtil) ReplaceObject(ref k8s2.ObjectRef, firstVersion *uo.UnstructuredObject, callback func(o *uo.UnstructuredObject) (*uo.UnstructuredObject, error))

func (*ApplyUtil) WaitReadiness 

func (a *ApplyUtil) WaitReadiness(ref k8s2.ObjectRef, timeout time.Duration) bool

type ApplyUtilOptions 

type ApplyUtilOptions struct {
	ForceApply          bool
	ReplaceOnError      bool
	ForceReplaceOnError bool
	DryRun              bool
	AbortOnError        bool
	WaitObjectTimeout   time.Duration
	NoWait              bool
}

type DeploymentErrorsAndWarnings 

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

func NewDeploymentErrorsAndWarnings 

func NewDeploymentErrorsAndWarnings() *DeploymentErrorsAndWarnings

func (*DeploymentErrorsAndWarnings) AddApiWarnings 

func (dew *DeploymentErrorsAndWarnings) AddApiWarnings(ref k8s.ObjectRef, warnings []k8s2.ApiWarning)

func (*DeploymentErrorsAndWarnings) AddError 

func (dew *DeploymentErrorsAndWarnings) AddError(ref k8s.ObjectRef, err error)

func (*DeploymentErrorsAndWarnings) AddWarning 

func (dew *DeploymentErrorsAndWarnings) AddWarning(ref k8s.ObjectRef, warning error)

func (*DeploymentErrorsAndWarnings) GetErrorsList 

func (dew *DeploymentErrorsAndWarnings) GetErrorsList() []types.DeploymentError

func (*DeploymentErrorsAndWarnings) GetMultiError 

func (dew *DeploymentErrorsAndWarnings) GetMultiError() error

func (*DeploymentErrorsAndWarnings) GetWarningsList 

func (dew *DeploymentErrorsAndWarnings) GetWarningsList() []types.DeploymentError

func (*DeploymentErrorsAndWarnings) HadError 

func (dew *DeploymentErrorsAndWarnings) HadError(ref k8s.ObjectRef) bool

func (*DeploymentErrorsAndWarnings) Init 

func (dew *DeploymentErrorsAndWarnings) Init()

type HooksUtil 

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

func NewHooksUtil 

func NewHooksUtil(a *ApplyUtil) *HooksUtil

func (*HooksUtil) DetermineHooks 

func (u *HooksUtil) DetermineHooks(d *deployment.DeploymentItem, hooks []string) []*hook

func (*HooksUtil) GetHook 

func (u *HooksUtil) GetHook(o *uo.UnstructuredObject) *hook

func (*HooksUtil) RunHooks 

func (u *HooksUtil) RunHooks(hooks []*hook)

type RemoteObjectUtils 

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

func NewRemoteObjectsUtil 

func NewRemoteObjectsUtil(dew *DeploymentErrorsAndWarnings) *RemoteObjectUtils

func (*RemoteObjectUtils) ForgetRemoteObject 

func (u *RemoteObjectUtils) ForgetRemoteObject(ref k8s2.ObjectRef)

func (*RemoteObjectUtils) GetFilteredRemoteObjects 

func (u *RemoteObjectUtils) GetFilteredRemoteObjects(inclusion *utils.Inclusion) []*uo.UnstructuredObject

func (*RemoteObjectUtils) GetRemoteNamespace 

func (u *RemoteObjectUtils) GetRemoteNamespace(name string) *uo.UnstructuredObject

func (*RemoteObjectUtils) GetRemoteObject 

func (u *RemoteObjectUtils) GetRemoteObject(ref k8s2.ObjectRef) *uo.UnstructuredObject

func (*RemoteObjectUtils) UpdateRemoteObjects 

func (u *RemoteObjectUtils) UpdateRemoteObjects(k *k8s.K8sCluster, labels map[string]string, refs []k8s2.ObjectRef) 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.