custom

Documentation

Index

• Constants
• Variables
• func OpTpy(v *value.Value) string
• type LoadTaskTemplate
• 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"
	// 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"
)

Variables

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

Functions

func OpTpy

func OpTpy(v *value.Value) string

OpTpy get label do

Types

type LoadTaskTemplate

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

LoadTaskTemplate gets the workflowStep definition from cluster and resolve it.

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.