Documentation
¶
Index ¶
- func Reusable(node *ir.Node) bool
- func SeedNodes(dag *ir.DAG, source *ir.DAGRunStatus, skipped []string) []runtime.NodeData
- func SeedNodesCarrying(dag *ir.DAG, source *ir.DAGRunStatus, skipped []string, ...) []runtime.NodeData
- func ToNode(n *ir.Node) *runtime.Node
- func ToNodeWithStep(n *ir.Node, step ir.Step) *runtime.Node
- func WithNodes(nodes []runtime.NodeData) ir.StatusOption
- func WithOnAbortNode(node *runtime.Node) ir.StatusOption
- func WithOnExitNode(node *runtime.Node) ir.StatusOption
- func WithOnFailureNode(node *runtime.Node) ir.StatusOption
- func WithOnInitNode(node *runtime.Node) ir.StatusOption
- func WithOnSuccessNode(node *runtime.Node) ir.StatusOption
- func WithOnWaitNode(node *runtime.Node) ir.StatusOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Reusable ¶ added in v2.17.2
Reusable reports whether a node's recorded state may stand in for a skipped step of another run: the node succeeded, or it was itself skipped by retry.
func SeedNodes ¶ added in v2.17.2
SeedNodes returns the initial node states for a new run of dag. Steps named in skipped are recorded as skipped by retry, so their dependents still run, and carry the outputs and completion details of the matching Reusable node in source. Every other step starts as not started. source may be nil.
func SeedNodesCarrying ¶
func SeedNodesCarrying(dag *ir.DAG, source *ir.DAGRunStatus, skipped []string, carry map[string]struct{}) []runtime.NodeData
SeedNodesCarrying is SeedNodes for a run in which only the steps in carry take the outputs of source. The other steps named in skipped are recorded as skipped by retry and carry nothing.
func ToNodeWithStep ¶
ToNodeWithStep converts a persistence Node back to a runtime Node using the supplied step definition.
func WithNodes ¶
func WithNodes(nodes []runtime.NodeData) ir.StatusOption
WithNodes converts runtime node data into persisted DAG-run nodes.
func WithOnAbortNode ¶
func WithOnAbortNode(node *runtime.Node) ir.StatusOption
WithOnAbortNode converts and sets the abort handler node.
func WithOnExitNode ¶
func WithOnExitNode(node *runtime.Node) ir.StatusOption
WithOnExitNode converts and sets the exit handler node.
func WithOnFailureNode ¶
func WithOnFailureNode(node *runtime.Node) ir.StatusOption
WithOnFailureNode converts and sets the failure handler node.
func WithOnInitNode ¶
func WithOnInitNode(node *runtime.Node) ir.StatusOption
WithOnInitNode converts and sets the initialization handler node.
func WithOnSuccessNode ¶
func WithOnSuccessNode(node *runtime.Node) ir.StatusOption
WithOnSuccessNode converts and sets the success handler node.
func WithOnWaitNode ¶
func WithOnWaitNode(node *runtime.Node) ir.StatusOption
WithOnWaitNode converts and sets the wait handler node.
Types ¶
This section is empty.
Source Files