custom

Documentation

Index

• Constants
• 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"
	// MaxErrorTimes is the max times of the workflow progress condition which is Failed.
	MaxErrorTimes = 10
)

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.