Documentation
¶
Index ¶
- func GetChildWorkflowExecutionID(nodeExecID *core.NodeExecutionIdentifier, attempt uint32) (*core.WorkflowExecutionIdentifier, error)
- func GetChildWorkflowExecutionIDForExecution(parentNodeExecID *core.NodeExecutionIdentifier, ...) (*core.WorkflowExecutionIdentifier, error)
- func GetChildWorkflowExecutionIDV2(nodeExecID *core.NodeExecutionIdentifier, attempt uint32) (*core.WorkflowExecutionIdentifier, error)
- func GetSubWorkflow(ctx context.Context, nCtx interfaces.NodeExecutionContext) (v1alpha1.ExecutableSubWorkflow, error)
- func New(executor interfaces.Node, workflowLauncher launchplan.Executor, ...) interfaces.NodeHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetChildWorkflowExecutionID ¶
func GetChildWorkflowExecutionID(nodeExecID *core.NodeExecutionIdentifier, attempt uint32) (*core.WorkflowExecutionIdentifier, error)
func GetChildWorkflowExecutionIDForExecution ¶
func GetChildWorkflowExecutionIDForExecution(parentNodeExecID *core.NodeExecutionIdentifier, nCtx interfaces.NodeExecutionContext) (*core.WorkflowExecutionIdentifier, error)
func GetChildWorkflowExecutionIDV2 ¶
func GetChildWorkflowExecutionIDV2(nodeExecID *core.NodeExecutionIdentifier, attempt uint32) (*core.WorkflowExecutionIdentifier, error)
func GetSubWorkflow ¶
func GetSubWorkflow(ctx context.Context, nCtx interfaces.NodeExecutionContext) (v1alpha1.ExecutableSubWorkflow, error)
Helper method that extracts the SubWorkflow from the ExecutionContext
func New ¶
func New(executor interfaces.Node, workflowLauncher launchplan.Executor, recoveryClient recovery.Client, eventConfig *config.EventConfig, scope promutils.Scope) interfaces.NodeHandler
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.