v1alpha1

package

Go to main page

Versions in this module

v0

v0.1.32

Jan 27, 2020

v0.1.31

Jan 18, 2020

v0.1.30

Jan 14, 2020

v0.1.29

Jan 14, 2020

v0.1.28

Jan 13, 2020

v0.1.27

Jan 10, 2020

Changes in this version

type ExecutableNodeStatus

+ GetOutputDir func() DataReference

type ExecutableTaskNodeStatus

+ GetLastPhaseUpdatedAt func() time.Time

type MutableNodeStatus

+ SetOutputDir func(d DataReference)

type MutableTaskNodeStatus

+ SetLastPhaseUpdatedAt func(updatedAt time.Time)

type NodeStatus

+ OutputDir DataReference

+ func (in *NodeStatus) GetOutputDir() DataReference

+ func (in *NodeStatus) SetOutputDir(d DataReference)

type TaskNodeStatus

+ LastPhaseUpdatedAt time.Time

+ func (in TaskNodeStatus) GetLastPhaseUpdatedAt() time.Time

+ func (in TaskNodeStatus) SetLastPhaseUpdatedAt(updatedAt time.Time)

v0.1.26

Jan 7, 2020

v0.1.25

Jan 2, 2020

Changes in this version

type FlyteWorkflow

+ DataReferenceConstructor storage.ReferenceConstructor

+ type Mutable interface

+ IsDirty func() bool

type MutableNodeStatus

+ ClearSubNodeStatus func()

+ type MutableStruct struct

+ func (in *MutableStruct) DeepCopy() *MutableStruct

+ func (in *MutableStruct) DeepCopyInto(out *MutableStruct)

+ func (in *MutableStruct) ResetDirty()

+ func (in *MutableStruct) SetDirty()

+ func (in MutableStruct) IsDirty() bool

type NodeStatus

+ DataReferenceConstructor storage.ReferenceConstructor

+ func (in *NodeStatus) ClearSubNodeStatus()

type WorkflowStatus

+ DataReferenceConstructor storage.ReferenceConstructor

v0.1.24

Jan 2, 2020

v0.1.23

Jan 2, 2020

v0.1.22

Dec 31, 2019

v0.1.21

Dec 23, 2019

v0.1.20

Dec 20, 2019

v0.1.19

Dec 18, 2019

v0.1.18

Dec 16, 2019

v0.1.17

Dec 11, 2019

Changes in this version

type ExecutableNode

+ GetActiveDeadline func() *time.Duration

+ GetExecutionDeadline func() *time.Duration

type ExecutableNodeStatus

+ GetLastAttemptStartedAt func() *metav1.Time

type MutableNodeStatus

+ ClearLastAttemptStartedAt func()

type NodePhase

+ const NodePhaseTimedOut

+ const NodePhaseTimingOut

type NodeSpec

+ ActiveDeadline *v1.Duration

+ ExecutionDeadline *v1.Duration

+ func (in *NodeSpec) GetActiveDeadline() *time.Duration

+ func (in *NodeSpec) GetExecutionDeadline() *time.Duration

type NodeStatus

+ LastAttemptStartedAt *metav1.Time

+ func (in *NodeStatus) ClearLastAttemptStartedAt()

+ func (in *NodeStatus) GetLastAttemptStartedAt() *metav1.Time

v0.1.16

Dec 6, 2019

v0.1.15

Dec 3, 2019

Changes in this version

type DynamicNodePhase

+ const DynamicNodePhaseFailing

type DynamicNodeStatus

+ Reason string

+ func (s *DynamicNodeStatus) GetDynamicNodeReason() string

+ func (s *DynamicNodeStatus) SetDynamicNodeReason(reason string)

type ExecutableDynamicNodeStatus

+ GetDynamicNodeReason func() string

type MutableDynamicNodeStatus

+ SetDynamicNodeReason func(reason string)

v0.1.14

Nov 13, 2019

v0.1.13

Nov 12, 2019

Changes in this version

type ExecutableTaskNodeStatus

+ GetBarrierClockTick func() uint32

+ GetPluginState func() []byte

+ GetPluginStateVersion func() uint32

type ExecutableWorkflowNodeStatus

+ GetWorkflowNodePhase func() WorkflowNodePhase

type FlyteWorkflow

+ func (in *FlyteWorkflow) GetOwnerReference() metav1.OwnerReference

type MutableNodeStatus

+ GetBranchStatus func() MutableBranchNodeStatus

