core

package

Go to main page

Versions in this module

v0

v0.18.14

Feb 26, 2021

v0.18.13

Feb 23, 2021

Changes in this version

type TaskTemplate

+ TaskTypeVersion int32

+ func (m *TaskTemplate) GetTaskTypeVersion() int32

v0.18.12

Feb 3, 2021

v0.18.11

Nov 30, 2020

v0.18.10

Nov 4, 2020

v0.18.9

Oct 7, 2020

v0.18.8

Oct 2, 2020

v0.18.7

Sep 29, 2020

v0.18.6

Sep 17, 2020

v0.18.5

Sep 15, 2020

v0.18.3

Aug 13, 2020

v0.18.2

Aug 11, 2020

v0.18.1

Jul 30, 2020

v0.18.0

Jul 30, 2020

v0.17.38

Jul 28, 2020

Changes in this version

+ var CatalogCacheStatus_name = map[int32]string

+ var CatalogCacheStatus_value = map[string]int32

+ type CatalogArtifactTag struct

+ ArtifactId string

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CatalogArtifactTag) Descriptor() ([]byte, []int)

+ func (*CatalogArtifactTag) ProtoMessage()

+ func (m *CatalogArtifactTag) GetArtifactId() string

+ func (m *CatalogArtifactTag) GetName() string

+ func (m *CatalogArtifactTag) Reset()

+ func (m *CatalogArtifactTag) String() string

+ func (m *CatalogArtifactTag) Validate() error

+ func (m *CatalogArtifactTag) XXX_DiscardUnknown()

+ func (m *CatalogArtifactTag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CatalogArtifactTag) XXX_Merge(src proto.Message)

+ func (m *CatalogArtifactTag) XXX_Size() int

+ func (m *CatalogArtifactTag) XXX_Unmarshal(b []byte) error

+ type CatalogArtifactTagValidationError struct

+ func (e CatalogArtifactTagValidationError) Cause() error

+ func (e CatalogArtifactTagValidationError) Error() string

+ func (e CatalogArtifactTagValidationError) ErrorName() string

+ func (e CatalogArtifactTagValidationError) Field() string

+ func (e CatalogArtifactTagValidationError) Key() bool

+ func (e CatalogArtifactTagValidationError) Reason() string

+ type CatalogCacheStatus int32

+ const CatalogCacheStatus_CACHE_DISABLED

+ const CatalogCacheStatus_CACHE_HIT

+ const CatalogCacheStatus_CACHE_LOOKUP_FAILURE

+ const CatalogCacheStatus_CACHE_MISS

+ const CatalogCacheStatus_CACHE_POPULATED

+ const CatalogCacheStatus_CACHE_PUT_FAILURE

+ func (CatalogCacheStatus) EnumDescriptor() ([]byte, []int)

+ func (x CatalogCacheStatus) String() string

+ type CatalogMetadata struct

+ ArtifactTag *CatalogArtifactTag

+ DatasetId *Identifier

+ SourceExecution isCatalogMetadata_SourceExecution

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CatalogMetadata) Descriptor() ([]byte, []int)

+ func (*CatalogMetadata) ProtoMessage()

+ func (*CatalogMetadata) XXX_OneofWrappers() []interface{}

+ func (m *CatalogMetadata) GetArtifactTag() *CatalogArtifactTag

+ func (m *CatalogMetadata) GetDatasetId() *Identifier

+ func (m *CatalogMetadata) GetSourceExecution() isCatalogMetadata_SourceExecution

+ func (m *CatalogMetadata) GetSourceTaskExecution() *TaskExecutionIdentifier

+ func (m *CatalogMetadata) Reset()

+ func (m *CatalogMetadata) String() string

+ func (m *CatalogMetadata) Validate() error

+ func (m *CatalogMetadata) XXX_DiscardUnknown()

+ func (m *CatalogMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CatalogMetadata) XXX_Merge(src proto.Message)

+ func (m *CatalogMetadata) XXX_Size() int

+ func (m *CatalogMetadata) XXX_Unmarshal(b []byte) error

+ type CatalogMetadataValidationError struct

+ func (e CatalogMetadataValidationError) Cause() error

+ func (e CatalogMetadataValidationError) Error() string

+ func (e CatalogMetadataValidationError) ErrorName() string

+ func (e CatalogMetadataValidationError) Field() string

+ func (e CatalogMetadataValidationError) Key() bool

+ func (e CatalogMetadataValidationError) Reason() string

+ type CatalogMetadata_SourceTaskExecution struct

+ SourceTaskExecution *TaskExecutionIdentifier

type ResourceType

+ const ResourceType_DATASET

v0.17.37

Jul 22, 2020

v0.17.36

Jul 8, 2020

Changes in this version

+ var QualityOfService_Tier_name = map[int32]string

+ var QualityOfService_Tier_value = map[string]int32

+ type QualityOfService struct

+ Designation isQualityOfService_Designation

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*QualityOfService) Descriptor() ([]byte, []int)

+ func (*QualityOfService) ProtoMessage()

+ func (*QualityOfService) XXX_OneofWrappers() []interface{}

+ func (m *QualityOfService) GetDesignation() isQualityOfService_Designation

+ func (m *QualityOfService) GetSpec() *QualityOfServiceSpec

+ func (m *QualityOfService) GetTier() QualityOfService_Tier

+ func (m *QualityOfService) Reset()

+ func (m *QualityOfService) String() string

+ func (m *QualityOfService) Validate() error

+ func (m *QualityOfService) XXX_DiscardUnknown()

+ func (m *QualityOfService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *QualityOfService) XXX_Merge(src proto.Message)

+ func (m *QualityOfService) XXX_Size() int

+ func (m *QualityOfService) XXX_Unmarshal(b []byte) error

+ type QualityOfServiceSpec struct

+ QueueingBudget *duration.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*QualityOfServiceSpec) Descriptor() ([]byte, []int)

+ func (*QualityOfServiceSpec) ProtoMessage()

+ func (m *QualityOfServiceSpec) GetQueueingBudget() *duration.Duration

+ func (m *QualityOfServiceSpec) Reset()

+ func (m *QualityOfServiceSpec) String() string

+ func (m *QualityOfServiceSpec) Validate() error

+ func (m *QualityOfServiceSpec) XXX_DiscardUnknown()

+ func (m *QualityOfServiceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *QualityOfServiceSpec) XXX_Merge(src proto.Message)

+ func (m *QualityOfServiceSpec) XXX_Size() int

+ func (m *QualityOfServiceSpec) XXX_Unmarshal(b []byte) error

+ type QualityOfServiceSpecValidationError struct

+ func (e QualityOfServiceSpecValidationError) Cause() error

+ func (e QualityOfServiceSpecValidationError) Error() string

+ func (e QualityOfServiceSpecValidationError) ErrorName() string

+ func (e QualityOfServiceSpecValidationError) Field() string

+ func (e QualityOfServiceSpecValidationError) Key() bool

+ func (e QualityOfServiceSpecValidationError) Reason() string

+ type QualityOfServiceValidationError struct

+ func (e QualityOfServiceValidationError) Cause() error

+ func (e QualityOfServiceValidationError) Error() string

+ func (e QualityOfServiceValidationError) ErrorName() string

+ func (e QualityOfServiceValidationError) Field() string

+ func (e QualityOfServiceValidationError) Key() bool

+ func (e QualityOfServiceValidationError) Reason() string

+ type QualityOfService_Spec struct

+ Spec *QualityOfServiceSpec

+ type QualityOfService_Tier int32

+ const QualityOfService_HIGH

+ const QualityOfService_LOW

+ const QualityOfService_MEDIUM

+ const QualityOfService_UNDEFINED

+ func (QualityOfService_Tier) EnumDescriptor() ([]byte, []int)

+ func (x QualityOfService_Tier) String() string

+ type QualityOfService_Tier_ struct

+ Tier QualityOfService_Tier

type WorkflowMetadata

+ QualityOfService *QualityOfService

+ func (m *WorkflowMetadata) GetQualityOfService() *QualityOfService

v0.17.34

Jun 10, 2020

v0.17.33

Jun 8, 2020

Changes in this version

+ var WorkflowMetadata_OnFailurePolicy_name = map[int32]string

+ var WorkflowMetadata_OnFailurePolicy_value = map[string]int32

type WorkflowMetadata

+ OnFailure WorkflowMetadata_OnFailurePolicy

+ func (m *WorkflowMetadata) GetOnFailure() WorkflowMetadata_OnFailurePolicy

+ type WorkflowMetadata_OnFailurePolicy int32

+ const WorkflowMetadata_FAIL_AFTER_EXECUTABLE_NODES_COMPLETE

+ const WorkflowMetadata_FAIL_AFTER_RUNNING_NODES_COMPLETE

+ const WorkflowMetadata_FAIL_IMMEDIATELY

+ func (WorkflowMetadata_OnFailurePolicy) EnumDescriptor() ([]byte, []int)

+ func (x WorkflowMetadata_OnFailurePolicy) String() string

v0.17.32

May 26, 2020

Changes in this version

+ var DataLoadingConfig_LiteralMapFormat_name = map[int32]string

+ var DataLoadingConfig_LiteralMapFormat_value = map[string]int32

+ var IOStrategy_DownloadMode_name = map[int32]string

+ var IOStrategy_DownloadMode_value = map[string]int32

+ var IOStrategy_UploadMode_name = map[int32]string

+ var IOStrategy_UploadMode_value = map[string]int32

type DataLoadingConfig

+ IoStrategy *IOStrategy

+ func (m *DataLoadingConfig) GetIoStrategy() *IOStrategy

+ type DataLoadingConfig_LiteralMapFormat int32

+ func (DataLoadingConfig_LiteralMapFormat) EnumDescriptor() ([]byte, []int)

+ func (x DataLoadingConfig_LiteralMapFormat) String() string

+ type IOStrategy struct

+ DownloadMode IOStrategy_DownloadMode

+ UploadMode IOStrategy_UploadMode

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*IOStrategy) Descriptor() ([]byte, []int)

+ func (*IOStrategy) ProtoMessage()

+ func (m *IOStrategy) GetDownloadMode() IOStrategy_DownloadMode

+ func (m *IOStrategy) GetUploadMode() IOStrategy_UploadMode

+ func (m *IOStrategy) Reset()

+ func (m *IOStrategy) String() string

+ func (m *IOStrategy) Validate() error

+ func (m *IOStrategy) XXX_DiscardUnknown()

+ func (m *IOStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IOStrategy) XXX_Merge(src proto.Message)

+ func (m *IOStrategy) XXX_Size() int

+ func (m *IOStrategy) XXX_Unmarshal(b []byte) error

+ type IOStrategyValidationError struct

+ func (e IOStrategyValidationError) Cause() error

+ func (e IOStrategyValidationError) Error() string

+ func (e IOStrategyValidationError) ErrorName() string

+ func (e IOStrategyValidationError) Field() string

+ func (e IOStrategyValidationError) Key() bool

+ func (e IOStrategyValidationError) Reason() string

+ type IOStrategy_DownloadMode int32

+ const IOStrategy_DOWNLOAD_EAGER

+ const IOStrategy_DOWNLOAD_STREAM

+ const IOStrategy_DO_NOT_DOWNLOAD

+ func (IOStrategy_DownloadMode) EnumDescriptor() ([]byte, []int)

+ func (x IOStrategy_DownloadMode) String() string

+ type IOStrategy_UploadMode int32

+ const IOStrategy_DO_NOT_UPLOAD

+ const IOStrategy_UPLOAD_EAGER

+ const IOStrategy_UPLOAD_ON_EXIT

+ func (IOStrategy_UploadMode) EnumDescriptor() ([]byte, []int)

+ func (x IOStrategy_UploadMode) String() string

v0.17.31

May 17, 2020

Changes in this version

+ var DataLoadingConfig_MetadataFormat_name = map[int32]string

+ var DataLoadingConfig_MetadataFormat_value = map[string]int32

type Container

+ DataConfig *DataLoadingConfig

+ func (m *Container) GetDataConfig() *DataLoadingConfig

+ type DataLoadingConfig struct

+ Enabled bool

+ Format DataLoadingConfig_MetadataFormat

+ InputPath string

+ OutputPath string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DataLoadingConfig) Descriptor() ([]byte, []int)

+ func (*DataLoadingConfig) ProtoMessage()

+ func (m *DataLoadingConfig) GetEnabled() bool

+ func (m *DataLoadingConfig) GetFormat() DataLoadingConfig_MetadataFormat

+ func (m *DataLoadingConfig) GetInputPath() string

+ func (m *DataLoadingConfig) GetOutputPath() string

+ func (m *DataLoadingConfig) Reset()

+ func (m *DataLoadingConfig) String() string

+ func (m *DataLoadingConfig) Validate() error

+ func (m *DataLoadingConfig) XXX_DiscardUnknown()

+ func (m *DataLoadingConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DataLoadingConfig) XXX_Merge(src proto.Message)

+ func (m *DataLoadingConfig) XXX_Size() int

+ func (m *DataLoadingConfig) XXX_Unmarshal(b []byte) error

+ type DataLoadingConfigValidationError struct

+ func (e DataLoadingConfigValidationError) Cause() error

+ func (e DataLoadingConfigValidationError) Error() string

+ func (e DataLoadingConfigValidationError) ErrorName() string

+ func (e DataLoadingConfigValidationError) Field() string

+ func (e DataLoadingConfigValidationError) Key() bool

