control

Documentation

Index

• func TerminalError(wrapped error) error
• type BatchReleaseControl
  • func NewBatchReleaseControl(impl workload.Accessor, c client.Client) *BatchReleaseControl
  • func (c *BatchReleaseControl) Finalize(ctx context.Context, info *workload.Info) error
  • func (c *BatchReleaseControl) Initialize(ctx context.Context, info *workload.Info, ...) error
  • func (c *BatchReleaseControl) UpdatePartition(ctx context.Context, info *workload.Info, expectedUpdated int32) (bool, error)
• type CanaryReleaseControl
  • func NewCanaryReleaseControl(impl workload.Accessor, c client.Client) *CanaryReleaseControl
  • func (c *CanaryReleaseControl) CreateOrUpdate(ctx context.Context, stable *workload.Info, replicas intstr.IntOrString, ...) (controllerutil.OperationResult, *workload.Info, error)
  • func (c *CanaryReleaseControl) Finalize(ctx context.Context, stable *workload.Info) error
  • func (c *CanaryReleaseControl) GetCanaryObject(cluster, namespace, name string) (client.Object, error)
  • func (c *CanaryReleaseControl) Initialize(ctx context.Context, stable *workload.Info, ...) error

Functions

func TerminalError

func TerminalError(wrapped error) error

TerminalError is an error that will not be retried but still be logged and recorded in metrics.

TODO: delete this error when controller-runtime version is grather than v0.15

Types

type BatchReleaseControl

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

func NewBatchReleaseControl

func NewBatchReleaseControl(impl workload.Accessor, c client.Client) *BatchReleaseControl

func (*BatchReleaseControl) Finalize

func (c *BatchReleaseControl) Finalize(ctx context.Context, info *workload.Info) error

func (*BatchReleaseControl) Initialize

func (c *BatchReleaseControl) Initialize(ctx context.Context, info *workload.Info, ownerKind, ownerName, rolloutRun string, batchIndex int32) error

func (*BatchReleaseControl) UpdatePartition

func (c *BatchReleaseControl) UpdatePartition(ctx context.Context, info *workload.Info, expectedUpdated int32) (bool, error)

type CanaryReleaseControl

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

func NewCanaryReleaseControl

func NewCanaryReleaseControl(impl workload.Accessor, c client.Client) *CanaryReleaseControl

func (*CanaryReleaseControl) CreateOrUpdate

func (c *CanaryReleaseControl) CreateOrUpdate(ctx context.Context, stable *workload.Info, replicas intstr.IntOrString, podTemplatePatch *rolloutv1alpha1.MetadataPatch) (controllerutil.OperationResult, *workload.Info, error)

func (*CanaryReleaseControl) Finalize

func (c *CanaryReleaseControl) Finalize(ctx context.Context, stable *workload.Info) error

func (*CanaryReleaseControl) GetCanaryObject

func (c *CanaryReleaseControl) GetCanaryObject(cluster, namespace, name string) (client.Object, error)

func (*CanaryReleaseControl) Initialize

func (c *CanaryReleaseControl) Initialize(ctx context.Context, stable *workload.Info, ownerKind, ownerName, rolloutRun string) error