+ GetDynamicNodeStatus func() MutableDynamicNodeStatus

+ GetTaskStatus func() MutableTaskNodeStatus

+ GetWorkflowStatus func() MutableWorkflowNodeStatus

type MutableTaskNodeStatus

+ SetBarrierClockTick func(tick uint32)

+ SetPluginState func([]byte)

+ SetPluginStateVersion func(uint32)

type MutableWorkflowNodeStatus

+ SetWorkflowNodePhase func(phase WorkflowNodePhase)

type NodeStatus

+ func (in *NodeStatus) GetBranchStatus() MutableBranchNodeStatus

+ func (in *NodeStatus) GetTaskStatus() MutableTaskNodeStatus

+ func (in *NodeStatus) GetWorkflowStatus() MutableWorkflowNodeStatus

+ func (in NodeStatus) GetDynamicNodeStatus() MutableDynamicNodeStatus

+ type TaskDetailsGetter interface

+ GetTask func(id TaskID) (ExecutableTask, error)

type TaskNodeStatus

+ BarrierClockTick uint32

+ PluginState []byte

+ PluginStateVersion uint32

+ func (in *TaskNodeStatus) Equals(other *TaskNodeStatus) bool

+ func (in *TaskNodeStatus) GetBarrierClockTick() uint32

+ func (in *TaskNodeStatus) GetPluginState() []byte

+ func (in *TaskNodeStatus) GetPluginStateVersion() uint32

+ func (in *TaskNodeStatus) SetBarrierClockTick(tick uint32)

+ func (in *TaskNodeStatus) SetPluginState(s []byte)

+ func (in *TaskNodeStatus) SetPluginStateVersion(v uint32)

type WorkflowMeta

+ GetOwnerReference func() metav1.OwnerReference

+ type WorkflowNodePhase int

+ const WorkflowNodePhaseExecuting

+ const WorkflowNodePhaseUndefined

type WorkflowNodeStatus

+ Phase WorkflowNodePhase

+ func (in *WorkflowNodeStatus) GetWorkflowNodePhase() WorkflowNodePhase

+ func (in *WorkflowNodeStatus) SetWorkflowNodePhase(phase WorkflowNodePhase)

v0.1.12

Nov 6, 2019

v0.1.11

Oct 28, 2019

v0.1.10

Oct 1, 2019

v0.1.9

Sep 20, 2019

Changes in this version

+ func GetCompiledFutureFile() string

v0.1.8

Sep 19, 2019

v0.1.7

Sep 18, 2019

v0.1.6

Sep 18, 2019

v0.1.5

Sep 17, 2019

v0.1.4

Sep 13, 2019

v0.1.3

Sep 11, 2019

v0.1.2

Sep 11, 2019

v0.1.1

Sep 9, 2019

v0.1.0

Sep 6, 2019

Changes in this version

+ const EndNodeID

+ const FlyteWorkflowKind

+ const StartNodeID

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var FlyteWorkflowGVK = SchemeGroupVersion.WithKind(FlyteWorkflowKind)

+ var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

+ var SchemeGroupVersion = schema.GroupVersion

+ func GetFutureFile() string

+ func IsPhaseTerminal(phase NodePhase) bool

+ func IsWorkflowPhaseTerminal(p WorkflowPhase) bool

+ func Kind(kind string) schema.GroupKind

+ func Resource(resource string) schema.GroupResource

+ type Alias struct

+ func (in *Alias) DeepCopy() *Alias

+ func (in *Alias) DeepCopyInto(out *Alias)

+ type BaseNode interface

+ GetID func() NodeID

+ GetKind func() NodeKind

+ type BaseWorkflow interface

+ FromNode func(name NodeID) ([]NodeID, error)

+ GetID func() WorkflowID

+ GetNode func(nodeID NodeID) (ExecutableNode, bool)

+ StartNode func() ExecutableNode

+ type BaseWorkflowWithStatus interface

+ type Binding struct

+ func (in *Binding) DeepCopy() *Binding

+ func (in *Binding) DeepCopyInto(out *Binding)

+ func (in *Binding) MarshalJSON() ([]byte, error)

+ func (in *Binding) UnmarshalJSON(b []byte) error

+ type BooleanExpression struct

+ func (in *BooleanExpression) DeepCopy() *BooleanExpression

+ func (in *BooleanExpression) DeepCopyInto(out *BooleanExpression)