+ func (e DataLoadingConfigValidationError) Reason() string

+ type DataLoadingConfig_MetadataFormat int32

+ const DataLoadingConfig_JSON

+ const DataLoadingConfig_PROTO

+ const DataLoadingConfig_YAML

+ func (DataLoadingConfig_MetadataFormat) EnumDescriptor() ([]byte, []int)

+ func (x DataLoadingConfig_MetadataFormat) String() string

v0.17.30

May 12, 2020

v0.17.29

May 12, 2020

v0.17.28

May 7, 2020

Changes in this version

type ContainerError

+ Origin ExecutionError_ErrorKind

+ func (m *ContainerError) GetOrigin() ExecutionError_ErrorKind

v0.17.27

Apr 3, 2020

v0.17.26

Apr 3, 2020

v0.17.25

Apr 2, 2020

v0.17.24

Apr 2, 2020

Changes in this version

type TaskExecution_Phase

+ const TaskExecution_INITIALIZING

+ const TaskExecution_WAITING_FOR_RESOURCES

v0.17.23

Apr 2, 2020

v0.17.22

Mar 31, 2020

v0.17.21

Mar 27, 2020

Changes in this version

type WorkflowMetadata

+ QueuingBudget *duration.Duration

+ func (m *WorkflowMetadata) GetQueuingBudget() *duration.Duration

v0.17.20

Mar 12, 2020

v0.17.9

Mar 10, 2020

v0.17.8

Mar 9, 2020

v0.17.7

Mar 2, 2020

v0.17.6

Feb 28, 2020

v0.17.5

Feb 28, 2020

v0.17.4

Feb 20, 2020

v0.17.3

Feb 12, 2020

v0.17.2

Feb 5, 2020

v0.17.1

Feb 5, 2020

v0.17.0

Jan 24, 2020

v0.16.6

Jan 10, 2020

v0.16.5

Jan 2, 2020

v0.16.4

Dec 30, 2019

v0.16.3

Dec 19, 2019

v0.16.2

Dec 11, 2019

v0.16.1

Oct 30, 2019

v0.16.0

Oct 9, 2019

v0.15.0

Oct 9, 2019

v0.14.1

Sep 6, 2019

v0.14.0

Sep 4, 2019

v0.4.20

Mar 12, 2020

Changes in this version

+ var ExecutionError_ErrorKind_name = map[int32]string

+ var ExecutionError_ErrorKind_value = map[string]int32

type BindingData

+ func (*BindingData) XXX_OneofWrappers() []interface{}

type BooleanExpression

+ func (*BooleanExpression) XXX_OneofWrappers() []interface{}

type ExecutionError

+ Kind ExecutionError_ErrorKind

+ func (m *ExecutionError) GetKind() ExecutionError_ErrorKind

+ type ExecutionError_ErrorKind int32

+ const ExecutionError_SYSTEM

+ const ExecutionError_UNKNOWN

+ const ExecutionError_USER

+ func (ExecutionError_ErrorKind) EnumDescriptor() ([]byte, []int)

+ func (x ExecutionError_ErrorKind) String() string

type IfElseBlock

+ func (*IfElseBlock) XXX_OneofWrappers() []interface{}

type Literal

+ func (*Literal) XXX_OneofWrappers() []interface{}

type LiteralType

+ func (*LiteralType) XXX_OneofWrappers() []interface{}

type Node

+ func (*Node) XXX_OneofWrappers() []interface{}

type NodeMetadata

+ InterruptibleValue isNodeMetadata_InterruptibleValue

+ func (*NodeMetadata) XXX_OneofWrappers() []interface{}

+ func (m *NodeMetadata) GetInterruptible() bool

+ func (m *NodeMetadata) GetInterruptibleValue() isNodeMetadata_InterruptibleValue

+ type NodeMetadata_Interruptible struct

+ Interruptible bool

type Operand

+ func (*Operand) XXX_OneofWrappers() []interface{}

type Parameter

+ func (*Parameter) XXX_OneofWrappers() []interface{}

type Primitive

+ func (*Primitive) XXX_OneofWrappers() []interface{}

type Scalar

+ func (*Scalar) XXX_OneofWrappers() []interface{}

type TaskMetadata

+ InterruptibleValue isTaskMetadata_InterruptibleValue

+ func (*TaskMetadata) XXX_OneofWrappers() []interface{}

+ func (m *TaskMetadata) GetInterruptible() bool

+ func (m *TaskMetadata) GetInterruptibleValue() isTaskMetadata_InterruptibleValue

+ type TaskMetadata_Interruptible struct

+ Interruptible bool

type TaskNode

+ func (*TaskNode) XXX_OneofWrappers() []interface{}

type TaskTemplate

+ func (*TaskTemplate) XXX_OneofWrappers() []interface{}

+ type WorkflowMetadataDefaults struct

+ Interruptible bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WorkflowMetadataDefaults) Descriptor() ([]byte, []int)

+ func (*WorkflowMetadataDefaults) ProtoMessage()

+ func (m *WorkflowMetadataDefaults) GetInterruptible() bool

+ func (m *WorkflowMetadataDefaults) Reset()

+ func (m *WorkflowMetadataDefaults) String() string

+ func (m *WorkflowMetadataDefaults) Validate() error

+ func (m *WorkflowMetadataDefaults) XXX_DiscardUnknown()

+ func (m *WorkflowMetadataDefaults) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowMetadataDefaults) XXX_Merge(src proto.Message)

+ func (m *WorkflowMetadataDefaults) XXX_Size() int

+ func (m *WorkflowMetadataDefaults) XXX_Unmarshal(b []byte) error

+ type WorkflowMetadataDefaultsValidationError struct

+ func (e WorkflowMetadataDefaultsValidationError) Cause() error

+ func (e WorkflowMetadataDefaultsValidationError) Error() string

+ func (e WorkflowMetadataDefaultsValidationError) ErrorName() string

+ func (e WorkflowMetadataDefaultsValidationError) Field() string

+ func (e WorkflowMetadataDefaultsValidationError) Key() bool

+ func (e WorkflowMetadataDefaultsValidationError) Reason() string

type WorkflowNode

+ func (*WorkflowNode) XXX_OneofWrappers() []interface{}

type WorkflowTemplate

+ MetadataDefaults *WorkflowMetadataDefaults

+ func (m *WorkflowTemplate) GetMetadataDefaults() *WorkflowMetadataDefaults

v0.1.1

Aug 30, 2019

v0.1.0

Aug 5, 2019

Changes in this version

+ var BlobType_BlobDimensionality_name = map[int32]string

+ var BlobType_BlobDimensionality_value = map[string]int32

+ var ComparisonExpression_Operator_name = map[int32]string

+ var ComparisonExpression_Operator_value = map[string]int32

+ var ConjunctionExpression_LogicalOperator_name = map[int32]string

+ var ConjunctionExpression_LogicalOperator_value = map[string]int32

+ var ContainerError_Kind_name = map[int32]string

+ var ContainerError_Kind_value = map[string]int32

+ var NodeExecution_Phase_name = map[int32]string

+ var NodeExecution_Phase_value = map[string]int32

+ var ResourceType_name = map[int32]string

+ var ResourceType_value = map[string]int32

+ var Resources_ResourceName_name = map[int32]string

+ var Resources_ResourceName_value = map[string]int32

+ var RuntimeMetadata_RuntimeType_name = map[int32]string

+ var RuntimeMetadata_RuntimeType_value = map[string]int32

+ var SchemaType_SchemaColumn_SchemaColumnType_name = map[int32]string

+ var SchemaType_SchemaColumn_SchemaColumnType_value = map[string]int32

+ var SimpleType_name = map[int32]string

+ var SimpleType_value = map[string]int32

+ var TaskExecution_Phase_name = map[int32]string

+ var TaskExecution_Phase_value = map[string]int32

+ var TaskLog_MessageFormat_name = map[int32]string

+ var TaskLog_MessageFormat_value = map[string]int32

+ var WorkflowExecution_Phase_name = map[int32]string

+ var WorkflowExecution_Phase_value = map[string]int32

+ type Alias struct

+ Alias string

+ Var string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Alias) Descriptor() ([]byte, []int)

+ func (*Alias) ProtoMessage()

+ func (dst *Alias) XXX_Merge(src proto.Message)

+ func (m *Alias) GetAlias() string

+ func (m *Alias) GetVar() string

+ func (m *Alias) Reset()

+ func (m *Alias) String() string

+ func (m *Alias) Validate() error

+ func (m *Alias) XXX_DiscardUnknown()

+ func (m *Alias) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Alias) XXX_Size() int

+ func (m *Alias) XXX_Unmarshal(b []byte) error

+ type AliasValidationError struct

+ func (e AliasValidationError) Cause() error

+ func (e AliasValidationError) Error() string

+ func (e AliasValidationError) ErrorName() string

+ func (e AliasValidationError) Field() string

+ func (e AliasValidationError) Key() bool

+ func (e AliasValidationError) Reason() string

+ type Binary struct

+ Tag string

+ Value []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Binary) Descriptor() ([]byte, []int)

+ func (*Binary) ProtoMessage()

+ func (dst *Binary) XXX_Merge(src proto.Message)

+ func (m *Binary) GetTag() string

+ func (m *Binary) GetValue() []byte

+ func (m *Binary) Reset()

+ func (m *Binary) String() string

+ func (m *Binary) Validate() error

+ func (m *Binary) XXX_DiscardUnknown()

+ func (m *Binary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Binary) XXX_Size() int

+ func (m *Binary) XXX_Unmarshal(b []byte) error

+ type BinaryValidationError struct

+ func (e BinaryValidationError) Cause() error

+ func (e BinaryValidationError) Error() string

+ func (e BinaryValidationError) ErrorName() string

+ func (e BinaryValidationError) Field() string

+ func (e BinaryValidationError) Key() bool

+ func (e BinaryValidationError) Reason() string

+ type Binding struct

+ Binding *BindingData

+ Var string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Binding) Descriptor() ([]byte, []int)

+ func (*Binding) ProtoMessage()

+ func (dst *Binding) XXX_Merge(src proto.Message)

+ func (m *Binding) GetBinding() *BindingData

+ func (m *Binding) GetVar() string

+ func (m *Binding) Reset()

+ func (m *Binding) String() string

+ func (m *Binding) Validate() error

+ func (m *Binding) XXX_DiscardUnknown()

+ func (m *Binding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Binding) XXX_Size() int

+ func (m *Binding) XXX_Unmarshal(b []byte) error

+ type BindingData struct

+ Value isBindingData_Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BindingData) Descriptor() ([]byte, []int)

+ func (*BindingData) ProtoMessage()

+ func (*BindingData) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *BindingData) XXX_Merge(src proto.Message)

+ func (m *BindingData) GetCollection() *BindingDataCollection

+ func (m *BindingData) GetMap() *BindingDataMap

+ func (m *BindingData) GetPromise() *OutputReference

+ func (m *BindingData) GetScalar() *Scalar

+ func (m *BindingData) GetValue() isBindingData_Value

+ func (m *BindingData) Reset()

+ func (m *BindingData) String() string

+ func (m *BindingData) Validate() error

+ func (m *BindingData) XXX_DiscardUnknown()

+ func (m *BindingData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BindingData) XXX_Size() int

+ func (m *BindingData) XXX_Unmarshal(b []byte) error

+ type BindingDataCollection struct

+ Bindings []*BindingData

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BindingDataCollection) Descriptor() ([]byte, []int)

+ func (*BindingDataCollection) ProtoMessage()

+ func (dst *BindingDataCollection) XXX_Merge(src proto.Message)

+ func (m *BindingDataCollection) GetBindings() []*BindingData

+ func (m *BindingDataCollection) Reset()

+ func (m *BindingDataCollection) String() string

+ func (m *BindingDataCollection) Validate() error

+ func (m *BindingDataCollection) XXX_DiscardUnknown()

+ func (m *BindingDataCollection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BindingDataCollection) XXX_Size() int

+ func (m *BindingDataCollection) XXX_Unmarshal(b []byte) error

+ type BindingDataCollectionValidationError struct

+ func (e BindingDataCollectionValidationError) Cause() error

+ func (e BindingDataCollectionValidationError) Error() string

+ func (e BindingDataCollectionValidationError) ErrorName() string

+ func (e BindingDataCollectionValidationError) Field() string

+ func (e BindingDataCollectionValidationError) Key() bool

+ func (e BindingDataCollectionValidationError) Reason() string

+ type BindingDataMap struct

+ Bindings map[string]*BindingData

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BindingDataMap) Descriptor() ([]byte, []int)

+ func (*BindingDataMap) ProtoMessage()

+ func (dst *BindingDataMap) XXX_Merge(src proto.Message)

+ func (m *BindingDataMap) GetBindings() map[string]*BindingData

+ func (m *BindingDataMap) Reset()

+ func (m *BindingDataMap) String() string

+ func (m *BindingDataMap) Validate() error

+ func (m *BindingDataMap) XXX_DiscardUnknown()

+ func (m *BindingDataMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BindingDataMap) XXX_Size() int

+ func (m *BindingDataMap) XXX_Unmarshal(b []byte) error

+ type BindingDataMapValidationError struct

+ func (e BindingDataMapValidationError) Cause() error

+ func (e BindingDataMapValidationError) Error() string

+ func (e BindingDataMapValidationError) ErrorName() string

+ func (e BindingDataMapValidationError) Field() string

