custom

Documentation

Index

• func CheckPending(ctx wfContext.Context, step v1alpha1.WorkflowStep, id string, ...) (bool, v1alpha1.StepStatus)
• func GetParameterTemplate(step v1alpha1.WorkflowStep) (string, error)
• func MakeBasicValue(wfCtx wfContext.Context, parameterTemplate string, pCtx process.Context) (*value.Value, string, error)
• func OpTpy(v *value.Value) string
• func ValidateIfValue(ctx wfContext.Context, step v1alpha1.WorkflowStep, ...) (bool, error)
• type LoadTaskTemplate
• type TaskLoader
  • func NewTaskLoader(lt LoadTaskTemplate, pkgDiscover *packages.PackageDiscover, ...) *TaskLoader
  • func (t *TaskLoader) GetTaskGenerator(ctx context.Context, name string) (types.TaskGenerator, error)

Functions

func CheckPending

func CheckPending(ctx wfContext.Context, step v1alpha1.WorkflowStep, id string, stepStatus map[string]v1alpha1.StepStatus, basicValue *value.Value) (bool, v1alpha1.StepStatus)

CheckPending checks whether to pending task run

func GetParameterTemplate

func GetParameterTemplate(step v1alpha1.WorkflowStep) (string, error)

GetParameterTemplate gets parameter template

func MakeBasicValue

func MakeBasicValue(wfCtx wfContext.Context, parameterTemplate string, pCtx process.Context) (*value.Value, string, error)

MakeBasicValue makes basic value

func OpTpy

func OpTpy(v *value.Value) string

OpTpy get label do

func ValidateIfValue

func ValidateIfValue(ctx wfContext.Context, step v1alpha1.WorkflowStep, stepStatus map[string]v1alpha1.StepStatus, options *types.PreCheckOptions) (bool, error)

ValidateIfValue validates the if value

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 types.Providers, logLevel int, pCtx process.Context) *TaskLoader

NewTaskLoader create a tasks loader.

func (*TaskLoader) GetTaskGenerator

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

GetTaskGenerator get TaskGenerator by name.