+ func (in *BooleanExpression) UnmarshalJSON(b []byte) error

+ func (in BooleanExpression) MarshalJSON() ([]byte, error)

+ type BranchNodePhase int

+ const BranchNodeError

+ const BranchNodeNotYetEvaluated

+ const BranchNodeSuccess

+ func (b BranchNodePhase) String() string

+ type BranchNodeSpec struct

+ Else *NodeID

+ ElseFail *Error

+ ElseIf []*IfBlock

+ If IfBlock

+ func (in *BranchNodeSpec) DeepCopy() *BranchNodeSpec

+ func (in *BranchNodeSpec) DeepCopyInto(out *BranchNodeSpec)

+ func (in *BranchNodeSpec) GetElse() *NodeID

+ func (in *BranchNodeSpec) GetElseFail() *core.Error

+ func (in *BranchNodeSpec) GetElseIf() []ExecutableIfBlock

+ func (in *BranchNodeSpec) GetIf() ExecutableIfBlock

+ type BranchNodeStatus struct

+ FinalizedNodeID *NodeID

+ Phase BranchNodePhase

+ func (in *BranchNodeStatus) DeepCopy() *BranchNodeStatus

+ func (in *BranchNodeStatus) DeepCopyInto(out *BranchNodeStatus)

+ func (in *BranchNodeStatus) Equals(other *BranchNodeStatus) bool

+ func (in *BranchNodeStatus) GetFinalizedNode() *NodeID

+ func (in *BranchNodeStatus) GetPhase() BranchNodePhase

+ func (in *BranchNodeStatus) SetBranchNodeError()

+ func (in *BranchNodeStatus) SetBranchNodeSuccess(id NodeID)

+ type Connections struct

+ DownstreamEdges map[NodeID][]NodeID

+ UpstreamEdges map[NodeID][]NodeID

+ func (in *Connections) DeepCopy() *Connections

+ func (in *Connections) DeepCopyInto(out *Connections)

+ func (in *Connections) MarshalJSON() ([]byte, error)

+ func (in *Connections) UnmarshalJSON(b []byte) error

+ type CustomState map[string]interface

+ func (in *CustomState) DeepCopy() *CustomState

+ func (in *CustomState) DeepCopyInto(out *CustomState)

+ type DataReference = storage.DataReference

+ func GetInputsFile(inputDir DataReference) DataReference

+ func GetOutputErrorFile(inputDir DataReference) DataReference

+ func GetOutputsFile(outputDir DataReference) DataReference

+ type DynamicNodePhase int

+ const DynamicNodePhaseExecuting

+ const DynamicNodePhaseNone

+ type DynamicNodeStatus struct

+ Phase DynamicNodePhase

+ func (in *DynamicNodeStatus) DeepCopy() *DynamicNodeStatus

+ func (in *DynamicNodeStatus) DeepCopyInto(out *DynamicNodeStatus)

+ func (s *DynamicNodeStatus) Equals(o *DynamicNodeStatus) bool

+ func (s *DynamicNodeStatus) GetDynamicNodePhase() DynamicNodePhase

+ func (s *DynamicNodeStatus) SetDynamicNodePhase(phase DynamicNodePhase)

+ type EnqueueWorkflow func(workflowID WorkflowID)

+ type Error struct

+ func (in *Error) DeepCopy() *Error

+ func (in *Error) DeepCopyInto(out *Error)

+ func (in Error) MarshalJSON() ([]byte, error)

+ func (in Error) UnmarshalJSON(b []byte) error

+ type ExecutableBranchNode interface

+ GetElse func() *NodeID

+ GetElseFail func() *core.Error

+ GetElseIf func() []ExecutableIfBlock

+ GetIf func() ExecutableIfBlock

+ type ExecutableBranchNodeStatus interface

+ GetFinalizedNode func() *NodeID

+ GetPhase func() BranchNodePhase

+ type ExecutableDynamicNodeStatus interface

+ GetDynamicNodePhase func() DynamicNodePhase

+ type ExecutableIfBlock interface

+ GetCondition func() *core.BooleanExpression

+ GetThenNode func() *NodeID

+ type ExecutableNode interface

+ GetBranchNode func() ExecutableBranchNode

+ GetConfig func() *v1.ConfigMap

+ GetInputBindings func() []*Binding

+ GetOutputAlias func() []Alias

+ GetResources func() *v1.ResourceRequirements

+ GetRetryStrategy func() *RetryStrategy

