executor

package

v0.0.2 Latest Latest Go to latest Published: Jan 24, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/KusionStack/rollout

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Executor
- func NewDefaultExecutor(logger logr.Logger) *Executor
- func (r *Executor) Do(ctx context.Context, executorContext *ExecutorContext) (bool, ctrl.Result, error)
type ExecutorContext
- func (c *ExecutorContext) Initialize()

Constants ¶

View Source

const (
	BatchStateInitial       = rolloutv1alpha1.BatchStepStatePending
	BatchStatePaused        = rolloutv1alpha1.BatchStepStatePaused
	BatchStatePreBatchHook  = rolloutv1alpha1.BatchStepStatePreBatchStepHook
	BatchStateUpgrading     = rolloutv1alpha1.BatchStepStateRunning
	BatchStatePostBatchHook = rolloutv1alpha1.BatchStepStatePostBatchStepHook
	BatchStateSucceeded     = rolloutv1alpha1.BatchStepStateSucceeded
)

View Source

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

View Source

const (
	CodeUpgradingError = "UpgradingError"

	ReasonCheckReadyError           = "CheckReadyError"
	ReasonUpgradePartitionError     = "UpgradePartitionError"
	ReasonWorkloadStoreNotExist     = "WorkloadStoreNotExist"
	ReasonWorkloadInterfaceNotExist = "WorkloadInterfaceNotExist"
)

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 context.Context, executorContext *ExecutorContext) (bool, ctrl.Result, error)

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

type ExecutorContext ¶

type ExecutorContext struct {
	Rollout    *rolloutv1alpha1.Rollout
	RolloutRun *rolloutv1alpha1.RolloutRun
	NewStatus  *rolloutv1alpha1.RolloutRunStatus
	Workloads  *workload.Set
}

ExecutorContext context of rolloutRun

func (*ExecutorContext) Initialize ¶

func (c *ExecutorContext) Initialize()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL