executor

Documentation

Index

• Constants
• type Executor
  • func NewDefaultExecutor(logger logr.Logger) *Executor
  • func (r *Executor) Do(ctx *ExecutorContext) (bool, ctrl.Result, error)
• type ExecutorContext
  • func (c *ExecutorContext) Fail(err error)
  • func (c *ExecutorContext) GetCurrentState() (string, rolloutv1alpha1.RolloutStepState)
  • func (c *ExecutorContext) GetWebhooksAndLatestStatusBy(hookType rolloutv1alpha1.HookType) ([]rolloutv1alpha1.RolloutWebhook, *rolloutv1alpha1.RolloutWebhookStatus)
  • func (c *ExecutorContext) Initialize()
  • func (c *ExecutorContext) MoveToNextState(nextState rolloutv1alpha1.RolloutStepState)
  • func (c *ExecutorContext) MoveToNextStateIfMatch(curState, nextState rolloutv1alpha1.RolloutStepState)
  • func (c *ExecutorContext) Pause()
  • func (c *ExecutorContext) SetWebhookStatus(status rolloutv1alpha1.RolloutWebhookStatus)

Constants

const (
	StepPending            = rolloutv1alpha1.RolloutStepPending
	StepPreCanaryStepHook  = rolloutv1alpha1.RolloutStepPreCanaryStepHook
	StepPreBatchStepHook   = rolloutv1alpha1.RolloutStepPreBatchStepHook
	StepRunning            = rolloutv1alpha1.RolloutStepRunning
	StepPostCanaryStepHook = rolloutv1alpha1.RolloutStepPostCanaryStepHook
	StepPostBatchStepHook  = rolloutv1alpha1.RolloutStepPostBatchStepHook
	StepSucceeded          = rolloutv1alpha1.RolloutStepSucceeded
	StepResourceRecycling  = rolloutv1alpha1.RolloutStepResourceRecycling
)

const (
	ReasonWebhookNotExist                 = "WebhookNotExist"
	ReasonWebhookExecuteError             = "WebhookExecuteError"
	ReasonWebhookFailurePolicyInvalid     = "WebhookFailurePolicyInvalid"
	ReasonWebhookReviewStatusCodeUnknown  = "WebhookReviewStatusCodeUnknown"
	ReasonWebhookFailureThresholdExceeded = "WebhookFailureThresholdExceeded"
)

Types

type Executor

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

func NewDefaultExecutor

func NewDefaultExecutor(logger logr.Logger) *Executor

func (*Executor) Do

func (r *Executor) Do(ctx *ExecutorContext) (bool, ctrl.Result, error)

Do execute the lifecycle for rollout run, and will return new status

type ExecutorContext

type ExecutorContext struct {
	context.Context

	Client   client.Client
	Recorder record.EventRecorder

	Accessor       workload.Accessor
	Rollout        *rolloutv1alpha1.Rollout
	RolloutRun     *rolloutv1alpha1.RolloutRun
	NewStatus      *rolloutv1alpha1.RolloutRunStatus
	Workloads      *workload.Set
	TrafficManager *traffic.Manager
	// contains filtered or unexported fields
}

ExecutorContext context of rolloutRun

func (*ExecutorContext) Fail

func (c *ExecutorContext) Fail(err error)

func (*ExecutorContext) GetCurrentState

func (c *ExecutorContext) GetCurrentState() (string, rolloutv1alpha1.RolloutStepState)

func (*ExecutorContext) GetWebhooksAndLatestStatusBy

func (c *ExecutorContext) GetWebhooksAndLatestStatusBy(hookType rolloutv1alpha1.HookType) ([]rolloutv1alpha1.RolloutWebhook, *rolloutv1alpha1.RolloutWebhookStatus)

func (*ExecutorContext) Initialize

func (c *ExecutorContext) Initialize()

func (*ExecutorContext) MoveToNextState

func (c *ExecutorContext) MoveToNextState(nextState rolloutv1alpha1.RolloutStepState)

func (*ExecutorContext) MoveToNextStateIfMatch

func (c *ExecutorContext) MoveToNextStateIfMatch(curState, nextState rolloutv1alpha1.RolloutStepState)

func (*ExecutorContext) Pause

func (c *ExecutorContext) Pause()

func (*ExecutorContext) SetWebhookStatus

func (c *ExecutorContext) SetWebhookStatus(status rolloutv1alpha1.RolloutWebhookStatus)