+ GetTaskID func() *TaskID

+ GetWorkflowNode func() ExecutableWorkflowNode

+ IsEndNode func() bool

+ IsStartNode func() bool

+ type ExecutableNodeStatus interface

+ GetAttempts func() uint32

+ GetDataDir func() DataReference

+ GetLastUpdatedAt func() *metav1.Time

+ GetMessage func() string

+ GetParentNodeID func() *NodeID

+ GetParentTaskID func() *core.TaskExecutionIdentifier

+ GetPhase func() NodePhase

+ GetQueuedAt func() *metav1.Time

+ GetStartedAt func() *metav1.Time

+ GetStoppedAt func() *metav1.Time

+ GetSubWorkflowNodeStatus func() ExecutableSubWorkflowNodeStatus

+ GetTaskNodeStatus func() ExecutableTaskNodeStatus

+ GetWorkflowNodeStatus func() ExecutableWorkflowNodeStatus

+ IsCached func() bool

+ IsDirty func() bool

+ type ExecutableSubWorkflow interface

+ GetConnections func() *Connections

+ GetNodes func() []NodeID

+ GetOnFailureNode func() ExecutableNode

+ GetOutputBindings func() []*Binding

+ GetOutputs func() *OutputVarMap

+ type ExecutableSubWorkflowNodeStatus interface

+ GetPhase func() WorkflowPhase

+ type ExecutableTask interface

+ CoreTask func() *core.TaskTemplate

+ TaskType func() TaskType

+ type ExecutableTaskNodeStatus interface

+ GetCustomState func() types2.CustomState

+ GetPhase func() types2.TaskPhase

+ GetPhaseVersion func() uint32

+ type ExecutableWorkflow interface

+ type ExecutableWorkflowNode interface

+ GetLaunchPlanRefID func() *LaunchPlanRefID

+ GetSubWorkflowRef func() *WorkflowID

+ type ExecutableWorkflowNodeStatus interface

+ GetWorkflowExecutionName func() string

+ type ExecutableWorkflowStatus interface

+ ConstructNodeDataDir func(ctx context.Context, constructor storage.ReferenceConstructor, name NodeID) (storage.DataReference, error)

+ GetDataDir func() DataReference

+ GetLastUpdatedAt func() *metav1.Time

+ GetMessage func() string

+ GetOutputReference func() DataReference

+ GetPhase func() WorkflowPhase

+ GetStartedAt func() *metav1.Time

+ GetStoppedAt func() *metav1.Time

+ IncFailedAttempts func()

+ IsTerminated func() bool

+ SetDataDir func(DataReference)

+ SetMessage func(msg string)

+ SetOutputReference func(reference DataReference)

+ UpdatePhase func(p WorkflowPhase, msg string)

+ type ExecutionID = WorkflowExecutionIdentifier

+ type FlyteWorkflow struct

+ AcceptedAt *metav1.Time

+ ActiveDeadlineSeconds *int64

+ ExecutionID ExecutionID

+ Inputs *Inputs

+ ServiceAccountName string

+ Status WorkflowStatus

+ SubWorkflows map[WorkflowID]*WorkflowSpec

+ Tasks map[TaskID]*TaskSpec

+ func (in *FlyteWorkflow) DeepCopy() *FlyteWorkflow

+ func (in *FlyteWorkflow) DeepCopyInto(out *FlyteWorkflow)

+ func (in *FlyteWorkflow) DeepCopyObject() runtime.Object

+ func (in *FlyteWorkflow) FindSubWorkflow(subID WorkflowID) ExecutableSubWorkflow

+ func (in *FlyteWorkflow) GetExecutionID() ExecutionID

+ func (in *FlyteWorkflow) GetExecutionStatus() ExecutableWorkflowStatus

+ func (in *FlyteWorkflow) GetK8sWorkflowID() types.NamespacedName

+ func (in *FlyteWorkflow) GetNodeExecutionStatus(id NodeID) ExecutableNodeStatus

+ func (in *FlyteWorkflow) GetServiceAccountName() string

+ func (in *FlyteWorkflow) GetTask(id TaskID) (ExecutableTask, error)

+ func (in *FlyteWorkflow) NewControllerRef() metav1.OwnerReference

+ type FlyteWorkflowList struct

+ Items []FlyteWorkflow

+ func (in *FlyteWorkflowList) DeepCopy() *FlyteWorkflowList

