Documentation ¶
Index ¶
- Constants
- type ApplyResourceOperation
- func (o *ApplyResourceOperation) Empty() bool
- func (o *ApplyResourceOperation) Execute(ctx context.Context) error
- func (o *ApplyResourceOperation) HumanID() string
- func (o *ApplyResourceOperation) ID() string
- func (o *ApplyResourceOperation) Status() Status
- func (o *ApplyResourceOperation) Type() Type
- type ApplyResourceOperationOptions
- type CreatePendingReleaseOperation
- func (o *CreatePendingReleaseOperation) Empty() bool
- func (o *CreatePendingReleaseOperation) Execute(ctx context.Context) error
- func (o *CreatePendingReleaseOperation) HumanID() string
- func (o *CreatePendingReleaseOperation) ID() string
- func (o *CreatePendingReleaseOperation) Status() Status
- func (o *CreatePendingReleaseOperation) Type() Type
- type CreateResourceOperation
- func (o *CreateResourceOperation) Empty() bool
- func (o *CreateResourceOperation) Execute(ctx context.Context) error
- func (o *CreateResourceOperation) HumanID() string
- func (o *CreateResourceOperation) ID() string
- func (o *CreateResourceOperation) Status() Status
- func (o *CreateResourceOperation) Type() Type
- type CreateResourceOperationOptions
- type DeleteResourceOperation
- func (o *DeleteResourceOperation) Empty() bool
- func (o *DeleteResourceOperation) Execute(ctx context.Context) error
- func (o *DeleteResourceOperation) HumanID() string
- func (o *DeleteResourceOperation) ID() string
- func (o *DeleteResourceOperation) Status() Status
- func (o *DeleteResourceOperation) Type() Type
- type DeleteResourceOperationOptions
- type FailReleaseOperation
- type Operation
- type RecreateResourceOperation
- func (o *RecreateResourceOperation) Empty() bool
- func (o *RecreateResourceOperation) Execute(ctx context.Context) error
- func (o *RecreateResourceOperation) HumanID() string
- func (o *RecreateResourceOperation) ID() string
- func (o *RecreateResourceOperation) Status() Status
- func (o *RecreateResourceOperation) Type() Type
- type RecreateResourceOperationOptions
- type StageOperation
- type Status
- type SucceedReleaseOperation
- func (o *SucceedReleaseOperation) Empty() bool
- func (o *SucceedReleaseOperation) Execute(ctx context.Context) error
- func (o *SucceedReleaseOperation) HumanID() string
- func (o *SucceedReleaseOperation) ID() string
- func (o *SucceedReleaseOperation) Status() Status
- func (o *SucceedReleaseOperation) Type() Type
- type SupersedeReleaseOperation
- func (o *SupersedeReleaseOperation) Empty() bool
- func (o *SupersedeReleaseOperation) Execute(ctx context.Context) error
- func (o *SupersedeReleaseOperation) HumanID() string
- func (o *SupersedeReleaseOperation) ID() string
- func (o *SupersedeReleaseOperation) Status() Status
- func (o *SupersedeReleaseOperation) Type() Type
- type TrackResourceAbsenceOperation
- func (o *TrackResourceAbsenceOperation) Empty() bool
- func (o *TrackResourceAbsenceOperation) Execute(ctx context.Context) error
- func (o *TrackResourceAbsenceOperation) HumanID() string
- func (o *TrackResourceAbsenceOperation) ID() string
- func (o *TrackResourceAbsenceOperation) Status() Status
- func (o *TrackResourceAbsenceOperation) Type() Type
- type TrackResourceAbsenceOperationOptions
- type TrackResourcePresenceOperation
- func (o *TrackResourcePresenceOperation) Empty() bool
- func (o *TrackResourcePresenceOperation) Execute(ctx context.Context) error
- func (o *TrackResourcePresenceOperation) HumanID() string
- func (o *TrackResourcePresenceOperation) ID() string
- func (o *TrackResourcePresenceOperation) Status() Status
- func (o *TrackResourcePresenceOperation) Type() Type
- type TrackResourcePresenceOperationOptions
- type TrackResourceReadinessOperation
- func (o *TrackResourceReadinessOperation) Empty() bool
- func (o *TrackResourceReadinessOperation) Execute(ctx context.Context) error
- func (o *TrackResourceReadinessOperation) HumanID() string
- func (o *TrackResourceReadinessOperation) ID() string
- func (o *TrackResourceReadinessOperation) Status() Status
- func (o *TrackResourceReadinessOperation) Type() Type
- type TrackResourceReadinessOperationOptions
- type Type
- type UpdateResourceOperation
- func (o *UpdateResourceOperation) Empty() bool
- func (o *UpdateResourceOperation) Execute(ctx context.Context) error
- func (o *UpdateResourceOperation) HumanID() string
- func (o *UpdateResourceOperation) ID() string
- func (o *UpdateResourceOperation) Status() Status
- func (o *UpdateResourceOperation) Type() Type
- type UpdateResourceOperationOptions
Constants ¶
View Source
const TypeApplyResourceOperation = "apply"
View Source
const TypeCreatePendingReleaseOperation = "create-pending-release"
View Source
const TypeCreateResourceOperation = "create"
View Source
const TypeDeleteResourceOperation = "delete"
View Source
const TypeExtraPostApplyResourceOperation = "extra-post-apply"
View Source
const TypeExtraPostCreateResourceOperation = "extra-post-create"
View Source
const TypeExtraPostDeleteResourceOperation = "extra-post-delete"
View Source
const TypeExtraPostRecreateResourceOperation = "extra-post-recreate"
View Source
const TypeExtraPostUpdateResourceOperation = "extra-post-update"
View Source
const TypeFailReleaseOperation = "fail-release"
View Source
const TypeRecreateResourceOperation = "recreate"
View Source
const TypeStageOperation = "stage"
View Source
const TypeSucceedReleaseOperation = "succeed-release"
View Source
const TypeSupersedeReleaseOperation = "supersede-release"
View Source
const TypeTrackResourceAbsenceOperation = "track-resource-absence"
View Source
const TypeTrackResourcePresenceOperation = "track-resource-presence"
View Source
const TypeTrackResourceReadinessOperation = "track-resource-readiness"
View Source
const TypeUpdateResourceOperation = "update"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ApplyResourceOperation ¶
type ApplyResourceOperation struct {
// contains filtered or unexported fields
}
func NewApplyResourceOperation ¶
func NewApplyResourceOperation( resource *resrcid.ResourceID, unstruct *unstructured.Unstructured, kubeClient kubeclnt.KubeClienter, opts ApplyResourceOperationOptions, ) (*ApplyResourceOperation, error)
func (*ApplyResourceOperation) Empty ¶
func (o *ApplyResourceOperation) Empty() bool
func (*ApplyResourceOperation) Execute ¶
func (o *ApplyResourceOperation) Execute(ctx context.Context) error
func (*ApplyResourceOperation) HumanID ¶
func (o *ApplyResourceOperation) HumanID() string
func (*ApplyResourceOperation) ID ¶
func (o *ApplyResourceOperation) ID() string
func (*ApplyResourceOperation) Status ¶
func (o *ApplyResourceOperation) Status() Status
func (*ApplyResourceOperation) Type ¶
func (o *ApplyResourceOperation) Type() Type
type ApplyResourceOperationOptions ¶
type ApplyResourceOperationOptions struct { ManageableBy resrc.ManageableBy ExtraPost bool }
type CreatePendingReleaseOperation ¶
type CreatePendingReleaseOperation struct {
// contains filtered or unexported fields
}
func NewCreatePendingReleaseOperation ¶
func NewCreatePendingReleaseOperation( rel *rls.Release, deployType common.DeployType, history rlshistor.Historier, ) *CreatePendingReleaseOperation
func (*CreatePendingReleaseOperation) Empty ¶
func (o *CreatePendingReleaseOperation) Empty() bool
func (*CreatePendingReleaseOperation) Execute ¶
func (o *CreatePendingReleaseOperation) Execute(ctx context.Context) error
func (*CreatePendingReleaseOperation) HumanID ¶
func (o *CreatePendingReleaseOperation) HumanID() string
func (*CreatePendingReleaseOperation) ID ¶
func (o *CreatePendingReleaseOperation) ID() string
func (*CreatePendingReleaseOperation) Status ¶
func (o *CreatePendingReleaseOperation) Status() Status
func (*CreatePendingReleaseOperation) Type ¶
func (o *CreatePendingReleaseOperation) Type() Type
type CreateResourceOperation ¶
type CreateResourceOperation struct {
// contains filtered or unexported fields
}
func NewCreateResourceOperation ¶
func NewCreateResourceOperation( resource *resrcid.ResourceID, unstruct *unstructured.Unstructured, kubeClient kubeclnt.KubeClienter, opts CreateResourceOperationOptions, ) *CreateResourceOperation
func (*CreateResourceOperation) Empty ¶
func (o *CreateResourceOperation) Empty() bool
func (*CreateResourceOperation) Execute ¶
func (o *CreateResourceOperation) Execute(ctx context.Context) error
func (*CreateResourceOperation) HumanID ¶
func (o *CreateResourceOperation) HumanID() string
func (*CreateResourceOperation) ID ¶
func (o *CreateResourceOperation) ID() string
func (*CreateResourceOperation) Status ¶
func (o *CreateResourceOperation) Status() Status
func (*CreateResourceOperation) Type ¶
func (o *CreateResourceOperation) Type() Type
type CreateResourceOperationOptions ¶
type CreateResourceOperationOptions struct { ManageableBy resrc.ManageableBy ForceReplicas *int ExtraPost bool }
type DeleteResourceOperation ¶
type DeleteResourceOperation struct {
// contains filtered or unexported fields
}
func NewDeleteResourceOperation ¶
func NewDeleteResourceOperation( resource *resrcid.ResourceID, kubeClient kubeclnt.KubeClienter, opts DeleteResourceOperationOptions, ) *DeleteResourceOperation
func (*DeleteResourceOperation) Empty ¶
func (o *DeleteResourceOperation) Empty() bool
func (*DeleteResourceOperation) Execute ¶
func (o *DeleteResourceOperation) Execute(ctx context.Context) error
func (*DeleteResourceOperation) HumanID ¶
func (o *DeleteResourceOperation) HumanID() string
func (*DeleteResourceOperation) ID ¶
func (o *DeleteResourceOperation) ID() string
func (*DeleteResourceOperation) Status ¶
func (o *DeleteResourceOperation) Status() Status
func (*DeleteResourceOperation) Type ¶
func (o *DeleteResourceOperation) Type() Type
type DeleteResourceOperationOptions ¶
type DeleteResourceOperationOptions struct {
ExtraPost bool
}
type FailReleaseOperation ¶
type FailReleaseOperation struct {
// contains filtered or unexported fields
}
func NewFailReleaseOperation ¶
func NewFailReleaseOperation( rel *rls.Release, history rlshistor.Historier, ) *FailReleaseOperation
func (*FailReleaseOperation) Empty ¶
func (o *FailReleaseOperation) Empty() bool
func (*FailReleaseOperation) Execute ¶
func (o *FailReleaseOperation) Execute(ctx context.Context) error
func (*FailReleaseOperation) HumanID ¶
func (o *FailReleaseOperation) HumanID() string
func (*FailReleaseOperation) ID ¶
func (o *FailReleaseOperation) ID() string
func (*FailReleaseOperation) Status ¶
func (o *FailReleaseOperation) Status() Status
func (*FailReleaseOperation) Type ¶
func (o *FailReleaseOperation) Type() Type
type RecreateResourceOperation ¶
type RecreateResourceOperation struct {
// contains filtered or unexported fields
}
func NewRecreateResourceOperation ¶
func NewRecreateResourceOperation( resource *resrcid.ResourceID, unstruct *unstructured.Unstructured, absenceTaskState *util.Concurrent[*statestore.AbsenceTaskState], kubeClient kubeclnt.KubeClienter, dynamicClient dynamic.Interface, mapper meta.ResettableRESTMapper, opts RecreateResourceOperationOptions, ) *RecreateResourceOperation
func (*RecreateResourceOperation) Empty ¶
func (o *RecreateResourceOperation) Empty() bool
func (*RecreateResourceOperation) Execute ¶
func (o *RecreateResourceOperation) Execute(ctx context.Context) error
func (*RecreateResourceOperation) HumanID ¶
func (o *RecreateResourceOperation) HumanID() string
func (*RecreateResourceOperation) ID ¶
func (o *RecreateResourceOperation) ID() string
func (*RecreateResourceOperation) Status ¶
func (o *RecreateResourceOperation) Status() Status
func (*RecreateResourceOperation) Type ¶
func (o *RecreateResourceOperation) Type() Type
type StageOperation ¶
type StageOperation struct {
// contains filtered or unexported fields
}
func NewStageOperation ¶
func NewStageOperation(name string) *StageOperation
func (*StageOperation) Empty ¶
func (o *StageOperation) Empty() bool
func (*StageOperation) HumanID ¶
func (o *StageOperation) HumanID() string
func (*StageOperation) ID ¶
func (o *StageOperation) ID() string
func (*StageOperation) Status ¶
func (o *StageOperation) Status() Status
func (*StageOperation) Type ¶
func (o *StageOperation) Type() Type
type SucceedReleaseOperation ¶
type SucceedReleaseOperation struct {
// contains filtered or unexported fields
}
func NewSucceedReleaseOperation ¶
func NewSucceedReleaseOperation( rel *rls.Release, history rlshistor.Historier, ) *SucceedReleaseOperation
func (*SucceedReleaseOperation) Empty ¶
func (o *SucceedReleaseOperation) Empty() bool
func (*SucceedReleaseOperation) Execute ¶
func (o *SucceedReleaseOperation) Execute(ctx context.Context) error
func (*SucceedReleaseOperation) HumanID ¶
func (o *SucceedReleaseOperation) HumanID() string
func (*SucceedReleaseOperation) ID ¶
func (o *SucceedReleaseOperation) ID() string
func (*SucceedReleaseOperation) Status ¶
func (o *SucceedReleaseOperation) Status() Status
func (*SucceedReleaseOperation) Type ¶
func (o *SucceedReleaseOperation) Type() Type
type SupersedeReleaseOperation ¶
type SupersedeReleaseOperation struct {
// contains filtered or unexported fields
}
func NewSupersedeReleaseOperation ¶
func NewSupersedeReleaseOperation( rel *rls.Release, history rlshistor.Historier, ) *SupersedeReleaseOperation
func (*SupersedeReleaseOperation) Empty ¶
func (o *SupersedeReleaseOperation) Empty() bool
func (*SupersedeReleaseOperation) Execute ¶
func (o *SupersedeReleaseOperation) Execute(ctx context.Context) error
func (*SupersedeReleaseOperation) HumanID ¶
func (o *SupersedeReleaseOperation) HumanID() string
func (*SupersedeReleaseOperation) ID ¶
func (o *SupersedeReleaseOperation) ID() string
func (*SupersedeReleaseOperation) Status ¶
func (o *SupersedeReleaseOperation) Status() Status
func (*SupersedeReleaseOperation) Type ¶
func (o *SupersedeReleaseOperation) Type() Type
type TrackResourceAbsenceOperation ¶
type TrackResourceAbsenceOperation struct {
// contains filtered or unexported fields
}
func NewTrackResourceAbsenceOperation ¶
func NewTrackResourceAbsenceOperation( resource *resrcid.ResourceID, taskState *util.Concurrent[*statestore.AbsenceTaskState], dynamicClient dynamic.Interface, mapper meta.ResettableRESTMapper, opts TrackResourceAbsenceOperationOptions, ) *TrackResourceAbsenceOperation
func (*TrackResourceAbsenceOperation) Empty ¶
func (o *TrackResourceAbsenceOperation) Empty() bool
func (*TrackResourceAbsenceOperation) Execute ¶
func (o *TrackResourceAbsenceOperation) Execute(ctx context.Context) error
func (*TrackResourceAbsenceOperation) HumanID ¶
func (o *TrackResourceAbsenceOperation) HumanID() string
func (*TrackResourceAbsenceOperation) ID ¶
func (o *TrackResourceAbsenceOperation) ID() string
func (*TrackResourceAbsenceOperation) Status ¶
func (o *TrackResourceAbsenceOperation) Status() Status
func (*TrackResourceAbsenceOperation) Type ¶
func (o *TrackResourceAbsenceOperation) Type() Type
type TrackResourcePresenceOperation ¶
type TrackResourcePresenceOperation struct {
// contains filtered or unexported fields
}
func NewTrackResourcePresenceOperation ¶
func NewTrackResourcePresenceOperation( resource *resrcid.ResourceID, taskState *util.Concurrent[*statestore.PresenceTaskState], dynamicClient dynamic.Interface, mapper meta.ResettableRESTMapper, opts TrackResourcePresenceOperationOptions, ) *TrackResourcePresenceOperation
func (*TrackResourcePresenceOperation) Empty ¶
func (o *TrackResourcePresenceOperation) Empty() bool
func (*TrackResourcePresenceOperation) Execute ¶
func (o *TrackResourcePresenceOperation) Execute(ctx context.Context) error
func (*TrackResourcePresenceOperation) HumanID ¶
func (o *TrackResourcePresenceOperation) HumanID() string
func (*TrackResourcePresenceOperation) ID ¶
func (o *TrackResourcePresenceOperation) ID() string
func (*TrackResourcePresenceOperation) Status ¶
func (o *TrackResourcePresenceOperation) Status() Status
func (*TrackResourcePresenceOperation) Type ¶
func (o *TrackResourcePresenceOperation) Type() Type
type TrackResourceReadinessOperation ¶
type TrackResourceReadinessOperation struct {
// contains filtered or unexported fields
}
func NewTrackResourceReadinessOperation ¶
func NewTrackResourceReadinessOperation( resource *resrcid.ResourceID, taskState *util.Concurrent[*statestore.ReadinessTaskState], logStore *util.Concurrent[*logstore.LogStore], staticClient kubernetes.Interface, dynamicClient dynamic.Interface, discoveryClient discovery.CachedDiscoveryInterface, mapper meta.ResettableRESTMapper, opts TrackResourceReadinessOperationOptions, ) *TrackResourceReadinessOperation
func (*TrackResourceReadinessOperation) Empty ¶
func (o *TrackResourceReadinessOperation) Empty() bool
func (*TrackResourceReadinessOperation) Execute ¶
func (o *TrackResourceReadinessOperation) Execute(ctx context.Context) error
func (*TrackResourceReadinessOperation) HumanID ¶
func (o *TrackResourceReadinessOperation) HumanID() string
func (*TrackResourceReadinessOperation) ID ¶
func (o *TrackResourceReadinessOperation) ID() string
func (*TrackResourceReadinessOperation) Status ¶
func (o *TrackResourceReadinessOperation) Status() Status
func (*TrackResourceReadinessOperation) Type ¶
func (o *TrackResourceReadinessOperation) Type() Type
type TrackResourceReadinessOperationOptions ¶
type TrackResourceReadinessOperationOptions struct { Timeout time.Duration NoActivityTimeout time.Duration IgnoreReadinessProbeFailsByContainerName map[string]time.Duration CaptureLogsFromTime time.Time SaveLogsOnlyForContainers []string SaveLogsByRegex *regexp.Regexp SaveLogsByRegexForContainers map[string]*regexp.Regexp IgnoreLogs bool IgnoreLogsForContainers []string SaveEvents bool }
type UpdateResourceOperation ¶
type UpdateResourceOperation struct {
// contains filtered or unexported fields
}
func NewUpdateResourceOperation ¶
func NewUpdateResourceOperation( resource *resrcid.ResourceID, unstruct *unstructured.Unstructured, kubeClient kubeclnt.KubeClienter, opts UpdateResourceOperationOptions, ) (*UpdateResourceOperation, error)
func (*UpdateResourceOperation) Empty ¶
func (o *UpdateResourceOperation) Empty() bool
func (*UpdateResourceOperation) Execute ¶
func (o *UpdateResourceOperation) Execute(ctx context.Context) error
func (*UpdateResourceOperation) HumanID ¶
func (o *UpdateResourceOperation) HumanID() string
func (*UpdateResourceOperation) ID ¶
func (o *UpdateResourceOperation) ID() string
func (*UpdateResourceOperation) Status ¶
func (o *UpdateResourceOperation) Status() Status
func (*UpdateResourceOperation) Type ¶
func (o *UpdateResourceOperation) Type() Type
type UpdateResourceOperationOptions ¶
type UpdateResourceOperationOptions struct { ManageableBy resrc.ManageableBy ExtraPost bool }
Source Files ¶
- apply_resource_operation.go
- create_pending_release_operation.go
- create_resource_operation.go
- delete_resource_operation.go
- fail_release_operation.go
- interface.go
- recreate_resource_operation.go
- stage_operation.go
- succeed_release_operation.go
- supersede_release_operation.go
- track_resource_absence.go
- track_resource_presence.go
- track_resource_readiness_operation.go
- update_resource_operation.go
Click to show internal directories.
Click to hide internal directories.