custom

Documentation

Index

• Constants
• Variables
• func CheckPending(ctx wfContext.Context, step v1beta1.WorkflowStep, ...) bool
• func IsStepFinish(phase common.WorkflowStepPhase, reason string) bool
• func OpTpy(v *value.Value) string
• func SkipTaskRunner(options *SkipOptions) bool
• type LoadTaskTemplate
• type SkipOptions
• type TaskLoader
  • func NewTaskLoader(lt LoadTaskTemplate, pkgDiscover *packages.PackageDiscover, ...) *TaskLoader
  • func (t *TaskLoader) GetTaskGenerator(ctx context.Context, name string) (wfTypes.TaskGenerator, error)

Constants

const (
	// StatusReasonWait is the reason of the workflow progress condition which is Wait.
	StatusReasonWait = "Wait"
	// StatusReasonSkip is the reason of the workflow progress condition which is Skip.
	StatusReasonSkip = "Skip"
	// StatusReasonRendering is the reason of the workflow progress condition which is Rendering.
	StatusReasonRendering = "Rendering"
	// StatusReasonExecute is the reason of the workflow progress condition which is Execute.
	StatusReasonExecute = "Execute"
	// StatusReasonSuspend is the reason of the workflow progress condition which is Suspend.
	StatusReasonSuspend = "Suspend"
	// StatusReasonTerminate is the reason of the workflow progress condition which is Terminate.
	StatusReasonTerminate = "Terminate"
	// StatusReasonParameter is the reason of the workflow progress condition which is ProcessParameter.
	StatusReasonParameter = "ProcessParameter"
	// StatusReasonOutput is the reason of the workflow progress condition which is Output.
	StatusReasonOutput = "Output"
	// StatusReasonFailedAfterRetries is the reason of the workflow progress condition which is FailedAfterRetries.
	StatusReasonFailedAfterRetries = "FailedAfterRetries"
)

Variables

var (
	// MaxWorkflowStepErrorRetryTimes is the max retry times of the failed workflow step.
	MaxWorkflowStepErrorRetryTimes = 10
)

Functions

func CheckPending

func CheckPending(ctx wfContext.Context, step v1beta1.WorkflowStep, stepStatus map[string]common.StepStatus) bool

CheckPending checks whether to pending task run

func IsStepFinish

func IsStepFinish(phase common.WorkflowStepPhase, reason string) bool

IsStepFinish will decide whether step is finish.

func OpTpy

func OpTpy(v *value.Value) string

OpTpy get label do

func SkipTaskRunner

func SkipTaskRunner(options *SkipOptions) bool

SkipTaskRunner will decide whether to skip task runner.

Types

type LoadTaskTemplate

type LoadTaskTemplate func(ctx context.Context, name string) (string, error)

LoadTaskTemplate gets the workflowStep definition from cluster and resolve it.

type SkipOptions

type SkipOptions struct {
	If             string
	DependsOnPhase common.WorkflowStepPhase
}

SkipOptions is the options of skip task runner

type TaskLoader

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

TaskLoader is a client that get taskGenerator.

func NewTaskLoader

func NewTaskLoader(lt LoadTaskTemplate, pkgDiscover *packages.PackageDiscover, handlers providers.Providers, logLevel int, pCtx process.Context) *TaskLoader

NewTaskLoader create a tasks loader.

func (*TaskLoader) GetTaskGenerator

func (t *TaskLoader) GetTaskGenerator(ctx context.Context, name string) (wfTypes.TaskGenerator, error)

GetTaskGenerator get TaskGenerator by name.