+ func (in *FlyteWorkflowList) DeepCopyInto(out *FlyteWorkflowList)

+ func (in *FlyteWorkflowList) DeepCopyObject() runtime.Object

+ type Identifier struct

+ func (in *Identifier) DeepCopy() *Identifier

+ func (in *Identifier) DeepCopyInto(out *Identifier)

+ func (in *Identifier) MarshalJSON() ([]byte, error)

+ func (in *Identifier) UnmarshalJSON(b []byte) error

+ type IfBlock struct

+ Condition BooleanExpression

+ ThenNode *NodeID

+ func (in *IfBlock) DeepCopy() *IfBlock

+ func (in *IfBlock) DeepCopyInto(out *IfBlock)

+ func (in *IfBlock) GetThenNode() *NodeID

+ func (in IfBlock) GetCondition() *core.BooleanExpression

+ type Inputs struct

+ func (in *Inputs) DeepCopy() *Inputs

+ func (in *Inputs) DeepCopyInto(out *Inputs)

+ func (in *Inputs) MarshalJSON() ([]byte, error)

+ func (in *Inputs) UnmarshalJSON(b []byte) error

+ type LaunchPlanRefID = Identifier

+ type MutableBranchNodeStatus interface

+ SetBranchNodeError func()

+ SetBranchNodeSuccess func(id NodeID)

+ type MutableDynamicNodeStatus interface

+ SetDynamicNodePhase func(phase DynamicNodePhase)

+ type MutableNodeStatus interface

+ ClearDynamicNodeStatus func()

+ ClearSubWorkflowStatus func()

+ ClearTaskStatus func()

+ ClearWorkflowStatus func()

+ GetOrCreateBranchStatus func() MutableBranchNodeStatus

+ GetOrCreateDynamicNodeStatus func() MutableDynamicNodeStatus

+ GetOrCreateSubWorkflowStatus func() MutableSubWorkflowNodeStatus

+ GetOrCreateTaskStatus func() MutableTaskNodeStatus

+ GetOrCreateWorkflowStatus func() MutableWorkflowNodeStatus

+ IncrementAttempts func() uint32

+ ResetDirty func()

+ SetCached func()

+ SetDataDir func(DataReference)

+ SetParentNodeID func(n *NodeID)

+ SetParentTaskID func(t *core.TaskExecutionIdentifier)

+ UpdatePhase func(phase NodePhase, occurredAt metav1.Time, reason string)

+ type MutableSubWorkflowNodeStatus interface

+ SetPhase func(phase WorkflowPhase)

+ type MutableTaskNodeStatus interface

+ SetCustomState func(state types2.CustomState)

+ SetPhase func(phase types2.TaskPhase)

+ SetPhaseVersion func(version uint32)

+ type MutableWorkflowNodeStatus interface

+ SetWorkflowExecutionName func(name string)

+ type NodeID = string

+ type NodeKind string

+ const NodeKindBranch

+ const NodeKindEnd

+ const NodeKindStart

+ const NodeKindTask

+ const NodeKindWorkflow

+ func (n NodeKind) String() string

+ type NodeMetadata struct

+ func (in *NodeMetadata) DeepCopy() *NodeMetadata

+ func (in *NodeMetadata) DeepCopyInto(out *NodeMetadata)

+ type NodePhase int

+ const NodePhaseFailed

+ const NodePhaseFailing

+ const NodePhaseNotYetStarted

+ const NodePhaseQueued

+ const NodePhaseRetryableFailure

+ const NodePhaseRunning

+ const NodePhaseSkipped

+ const NodePhaseSucceeded

+ const NodePhaseSucceeding

+ func (p NodePhase) String() string

+ type NodeSpec struct

+ ActiveDeadlineSeconds *int64

+ Affinity *typesv1.Affinity

+ BranchNode *BranchNodeSpec

+ Config *typesv1.ConfigMap

+ Hostname string

+ ID NodeID

+ ImagePullSecrets []typesv1.LocalObjectReference

+ InputBindings []*Binding

+ Kind NodeKind

+ OutputAliases []Alias

+ Resources *typesv1.ResourceRequirements

+ RetryStrategy *RetryStrategy

+ SchedulerName string

+ SecurityContext *typesv1.PodSecurityContext

+ Subdomain string

+ TaskRef *TaskID

+ Tolerations []typesv1.Toleration

+ WorkflowNode *WorkflowNodeSpec

+ func (in *NodeSpec) DeepCopy() *NodeSpec