+ func (e BindingDataMapValidationError) Key() bool

+ func (e BindingDataMapValidationError) Reason() string

+ type BindingDataValidationError struct

+ func (e BindingDataValidationError) Cause() error

+ func (e BindingDataValidationError) Error() string

+ func (e BindingDataValidationError) ErrorName() string

+ func (e BindingDataValidationError) Field() string

+ func (e BindingDataValidationError) Key() bool

+ func (e BindingDataValidationError) Reason() string

+ type BindingData_Collection struct

+ Collection *BindingDataCollection

+ type BindingData_Map struct

+ Map *BindingDataMap

+ type BindingData_Promise struct

+ Promise *OutputReference

+ type BindingData_Scalar struct

+ Scalar *Scalar

+ type BindingValidationError struct

+ func (e BindingValidationError) Cause() error

+ func (e BindingValidationError) Error() string

+ func (e BindingValidationError) ErrorName() string

+ func (e BindingValidationError) Field() string

+ func (e BindingValidationError) Key() bool

+ func (e BindingValidationError) Reason() string

+ type Blob struct

+ Metadata *BlobMetadata

+ Uri string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Blob) Descriptor() ([]byte, []int)

+ func (*Blob) ProtoMessage()

+ func (dst *Blob) XXX_Merge(src proto.Message)

+ func (m *Blob) GetMetadata() *BlobMetadata

+ func (m *Blob) GetUri() string

+ func (m *Blob) Reset()

+ func (m *Blob) String() string

+ func (m *Blob) Validate() error

+ func (m *Blob) XXX_DiscardUnknown()

+ func (m *Blob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Blob) XXX_Size() int

+ func (m *Blob) XXX_Unmarshal(b []byte) error

+ type BlobMetadata struct

+ Type *BlobType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BlobMetadata) Descriptor() ([]byte, []int)

+ func (*BlobMetadata) ProtoMessage()

+ func (dst *BlobMetadata) XXX_Merge(src proto.Message)

+ func (m *BlobMetadata) GetType() *BlobType

+ func (m *BlobMetadata) Reset()

+ func (m *BlobMetadata) String() string

+ func (m *BlobMetadata) Validate() error

+ func (m *BlobMetadata) XXX_DiscardUnknown()

+ func (m *BlobMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BlobMetadata) XXX_Size() int

+ func (m *BlobMetadata) XXX_Unmarshal(b []byte) error

+ type BlobMetadataValidationError struct

+ func (e BlobMetadataValidationError) Cause() error

+ func (e BlobMetadataValidationError) Error() string

+ func (e BlobMetadataValidationError) ErrorName() string

+ func (e BlobMetadataValidationError) Field() string

+ func (e BlobMetadataValidationError) Key() bool

+ func (e BlobMetadataValidationError) Reason() string

+ type BlobType struct

+ Dimensionality BlobType_BlobDimensionality

+ Format string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BlobType) Descriptor() ([]byte, []int)

+ func (*BlobType) ProtoMessage()

+ func (dst *BlobType) XXX_Merge(src proto.Message)

+ func (m *BlobType) GetDimensionality() BlobType_BlobDimensionality

+ func (m *BlobType) GetFormat() string

+ func (m *BlobType) Reset()

+ func (m *BlobType) String() string

+ func (m *BlobType) Validate() error

+ func (m *BlobType) XXX_DiscardUnknown()

+ func (m *BlobType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BlobType) XXX_Size() int

+ func (m *BlobType) XXX_Unmarshal(b []byte) error

+ type BlobTypeValidationError struct

+ func (e BlobTypeValidationError) Cause() error

+ func (e BlobTypeValidationError) Error() string

+ func (e BlobTypeValidationError) ErrorName() string

+ func (e BlobTypeValidationError) Field() string

+ func (e BlobTypeValidationError) Key() bool

+ func (e BlobTypeValidationError) Reason() string

+ type BlobType_BlobDimensionality int32

+ const BlobType_MULTIPART

+ const BlobType_SINGLE

+ func (BlobType_BlobDimensionality) EnumDescriptor() ([]byte, []int)

+ func (x BlobType_BlobDimensionality) String() string

+ type BlobValidationError struct

+ func (e BlobValidationError) Cause() error

+ func (e BlobValidationError) Error() string

+ func (e BlobValidationError) ErrorName() string

+ func (e BlobValidationError) Field() string

+ func (e BlobValidationError) Key() bool

+ func (e BlobValidationError) Reason() string

+ type BooleanExpression struct

+ Expr isBooleanExpression_Expr

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BooleanExpression) Descriptor() ([]byte, []int)

+ func (*BooleanExpression) ProtoMessage()

+ func (*BooleanExpression) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *BooleanExpression) XXX_Merge(src proto.Message)

+ func (m *BooleanExpression) GetComparison() *ComparisonExpression

+ func (m *BooleanExpression) GetConjunction() *ConjunctionExpression

+ func (m *BooleanExpression) GetExpr() isBooleanExpression_Expr

+ func (m *BooleanExpression) Reset()

+ func (m *BooleanExpression) String() string

+ func (m *BooleanExpression) Validate() error

+ func (m *BooleanExpression) XXX_DiscardUnknown()

+ func (m *BooleanExpression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BooleanExpression) XXX_Size() int

+ func (m *BooleanExpression) XXX_Unmarshal(b []byte) error

+ type BooleanExpressionValidationError struct

+ func (e BooleanExpressionValidationError) Cause() error

+ func (e BooleanExpressionValidationError) Error() string

+ func (e BooleanExpressionValidationError) ErrorName() string

+ func (e BooleanExpressionValidationError) Field() string

+ func (e BooleanExpressionValidationError) Key() bool

+ func (e BooleanExpressionValidationError) Reason() string

+ type BooleanExpression_Comparison struct

+ Comparison *ComparisonExpression

+ type BooleanExpression_Conjunction struct

+ Conjunction *ConjunctionExpression

+ type BranchNode struct

+ IfElse *IfElseBlock

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BranchNode) Descriptor() ([]byte, []int)

+ func (*BranchNode) ProtoMessage()

+ func (dst *BranchNode) XXX_Merge(src proto.Message)

+ func (m *BranchNode) GetIfElse() *IfElseBlock

+ func (m *BranchNode) Reset()

+ func (m *BranchNode) String() string

+ func (m *BranchNode) Validate() error

+ func (m *BranchNode) XXX_DiscardUnknown()

+ func (m *BranchNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BranchNode) XXX_Size() int

+ func (m *BranchNode) XXX_Unmarshal(b []byte) error

+ type BranchNodeValidationError struct

+ func (e BranchNodeValidationError) Cause() error

+ func (e BranchNodeValidationError) Error() string

+ func (e BranchNodeValidationError) ErrorName() string

+ func (e BranchNodeValidationError) Field() string

+ func (e BranchNodeValidationError) Key() bool

+ func (e BranchNodeValidationError) Reason() string

+ type ComparisonExpression struct

+ LeftValue *Operand

+ Operator ComparisonExpression_Operator

+ RightValue *Operand

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ComparisonExpression) Descriptor() ([]byte, []int)

+ func (*ComparisonExpression) ProtoMessage()

+ func (dst *ComparisonExpression) XXX_Merge(src proto.Message)

+ func (m *ComparisonExpression) GetLeftValue() *Operand

+ func (m *ComparisonExpression) GetOperator() ComparisonExpression_Operator

+ func (m *ComparisonExpression) GetRightValue() *Operand

+ func (m *ComparisonExpression) Reset()

+ func (m *ComparisonExpression) String() string

+ func (m *ComparisonExpression) Validate() error

+ func (m *ComparisonExpression) XXX_DiscardUnknown()

+ func (m *ComparisonExpression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ComparisonExpression) XXX_Size() int

+ func (m *ComparisonExpression) XXX_Unmarshal(b []byte) error

+ type ComparisonExpressionValidationError struct

+ func (e ComparisonExpressionValidationError) Cause() error

+ func (e ComparisonExpressionValidationError) Error() string

+ func (e ComparisonExpressionValidationError) ErrorName() string

+ func (e ComparisonExpressionValidationError) Field() string

+ func (e ComparisonExpressionValidationError) Key() bool

+ func (e ComparisonExpressionValidationError) Reason() string

+ type ComparisonExpression_Operator int32

+ const ComparisonExpression_EQ

+ const ComparisonExpression_GT

+ const ComparisonExpression_GTE

+ const ComparisonExpression_LT

+ const ComparisonExpression_LTE

+ const ComparisonExpression_NEQ

+ func (ComparisonExpression_Operator) EnumDescriptor() ([]byte, []int)

+ func (x ComparisonExpression_Operator) String() string

+ type CompiledTask struct

+ Template *TaskTemplate

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CompiledTask) Descriptor() ([]byte, []int)

+ func (*CompiledTask) ProtoMessage()

+ func (dst *CompiledTask) XXX_Merge(src proto.Message)

+ func (m *CompiledTask) GetTemplate() *TaskTemplate

+ func (m *CompiledTask) Reset()

+ func (m *CompiledTask) String() string

+ func (m *CompiledTask) Validate() error

+ func (m *CompiledTask) XXX_DiscardUnknown()

+ func (m *CompiledTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CompiledTask) XXX_Size() int

+ func (m *CompiledTask) XXX_Unmarshal(b []byte) error

+ type CompiledTaskValidationError struct

+ func (e CompiledTaskValidationError) Cause() error

+ func (e CompiledTaskValidationError) Error() string

+ func (e CompiledTaskValidationError) ErrorName() string

+ func (e CompiledTaskValidationError) Field() string

+ func (e CompiledTaskValidationError) Key() bool

+ func (e CompiledTaskValidationError) Reason() string

+ type CompiledWorkflow struct

+ Connections *ConnectionSet

+ Template *WorkflowTemplate

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CompiledWorkflow) Descriptor() ([]byte, []int)

+ func (*CompiledWorkflow) ProtoMessage()

+ func (dst *CompiledWorkflow) XXX_Merge(src proto.Message)

+ func (m *CompiledWorkflow) GetConnections() *ConnectionSet

+ func (m *CompiledWorkflow) GetTemplate() *WorkflowTemplate

+ func (m *CompiledWorkflow) Reset()

+ func (m *CompiledWorkflow) String() string

+ func (m *CompiledWorkflow) Validate() error

+ func (m *CompiledWorkflow) XXX_DiscardUnknown()

+ func (m *CompiledWorkflow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CompiledWorkflow) XXX_Size() int

+ func (m *CompiledWorkflow) XXX_Unmarshal(b []byte) error

+ type CompiledWorkflowClosure struct

+ Primary *CompiledWorkflow

+ SubWorkflows []*CompiledWorkflow

+ Tasks []*CompiledTask

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CompiledWorkflowClosure) Descriptor() ([]byte, []int)

+ func (*CompiledWorkflowClosure) ProtoMessage()

+ func (dst *CompiledWorkflowClosure) XXX_Merge(src proto.Message)

+ func (m *CompiledWorkflowClosure) GetPrimary() *CompiledWorkflow

+ func (m *CompiledWorkflowClosure) GetSubWorkflows() []*CompiledWorkflow

+ func (m *CompiledWorkflowClosure) GetTasks() []*CompiledTask

+ func (m *CompiledWorkflowClosure) Reset()

+ func (m *CompiledWorkflowClosure) String() string

+ func (m *CompiledWorkflowClosure) Validate() error

+ func (m *CompiledWorkflowClosure) XXX_DiscardUnknown()

+ func (m *CompiledWorkflowClosure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CompiledWorkflowClosure) XXX_Size() int

+ func (m *CompiledWorkflowClosure) XXX_Unmarshal(b []byte) error

+ type CompiledWorkflowClosureValidationError struct

+ func (e CompiledWorkflowClosureValidationError) Cause() error

+ func (e CompiledWorkflowClosureValidationError) Error() string

+ func (e CompiledWorkflowClosureValidationError) ErrorName() string

+ func (e CompiledWorkflowClosureValidationError) Field() string

+ func (e CompiledWorkflowClosureValidationError) Key() bool

+ func (e CompiledWorkflowClosureValidationError) Reason() string

+ type CompiledWorkflowValidationError struct

+ func (e CompiledWorkflowValidationError) Cause() error

+ func (e CompiledWorkflowValidationError) Error() string

+ func (e CompiledWorkflowValidationError) ErrorName() string

+ func (e CompiledWorkflowValidationError) Field() string

+ func (e CompiledWorkflowValidationError) Key() bool

+ func (e CompiledWorkflowValidationError) Reason() string

+ type ConjunctionExpression struct

+ LeftExpression *BooleanExpression

+ Operator ConjunctionExpression_LogicalOperator

+ RightExpression *BooleanExpression

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ConjunctionExpression) Descriptor() ([]byte, []int)

+ func (*ConjunctionExpression) ProtoMessage()

+ func (dst *ConjunctionExpression) XXX_Merge(src proto.Message)

+ func (m *ConjunctionExpression) GetLeftExpression() *BooleanExpression

+ func (m *ConjunctionExpression) GetOperator() ConjunctionExpression_LogicalOperator

+ func (m *ConjunctionExpression) GetRightExpression() *BooleanExpression

+ func (m *ConjunctionExpression) Reset()

+ func (m *ConjunctionExpression) String() string

+ func (m *ConjunctionExpression) Validate() error

+ func (m *ConjunctionExpression) XXX_DiscardUnknown()

