Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

executor

package

Go to main page

Versions in this module

v0

v0.2.0

Jul 27, 2025

v0.1.3

Mar 7, 2025

Changes in this version

+ const StepNone

type ExecutorContext

+ OwnerKind string

+ OwnerName string

+ func (c *ExecutorContext) SkipCurrentRelease()

+ func (e *ExecutorContext) GetBatchLogger() logr.Logger

+ func (e *ExecutorContext) GetCanaryLogger() logr.Logger

+ func (e *ExecutorContext) GetLogger() logr.Logger

+ func (e *ExecutorContext) WithLogger(logger logr.Logger) logr.Logger

v0.1.2

Mar 26, 2024

v0.1.1

Mar 25, 2024

Changes in this version

type ExecutorContext

+ Accessor workload.Accessor

+ Client client.Client

+ Recorder record.EventRecorder

v0.1.0

Mar 7, 2024

Changes in this version

+ const StepPending

+ const StepPostBatchStepHook

+ const StepPostCanaryStepHook

+ const StepPreBatchStepHook

+ const StepPreCanaryStepHook

+ const StepResourceRecycling

+ const StepRunning

+ const StepSucceeded

type ExecutorContext

+ TrafficManager *traffic.Manager

+ 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) MoveToNextState(nextState rolloutv1alpha1.RolloutStepState)

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

+ func (c *ExecutorContext) Pause()

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

v0.0.2

Jan 24, 2024

Changes in this version

+ const BatchStateInitial

+ const BatchStatePaused

+ const BatchStatePostBatchHook

+ const BatchStatePreBatchHook

+ const BatchStateSucceeded

+ const BatchStateUpgrading

+ const CodeUpgradingError

+ const ReasonCheckReadyError

+ const ReasonUpgradePartitionError

+ const ReasonWebhookExecuteError

+ const ReasonWebhookFailurePolicyInvalid

+ const ReasonWebhookFailureThresholdExceeded

+ const ReasonWebhookNotExist

+ const ReasonWebhookReviewStatusCodeUnknown

+ const ReasonWorkloadInterfaceNotExist

+ const ReasonWorkloadStoreNotExist

+ type Executor struct

+ func NewDefaultExecutor(logger logr.Logger) *Executor

+ func (r *Executor) Do(ctx context.Context, executorContext *ExecutorContext) (bool, ctrl.Result, error)

+ type ExecutorContext struct

+ NewStatus *rolloutv1alpha1.RolloutRunStatus

+ Rollout *rolloutv1alpha1.Rollout

+ RolloutRun *rolloutv1alpha1.RolloutRun

+ Workloads *workload.Set

+ func (c *ExecutorContext) Initialize()