+ func (in *NodeSpec) DeepCopyInto(out *NodeSpec)

+ func (in *NodeSpec) GetBranchNode() ExecutableBranchNode

+ func (in *NodeSpec) GetConfig() *typesv1.ConfigMap

+ func (in *NodeSpec) GetID() NodeID

+ func (in *NodeSpec) GetInputBindings() []*Binding

+ func (in *NodeSpec) GetKind() NodeKind

+ func (in *NodeSpec) GetOutputAlias() []Alias

+ func (in *NodeSpec) GetResources() *typesv1.ResourceRequirements

+ func (in *NodeSpec) GetRetryStrategy() *RetryStrategy

+ func (in *NodeSpec) GetTaskID() *TaskID

+ func (in *NodeSpec) GetWorkflowNode() ExecutableWorkflowNode

+ func (in *NodeSpec) IsEndNode() bool

+ func (in *NodeSpec) IsStartNode() bool

+ type NodeStatus struct

+ Attempts uint32

+ BranchStatus *BranchNodeStatus

+ Cached bool

+ DataDir DataReference

+ DynamicNodeStatus *DynamicNodeStatus

+ LastUpdatedAt *metav1.Time

+ Message string

+ ParentNode *NodeID

+ ParentTask *TaskExecutionIdentifier

+ Phase NodePhase

+ QueuedAt *metav1.Time

+ StartedAt *metav1.Time

+ StoppedAt *metav1.Time

+ SubNodeStatus map[NodeID]*NodeStatus

+ SubWorkflowNodeStatus *SubWorkflowNodeStatus

+ TaskNodeStatus *TaskNodeStatus

+ WorkflowNodeStatus *WorkflowNodeStatus

+ func (in *NodeStatus) ClearDynamicNodeStatus()

+ func (in *NodeStatus) ClearSubWorkflowStatus()

+ func (in *NodeStatus) ClearTaskStatus()

+ func (in *NodeStatus) ClearWorkflowStatus()

+ func (in *NodeStatus) DeepCopy() *NodeStatus

+ func (in *NodeStatus) DeepCopyInto(out *NodeStatus)

+ func (in *NodeStatus) Equals(other *NodeStatus) bool

+ func (in *NodeStatus) GetAttempts() uint32

+ func (in *NodeStatus) GetDataDir() DataReference

+ func (in *NodeStatus) GetLastUpdatedAt() *metav1.Time

+ func (in *NodeStatus) GetMessage() string

+ func (in *NodeStatus) GetNodeExecutionStatus(id NodeID) ExecutableNodeStatus

+ func (in *NodeStatus) GetOrCreateBranchStatus() MutableBranchNodeStatus

+ func (in *NodeStatus) GetOrCreateDynamicNodeStatus() MutableDynamicNodeStatus

+ func (in *NodeStatus) GetOrCreateTaskStatus() MutableTaskNodeStatus

+ func (in *NodeStatus) GetOrCreateWorkflowStatus() MutableWorkflowNodeStatus

+ func (in *NodeStatus) GetParentNodeID() *NodeID

+ func (in *NodeStatus) GetParentTaskID() *core.TaskExecutionIdentifier

+ func (in *NodeStatus) GetPhase() NodePhase

+ func (in *NodeStatus) GetQueuedAt() *metav1.Time

+ func (in *NodeStatus) GetStartedAt() *metav1.Time

+ func (in *NodeStatus) GetStoppedAt() *metav1.Time

+ func (in *NodeStatus) GetWorkflowNodeStatus() ExecutableWorkflowNodeStatus

+ func (in *NodeStatus) IncrementAttempts() uint32

+ func (in *NodeStatus) IsCached() bool

+ func (in *NodeStatus) IsDirty() bool

+ func (in *NodeStatus) IsTerminated() bool

+ func (in *NodeStatus) ResetDirty()

+ func (in *NodeStatus) SetCached()

+ func (in *NodeStatus) SetDataDir(d DataReference)

+ func (in *NodeStatus) SetParentNodeID(n *NodeID)

+ func (in *NodeStatus) SetParentTaskID(t *core.TaskExecutionIdentifier)

+ func (in *NodeStatus) UpdatePhase(p NodePhase, occurredAt metav1.Time, reason string)

+ func (in NodeStatus) GetOrCreateSubWorkflowStatus() MutableSubWorkflowNodeStatus