+ func (m *ConjunctionExpression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConjunctionExpression) XXX_Size() int

+ func (m *ConjunctionExpression) XXX_Unmarshal(b []byte) error

+ type ConjunctionExpressionValidationError struct

+ func (e ConjunctionExpressionValidationError) Cause() error

+ func (e ConjunctionExpressionValidationError) Error() string

+ func (e ConjunctionExpressionValidationError) ErrorName() string

+ func (e ConjunctionExpressionValidationError) Field() string

+ func (e ConjunctionExpressionValidationError) Key() bool

+ func (e ConjunctionExpressionValidationError) Reason() string

+ type ConjunctionExpression_LogicalOperator int32

+ const ConjunctionExpression_AND

+ const ConjunctionExpression_OR

+ func (ConjunctionExpression_LogicalOperator) EnumDescriptor() ([]byte, []int)

+ func (x ConjunctionExpression_LogicalOperator) String() string

+ type ConnectionSet struct

+ Downstream map[string]*ConnectionSet_IdList

+ Upstream map[string]*ConnectionSet_IdList

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ConnectionSet) Descriptor() ([]byte, []int)

+ func (*ConnectionSet) ProtoMessage()

+ func (dst *ConnectionSet) XXX_Merge(src proto.Message)

+ func (m *ConnectionSet) GetDownstream() map[string]*ConnectionSet_IdList

+ func (m *ConnectionSet) GetUpstream() map[string]*ConnectionSet_IdList

+ func (m *ConnectionSet) Reset()

+ func (m *ConnectionSet) String() string

+ func (m *ConnectionSet) Validate() error

+ func (m *ConnectionSet) XXX_DiscardUnknown()

+ func (m *ConnectionSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConnectionSet) XXX_Size() int

+ func (m *ConnectionSet) XXX_Unmarshal(b []byte) error

+ type ConnectionSetValidationError struct

+ func (e ConnectionSetValidationError) Cause() error

+ func (e ConnectionSetValidationError) Error() string

+ func (e ConnectionSetValidationError) ErrorName() string

+ func (e ConnectionSetValidationError) Field() string

+ func (e ConnectionSetValidationError) Key() bool

+ func (e ConnectionSetValidationError) Reason() string

+ type ConnectionSet_IdList struct

+ Ids []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ConnectionSet_IdList) Descriptor() ([]byte, []int)

+ func (*ConnectionSet_IdList) ProtoMessage()

+ func (dst *ConnectionSet_IdList) XXX_Merge(src proto.Message)

+ func (m *ConnectionSet_IdList) GetIds() []string

+ func (m *ConnectionSet_IdList) Reset()

+ func (m *ConnectionSet_IdList) String() string

+ func (m *ConnectionSet_IdList) Validate() error

+ func (m *ConnectionSet_IdList) XXX_DiscardUnknown()

+ func (m *ConnectionSet_IdList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConnectionSet_IdList) XXX_Size() int

+ func (m *ConnectionSet_IdList) XXX_Unmarshal(b []byte) error

+ type ConnectionSet_IdListValidationError struct

+ func (e ConnectionSet_IdListValidationError) Cause() error

+ func (e ConnectionSet_IdListValidationError) Error() string

+ func (e ConnectionSet_IdListValidationError) ErrorName() string

+ func (e ConnectionSet_IdListValidationError) Field() string

+ func (e ConnectionSet_IdListValidationError) Key() bool

+ func (e ConnectionSet_IdListValidationError) Reason() string

+ type Container struct

+ Args []string

+ Command []string

+ Config []*KeyValuePair

+ Env []*KeyValuePair

+ Image string

+ Ports []*ContainerPort

+ Resources *Resources

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Container) Descriptor() ([]byte, []int)

+ func (*Container) ProtoMessage()

+ func (dst *Container) XXX_Merge(src proto.Message)

+ func (m *Container) GetArgs() []string

+ func (m *Container) GetCommand() []string

+ func (m *Container) GetConfig() []*KeyValuePair

+ func (m *Container) GetEnv() []*KeyValuePair

+ func (m *Container) GetImage() string

+ func (m *Container) GetPorts() []*ContainerPort

+ func (m *Container) GetResources() *Resources

+ func (m *Container) Reset()

+ func (m *Container) String() string

+ func (m *Container) Validate() error

+ func (m *Container) XXX_DiscardUnknown()

+ func (m *Container) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Container) XXX_Size() int

+ func (m *Container) XXX_Unmarshal(b []byte) error

+ type ContainerError struct

+ Code string

+ Kind ContainerError_Kind

+ Message string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ContainerError) Descriptor() ([]byte, []int)

+ func (*ContainerError) ProtoMessage()

+ func (dst *ContainerError) XXX_Merge(src proto.Message)

+ func (m *ContainerError) GetCode() string

+ func (m *ContainerError) GetKind() ContainerError_Kind

+ func (m *ContainerError) GetMessage() string

+ func (m *ContainerError) Reset()

+ func (m *ContainerError) String() string

+ func (m *ContainerError) Validate() error

+ func (m *ContainerError) XXX_DiscardUnknown()

+ func (m *ContainerError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ContainerError) XXX_Size() int

+ func (m *ContainerError) XXX_Unmarshal(b []byte) error

+ type ContainerErrorValidationError struct

+ func (e ContainerErrorValidationError) Cause() error

+ func (e ContainerErrorValidationError) Error() string

+ func (e ContainerErrorValidationError) ErrorName() string

+ func (e ContainerErrorValidationError) Field() string

+ func (e ContainerErrorValidationError) Key() bool

+ func (e ContainerErrorValidationError) Reason() string

+ type ContainerError_Kind int32

+ const ContainerError_NON_RECOVERABLE

+ const ContainerError_RECOVERABLE

+ func (ContainerError_Kind) EnumDescriptor() ([]byte, []int)

+ func (x ContainerError_Kind) String() string

+ type ContainerPort struct

+ ContainerPort uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ContainerPort) Descriptor() ([]byte, []int)

+ func (*ContainerPort) ProtoMessage()

+ func (dst *ContainerPort) XXX_Merge(src proto.Message)

+ func (m *ContainerPort) GetContainerPort() uint32

+ func (m *ContainerPort) Reset()

+ func (m *ContainerPort) String() string

+ func (m *ContainerPort) Validate() error

+ func (m *ContainerPort) XXX_DiscardUnknown()

+ func (m *ContainerPort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ContainerPort) XXX_Size() int

+ func (m *ContainerPort) XXX_Unmarshal(b []byte) error

+ type ContainerPortValidationError struct

+ func (e ContainerPortValidationError) Cause() error

+ func (e ContainerPortValidationError) Error() string

+ func (e ContainerPortValidationError) ErrorName() string

+ func (e ContainerPortValidationError) Field() string

+ func (e ContainerPortValidationError) Key() bool

+ func (e ContainerPortValidationError) Reason() string

+ type ContainerValidationError struct

+ func (e ContainerValidationError) Cause() error

+ func (e ContainerValidationError) Error() string

+ func (e ContainerValidationError) ErrorName() string

+ func (e ContainerValidationError) Field() string

+ func (e ContainerValidationError) Key() bool

+ func (e ContainerValidationError) Reason() string

+ type DynamicJobSpec struct

+ MinSuccesses int64

+ Nodes []*Node

+ Outputs []*Binding

+ Subworkflows []*WorkflowTemplate

+ Tasks []*TaskTemplate

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DynamicJobSpec) Descriptor() ([]byte, []int)

+ func (*DynamicJobSpec) ProtoMessage()

+ func (dst *DynamicJobSpec) XXX_Merge(src proto.Message)

+ func (m *DynamicJobSpec) GetMinSuccesses() int64

+ func (m *DynamicJobSpec) GetNodes() []*Node

+ func (m *DynamicJobSpec) GetOutputs() []*Binding

+ func (m *DynamicJobSpec) GetSubworkflows() []*WorkflowTemplate

+ func (m *DynamicJobSpec) GetTasks() []*TaskTemplate

+ func (m *DynamicJobSpec) Reset()

+ func (m *DynamicJobSpec) String() string

+ func (m *DynamicJobSpec) Validate() error

+ func (m *DynamicJobSpec) XXX_DiscardUnknown()

+ func (m *DynamicJobSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DynamicJobSpec) XXX_Size() int

+ func (m *DynamicJobSpec) XXX_Unmarshal(b []byte) error

+ type DynamicJobSpecValidationError struct

+ func (e DynamicJobSpecValidationError) Cause() error

+ func (e DynamicJobSpecValidationError) Error() string

+ func (e DynamicJobSpecValidationError) ErrorName() string

+ func (e DynamicJobSpecValidationError) Field() string

+ func (e DynamicJobSpecValidationError) Key() bool

+ func (e DynamicJobSpecValidationError) Reason() string

+ type Error struct

+ FailedNodeId string

+ Message string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Error) Descriptor() ([]byte, []int)

+ func (*Error) ProtoMessage()

+ func (dst *Error) XXX_Merge(src proto.Message)

+ func (m *Error) GetFailedNodeId() string

+ func (m *Error) GetMessage() string

+ func (m *Error) Reset()

+ func (m *Error) String() string

+ func (m *Error) Validate() error

+ func (m *Error) XXX_DiscardUnknown()

+ func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Error) XXX_Size() int

+ func (m *Error) XXX_Unmarshal(b []byte) error

+ type ErrorDocument struct

+ Error *ContainerError

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ErrorDocument) Descriptor() ([]byte, []int)

+ func (*ErrorDocument) ProtoMessage()

+ func (dst *ErrorDocument) XXX_Merge(src proto.Message)

+ func (m *ErrorDocument) GetError() *ContainerError

+ func (m *ErrorDocument) Reset()

+ func (m *ErrorDocument) String() string

+ func (m *ErrorDocument) Validate() error

+ func (m *ErrorDocument) XXX_DiscardUnknown()

+ func (m *ErrorDocument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ErrorDocument) XXX_Size() int

+ func (m *ErrorDocument) XXX_Unmarshal(b []byte) error

+ type ErrorDocumentValidationError struct

+ func (e ErrorDocumentValidationError) Cause() error

+ func (e ErrorDocumentValidationError) Error() string

+ func (e ErrorDocumentValidationError) ErrorName() string

+ func (e ErrorDocumentValidationError) Field() string

+ func (e ErrorDocumentValidationError) Key() bool

+ func (e ErrorDocumentValidationError) Reason() string

+ type ErrorValidationError struct

+ func (e ErrorValidationError) Cause() error

+ func (e ErrorValidationError) Error() string

+ func (e ErrorValidationError) ErrorName() string

+ func (e ErrorValidationError) Field() string

+ func (e ErrorValidationError) Key() bool

+ func (e ErrorValidationError) Reason() string

+ type ExecutionError struct

+ Code string

+ ErrorUri string

+ Message string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ExecutionError) Descriptor() ([]byte, []int)

+ func (*ExecutionError) ProtoMessage()

+ func (dst *ExecutionError) XXX_Merge(src proto.Message)

+ func (m *ExecutionError) GetCode() string

+ func (m *ExecutionError) GetErrorUri() string

+ func (m *ExecutionError) GetMessage() string

+ func (m *ExecutionError) Reset()

+ func (m *ExecutionError) String() string

+ func (m *ExecutionError) Validate() error

+ func (m *ExecutionError) XXX_DiscardUnknown()

+ func (m *ExecutionError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ExecutionError) XXX_Size() int

+ func (m *ExecutionError) XXX_Unmarshal(b []byte) error

+ type ExecutionErrorValidationError struct

+ func (e ExecutionErrorValidationError) Cause() error

+ func (e ExecutionErrorValidationError) Error() string

+ func (e ExecutionErrorValidationError) ErrorName() string

+ func (e ExecutionErrorValidationError) Field() string

+ func (e ExecutionErrorValidationError) Key() bool

+ func (e ExecutionErrorValidationError) Reason() string

+ type Identifier struct

+ Domain string

+ Name string

+ Project string

+ ResourceType ResourceType

+ Version string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Identifier) Descriptor() ([]byte, []int)

+ func (*Identifier) ProtoMessage()

+ func (dst *Identifier) XXX_Merge(src proto.Message)

+ func (m *Identifier) GetDomain() string

+ func (m *Identifier) GetName() string

+ func (m *Identifier) GetProject() string

+ func (m *Identifier) GetResourceType() ResourceType

+ func (m *Identifier) GetVersion() string

+ func (m *Identifier) Reset()

+ func (m *Identifier) String() string

+ func (m *Identifier) Validate() error

+ func (m *Identifier) XXX_DiscardUnknown()

+ func (m *Identifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Identifier) XXX_Size() int

+ func (m *Identifier) XXX_Unmarshal(b []byte) error

+ type IdentifierValidationError struct

+ func (e IdentifierValidationError) Cause() error

+ func (e IdentifierValidationError) Error() string

+ func (e IdentifierValidationError) ErrorName() string

+ func (e IdentifierValidationError) Field() string

+ func (e IdentifierValidationError) Key() bool

+ func (e IdentifierValidationError) Reason() string

+ type IfBlock struct

+ Condition *BooleanExpression

+ ThenNode *Node

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*IfBlock) Descriptor() ([]byte, []int)

+ func (*IfBlock) ProtoMessage()

+ func (dst *IfBlock) XXX_Merge(src proto.Message)

+ func (m *IfBlock) GetCondition() *BooleanExpression

+ func (m *IfBlock) GetThenNode() *Node

