Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + type AbortData struct + Cluster string + ExecutionID *core.WorkflowExecutionIdentifier + Namespace string + type Compiler interface + CompileTask func(task *core.TaskTemplate) (*core.CompiledTask, error) + CompileWorkflow func(primaryWf *core.WorkflowTemplate, subworkflows []*core.WorkflowTemplate, ...) (*core.CompiledWorkflowClosure, error) + GetRequirements func(fg *core.WorkflowTemplate, subWfs []*core.WorkflowTemplate) (compiler.WorkflowExecutionRequirements, error) + type ExecutionData struct + ExecutionID *core.WorkflowExecutionIdentifier + ExecutionParameters ExecutionParameters + Namespace string + ReferenceLaunchPlanName string + ReferenceWorkflowName string + WorkflowClosure *core.CompiledWorkflowClosure + WorkflowClosureReference storage.DataReference + type ExecutionParameters struct + AcceptedAt time.Time + Annotations map[string]string + ClusterAssignment *admin.ClusterAssignment + EventVersion int + ExecutionConfig *admin.WorkflowExecutionConfig + Inputs *core.LiteralMap + Labels map[string]string + RawOutputDataConfig *admin.RawOutputDataConfig + RecoveryExecution *core.WorkflowExecutionIdentifier + RoleNameKey string + TaskPluginOverrides []*admin.PluginOverride + TaskResources *TaskResources + type ExecutionResponse struct + Cluster string + type KozmoWorkflowBuilder interface + Build func(wfClosure *core.CompiledWorkflowClosure, inputs *core.LiteralMap, ...) (*v1alpha1.KozmoWorkflow, error) + type TaskResources struct + Defaults runtime.TaskResourceSet + Limits runtime.TaskResourceSet + type WorkflowExecutor interface + Abort func(ctx context.Context, data AbortData) error + Execute func(ctx context.Context, data ExecutionData) (ExecutionResponse, error) + ID func() string
Go to main page