custom

Documentation

Index

• func CheckPending(ctx wfContext.Context, step v1beta1.WorkflowStep, ...) bool
• func MakeValueForContext(ctx wfContext.Context, pd *packages.PackageDiscover, id string, ...) (*value.Value, error)
• func OpTpy(v *value.Value) string
• func ValidateIfValue(ctx wfContext.Context, step v1beta1.WorkflowStep, ...) (bool, error)
• type LoadTaskTemplate
• type TaskLoader
  • func NewTaskLoader(lt LoadTaskTemplate, pkgDiscover *packages.PackageDiscover, ...) *TaskLoader
  • func (t *TaskLoader) GetTaskGenerator(ctx context.Context, name string) (wfTypes.TaskGenerator, error)

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 MakeValueForContext

func MakeValueForContext(ctx wfContext.Context, pd *packages.PackageDiscover, id string, pCtx process.Context) (*value.Value, error)

MakeValueForContext makes context value

func OpTpy

func OpTpy(v *value.Value) string

OpTpy get label do

func ValidateIfValue

func ValidateIfValue(ctx wfContext.Context, step v1beta1.WorkflowStep, stepStatus map[string]common.StepStatus, options *wfTypes.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 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.