+ func (m *IfBlock) Reset()

+ func (m *IfBlock) String() string

+ func (m *IfBlock) Validate() error

+ func (m *IfBlock) XXX_DiscardUnknown()

+ func (m *IfBlock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IfBlock) XXX_Size() int

+ func (m *IfBlock) XXX_Unmarshal(b []byte) error

+ type IfBlockValidationError struct

+ func (e IfBlockValidationError) Cause() error

+ func (e IfBlockValidationError) Error() string

+ func (e IfBlockValidationError) ErrorName() string

+ func (e IfBlockValidationError) Field() string

+ func (e IfBlockValidationError) Key() bool

+ func (e IfBlockValidationError) Reason() string

+ type IfElseBlock struct

+ Case *IfBlock

+ Default isIfElseBlock_Default

+ Other []*IfBlock

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*IfElseBlock) Descriptor() ([]byte, []int)

+ func (*IfElseBlock) ProtoMessage()

+ func (*IfElseBlock) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *IfElseBlock) XXX_Merge(src proto.Message)

+ func (m *IfElseBlock) GetCase() *IfBlock

+ func (m *IfElseBlock) GetDefault() isIfElseBlock_Default

+ func (m *IfElseBlock) GetElseNode() *Node

+ func (m *IfElseBlock) GetError() *Error

+ func (m *IfElseBlock) GetOther() []*IfBlock

+ func (m *IfElseBlock) Reset()

+ func (m *IfElseBlock) String() string

+ func (m *IfElseBlock) Validate() error

+ func (m *IfElseBlock) XXX_DiscardUnknown()

+ func (m *IfElseBlock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IfElseBlock) XXX_Size() int

+ func (m *IfElseBlock) XXX_Unmarshal(b []byte) error

+ type IfElseBlockValidationError struct

+ func (e IfElseBlockValidationError) Cause() error

+ func (e IfElseBlockValidationError) Error() string

+ func (e IfElseBlockValidationError) ErrorName() string

+ func (e IfElseBlockValidationError) Field() string

+ func (e IfElseBlockValidationError) Key() bool

+ func (e IfElseBlockValidationError) Reason() string

+ type IfElseBlock_ElseNode struct

+ ElseNode *Node

+ type IfElseBlock_Error struct

+ Error *Error

+ type KeyValuePair struct

+ Key string

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*KeyValuePair) Descriptor() ([]byte, []int)

+ func (*KeyValuePair) ProtoMessage()

+ func (dst *KeyValuePair) XXX_Merge(src proto.Message)

+ func (m *KeyValuePair) GetKey() string

+ func (m *KeyValuePair) GetValue() string

+ func (m *KeyValuePair) Reset()

+ func (m *KeyValuePair) String() string

+ func (m *KeyValuePair) Validate() error

+ func (m *KeyValuePair) XXX_DiscardUnknown()

+ func (m *KeyValuePair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *KeyValuePair) XXX_Size() int

+ func (m *KeyValuePair) XXX_Unmarshal(b []byte) error

+ type KeyValuePairValidationError struct

+ func (e KeyValuePairValidationError) Cause() error

+ func (e KeyValuePairValidationError) Error() string

+ func (e KeyValuePairValidationError) ErrorName() string

+ func (e KeyValuePairValidationError) Field() string

+ func (e KeyValuePairValidationError) Key() bool

+ func (e KeyValuePairValidationError) Reason() string

+ type Literal struct

+ Value isLiteral_Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Literal) Descriptor() ([]byte, []int)

+ func (*Literal) ProtoMessage()

+ func (*Literal) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *Literal) XXX_Merge(src proto.Message)

+ func (m *Literal) GetCollection() *LiteralCollection

+ func (m *Literal) GetMap() *LiteralMap

+ func (m *Literal) GetScalar() *Scalar

+ func (m *Literal) GetValue() isLiteral_Value

+ func (m *Literal) Reset()

+ func (m *Literal) String() string

+ func (m *Literal) Validate() error

+ func (m *Literal) XXX_DiscardUnknown()

+ func (m *Literal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Literal) XXX_Size() int

+ func (m *Literal) XXX_Unmarshal(b []byte) error

+ type LiteralCollection struct

+ Literals []*Literal

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LiteralCollection) Descriptor() ([]byte, []int)

+ func (*LiteralCollection) ProtoMessage()

+ func (dst *LiteralCollection) XXX_Merge(src proto.Message)

+ func (m *LiteralCollection) GetLiterals() []*Literal

+ func (m *LiteralCollection) Reset()

+ func (m *LiteralCollection) String() string

+ func (m *LiteralCollection) Validate() error

+ func (m *LiteralCollection) XXX_DiscardUnknown()

+ func (m *LiteralCollection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LiteralCollection) XXX_Size() int

+ func (m *LiteralCollection) XXX_Unmarshal(b []byte) error

+ type LiteralCollectionValidationError struct

+ func (e LiteralCollectionValidationError) Cause() error

+ func (e LiteralCollectionValidationError) Error() string

+ func (e LiteralCollectionValidationError) ErrorName() string

+ func (e LiteralCollectionValidationError) Field() string

+ func (e LiteralCollectionValidationError) Key() bool

+ func (e LiteralCollectionValidationError) Reason() string

+ type LiteralMap struct

+ Literals map[string]*Literal

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LiteralMap) Descriptor() ([]byte, []int)

+ func (*LiteralMap) ProtoMessage()

+ func (dst *LiteralMap) XXX_Merge(src proto.Message)

+ func (m *LiteralMap) GetLiterals() map[string]*Literal

+ func (m *LiteralMap) Reset()

+ func (m *LiteralMap) String() string

+ func (m *LiteralMap) Validate() error

+ func (m *LiteralMap) XXX_DiscardUnknown()

+ func (m *LiteralMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LiteralMap) XXX_Size() int

+ func (m *LiteralMap) XXX_Unmarshal(b []byte) error

+ type LiteralMapValidationError struct

+ func (e LiteralMapValidationError) Cause() error

+ func (e LiteralMapValidationError) Error() string

+ func (e LiteralMapValidationError) ErrorName() string

+ func (e LiteralMapValidationError) Field() string

+ func (e LiteralMapValidationError) Key() bool

+ func (e LiteralMapValidationError) Reason() string

+ type LiteralType struct

+ Metadata *_struct.Struct

+ Type isLiteralType_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LiteralType) Descriptor() ([]byte, []int)

+ func (*LiteralType) ProtoMessage()

+ func (*LiteralType) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *LiteralType) XXX_Merge(src proto.Message)

+ func (m *LiteralType) GetBlob() *BlobType

+ func (m *LiteralType) GetCollectionType() *LiteralType

+ func (m *LiteralType) GetMapValueType() *LiteralType

+ func (m *LiteralType) GetMetadata() *_struct.Struct

+ func (m *LiteralType) GetSchema() *SchemaType

+ func (m *LiteralType) GetSimple() SimpleType

+ func (m *LiteralType) GetType() isLiteralType_Type

+ func (m *LiteralType) Reset()

+ func (m *LiteralType) String() string

+ func (m *LiteralType) Validate() error

+ func (m *LiteralType) XXX_DiscardUnknown()

+ func (m *LiteralType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LiteralType) XXX_Size() int

+ func (m *LiteralType) XXX_Unmarshal(b []byte) error

+ type LiteralTypeValidationError struct

+ func (e LiteralTypeValidationError) Cause() error

+ func (e LiteralTypeValidationError) Error() string

+ func (e LiteralTypeValidationError) ErrorName() string

+ func (e LiteralTypeValidationError) Field() string

+ func (e LiteralTypeValidationError) Key() bool

+ func (e LiteralTypeValidationError) Reason() string

+ type LiteralType_Blob struct

+ Blob *BlobType

+ type LiteralType_CollectionType struct

+ CollectionType *LiteralType

+ type LiteralType_MapValueType struct

+ MapValueType *LiteralType

+ type LiteralType_Schema struct

+ Schema *SchemaType

+ type LiteralType_Simple struct

+ Simple SimpleType

+ type LiteralValidationError struct

+ func (e LiteralValidationError) Cause() error

+ func (e LiteralValidationError) Error() string

+ func (e LiteralValidationError) ErrorName() string

+ func (e LiteralValidationError) Field() string

+ func (e LiteralValidationError) Key() bool

+ func (e LiteralValidationError) Reason() string

+ type Literal_Collection struct

+ Collection *LiteralCollection

+ type Literal_Map struct

+ Map *LiteralMap

+ type Literal_Scalar struct

+ Scalar *Scalar

+ type Node struct

+ Id string

+ Inputs []*Binding

+ Metadata *NodeMetadata

+ OutputAliases []*Alias

+ Target isNode_Target

+ UpstreamNodeIds []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Node) Descriptor() ([]byte, []int)

+ func (*Node) ProtoMessage()

+ func (*Node) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *Node) XXX_Merge(src proto.Message)

+ func (m *Node) GetBranchNode() *BranchNode

+ func (m *Node) GetId() string

+ func (m *Node) GetInputs() []*Binding

+ func (m *Node) GetMetadata() *NodeMetadata

+ func (m *Node) GetOutputAliases() []*Alias

+ func (m *Node) GetTarget() isNode_Target

+ func (m *Node) GetTaskNode() *TaskNode

+ func (m *Node) GetUpstreamNodeIds() []string

+ func (m *Node) GetWorkflowNode() *WorkflowNode

+ func (m *Node) Reset()

+ func (m *Node) String() string

+ func (m *Node) Validate() error

+ func (m *Node) XXX_DiscardUnknown()

+ func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Node) XXX_Size() int

+ func (m *Node) XXX_Unmarshal(b []byte) error

+ type NodeExecution struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeExecution) Descriptor() ([]byte, []int)

+ func (*NodeExecution) ProtoMessage()

+ func (dst *NodeExecution) XXX_Merge(src proto.Message)

+ func (m *NodeExecution) Reset()

+ func (m *NodeExecution) String() string

+ func (m *NodeExecution) Validate() error

+ func (m *NodeExecution) XXX_DiscardUnknown()

+ func (m *NodeExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NodeExecution) XXX_Size() int

+ func (m *NodeExecution) XXX_Unmarshal(b []byte) error

+ type NodeExecutionIdentifier struct

+ ExecutionId *WorkflowExecutionIdentifier

+ NodeId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeExecutionIdentifier) Descriptor() ([]byte, []int)

+ func (*NodeExecutionIdentifier) ProtoMessage()

+ func (dst *NodeExecutionIdentifier) XXX_Merge(src proto.Message)

+ func (m *NodeExecutionIdentifier) GetExecutionId() *WorkflowExecutionIdentifier

+ func (m *NodeExecutionIdentifier) GetNodeId() string

+ func (m *NodeExecutionIdentifier) Reset()

+ func (m *NodeExecutionIdentifier) String() string

+ func (m *NodeExecutionIdentifier) Validate() error

+ func (m *NodeExecutionIdentifier) XXX_DiscardUnknown()

+ func (m *NodeExecutionIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NodeExecutionIdentifier) XXX_Size() int

+ func (m *NodeExecutionIdentifier) XXX_Unmarshal(b []byte) error

+ type NodeExecutionIdentifierValidationError struct

+ func (e NodeExecutionIdentifierValidationError) Cause() error

+ func (e NodeExecutionIdentifierValidationError) Error() string

+ func (e NodeExecutionIdentifierValidationError) ErrorName() string

+ func (e NodeExecutionIdentifierValidationError) Field() string

+ func (e NodeExecutionIdentifierValidationError) Key() bool

+ func (e NodeExecutionIdentifierValidationError) Reason() string

+ type NodeExecutionValidationError struct

+ func (e NodeExecutionValidationError) Cause() error

+ func (e NodeExecutionValidationError) Error() string

+ func (e NodeExecutionValidationError) ErrorName() string

+ func (e NodeExecutionValidationError) Field() string

+ func (e NodeExecutionValidationError) Key() bool

+ func (e NodeExecutionValidationError) Reason() string

+ type NodeExecution_Phase int32

+ const NodeExecution_ABORTED

+ const NodeExecution_FAILED

+ const NodeExecution_FAILING

+ const NodeExecution_QUEUED

+ const NodeExecution_RUNNING

+ const NodeExecution_SKIPPED

+ const NodeExecution_SUCCEEDED

+ const NodeExecution_TIMED_OUT

+ const NodeExecution_UNDEFINED

+ func (NodeExecution_Phase) EnumDescriptor() ([]byte, []int)

+ func (x NodeExecution_Phase) String() string

+ type NodeMetadata struct

+ Name string

+ Retries *RetryStrategy

+ Timeout *duration.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeMetadata) Descriptor() ([]byte, []int)

+ func (*NodeMetadata) ProtoMessage()

+ func (dst *NodeMetadata) XXX_Merge(src proto.Message)

+ func (m *NodeMetadata) GetName() string

+ func (m *NodeMetadata) GetRetries() *RetryStrategy

+ func (m *NodeMetadata) GetTimeout() *duration.Duration

+ func (m *NodeMetadata) Reset()

+ func (m *NodeMetadata) String() string

+ func (m *NodeMetadata) Validate() error

+ func (m *NodeMetadata) XXX_DiscardUnknown()

+ func (m *NodeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NodeMetadata) XXX_Size() int

+ func (m *NodeMetadata) XXX_Unmarshal(b []byte) error

+ type NodeMetadataValidationError struct