+ func (in NodeStatus) GetSubWorkflowNodeStatus() ExecutableSubWorkflowNodeStatus

+ func (in NodeStatus) GetTaskNodeStatus() ExecutableTaskNodeStatus

+ func (in NodeStatus) VisitNodeStatuses(visitor NodeStatusVisitFn)

+ type NodeStatusGetter interface

+ GetNodeExecutionStatus func(id NodeID) ExecutableNodeStatus

+ type NodeStatusMap = map[NodeID]ExecutableNodeStatus

+ type NodeStatusVisitFn = func(node NodeID, status ExecutableNodeStatus)

+ type NodeStatusVisitor interface

+ VisitNodeStatuses func(visitor NodeStatusVisitFn)

+ type OutputVarMap struct

+ func (in *OutputVarMap) DeepCopy() *OutputVarMap

+ func (in *OutputVarMap) DeepCopyInto(out *OutputVarMap)

+ func (in *OutputVarMap) MarshalJSON() ([]byte, error)

+ func (in *OutputVarMap) UnmarshalJSON(b []byte) error

+ type RetryStrategy struct

+ MinAttempts *int

+ func (in *RetryStrategy) DeepCopy() *RetryStrategy

+ func (in *RetryStrategy) DeepCopyInto(out *RetryStrategy)

+ type SubWorkflowNodeStatus struct

+ Phase WorkflowPhase

+ func (in *SubWorkflowNodeStatus) DeepCopy() *SubWorkflowNodeStatus

+ func (in *SubWorkflowNodeStatus) DeepCopyInto(out *SubWorkflowNodeStatus)

+ func (s *SubWorkflowNodeStatus) SetPhase(phase WorkflowPhase)

+ func (s SubWorkflowNodeStatus) GetPhase() WorkflowPhase

+ type TaskExecutionIdentifier struct

+ func (in *TaskExecutionIdentifier) DeepCopy() *TaskExecutionIdentifier

+ func (in *TaskExecutionIdentifier) DeepCopyInto(out *TaskExecutionIdentifier)

+ type TaskID = string

+ type TaskNodeStatus struct

+ CustomState types.CustomState

+ Phase types.TaskPhase

+ PhaseVersion uint32

+ func (in *TaskNodeStatus) DeepCopy() *TaskNodeStatus

+ func (in *TaskNodeStatus) DeepCopyInto(out *TaskNodeStatus)

+ func (in *TaskNodeStatus) SetCustomState(state types.CustomState)

+ func (in *TaskNodeStatus) SetPhase(phase types.TaskPhase)

+ func (in *TaskNodeStatus) SetPhaseVersion(version uint32)

+ func (in *TaskNodeStatus) UpdateCustomState(state types.CustomState)

+ func (in *TaskNodeStatus) UpdatePhase(phase types.TaskPhase, phaseVersion uint32)

+ func (in TaskNodeStatus) GetCustomState() types.CustomState

+ func (in TaskNodeStatus) GetPhase() types.TaskPhase

+ func (in TaskNodeStatus) GetPhaseVersion() uint32

+ type TaskSpec struct

+ func (in *TaskSpec) CoreTask() *core.TaskTemplate

+ func (in *TaskSpec) DeepCopy() *TaskSpec

+ func (in *TaskSpec) DeepCopyInto(out *TaskSpec)

+ func (in *TaskSpec) MarshalJSON() ([]byte, error)

+ func (in *TaskSpec) TaskType() TaskType

+ func (in *TaskSpec) UnmarshalJSON(b []byte) error

+ type TaskType = string

+ type WorkflowExecutionIdentifier struct

+ func (in *WorkflowExecutionIdentifier) DeepCopy() *WorkflowExecutionIdentifier

+ func (in *WorkflowExecutionIdentifier) DeepCopyInto(out *WorkflowExecutionIdentifier)

+ type WorkflowID = string

+ type WorkflowMeta interface

+ GetAnnotations func() map[string]string

+ GetCreationTimestamp func() metav1.Time

+ GetExecutionID func() ExecutionID

+ GetK8sWorkflowID func() types.NamespacedName

+ GetLabels func() map[string]string

+ GetName func() string

+ GetNamespace func() string

+ GetServiceAccountName func() string

+ NewControllerRef func() metav1.OwnerReference

+ type WorkflowMetaExtended interface

+ FindSubWorkflow func(subID WorkflowID) ExecutableSubWorkflow

+ GetExecutionStatus func() ExecutableWorkflowStatus

