Documentation
¶
Index ¶
- func CheckPending(ctx wfContext.Context, step v1alpha1.WorkflowStep, id string, ...) (bool, v1alpha1.StepStatus)
- func MakeBasicValue(ctx monitorContext.Context, compiler *cuex.Compiler, ...) (cue.Value, error)
- func ResolveActionBreak(err error) error
- func ValidateIfValue(ctx wfContext.Context, step v1alpha1.WorkflowStep, ...) (bool, error)
- type LoadTaskTemplate
- type TaskLoader
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckPending ¶
func CheckPending(ctx wfContext.Context, step v1alpha1.WorkflowStep, id string, stepStatus map[string]v1alpha1.StepStatus, basicValue cue.Value) (bool, v1alpha1.StepStatus)
CheckPending checks whether to pending task run
func MakeBasicValue ¶
func MakeBasicValue(ctx monitorContext.Context, compiler *cuex.Compiler, properties *runtime.RawExtension, pCtx process.Context) (cue.Value, error)
MakeBasicValue makes basic value
func ResolveActionBreak ¶ added in v0.6.2
ResolveActionBreak resolve action break error
func ValidateIfValue ¶
func ValidateIfValue(ctx wfContext.Context, step v1alpha1.WorkflowStep, stepStatus map[string]v1alpha1.StepStatus, basicVal cue.Value) (bool, error)
ValidateIfValue validates the if value
Types ¶
type LoadTaskTemplate ¶
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, logLevel int, pCtx process.Context, compiler *cuex.Compiler) *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.
Source Files
Click to show internal directories.
Click to hide internal directories.