+ func (e NodeMetadataValidationError) Cause() error

+ func (e NodeMetadataValidationError) Error() string

+ func (e NodeMetadataValidationError) ErrorName() string

+ func (e NodeMetadataValidationError) Field() string

+ func (e NodeMetadataValidationError) Key() bool

+ func (e NodeMetadataValidationError) Reason() string

+ type NodeValidationError struct

+ func (e NodeValidationError) Cause() error

+ func (e NodeValidationError) Error() string

+ func (e NodeValidationError) ErrorName() string

+ func (e NodeValidationError) Field() string

+ func (e NodeValidationError) Key() bool

+ func (e NodeValidationError) Reason() string

+ type Node_BranchNode struct

+ BranchNode *BranchNode

+ type Node_TaskNode struct

+ TaskNode *TaskNode

+ type Node_WorkflowNode struct

+ WorkflowNode *WorkflowNode

+ type Operand struct

+ Val isOperand_Val

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Operand) Descriptor() ([]byte, []int)

+ func (*Operand) ProtoMessage()

+ func (*Operand) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *Operand) XXX_Merge(src proto.Message)

+ func (m *Operand) GetPrimitive() *Primitive

+ func (m *Operand) GetVal() isOperand_Val

+ func (m *Operand) GetVar() string

+ func (m *Operand) Reset()

+ func (m *Operand) String() string

+ func (m *Operand) Validate() error

+ func (m *Operand) XXX_DiscardUnknown()

+ func (m *Operand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Operand) XXX_Size() int

+ func (m *Operand) XXX_Unmarshal(b []byte) error

+ type OperandValidationError struct

+ func (e OperandValidationError) Cause() error

+ func (e OperandValidationError) Error() string

+ func (e OperandValidationError) ErrorName() string

+ func (e OperandValidationError) Field() string

+ func (e OperandValidationError) Key() bool

+ func (e OperandValidationError) Reason() string

+ type Operand_Primitive struct

+ Primitive *Primitive

+ type Operand_Var struct

+ Var string

+ type OutputReference struct

+ NodeId string

+ Var string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OutputReference) Descriptor() ([]byte, []int)

+ func (*OutputReference) ProtoMessage()

+ func (dst *OutputReference) XXX_Merge(src proto.Message)

+ func (m *OutputReference) GetNodeId() string

+ func (m *OutputReference) GetVar() string

+ func (m *OutputReference) Reset()

+ func (m *OutputReference) String() string

+ func (m *OutputReference) Validate() error

+ func (m *OutputReference) XXX_DiscardUnknown()

+ func (m *OutputReference) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *OutputReference) XXX_Size() int

+ func (m *OutputReference) XXX_Unmarshal(b []byte) error

+ type OutputReferenceValidationError struct

+ func (e OutputReferenceValidationError) Cause() error

+ func (e OutputReferenceValidationError) Error() string

+ func (e OutputReferenceValidationError) ErrorName() string

+ func (e OutputReferenceValidationError) Field() string

+ func (e OutputReferenceValidationError) Key() bool

+ func (e OutputReferenceValidationError) Reason() string

+ type Parameter struct

+ Behavior isParameter_Behavior

+ Var *Variable

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Parameter) Descriptor() ([]byte, []int)

+ func (*Parameter) ProtoMessage()

+ func (*Parameter) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *Parameter) XXX_Merge(src proto.Message)

+ func (m *Parameter) GetBehavior() isParameter_Behavior

+ func (m *Parameter) GetDefault() *Literal

+ func (m *Parameter) GetRequired() bool

+ func (m *Parameter) GetVar() *Variable

+ func (m *Parameter) Reset()

+ func (m *Parameter) String() string

+ func (m *Parameter) Validate() error

+ func (m *Parameter) XXX_DiscardUnknown()

+ func (m *Parameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Parameter) XXX_Size() int

+ func (m *Parameter) XXX_Unmarshal(b []byte) error

+ type ParameterMap struct

+ Parameters map[string]*Parameter

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ParameterMap) Descriptor() ([]byte, []int)

+ func (*ParameterMap) ProtoMessage()

+ func (dst *ParameterMap) XXX_Merge(src proto.Message)

+ func (m *ParameterMap) GetParameters() map[string]*Parameter

+ func (m *ParameterMap) Reset()

+ func (m *ParameterMap) String() string

+ func (m *ParameterMap) Validate() error

+ func (m *ParameterMap) XXX_DiscardUnknown()

+ func (m *ParameterMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ParameterMap) XXX_Size() int

+ func (m *ParameterMap) XXX_Unmarshal(b []byte) error

+ type ParameterMapValidationError struct

+ func (e ParameterMapValidationError) Cause() error

+ func (e ParameterMapValidationError) Error() string

+ func (e ParameterMapValidationError) ErrorName() string

+ func (e ParameterMapValidationError) Field() string

+ func (e ParameterMapValidationError) Key() bool

+ func (e ParameterMapValidationError) Reason() string

+ type ParameterValidationError struct

+ func (e ParameterValidationError) Cause() error

+ func (e ParameterValidationError) Error() string

+ func (e ParameterValidationError) ErrorName() string

+ func (e ParameterValidationError) Field() string

+ func (e ParameterValidationError) Key() bool

+ func (e ParameterValidationError) Reason() string

+ type Parameter_Default struct

+ Default *Literal

+ type Parameter_Required struct

+ Required bool

+ type Primitive struct

+ Value isPrimitive_Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Primitive) Descriptor() ([]byte, []int)

+ func (*Primitive) ProtoMessage()

+ func (*Primitive) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *Primitive) XXX_Merge(src proto.Message)

+ func (m *Primitive) GetBoolean() bool

+ func (m *Primitive) GetDatetime() *timestamp.Timestamp

+ func (m *Primitive) GetDuration() *duration.Duration

+ func (m *Primitive) GetFloatValue() float64

+ func (m *Primitive) GetInteger() int64

+ func (m *Primitive) GetStringValue() string

+ func (m *Primitive) GetValue() isPrimitive_Value

+ func (m *Primitive) Reset()

+ func (m *Primitive) String() string

+ func (m *Primitive) Validate() error

+ func (m *Primitive) XXX_DiscardUnknown()

+ func (m *Primitive) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Primitive) XXX_Size() int

+ func (m *Primitive) XXX_Unmarshal(b []byte) error

+ type PrimitiveValidationError struct

+ func (e PrimitiveValidationError) Cause() error

+ func (e PrimitiveValidationError) Error() string

+ func (e PrimitiveValidationError) ErrorName() string

+ func (e PrimitiveValidationError) Field() string

+ func (e PrimitiveValidationError) Key() bool

+ func (e PrimitiveValidationError) Reason() string

+ type Primitive_Boolean struct

+ Boolean bool

+ type Primitive_Datetime struct

+ Datetime *timestamp.Timestamp

+ type Primitive_Duration struct

+ Duration *duration.Duration

+ type Primitive_FloatValue struct

+ FloatValue float64

+ type Primitive_Integer struct

+ Integer int64

+ type Primitive_StringValue struct

+ StringValue string

+ type ResourceType int32

+ const ResourceType_LAUNCH_PLAN

+ const ResourceType_TASK

+ const ResourceType_UNSPECIFIED

+ const ResourceType_WORKFLOW

+ func (ResourceType) EnumDescriptor() ([]byte, []int)

+ func (x ResourceType) String() string

+ type Resources struct

+ Limits []*Resources_ResourceEntry

+ Requests []*Resources_ResourceEntry

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Resources) Descriptor() ([]byte, []int)

+ func (*Resources) ProtoMessage()

+ func (dst *Resources) XXX_Merge(src proto.Message)

+ func (m *Resources) GetLimits() []*Resources_ResourceEntry

+ func (m *Resources) GetRequests() []*Resources_ResourceEntry

+ func (m *Resources) Reset()

+ func (m *Resources) String() string

+ func (m *Resources) Validate() error

+ func (m *Resources) XXX_DiscardUnknown()

+ func (m *Resources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Resources) XXX_Size() int

+ func (m *Resources) XXX_Unmarshal(b []byte) error

+ type ResourcesValidationError struct

+ func (e ResourcesValidationError) Cause() error

+ func (e ResourcesValidationError) Error() string

+ func (e ResourcesValidationError) ErrorName() string

+ func (e ResourcesValidationError) Field() string

+ func (e ResourcesValidationError) Key() bool

+ func (e ResourcesValidationError) Reason() string

+ type Resources_ResourceEntry struct

+ Name Resources_ResourceName

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Resources_ResourceEntry) Descriptor() ([]byte, []int)

+ func (*Resources_ResourceEntry) ProtoMessage()

+ func (dst *Resources_ResourceEntry) XXX_Merge(src proto.Message)

+ func (m *Resources_ResourceEntry) GetName() Resources_ResourceName

+ func (m *Resources_ResourceEntry) GetValue() string

+ func (m *Resources_ResourceEntry) Reset()

+ func (m *Resources_ResourceEntry) String() string

+ func (m *Resources_ResourceEntry) Validate() error

+ func (m *Resources_ResourceEntry) XXX_DiscardUnknown()

+ func (m *Resources_ResourceEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Resources_ResourceEntry) XXX_Size() int

+ func (m *Resources_ResourceEntry) XXX_Unmarshal(b []byte) error

+ type Resources_ResourceEntryValidationError struct

+ func (e Resources_ResourceEntryValidationError) Cause() error

+ func (e Resources_ResourceEntryValidationError) Error() string

+ func (e Resources_ResourceEntryValidationError) ErrorName() string

+ func (e Resources_ResourceEntryValidationError) Field() string

+ func (e Resources_ResourceEntryValidationError) Key() bool

+ func (e Resources_ResourceEntryValidationError) Reason() string

+ type Resources_ResourceName int32

+ const Resources_CPU

+ const Resources_GPU

+ const Resources_MEMORY

+ const Resources_STORAGE

+ const Resources_UNKNOWN

+ func (Resources_ResourceName) EnumDescriptor() ([]byte, []int)

+ func (x Resources_ResourceName) String() string

+ type RetryStrategy struct

+ Retries uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RetryStrategy) Descriptor() ([]byte, []int)

+ func (*RetryStrategy) ProtoMessage()

+ func (dst *RetryStrategy) XXX_Merge(src proto.Message)

+ func (m *RetryStrategy) GetRetries() uint32

+ func (m *RetryStrategy) Reset()

+ func (m *RetryStrategy) String() string

+ func (m *RetryStrategy) Validate() error

+ func (m *RetryStrategy) XXX_DiscardUnknown()

+ func (m *RetryStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RetryStrategy) XXX_Size() int

+ func (m *RetryStrategy) XXX_Unmarshal(b []byte) error

+ type RetryStrategyValidationError struct

+ func (e RetryStrategyValidationError) Cause() error

+ func (e RetryStrategyValidationError) Error() string

+ func (e RetryStrategyValidationError) ErrorName() string

+ func (e RetryStrategyValidationError) Field() string

+ func (e RetryStrategyValidationError) Key() bool

+ func (e RetryStrategyValidationError) Reason() string

+ type RuntimeMetadata struct

+ Flavor string

+ Type RuntimeMetadata_RuntimeType

+ Version string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RuntimeMetadata) Descriptor() ([]byte, []int)

+ func (*RuntimeMetadata) ProtoMessage()

+ func (dst *RuntimeMetadata) XXX_Merge(src proto.Message)

+ func (m *RuntimeMetadata) GetFlavor() string

+ func (m *RuntimeMetadata) GetType() RuntimeMetadata_RuntimeType

+ func (m *RuntimeMetadata) GetVersion() string

+ func (m *RuntimeMetadata) Reset()

+ func (m *RuntimeMetadata) String() string

+ func (m *RuntimeMetadata) Validate() error

+ func (m *RuntimeMetadata) XXX_DiscardUnknown()

+ func (m *RuntimeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RuntimeMetadata) XXX_Size() int

+ func (m *RuntimeMetadata) XXX_Unmarshal(b []byte) error

+ type RuntimeMetadataValidationError struct

+ func (e RuntimeMetadataValidationError) Cause() error

+ func (e RuntimeMetadataValidationError) Error() string

+ func (e RuntimeMetadataValidationError) ErrorName() string

+ func (e RuntimeMetadataValidationError) Field() string

+ func (e RuntimeMetadataValidationError) Key() bool

+ func (e RuntimeMetadataValidationError) Reason() string

+ type RuntimeMetadata_RuntimeType int32

+ const RuntimeMetadata_FLYTE_SDK

+ const RuntimeMetadata_OTHER

+ func (RuntimeMetadata_RuntimeType) EnumDescriptor() ([]byte, []int)

+ func (x RuntimeMetadata_RuntimeType) String() string

+ type Scalar struct

+ Value isScalar_Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Scalar) Descriptor() ([]byte, []int)

+ func (*Scalar) ProtoMessage()

+ func (*Scalar) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *Scalar) XXX_Merge(src proto.Message)

+ func (m *Scalar) GetBinary() *Binary

+ func (m *Scalar) GetBlob() *Blob

+ func (m *Scalar) GetError() *Error

+ func (m *Scalar) GetGeneric() *_struct.Struct

+ func (m *Scalar) GetNoneType() *Void

+ func (m *Scalar) GetPrimitive() *Primitive

+ func (m *Scalar) GetSchema() *Schema

+ func (m *Scalar) GetValue() isScalar_Value

+ func (m *Scalar) Reset()

+ func (m *Scalar) String() string

+ func (m *Scalar) Validate() error

+ func (m *Scalar) XXX_DiscardUnknown()

+ func (m *Scalar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Scalar) XXX_Size() int

+ func (m *Scalar) XXX_Unmarshal(b []byte) error

+ type ScalarValidationError struct

+ func (e ScalarValidationError) Cause() error

+ func (e ScalarValidationError) Error() string

+ func (e ScalarValidationError) ErrorName() string

+ func (e ScalarValidationError) Field() string

+ func (e ScalarValidationError) Key() bool

+ func (e ScalarValidationError) Reason() string

+ type Scalar_Binary struct

+ Binary *Binary

+ type Scalar_Blob struct

+ Blob *Blob

+ type Scalar_Error struct

+ Error *Error

+ type Scalar_Generic struct

+ Generic *_struct.Struct

+ type Scalar_NoneType struct

+ NoneType *Void

+ type Scalar_Primitive struct

+ Primitive *Primitive

+ type Scalar_Schema struct

+ Schema *Schema

+ type Schema struct

+ Type *SchemaType

+ Uri string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Schema) Descriptor() ([]byte, []int)

+ func (*Schema) ProtoMessage()

+ func (dst *Schema) XXX_Merge(src proto.Message)

+ func (m *Schema) GetType() *SchemaType

+ func (m *Schema) GetUri() string

+ func (m *Schema) Reset()

+ func (m *Schema) String() string

+ func (m *Schema) Validate() error

+ func (m *Schema) XXX_DiscardUnknown()

+ func (m *Schema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Schema) XXX_Size() int

+ func (m *Schema) XXX_Unmarshal(b []byte) error

+ type SchemaType struct

+ Columns []*SchemaType_SchemaColumn

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SchemaType) Descriptor() ([]byte, []int)

+ func (*SchemaType) ProtoMessage()

+ func (dst *SchemaType) XXX_Merge(src proto.Message)

+ func (m *SchemaType) GetColumns() []*SchemaType_SchemaColumn

+ func (m *SchemaType) Reset()

+ func (m *SchemaType) String() string

+ func (m *SchemaType) Validate() error

+ func (m *SchemaType) XXX_DiscardUnknown()

+ func (m *SchemaType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SchemaType) XXX_Size() int

+ func (m *SchemaType) XXX_Unmarshal(b []byte) error

+ type SchemaTypeValidationError struct

+ func (e SchemaTypeValidationError) Cause() error

+ func (e SchemaTypeValidationError) Error() string

+ func (e SchemaTypeValidationError) ErrorName() string

+ func (e SchemaTypeValidationError) Field() string

+ func (e SchemaTypeValidationError) Key() bool

+ func (e SchemaTypeValidationError) Reason() string

+ type SchemaType_SchemaColumn struct

+ Name string

+ Type SchemaType_SchemaColumn_SchemaColumnType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SchemaType_SchemaColumn) Descriptor() ([]byte, []int)

+ func (*SchemaType_SchemaColumn) ProtoMessage()

+ func (dst *SchemaType_SchemaColumn) XXX_Merge(src proto.Message)

+ func (m *SchemaType_SchemaColumn) GetName() string

+ func (m *SchemaType_SchemaColumn) GetType() SchemaType_SchemaColumn_SchemaColumnType

+ func (m *SchemaType_SchemaColumn) Reset()

+ func (m *SchemaType_SchemaColumn) String() string

+ func (m *SchemaType_SchemaColumn) Validate() error

+ func (m *SchemaType_SchemaColumn) XXX_DiscardUnknown()

+ func (m *SchemaType_SchemaColumn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SchemaType_SchemaColumn) XXX_Size() int

+ func (m *SchemaType_SchemaColumn) XXX_Unmarshal(b []byte) error

+ type SchemaType_SchemaColumnValidationError struct

+ func (e SchemaType_SchemaColumnValidationError) Cause() error

+ func (e SchemaType_SchemaColumnValidationError) Error() string

+ func (e SchemaType_SchemaColumnValidationError) ErrorName() string

+ func (e SchemaType_SchemaColumnValidationError) Field() string

+ func (e SchemaType_SchemaColumnValidationError) Key() bool

+ func (e SchemaType_SchemaColumnValidationError) Reason() string

+ type SchemaType_SchemaColumn_SchemaColumnType int32

+ const SchemaType_SchemaColumn_BOOLEAN

+ const SchemaType_SchemaColumn_DATETIME

+ const SchemaType_SchemaColumn_DURATION

+ const SchemaType_SchemaColumn_FLOAT

+ const SchemaType_SchemaColumn_INTEGER

+ const SchemaType_SchemaColumn_STRING

+ func (SchemaType_SchemaColumn_SchemaColumnType) EnumDescriptor() ([]byte, []int)

+ func (x SchemaType_SchemaColumn_SchemaColumnType) String() string

+ type SchemaValidationError struct

+ func (e SchemaValidationError) Cause() error

+ func (e SchemaValidationError) Error() string

+ func (e SchemaValidationError) ErrorName() string

+ func (e SchemaValidationError) Field() string

+ func (e SchemaValidationError) Key() bool

+ func (e SchemaValidationError) Reason() string

+ type SimpleType int32

+ const SimpleType_BINARY

+ const SimpleType_BOOLEAN

+ const SimpleType_DATETIME

+ const SimpleType_DURATION

+ const SimpleType_ERROR

+ const SimpleType_FLOAT

+ const SimpleType_INTEGER

+ const SimpleType_NONE

+ const SimpleType_STRING

+ const SimpleType_STRUCT

+ func (SimpleType) EnumDescriptor() ([]byte, []int)

+ func (x SimpleType) String() string

+ type TaskExecution struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TaskExecution) Descriptor() ([]byte, []int)

+ func (*TaskExecution) ProtoMessage()

+ func (dst *TaskExecution) XXX_Merge(src proto.Message)

+ func (m *TaskExecution) Reset()

+ func (m *TaskExecution) String() string

+ func (m *TaskExecution) Validate() error

+ func (m *TaskExecution) XXX_DiscardUnknown()

+ func (m *TaskExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskExecution) XXX_Size() int

+ func (m *TaskExecution) XXX_Unmarshal(b []byte) error

+ type TaskExecutionIdentifier struct

+ NodeExecutionId *NodeExecutionIdentifier

+ RetryAttempt uint32

+ TaskId *Identifier

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TaskExecutionIdentifier) Descriptor() ([]byte, []int)

+ func (*TaskExecutionIdentifier) ProtoMessage()

+ func (dst *TaskExecutionIdentifier) XXX_Merge(src proto.Message)

+ func (m *TaskExecutionIdentifier) GetNodeExecutionId() *NodeExecutionIdentifier

+ func (m *TaskExecutionIdentifier) GetRetryAttempt() uint32

+ func (m *TaskExecutionIdentifier) GetTaskId() *Identifier

+ func (m *TaskExecutionIdentifier) Reset()

+ func (m *TaskExecutionIdentifier) String() string

+ func (m *TaskExecutionIdentifier) Validate() error

+ func (m *TaskExecutionIdentifier) XXX_DiscardUnknown()

+ func (m *TaskExecutionIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskExecutionIdentifier) XXX_Size() int

+ func (m *TaskExecutionIdentifier) XXX_Unmarshal(b []byte) error

+ type TaskExecutionIdentifierValidationError struct

+ func (e TaskExecutionIdentifierValidationError) Cause() error

+ func (e TaskExecutionIdentifierValidationError) Error() string

+ func (e TaskExecutionIdentifierValidationError) ErrorName() string

+ func (e TaskExecutionIdentifierValidationError) Field() string

+ func (e TaskExecutionIdentifierValidationError) Key() bool

+ func (e TaskExecutionIdentifierValidationError) Reason() string

+ type TaskExecutionValidationError struct

+ func (e TaskExecutionValidationError) Cause() error

+ func (e TaskExecutionValidationError) Error() string

+ func (e TaskExecutionValidationError) ErrorName() string

+ func (e TaskExecutionValidationError) Field() string

+ func (e TaskExecutionValidationError) Key() bool

+ func (e TaskExecutionValidationError) Reason() string

+ type TaskExecution_Phase int32

+ const TaskExecution_ABORTED

+ const TaskExecution_FAILED

+ const TaskExecution_QUEUED

+ const TaskExecution_RUNNING

+ const TaskExecution_SUCCEEDED

+ const TaskExecution_UNDEFINED

+ func (TaskExecution_Phase) EnumDescriptor() ([]byte, []int)

+ func (x TaskExecution_Phase) String() string

+ type TaskLog struct

+ MessageFormat TaskLog_MessageFormat

+ Name string

+ Ttl *duration.Duration

+ Uri string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TaskLog) Descriptor() ([]byte, []int)

+ func (*TaskLog) ProtoMessage()

+ func (dst *TaskLog) XXX_Merge(src proto.Message)

+ func (m *TaskLog) GetMessageFormat() TaskLog_MessageFormat

+ func (m *TaskLog) GetName() string

+ func (m *TaskLog) GetTtl() *duration.Duration

+ func (m *TaskLog) GetUri() string

+ func (m *TaskLog) Reset()

+ func (m *TaskLog) String() string

+ func (m *TaskLog) Validate() error

+ func (m *TaskLog) XXX_DiscardUnknown()

+ func (m *TaskLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskLog) XXX_Size() int

+ func (m *TaskLog) XXX_Unmarshal(b []byte) error

+ type TaskLogValidationError struct

+ func (e TaskLogValidationError) Cause() error

+ func (e TaskLogValidationError) Error() string

+ func (e TaskLogValidationError) ErrorName() string

+ func (e TaskLogValidationError) Field() string

+ func (e TaskLogValidationError) Key() bool

+ func (e TaskLogValidationError) Reason() string

+ type TaskLog_MessageFormat int32

+ const TaskLog_CSV

+ const TaskLog_JSON

+ const TaskLog_UNKNOWN

+ func (TaskLog_MessageFormat) EnumDescriptor() ([]byte, []int)

+ func (x TaskLog_MessageFormat) String() string

+ type TaskMetadata struct

+ DeprecatedErrorMessage string

+ Discoverable bool

+ DiscoveryVersion string

+ Retries *RetryStrategy

+ Runtime *RuntimeMetadata

+ Timeout *duration.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TaskMetadata) Descriptor() ([]byte, []int)

+ func (*TaskMetadata) ProtoMessage()

+ func (dst *TaskMetadata) XXX_Merge(src proto.Message)

+ func (m *TaskMetadata) GetDeprecatedErrorMessage() string

+ func (m *TaskMetadata) GetDiscoverable() bool

+ func (m *TaskMetadata) GetDiscoveryVersion() string

+ func (m *TaskMetadata) GetRetries() *RetryStrategy

+ func (m *TaskMetadata) GetRuntime() *RuntimeMetadata

+ func (m *TaskMetadata) GetTimeout() *duration.Duration

+ func (m *TaskMetadata) Reset()

+ func (m *TaskMetadata) String() string

+ func (m *TaskMetadata) Validate() error

+ func (m *TaskMetadata) XXX_DiscardUnknown()

+ func (m *TaskMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskMetadata) XXX_Size() int

+ func (m *TaskMetadata) XXX_Unmarshal(b []byte) error

+ type TaskMetadataValidationError struct

+ func (e TaskMetadataValidationError) Cause() error

+ func (e TaskMetadataValidationError) Error() string

+ func (e TaskMetadataValidationError) ErrorName() string

+ func (e TaskMetadataValidationError) Field() string

+ func (e TaskMetadataValidationError) Key() bool

+ func (e TaskMetadataValidationError) Reason() string

+ type TaskNode struct

+ Reference isTaskNode_Reference

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TaskNode) Descriptor() ([]byte, []int)

+ func (*TaskNode) ProtoMessage()

+ func (*TaskNode) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *TaskNode) XXX_Merge(src proto.Message)

+ func (m *TaskNode) GetReference() isTaskNode_Reference

+ func (m *TaskNode) GetReferenceId() *Identifier

+ func (m *TaskNode) Reset()

+ func (m *TaskNode) String() string

+ func (m *TaskNode) Validate() error

+ func (m *TaskNode) XXX_DiscardUnknown()

+ func (m *TaskNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskNode) XXX_Size() int

+ func (m *TaskNode) XXX_Unmarshal(b []byte) error

+ type TaskNodeValidationError struct

+ func (e TaskNodeValidationError) Cause() error

+ func (e TaskNodeValidationError) Error() string

+ func (e TaskNodeValidationError) ErrorName() string

+ func (e TaskNodeValidationError) Field() string

+ func (e TaskNodeValidationError) Key() bool

+ func (e TaskNodeValidationError) Reason() string

+ type TaskNode_ReferenceId struct

+ ReferenceId *Identifier

+ type TaskTemplate struct

+ Custom *_struct.Struct

+ Id *Identifier

+ Interface *TypedInterface

+ Metadata *TaskMetadata

+ Target isTaskTemplate_Target

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TaskTemplate) Descriptor() ([]byte, []int)

+ func (*TaskTemplate) ProtoMessage()

+ func (*TaskTemplate) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *TaskTemplate) XXX_Merge(src proto.Message)

+ func (m *TaskTemplate) GetContainer() *Container

+ func (m *TaskTemplate) GetCustom() *_struct.Struct

+ func (m *TaskTemplate) GetId() *Identifier

+ func (m *TaskTemplate) GetInterface() *TypedInterface

+ func (m *TaskTemplate) GetMetadata() *TaskMetadata

+ func (m *TaskTemplate) GetTarget() isTaskTemplate_Target

+ func (m *TaskTemplate) GetType() string

+ func (m *TaskTemplate) Reset()

+ func (m *TaskTemplate) String() string

+ func (m *TaskTemplate) Validate() error

+ func (m *TaskTemplate) XXX_DiscardUnknown()

+ func (m *TaskTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TaskTemplate) XXX_Size() int

+ func (m *TaskTemplate) XXX_Unmarshal(b []byte) error

+ type TaskTemplateValidationError struct

+ func (e TaskTemplateValidationError) Cause() error

+ func (e TaskTemplateValidationError) Error() string

+ func (e TaskTemplateValidationError) ErrorName() string

+ func (e TaskTemplateValidationError) Field() string

+ func (e TaskTemplateValidationError) Key() bool

+ func (e TaskTemplateValidationError) Reason() string

+ type TaskTemplate_Container struct

+ Container *Container

+ type TypedInterface struct

+ Inputs *VariableMap

+ Outputs *VariableMap

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TypedInterface) Descriptor() ([]byte, []int)

+ func (*TypedInterface) ProtoMessage()

+ func (dst *TypedInterface) XXX_Merge(src proto.Message)

+ func (m *TypedInterface) GetInputs() *VariableMap

+ func (m *TypedInterface) GetOutputs() *VariableMap

+ func (m *TypedInterface) Reset()

+ func (m *TypedInterface) String() string

+ func (m *TypedInterface) Validate() error

+ func (m *TypedInterface) XXX_DiscardUnknown()

+ func (m *TypedInterface) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TypedInterface) XXX_Size() int

+ func (m *TypedInterface) XXX_Unmarshal(b []byte) error

+ type TypedInterfaceValidationError struct

+ func (e TypedInterfaceValidationError) Cause() error

+ func (e TypedInterfaceValidationError) Error() string

+ func (e TypedInterfaceValidationError) ErrorName() string

+ func (e TypedInterfaceValidationError) Field() string

+ func (e TypedInterfaceValidationError) Key() bool

+ func (e TypedInterfaceValidationError) Reason() string

+ type Variable struct

+ Description string

+ Type *LiteralType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Variable) Descriptor() ([]byte, []int)

+ func (*Variable) ProtoMessage()

+ func (dst *Variable) XXX_Merge(src proto.Message)

+ func (m *Variable) GetDescription() string

+ func (m *Variable) GetType() *LiteralType

+ func (m *Variable) Reset()

+ func (m *Variable) String() string

+ func (m *Variable) Validate() error

+ func (m *Variable) XXX_DiscardUnknown()

+ func (m *Variable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Variable) XXX_Size() int

+ func (m *Variable) XXX_Unmarshal(b []byte) error

+ type VariableMap struct

+ Variables map[string]*Variable

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*VariableMap) Descriptor() ([]byte, []int)

+ func (*VariableMap) ProtoMessage()

+ func (dst *VariableMap) XXX_Merge(src proto.Message)

+ func (m *VariableMap) GetVariables() map[string]*Variable

+ func (m *VariableMap) Reset()

+ func (m *VariableMap) String() string

+ func (m *VariableMap) Validate() error

+ func (m *VariableMap) XXX_DiscardUnknown()

+ func (m *VariableMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VariableMap) XXX_Size() int

+ func (m *VariableMap) XXX_Unmarshal(b []byte) error

+ type VariableMapValidationError struct

+ func (e VariableMapValidationError) Cause() error

+ func (e VariableMapValidationError) Error() string

+ func (e VariableMapValidationError) ErrorName() string

+ func (e VariableMapValidationError) Field() string

+ func (e VariableMapValidationError) Key() bool

+ func (e VariableMapValidationError) Reason() string

+ type VariableValidationError struct

+ func (e VariableValidationError) Cause() error

+ func (e VariableValidationError) Error() string

+ func (e VariableValidationError) ErrorName() string

+ func (e VariableValidationError) Field() string

+ func (e VariableValidationError) Key() bool

+ func (e VariableValidationError) Reason() string

+ type Void struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Void) Descriptor() ([]byte, []int)

+ func (*Void) ProtoMessage()

+ func (dst *Void) XXX_Merge(src proto.Message)

+ func (m *Void) Reset()

+ func (m *Void) String() string

+ func (m *Void) Validate() error

+ func (m *Void) XXX_DiscardUnknown()

+ func (m *Void) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Void) XXX_Size() int

+ func (m *Void) XXX_Unmarshal(b []byte) error

+ type VoidValidationError struct

+ func (e VoidValidationError) Cause() error

+ func (e VoidValidationError) Error() string

+ func (e VoidValidationError) ErrorName() string

+ func (e VoidValidationError) Field() string

+ func (e VoidValidationError) Key() bool

+ func (e VoidValidationError) Reason() string

+ type WorkflowClosure struct

+ Tasks []*TaskTemplate

+ Workflow *WorkflowTemplate

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WorkflowClosure) Descriptor() ([]byte, []int)

+ func (*WorkflowClosure) ProtoMessage()

+ func (dst *WorkflowClosure) XXX_Merge(src proto.Message)

+ func (m *WorkflowClosure) GetTasks() []*TaskTemplate

+ func (m *WorkflowClosure) GetWorkflow() *WorkflowTemplate

+ func (m *WorkflowClosure) Reset()

+ func (m *WorkflowClosure) String() string

+ func (m *WorkflowClosure) Validate() error

+ func (m *WorkflowClosure) XXX_DiscardUnknown()

+ func (m *WorkflowClosure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowClosure) XXX_Size() int

+ func (m *WorkflowClosure) XXX_Unmarshal(b []byte) error

+ type WorkflowClosureValidationError struct

+ func (e WorkflowClosureValidationError) Cause() error

+ func (e WorkflowClosureValidationError) Error() string

+ func (e WorkflowClosureValidationError) ErrorName() string

+ func (e WorkflowClosureValidationError) Field() string

+ func (e WorkflowClosureValidationError) Key() bool

+ func (e WorkflowClosureValidationError) Reason() string

+ type WorkflowExecution struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WorkflowExecution) Descriptor() ([]byte, []int)

+ func (*WorkflowExecution) ProtoMessage()

+ func (dst *WorkflowExecution) XXX_Merge(src proto.Message)

+ func (m *WorkflowExecution) Reset()

+ func (m *WorkflowExecution) String() string

+ func (m *WorkflowExecution) Validate() error

+ func (m *WorkflowExecution) XXX_DiscardUnknown()

+ func (m *WorkflowExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowExecution) XXX_Size() int

+ func (m *WorkflowExecution) XXX_Unmarshal(b []byte) error

+ type WorkflowExecutionIdentifier struct

+ Domain string

+ Name string

+ Project string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WorkflowExecutionIdentifier) Descriptor() ([]byte, []int)

+ func (*WorkflowExecutionIdentifier) ProtoMessage()

+ func (dst *WorkflowExecutionIdentifier) XXX_Merge(src proto.Message)

+ func (m *WorkflowExecutionIdentifier) GetDomain() string

+ func (m *WorkflowExecutionIdentifier) GetName() string

+ func (m *WorkflowExecutionIdentifier) GetProject() string

+ func (m *WorkflowExecutionIdentifier) Reset()

+ func (m *WorkflowExecutionIdentifier) String() string

+ func (m *WorkflowExecutionIdentifier) Validate() error

+ func (m *WorkflowExecutionIdentifier) XXX_DiscardUnknown()

+ func (m *WorkflowExecutionIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowExecutionIdentifier) XXX_Size() int

+ func (m *WorkflowExecutionIdentifier) XXX_Unmarshal(b []byte) error

+ type WorkflowExecutionIdentifierValidationError struct

+ func (e WorkflowExecutionIdentifierValidationError) Cause() error

+ func (e WorkflowExecutionIdentifierValidationError) Error() string

+ func (e WorkflowExecutionIdentifierValidationError) ErrorName() string

+ func (e WorkflowExecutionIdentifierValidationError) Field() string

+ func (e WorkflowExecutionIdentifierValidationError) Key() bool

+ func (e WorkflowExecutionIdentifierValidationError) Reason() string

+ type WorkflowExecutionValidationError struct

+ func (e WorkflowExecutionValidationError) Cause() error

+ func (e WorkflowExecutionValidationError) Error() string

+ func (e WorkflowExecutionValidationError) ErrorName() string

+ func (e WorkflowExecutionValidationError) Field() string

+ func (e WorkflowExecutionValidationError) Key() bool

+ func (e WorkflowExecutionValidationError) Reason() string

+ type WorkflowExecution_Phase int32

+ const WorkflowExecution_ABORTED

+ const WorkflowExecution_FAILED

+ const WorkflowExecution_FAILING

+ const WorkflowExecution_QUEUED

+ const WorkflowExecution_RUNNING

+ const WorkflowExecution_SUCCEEDED

+ const WorkflowExecution_SUCCEEDING

+ const WorkflowExecution_TIMED_OUT

+ const WorkflowExecution_UNDEFINED

+ func (WorkflowExecution_Phase) EnumDescriptor() ([]byte, []int)

+ func (x WorkflowExecution_Phase) String() string

+ type WorkflowMetadata struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WorkflowMetadata) Descriptor() ([]byte, []int)

+ func (*WorkflowMetadata) ProtoMessage()

+ func (dst *WorkflowMetadata) XXX_Merge(src proto.Message)

+ func (m *WorkflowMetadata) Reset()

+ func (m *WorkflowMetadata) String() string

+ func (m *WorkflowMetadata) Validate() error

+ func (m *WorkflowMetadata) XXX_DiscardUnknown()

+ func (m *WorkflowMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowMetadata) XXX_Size() int

+ func (m *WorkflowMetadata) XXX_Unmarshal(b []byte) error

+ type WorkflowMetadataValidationError struct

+ func (e WorkflowMetadataValidationError) Cause() error

+ func (e WorkflowMetadataValidationError) Error() string

+ func (e WorkflowMetadataValidationError) ErrorName() string

+ func (e WorkflowMetadataValidationError) Field() string

+ func (e WorkflowMetadataValidationError) Key() bool

+ func (e WorkflowMetadataValidationError) Reason() string

+ type WorkflowNode struct

+ Reference isWorkflowNode_Reference

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WorkflowNode) Descriptor() ([]byte, []int)

+ func (*WorkflowNode) ProtoMessage()

+ func (*WorkflowNode) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *WorkflowNode) XXX_Merge(src proto.Message)

+ func (m *WorkflowNode) GetLaunchplanRef() *Identifier

+ func (m *WorkflowNode) GetReference() isWorkflowNode_Reference

+ func (m *WorkflowNode) GetSubWorkflowRef() *Identifier

+ func (m *WorkflowNode) Reset()

+ func (m *WorkflowNode) String() string

+ func (m *WorkflowNode) Validate() error

+ func (m *WorkflowNode) XXX_DiscardUnknown()

+ func (m *WorkflowNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowNode) XXX_Size() int

+ func (m *WorkflowNode) XXX_Unmarshal(b []byte) error

+ type WorkflowNodeValidationError struct

+ func (e WorkflowNodeValidationError) Cause() error

+ func (e WorkflowNodeValidationError) Error() string

+ func (e WorkflowNodeValidationError) ErrorName() string

+ func (e WorkflowNodeValidationError) Field() string

+ func (e WorkflowNodeValidationError) Key() bool

+ func (e WorkflowNodeValidationError) Reason() string

+ type WorkflowNode_LaunchplanRef struct

+ LaunchplanRef *Identifier

+ type WorkflowNode_SubWorkflowRef struct

+ SubWorkflowRef *Identifier

+ type WorkflowTemplate struct

+ FailureNode *Node

+ Id *Identifier

+ Interface *TypedInterface

+ Metadata *WorkflowMetadata

+ Nodes []*Node

+ Outputs []*Binding

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WorkflowTemplate) Descriptor() ([]byte, []int)

+ func (*WorkflowTemplate) ProtoMessage()

+ func (dst *WorkflowTemplate) XXX_Merge(src proto.Message)

+ func (m *WorkflowTemplate) GetFailureNode() *Node

+ func (m *WorkflowTemplate) GetId() *Identifier

+ func (m *WorkflowTemplate) GetInterface() *TypedInterface

+ func (m *WorkflowTemplate) GetMetadata() *WorkflowMetadata

+ func (m *WorkflowTemplate) GetNodes() []*Node

+ func (m *WorkflowTemplate) GetOutputs() []*Binding

+ func (m *WorkflowTemplate) Reset()

+ func (m *WorkflowTemplate) String() string

+ func (m *WorkflowTemplate) Validate() error

+ func (m *WorkflowTemplate) XXX_DiscardUnknown()

+ func (m *WorkflowTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WorkflowTemplate) XXX_Size() int

+ func (m *WorkflowTemplate) XXX_Unmarshal(b []byte) error

+ type WorkflowTemplateValidationError struct

+ func (e WorkflowTemplateValidationError) Cause() error

+ func (e WorkflowTemplateValidationError) Error() string

+ func (e WorkflowTemplateValidationError) ErrorName() string

+ func (e WorkflowTemplateValidationError) Field() string

+ func (e WorkflowTemplateValidationError) Key() bool

+ func (e WorkflowTemplateValidationError) Reason() string

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