+ GetTask func(id TaskID) (ExecutableTask, error)

+ type WorkflowNodeSpec struct

+ LaunchPlanRefID *LaunchPlanRefID

+ SubWorkflowReference *WorkflowID

+ func (in *WorkflowNodeSpec) DeepCopy() *WorkflowNodeSpec

+ func (in *WorkflowNodeSpec) DeepCopyInto(out *WorkflowNodeSpec)

+ func (in *WorkflowNodeSpec) GetLaunchPlanRefID() *LaunchPlanRefID

+ func (in *WorkflowNodeSpec) GetSubWorkflowRef() *WorkflowID

+ type WorkflowNodeStatus struct

+ WorkflowName string

+ func (in *WorkflowNodeStatus) DeepCopy() *WorkflowNodeStatus

+ func (in *WorkflowNodeStatus) DeepCopyInto(out *WorkflowNodeStatus)

+ func (in *WorkflowNodeStatus) GetWorkflowExecutionName() string

+ func (in *WorkflowNodeStatus) SetWorkflowExecutionName(name string)

+ type WorkflowPhase int

+ const WorkflowPhaseAborted

+ const WorkflowPhaseFailed

+ const WorkflowPhaseFailing

+ const WorkflowPhaseReady

+ const WorkflowPhaseRunning

+ const WorkflowPhaseSucceeding

+ const WorkflowPhaseSuccess

+ func (p WorkflowPhase) String() string

+ type WorkflowSpec struct

+ Connections Connections

+ ID WorkflowID

+ Nodes map[NodeID]*NodeSpec

+ OnFailure *NodeSpec

+ OutputBindings []*Binding

+ Outputs *OutputVarMap

+ func (in *WorkflowSpec) DeepCopy() *WorkflowSpec

+ func (in *WorkflowSpec) DeepCopyInto(out *WorkflowSpec)

+ func (in *WorkflowSpec) FromNode(name NodeID) ([]NodeID, error)

+ func (in *WorkflowSpec) GetConnections() *Connections

+ func (in *WorkflowSpec) GetID() WorkflowID

+ func (in *WorkflowSpec) GetNode(nodeID NodeID) (ExecutableNode, bool)

+ func (in *WorkflowSpec) GetNodes() []NodeID

+ func (in *WorkflowSpec) GetOnFailureNode() ExecutableNode

+ func (in *WorkflowSpec) GetOutputBindings() []*Binding

+ func (in *WorkflowSpec) GetOutputs() *OutputVarMap

+ func (in *WorkflowSpec) StartNode() ExecutableNode

+ type WorkflowStatus struct

+ DataDir DataReference

+ FailedAttempts uint32

+ LastUpdatedAt *metav1.Time

+ Message string

+ NodeStatus map[NodeID]*NodeStatus

+ OutputReference DataReference

+ Phase WorkflowPhase

+ StartedAt *metav1.Time

+ StoppedAt *metav1.Time

+ func (in *WorkflowStatus) ConstructNodeDataDir(ctx context.Context, constructor storage.ReferenceConstructor, name NodeID) (storage.DataReference, error)

+ func (in *WorkflowStatus) DeepCopy() *WorkflowStatus

+ func (in *WorkflowStatus) DeepCopyInto(out *WorkflowStatus)

+ func (in *WorkflowStatus) Equals(other *WorkflowStatus) bool

+ func (in *WorkflowStatus) GetDataDir() DataReference

+ func (in *WorkflowStatus) GetLastUpdatedAt() *metav1.Time

+ func (in *WorkflowStatus) GetMessage() string

+ func (in *WorkflowStatus) GetNodeExecutionStatus(id NodeID) ExecutableNodeStatus

+ func (in *WorkflowStatus) GetOutputReference() DataReference

+ func (in *WorkflowStatus) GetPhase() WorkflowPhase

+ func (in *WorkflowStatus) GetStartedAt() *metav1.Time

+ func (in *WorkflowStatus) GetStoppedAt() *metav1.Time

+ func (in *WorkflowStatus) IncFailedAttempts()

+ func (in *WorkflowStatus) IsTerminated() bool

+ func (in *WorkflowStatus) SetDataDir(d DataReference)

+ func (in *WorkflowStatus) SetMessage(msg string)

+ func (in *WorkflowStatus) SetOutputReference(reference DataReference)

+ func (in *WorkflowStatus) UpdatePhase(p WorkflowPhase, msg string)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL