Affected by 
Documentation
¶
Index ¶
- func ToNode(n *execution.Node) *runtime.Node
- type StatusBuilder
- type StatusOption
- func WithAttemptID(attemptID string) StatusOption
- func WithCreatedAt(t int64) StatusOption
- func WithError(err string) StatusOption
- func WithFinishedAt(t time.Time) StatusOption
- func WithHierarchyRefs(root execution.DAGRunRef, parent execution.DAGRunRef) StatusOption
- func WithLogFilePath(logFilePath string) StatusOption
- func WithNodes(nodes []runtime.NodeData) StatusOption
- func WithOnCancelNode(node *runtime.Node) StatusOption
- func WithOnExitNode(node *runtime.Node) StatusOption
- func WithOnFailureNode(node *runtime.Node) StatusOption
- func WithOnInitNode(node *runtime.Node) StatusOption
- func WithOnSuccessNode(node *runtime.Node) StatusOption
- func WithOnWaitNode(node *runtime.Node) StatusOption
- func WithPreconditions(conditions []*core.Condition) StatusOption
- func WithQueuedAt(formattedTime string) StatusOption
- func WithWorkerID(workerID string) StatusOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type StatusBuilder ¶
type StatusBuilder struct {
// contains filtered or unexported fields
}
StatusBuilder creates Status objects for a specific DAG
func NewStatusBuilder ¶
func NewStatusBuilder(dag *core.DAG) *StatusBuilder
NewStatusBuilder creates a new StatusFactory for the specified DAG
func (*StatusBuilder) Create ¶
func (f *StatusBuilder) Create( dagRunID string, status core.Status, pid int, startedAt time.Time, opts ...StatusOption, ) execution.DAGRunStatus
Create builds a Status object for a dag-run with the specified parameters
type StatusOption ¶
type StatusOption func(*execution.DAGRunStatus)
StatusOption is a functional option pattern for configuring Status objects
func WithAttemptID ¶
func WithAttemptID(attemptID string) StatusOption
func WithCreatedAt ¶
func WithCreatedAt(t int64) StatusOption
WithCreatedAt returns a StatusOption that sets the created time
func WithError ¶ added in v1.27.0
func WithError(err string) StatusOption
WithError returns a StatusOption that sets the top-level error message
func WithFinishedAt ¶
func WithFinishedAt(t time.Time) StatusOption
WithFinishedAt returns a StatusOption that sets the finished time
func WithHierarchyRefs ¶
func WithHierarchyRefs(root execution.DAGRunRef, parent execution.DAGRunRef) StatusOption
WithHierarchyRefs returns a StatusOption that sets the root DAG information
func WithLogFilePath ¶
func WithLogFilePath(logFilePath string) StatusOption
WithLogFilePath returns a StatusOption that sets the log file path
func WithNodes ¶
func WithNodes(nodes []runtime.NodeData) StatusOption
WithNodes returns a StatusOption that sets the node data for the status
func WithOnCancelNode ¶
func WithOnCancelNode(node *runtime.Node) StatusOption
WithOnCancelNode returns a StatusOption that sets the cancel handler node
func WithOnExitNode ¶
func WithOnExitNode(node *runtime.Node) StatusOption
WithOnExitNode returns a StatusOption that sets the exit handler node
func WithOnFailureNode ¶
func WithOnFailureNode(node *runtime.Node) StatusOption
WithOnFailureNode returns a StatusOption that sets the failure handler node
func WithOnInitNode ¶ added in v1.26.0
func WithOnInitNode(node *runtime.Node) StatusOption
WithOnInitNode returns a StatusOption that sets the init handler node
func WithOnSuccessNode ¶
func WithOnSuccessNode(node *runtime.Node) StatusOption
WithOnSuccessNode returns a StatusOption that sets the success handler node
func WithOnWaitNode ¶ added in v1.30.0
func WithOnWaitNode(node *runtime.Node) StatusOption
WithOnWaitNode returns a StatusOption that sets the wait handler node
func WithPreconditions ¶
func WithPreconditions(conditions []*core.Condition) StatusOption
WithPreconditions returns a StatusOption that sets the preconditions
func WithQueuedAt ¶
func WithQueuedAt(formattedTime string) StatusOption
WithQueuedAt returns a StatusOption that sets the finished time
func WithWorkerID ¶ added in v1.30.0
func WithWorkerID(workerID string) StatusOption
WithWorkerID returns a StatusOption that sets the worker ID
Source Files