opertn

package
v0.0.0-...-3d5d804 Latest Latest
Warning

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

Go to latest
Published: Apr 24, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

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 (*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 (*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 (*CreatePendingReleaseOperation) Execute

func (*CreatePendingReleaseOperation) HumanID

func (*CreatePendingReleaseOperation) ID

func (*CreatePendingReleaseOperation) Status

func (*CreatePendingReleaseOperation) Type

type CreateResourceOperation

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

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 (*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 (*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 Operation

type Operation interface {
	Execute(ctx context.Context) error
	ID() string
	HumanID() string
	Status() Status
	Type() Type
	Empty() bool
}

type RecreateResourceOperation

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

func (*RecreateResourceOperation) Empty

func (o *RecreateResourceOperation) Empty() bool

func (*RecreateResourceOperation) Execute

func (*RecreateResourceOperation) HumanID

func (o *RecreateResourceOperation) HumanID() string

func (*RecreateResourceOperation) ID

func (*RecreateResourceOperation) Status

func (o *RecreateResourceOperation) Status() Status

func (*RecreateResourceOperation) Type

func (o *RecreateResourceOperation) Type() Type

type RecreateResourceOperationOptions

type RecreateResourceOperationOptions struct {
	ManageableBy            resrc.ManageableBy
	ForceReplicas           *int
	DeletionTrackTimeout    time.Duration
	DeletionTrackPollPeriod time.Duration
	ExtraPost               bool
}

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

func (o *StageOperation) Execute(ctx context.Context) error

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 Status

type Status string
const (
	StatusUnknown   Status = ""
	StatusCompleted Status = "completed"
	StatusFailed    Status = "failed"
)

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 (*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 (*SupersedeReleaseOperation) HumanID

func (o *SupersedeReleaseOperation) HumanID() string

func (*SupersedeReleaseOperation) ID

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 (*TrackResourceAbsenceOperation) Empty

func (*TrackResourceAbsenceOperation) Execute

func (*TrackResourceAbsenceOperation) HumanID

func (*TrackResourceAbsenceOperation) ID

func (*TrackResourceAbsenceOperation) Status

func (*TrackResourceAbsenceOperation) Type

type TrackResourceAbsenceOperationOptions

type TrackResourceAbsenceOperationOptions struct {
	Timeout    time.Duration
	PollPeriod time.Duration
}

type TrackResourcePresenceOperation

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

func (*TrackResourcePresenceOperation) Empty

func (*TrackResourcePresenceOperation) Execute

func (*TrackResourcePresenceOperation) HumanID

func (*TrackResourcePresenceOperation) ID

func (*TrackResourcePresenceOperation) Status

func (*TrackResourcePresenceOperation) Type

type TrackResourcePresenceOperationOptions

type TrackResourcePresenceOperationOptions struct {
	Timeout    time.Duration
	PollPeriod time.Duration
}

type TrackResourceReadinessOperation

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

func (*TrackResourceReadinessOperation) Empty

func (*TrackResourceReadinessOperation) Execute

func (*TrackResourceReadinessOperation) HumanID

func (*TrackResourceReadinessOperation) ID

func (*TrackResourceReadinessOperation) Status

func (*TrackResourceReadinessOperation) 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 Type

type Type string

type UpdateResourceOperation

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

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 (*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
}

Jump to

Keyboard shortcuts

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