executor

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 27, 2025 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	StepNone               = rolloutv1alpha1.RolloutStepNone
	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 

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
	OwnerKind      string
	OwnerName      string
	RolloutRun     *rolloutv1alpha1.RolloutRun
	NewStatus      *rolloutv1alpha1.RolloutRunStatus
	Workloads      *workload.Set
	TrafficManager *trafficcontrol.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) GetBatchLogger added in v0.1.3 

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

func (*ExecutorContext) GetCanaryLogger added in v0.1.3 

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

func (*ExecutorContext) GetCurrentState added in v0.1.0 

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

func (*ExecutorContext) GetLogger added in v0.1.3 

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

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)

func (*ExecutorContext) SkipCurrentRelease added in v0.1.3 

func (c *ExecutorContext) SkipCurrentRelease()

func (*ExecutorContext) WithLogger added in v0.1.3 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.