Documentation ¶
Index ¶
- Constants
- type Executor
- 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 ¶
View Source
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 )
View Source
const ( ReasonWebhookNotExist = "WebhookNotExist" ReasonWebhookExecuteError = "WebhookExecuteError" ReasonWebhookFailurePolicyInvalid = "WebhookFailurePolicyInvalid" ReasonWebhookReviewStatusCodeUnknown = "WebhookReviewStatusCodeUnknown" ReasonWebhookFailureThresholdExceeded = "WebhookFailureThresholdExceeded" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
func NewDefaultExecutor ¶
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 ¶ added in v0.1.0
func (c *ExecutorContext) Fail(err error)
func (*ExecutorContext) GetCurrentState ¶ added in v0.1.0
func (c *ExecutorContext) GetCurrentState() (string, rolloutv1alpha1.RolloutStepState)
func (*ExecutorContext) GetWebhooksAndLatestStatusBy ¶ added in v0.1.0
func (c *ExecutorContext) GetWebhooksAndLatestStatusBy(hookType rolloutv1alpha1.HookType) ([]rolloutv1alpha1.RolloutWebhook, *rolloutv1alpha1.RolloutWebhookStatus)
func (*ExecutorContext) Initialize ¶
func (c *ExecutorContext) Initialize()
func (*ExecutorContext) MoveToNextState ¶ added in v0.1.0
func (c *ExecutorContext) MoveToNextState(nextState rolloutv1alpha1.RolloutStepState)
func (*ExecutorContext) MoveToNextStateIfMatch ¶ added in v0.1.0
func (c *ExecutorContext) MoveToNextStateIfMatch(curState, nextState rolloutv1alpha1.RolloutStepState)
func (*ExecutorContext) Pause ¶ added in v0.1.0
func (c *ExecutorContext) Pause()
func (*ExecutorContext) SetWebhookStatus ¶ added in v0.1.0
func (c *ExecutorContext) SetWebhookStatus(status rolloutv1alpha1.RolloutWebhookStatus)
Click to show internal directories.
Click to hide internal directories.