utils

package
v2.23.5 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2024 License: Apache-2.0 Imports: 29 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DeleteObjects 

func DeleteObjects(ctx context.Context, k *k8s.K8sCluster, refs []k8s2.ObjectRef, dew *DeploymentErrorsAndWarnings, doWait bool) []k8s2.ObjectRef

func FindObjectsForDelete 

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

Types

type ApplyDeploymentsUtil 

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

func NewApplyDeploymentsUtil 

func NewApplyDeploymentsUtil(ctx context.Context, dew *DeploymentErrorsAndWarnings, ru *RemoteObjectUtils, k *k8s.K8sCluster, o *ApplyUtilOptions) *ApplyDeploymentsUtil

func (*ApplyDeploymentsUtil) ApplyDeployments 

func (a *ApplyDeploymentsUtil) ApplyDeployments(deployments []*deployment.DeploymentItem)

func (*ApplyDeploymentsUtil) GetAppliedHookObjects 

func (ad *ApplyDeploymentsUtil) GetAppliedHookObjects() []*uo.UnstructuredObject

func (*ApplyDeploymentsUtil) GetAppliedObjects 

func (ad *ApplyDeploymentsUtil) GetAppliedObjects() []*uo.UnstructuredObject

func (*ApplyDeploymentsUtil) GetAppliedObjectsMap 

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

func (*ApplyDeploymentsUtil) GetDeletedObjects 

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

func (*ApplyDeploymentsUtil) GetNewObjectRefs added in v2.20.0 

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

func (*ApplyDeploymentsUtil) NewApplyUtil 

func (ad *ApplyDeploymentsUtil) NewApplyUtil(ctx context.Context, statusCtx *status.StatusContext) *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
	ReadinessTimeout    time.Duration
	NoWait              bool

	SkipResourceVersions map[k8s2.ObjectRef]string
}

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) Clone added in v2.21.0 

func (dew *DeploymentErrorsAndWarnings) Clone() *DeploymentErrorsAndWarnings

func (*DeploymentErrorsAndWarnings) GetErrorsList 

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

func (*DeploymentErrorsAndWarnings) GetMultiError 

func (dew *DeploymentErrorsAndWarnings) GetMultiError() error

func (*DeploymentErrorsAndWarnings) GetWarningsList 

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

func (*DeploymentErrorsAndWarnings) HadError 

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

func (*DeploymentErrorsAndWarnings) Init 

func (dew *DeploymentErrorsAndWarnings) Init()

type DiffUtil added in v2.20.0 

type DiffUtil struct {
	IgnoreTags        bool
	IgnoreLabels      bool
	IgnoreAnnotations bool
	Swapped           bool

	ChangedObjects []result.ChangedObject
	// contains filtered or unexported fields
}

func NewDiffUtil 

func NewDiffUtil(dew *DeploymentErrorsAndWarnings, ru *RemoteObjectUtils, appliedObjects map[k8s2.ObjectRef]*uo.UnstructuredObject) *DiffUtil

func (*DiffUtil) DiffDeploymentItems added in v2.20.0 

func (u *DiffUtil) DiffDeploymentItems(deployments []*deployment.DeploymentItem)

func (*DiffUtil) DiffObjects added in v2.20.0 

func (u *DiffUtil) DiffObjects(objects []*uo.UnstructuredObject)

func (*DiffUtil) GetDiffRef added in v2.20.5 

func (u *DiffUtil) GetDiffRef(o *uo.UnstructuredObject) k8s2.ObjectRef

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(ctx context.Context, 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(k *k8s.K8sCluster, name string) (*uo.UnstructuredObject, error)

func (*RemoteObjectUtils) GetRemoteObject 

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

func (*RemoteObjectUtils) UpdateRemoteObjects 

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