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 + var NodeStatusComplete = NodeStatus + var NodeStatusPending = NodeStatus + var NodeStatusQueued = NodeStatus + var NodeStatusRecovered = NodeStatus + var NodeStatusRunning = NodeStatus + var NodeStatusSuccess = NodeStatus + var NodeStatusTimedOut = NodeStatus + var NodeStatusUndefined = NodeStatus + type CacheableNodeHandler interface + GetCatalogKey func(ctx context.Context, executionContext NodeExecutionContext) (catalog.Key, error) + IsCacheable func(ctx context.Context, executionContext NodeExecutionContext) (bool, bool, error) + type EventRecorder interface + type HandlerFactory interface + GetHandler func(kind v1alpha1.NodeKind) (NodeHandler, error) + Setup func(ctx context.Context, executor Node, setup SetupContext) error + type Node interface + AbortHandler func(ctx context.Context, execContext executors.ExecutionContext, ...) error + FinalizeHandler func(ctx context.Context, execContext executors.ExecutionContext, ...) error + GetNodeExecutionContextBuilder func() NodeExecutionContextBuilder + Initialize func(ctx context.Context) error + RecursiveNodeHandler func(ctx context.Context, execContext executors.ExecutionContext, ...) (NodeStatus, error) + SetInputsForStartNode func(ctx context.Context, execContext executors.ExecutionContext, ...) (NodeStatus, error) + WithNodeExecutionContextBuilder func(NodeExecutionContextBuilder) Node + type NodeExecutionContext interface + ContextualNodeLookup func() executors.NodeLookup + CurrentAttempt func() uint32 + DataStore func() *storage.DataStore + EnqueueOwnerFunc func() func() error + EventsRecorder func() EventRecorder + ExecutionContext func() executors.ExecutionContext + InputReader func() io.InputReader + MaxDatasetSizeBytes func() int64 + Node func() v1alpha1.ExecutableNode + NodeExecutionMetadata func() NodeExecutionMetadata + NodeID func() v1alpha1.NodeID + NodeStateReader func() NodeStateReader + NodeStateWriter func() NodeStateWriter + NodeStatus func() v1alpha1.ExecutableNodeStatus + OutputShardSelector func() ioutils.ShardSelector + RawOutputPrefix func() storage.DataReference + TaskReader func() TaskReader + type NodeExecutionContextBuilder interface + BuildNodeExecutionContext func(ctx context.Context, executionContext executors.ExecutionContext, ...) (NodeExecutionContext, error) + type NodeExecutionMetadata interface + GetAnnotations func() map[string]string + GetInterruptibleFailureThreshold func() int32 + GetK8sServiceAccount func() string + GetLabels func() map[string]string + GetNamespace func() string + GetNodeExecutionID func() *core.NodeExecutionIdentifier + GetOwnerID func() types.NamespacedName + GetOwnerReference func() v1.OwnerReference + GetSecurityContext func() core.SecurityContext + IsInterruptible func() bool + type NodeExecutor interface + Abort func(ctx context.Context, h NodeHandler, nCtx NodeExecutionContext, reason string, ...) error + Finalize func(ctx context.Context, h NodeHandler, nCtx NodeExecutionContext) error + HandleNode func(ctx context.Context, dag executors.DAGStructure, nCtx NodeExecutionContext, ...) (NodeStatus, error) + type NodeHandler interface + Abort func(ctx context.Context, executionContext NodeExecutionContext, reason string) error + Finalize func(ctx context.Context, executionContext NodeExecutionContext) error + FinalizeRequired func() bool + Handle func(ctx context.Context, executionContext NodeExecutionContext) (handler.Transition, error) + Setup func(ctx context.Context, setupContext SetupContext) error + type NodePhase int + const NodePhaseComplete + const NodePhaseFailed + const NodePhasePending + const NodePhaseQueued + const NodePhaseRecovered + const NodePhaseRunning + const NodePhaseSuccess + const NodePhaseTimedOut + const NodePhaseTimingOut + const NodePhaseUndefined + func (p NodePhase) String() string + type NodeStateReader interface + GetArrayNodeState func() handler.ArrayNodeState + GetBranchNodeState func() handler.BranchNodeState + GetDynamicNodeState func() handler.DynamicNodeState + GetGateNodeState func() handler.GateNodeState + GetTaskNodeState func() handler.TaskNodeState + GetWorkflowNodeState func() handler.WorkflowNodeState + HasArrayNodeState func() bool + HasBranchNodeState func() bool + HasDynamicNodeState func() bool + HasGateNodeState func() bool + HasTaskNodeState func() bool + HasWorkflowNodeState func() bool + type NodeStateWriter interface + ClearNodeStatus func() + PutArrayNodeState func(s handler.ArrayNodeState) error + PutBranchNode func(s handler.BranchNodeState) error + PutDynamicNodeState func(s handler.DynamicNodeState) error + PutGateNodeState func(s handler.GateNodeState) error + PutTaskNodeState func(s handler.TaskNodeState) error + PutWorkflowNodeState func(s handler.WorkflowNodeState) error + type NodeStatus struct + Err *core.ExecutionError + NodePhase NodePhase + func NodeStatusFailed(err *core.ExecutionError) NodeStatus + func (n *NodeStatus) HasFailed() bool + func (n *NodeStatus) HasTimedOut() bool + func (n *NodeStatus) IsComplete() bool + func (n *NodeStatus) PartiallyComplete() bool + type SetupContext interface + EnqueueOwner func() func(string) + MetricsScope func() promutils.Scope + OwnerKind func() string + type TaskReader interface + GetTaskID func() *core.Identifier + GetTaskType func() v1alpha1.TaskType + Read func(ctx context.Context) (*core.TaskTemplate, error)
Go to main page