utils

Documentation

Index

• func DeleteObjects(k *k8s.K8sCluster, refs []k8s2.ObjectRef, doWait bool) (*types.CommandResult, error)
• func DownscaleObject(remote *uo.UnstructuredObject, local *uo.UnstructuredObject) (*uo.UnstructuredObject, error)
• func FindObjectsForDelete(k *k8s.K8sCluster, allClusterObjects []*uo.UnstructuredObject, ...) ([]k8s2.ObjectRef, error)
• func IsDownscaleDelete(o *uo.UnstructuredObject) bool
• func NewDiffUtil(dew *DeploymentErrorsAndWarnings, deployments []*deployment.DeploymentItem, ...) *diffUtil
• type ApplyUtil
  • func NewApplyUtil(dew *DeploymentErrorsAndWarnings, deployments []*deployment.DeploymentItem, ...) *ApplyUtil
  • func (a *ApplyUtil) ApplyDeployments()
  • func (a *ApplyUtil) ApplyObject(x *uo.UnstructuredObject, replaced bool, hook bool)
  • func (a *ApplyUtil) DeleteObject(ref k8s2.ObjectRef, hook bool) bool
  • func (a *ApplyUtil) DoLog(d *deployment.DeploymentItem, level log.Level, s string, f ...interface{})
  • func (a *ApplyUtil) GetAppliedHookObjects() []*types.RefAndObject
  • func (a *ApplyUtil) GetDeletedObjectsList() []k8s2.ObjectRef
  • func (a *ApplyUtil) HadError(ref k8s2.ObjectRef) bool
  • func (a *ApplyUtil) HandleError(ref k8s2.ObjectRef, err error)
  • func (a *ApplyUtil) HandleWarning(ref k8s2.ObjectRef, warning error)
  • func (a *ApplyUtil) ReplaceObject(ref k8s2.ObjectRef, firstVersion *uo.UnstructuredObject, ...)
  • func (a *ApplyUtil) WaitReadiness(ref k8s2.ObjectRef) bool
• type ApplyUtilOptions
• type DeploymentErrorsAndWarnings
  • func NewDeploymentErrorsAndWarnings() *DeploymentErrorsAndWarnings
  • func (dew *DeploymentErrorsAndWarnings) AddApiWarnings(ref k8s.ObjectRef, warnings []k8s2.ApiWarning)
  • func (dew *DeploymentErrorsAndWarnings) AddError(ref k8s.ObjectRef, err error)
  • func (dew *DeploymentErrorsAndWarnings) AddWarning(ref k8s.ObjectRef, warning error)
  • func (dew *DeploymentErrorsAndWarnings) GetErrorsList() []types.DeploymentError
  • func (dew *DeploymentErrorsAndWarnings) GetMultiError() error
  • func (dew *DeploymentErrorsAndWarnings) GetWarningsList() []types.DeploymentError
  • func (dew *DeploymentErrorsAndWarnings) HadError(ref k8s.ObjectRef) bool
  • func (dew *DeploymentErrorsAndWarnings) Init()
• type HooksUtil
  • func NewHooksUtil(a *ApplyUtil) *HooksUtil
  • func (u *HooksUtil) GetHook(o *uo.UnstructuredObject) *hook
  • func (u *HooksUtil) RunHooks(d *deployment.DeploymentItem, hooks []string)
• type RemoteObjectUtils
  • func NewRemoteObjectsUtil(dew *DeploymentErrorsAndWarnings) *RemoteObjectUtils
  • func (u *RemoteObjectUtils) ForgetRemoteObject(ref k8s2.ObjectRef)
  • func (u *RemoteObjectUtils) GetFilteredRemoteObjects(inclusion *utils.Inclusion) []*uo.UnstructuredObject
  • func (u *RemoteObjectUtils) GetRemoteObject(ref k8s2.ObjectRef) *uo.UnstructuredObject
  • func (u *RemoteObjectUtils) UpdateRemoteObjects(k *k8s.K8sCluster, labels map[string]string, refs []k8s2.ObjectRef) error

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 NewApplyUtil

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

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