utils

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

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

Go to latest
Published: Mar 24, 2022 License: Apache-2.0 Imports: 25 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

Types

type ApplyUtil

type ApplyUtil struct {
	AppliedObjects map[k8s2.ObjectRef]*uo.UnstructuredObject
	// contains filtered or unexported fields
}

func (*ApplyUtil) ApplyDeployments

func (a *ApplyUtil) ApplyDeployments()

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

func (a *ApplyUtil) DoLog(d *deployment.DeploymentItem, level log.Level, s string, f ...interface{})

func (*ApplyUtil) GetAppliedHookObjects

func (a *ApplyUtil) GetAppliedHookObjects() []*types.RefAndObject

func (*ApplyUtil) GetDeletedObjectsList

func (a *ApplyUtil) GetDeletedObjectsList() []k8s2.ObjectRef

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

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

func (*HooksUtil) RunHooks

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

type RemoteObjectUtils

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

func (*RemoteObjectUtils) ForgetRemoteObject

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

func (*RemoteObjectUtils) GetFilteredRemoteObjects

func (u *RemoteObjectUtils) GetFilteredRemoteObjects(inclusion *utils.Inclusion) []*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

Jump to

Keyboard shortcuts

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