control

Documentation

Index

• func TerminalError(wrapped error) error
• type BatchReleaseControl
  • func NewBatchReleaseControl(impl workload.Accessor, client client.Client) *BatchReleaseControl
  • func (c *BatchReleaseControl) Finalize(workload *workload.Info) error
  • func (c *BatchReleaseControl) Initialize(workload *workload.Info, rollout, rolloutRun string, batchIndex int32) error
  • func (c *BatchReleaseControl) UpdatePartition(workload *workload.Info, partition intstr.IntOrString) (bool, error)
• type CanaryReleaseControl
  • func NewCanaryReleaseControl(impl workload.Accessor, client 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(stable *workload.Info) error
  • func (c *CanaryReleaseControl) Initialize(stable *workload.Info, rollout, rolloutRun string) 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, client client.Client) *BatchReleaseControl

func (*BatchReleaseControl) Finalize

func (c *BatchReleaseControl) Finalize(workload *workload.Info) error

func (*BatchReleaseControl) Initialize

func (c *BatchReleaseControl) Initialize(workload *workload.Info, rollout, rolloutRun string, batchIndex int32) error

func (*BatchReleaseControl) UpdatePartition

func (c *BatchReleaseControl) UpdatePartition(workload *workload.Info, partition intstr.IntOrString) (bool, error)

type CanaryReleaseControl

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

func NewCanaryReleaseControl

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

func (*CanaryReleaseControl) CreateOrUpdate

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

func (*CanaryReleaseControl) Finalize

func (c *CanaryReleaseControl) Finalize(stable *workload.Info) error

func (*CanaryReleaseControl) Initialize

func (c *CanaryReleaseControl) Initialize(stable *workload.Info, rollout, rolloutRun string) error