Documentation ¶
Index ¶
- func DeleteObjects(ctx context.Context, k *k8s.K8sCluster, refs []k8s2.ObjectRef, ...) []k8s2.ObjectRef
- func FindObjectsForDelete(k *k8s.K8sCluster, allClusterObjects []*uo.UnstructuredObject, ...) ([]k8s2.ObjectRef, error)
- type ApplyDeploymentsUtil
- func (a *ApplyDeploymentsUtil) ApplyDeployments(deployments []*deployment.DeploymentItem)
- func (ad *ApplyDeploymentsUtil) GetAppliedHookObjects() []*uo.UnstructuredObject
- func (ad *ApplyDeploymentsUtil) GetAppliedObjects() []*uo.UnstructuredObject
- func (ad *ApplyDeploymentsUtil) GetAppliedObjectsMap() map[k8s2.ObjectRef]*uo.UnstructuredObject
- func (ad *ApplyDeploymentsUtil) GetDeletedObjects() []k8s2.ObjectRef
- func (ad *ApplyDeploymentsUtil) GetNewObjectRefs() []k8s2.ObjectRef
- func (ad *ApplyDeploymentsUtil) NewApplyUtil(ctx context.Context, statusCtx *status.StatusContext) *ApplyUtil
- type ApplyUtil
- func (a *ApplyUtil) ApplyObject(d *deployment.DeploymentItem, x *uo.UnstructuredObject, replaced bool, ...)
- func (a *ApplyUtil) DeleteObject(ref k8s2.ObjectRef, hook bool) bool
- 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, timeout time.Duration) bool
- type ApplyUtilOptions
- type 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) Clone() *DeploymentErrorsAndWarnings
- func (dew *DeploymentErrorsAndWarnings) GetErrorsList() []result.DeploymentError
- func (dew *DeploymentErrorsAndWarnings) GetMultiError() error
- func (dew *DeploymentErrorsAndWarnings) GetWarningsList() []result.DeploymentError
- func (dew *DeploymentErrorsAndWarnings) HadError(ref k8s.ObjectRef) bool
- func (dew *DeploymentErrorsAndWarnings) Init()
- type DiffUtil
- type HooksUtil
- type RemoteObjectUtils
- func (u *RemoteObjectUtils) ForgetRemoteObject(ref k8s2.ObjectRef)
- func (u *RemoteObjectUtils) GetFilteredRemoteObjects(inclusion *utils.Inclusion) []*uo.UnstructuredObject
- func (u *RemoteObjectUtils) GetRemoteNamespace(k *k8s.K8sCluster, name string) (*uo.UnstructuredObject, error)
- func (u *RemoteObjectUtils) GetRemoteObject(ref k8s2.ObjectRef) *uo.UnstructuredObject
- func (u *RemoteObjectUtils) UpdateRemoteObjects(k *k8s.K8sCluster, discriminator *string, refs []k8s2.ObjectRef, ...) error
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(d *deployment.DeploymentItem, x *uo.UnstructuredObject, replaced bool, hook bool)
func (*ApplyUtil) DeleteObject ¶
func (*ApplyUtil) HandleWarning ¶
func (*ApplyUtil) ReplaceObject ¶
func (a *ApplyUtil) ReplaceObject(ref k8s2.ObjectRef, firstVersion *uo.UnstructuredObject, callback func(o *uo.UnstructuredObject) (*uo.UnstructuredObject, error))
type ApplyUtilOptions ¶
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 IgnoreKluctlMetadata 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 (*HooksUtil) DetermineHooks ¶
func (u *HooksUtil) DetermineHooks(d *deployment.DeploymentItem, hooks []string) []*hook
func (*HooksUtil) GetHook ¶
func (u *HooksUtil) GetHook(di *deployment.DeploymentItem, o *uo.UnstructuredObject) *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
Click to show internal directories.
Click to hide internal directories.