core

package

Go to main page

Versions in this module

v1

v1.14.1

Dec 20, 2024

Changes in this version

+ var ArrayNode_DataMode_name = map[int32]string

+ var ArrayNode_DataMode_value = map[string]int32

type ArrayNode

+ DataMode ArrayNode_DataMode

+ func (x *ArrayNode) GetDataMode() ArrayNode_DataMode

+ type ArrayNode_DataMode int32

+ const ArrayNode_INDIVIDUAL_INPUT_FILES

+ const ArrayNode_SINGLE_INPUT_FILE

+ func (ArrayNode_DataMode) Descriptor() protoreflect.EnumDescriptor

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

+ func (ArrayNode_DataMode) Type() protoreflect.EnumType

+ func (x ArrayNode_DataMode) Enum() *ArrayNode_DataMode

+ func (x ArrayNode_DataMode) Number() protoreflect.EnumNumber

+ func (x ArrayNode_DataMode) String() string

type BindingData

+ func (x *BindingData) GetOffloadedMetadata() *LiteralOffloadedMetadata

+ type BindingData_OffloadedMetadata struct

+ OffloadedMetadata *LiteralOffloadedMetadata

v1.14.0

Dec 6, 2024

v1.13.9

Dec 2, 2024

Changes in this version

type ArrayNode

+ IsOriginalSubNodeInterface *wrapperspb.BoolValue

+ func (x *ArrayNode) GetIsOriginalSubNodeInterface() *wrapperspb.BoolValue

v1.13.8

Dec 2, 2024

Changes in this version

type TaskMetadata

+ IsEager bool

+ func (x *TaskMetadata) GetIsEager() bool

v1.13.7

Nov 15, 2024

Changes in this version

type ContainerError

+ Timestamp *timestamppb.Timestamp

+ Worker string

+ func (x *ContainerError) GetTimestamp() *timestamppb.Timestamp

+ func (x *ContainerError) GetWorker() string

type ExecutionError

+ Timestamp *timestamppb.Timestamp

+ Worker string

+ func (x *ExecutionError) GetTimestamp() *timestamppb.Timestamp

+ func (x *ExecutionError) GetWorker() string

v1.13.6

Nov 12, 2024

v1.13.5

Oct 23, 2024

v1.13.4

Sep 16, 2024

Changes in this version

type Literal

+ func (x *Literal) GetOffloadedMetadata() *LiteralOffloadedMetadata

+ type LiteralOffloadedMetadata struct

+ InferredType *LiteralType

+ SizeBytes uint64

+ Uri string

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

+ func (*LiteralOffloadedMetadata) ProtoMessage()

+ func (x *LiteralOffloadedMetadata) GetInferredType() *LiteralType

+ func (x *LiteralOffloadedMetadata) GetSizeBytes() uint64

+ func (x *LiteralOffloadedMetadata) GetUri() string

+ func (x *LiteralOffloadedMetadata) ProtoReflect() protoreflect.Message

+ func (x *LiteralOffloadedMetadata) Reset()

+ func (x *LiteralOffloadedMetadata) String() string

+ type Literal_OffloadedMetadata struct

+ OffloadedMetadata *LiteralOffloadedMetadata

v1.13.3

Aug 28, 2024

v1.13.2

Aug 14, 2024

Changes in this version

type Literal

+ SizeBytes uint64

+ Uri string

+ func (x *Literal) GetSizeBytes() uint64

+ func (x *Literal) GetUri() string

v1.13.1

Aug 8, 2024

Changes in this version

+ var ArrayNode_ExecutionMode_name = map[int32]string

+ var ArrayNode_ExecutionMode_value = map[string]int32

type ArrayNode

+ ExecutionMode ArrayNode_ExecutionMode

+ func (x *ArrayNode) GetExecutionMode() ArrayNode_ExecutionMode

+ type ArrayNode_ExecutionMode int32

+ const ArrayNode_FULL_STATE

+ const ArrayNode_MINIMAL_STATE

+ func (ArrayNode_ExecutionMode) Descriptor() protoreflect.EnumDescriptor

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

+ func (ArrayNode_ExecutionMode) Type() protoreflect.EnumType

+ func (x ArrayNode_ExecutionMode) Enum() *ArrayNode_ExecutionMode

+ func (x ArrayNode_ExecutionMode) Number() protoreflect.EnumNumber

+ func (x ArrayNode_ExecutionMode) String() string

v1.13.0

Jul 3, 2024

Changes in this version

type ExecutionEnv

+ Name string

+ Version string

+ func (x *ExecutionEnv) GetName() string

+ func (x *ExecutionEnv) GetVersion() string

type TaskLog

+ HideOnceFinished bool

+ ShowWhilePending bool

+ func (x *TaskLog) GetHideOnceFinished() bool

+ func (x *TaskLog) GetShowWhilePending() bool

v1.13.0-rc0

Jun 26, 2024

v1.12.1-rc0

May 31, 2024

v1.12.0

May 6, 2024

Changes in this version

+ var File_flyteidl_core_execution_envs_proto protoreflect.FileDescriptor

type ArrayNode

+ ParallelismOption isArrayNode_ParallelismOption

+ func (m *ArrayNode) GetParallelismOption() isArrayNode_ParallelismOption

+ type ArrayNode_Parallelism struct

+ Parallelism uint32

+ type ExecutionEnv struct

+ Environment isExecutionEnv_Environment

+ Id string

+ Type string

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

+ func (*ExecutionEnv) ProtoMessage()

+ func (m *ExecutionEnv) GetEnvironment() isExecutionEnv_Environment

+ func (x *ExecutionEnv) GetExtant() *structpb.Struct

+ func (x *ExecutionEnv) GetId() string

+ func (x *ExecutionEnv) GetSpec() *structpb.Struct

+ func (x *ExecutionEnv) GetType() string

+ func (x *ExecutionEnv) ProtoReflect() protoreflect.Message

+ func (x *ExecutionEnv) Reset()

+ func (x *ExecutionEnv) String() string

+ type ExecutionEnvAssignment struct

+ ExecutionEnv *ExecutionEnv

+ NodeIds []string

+ TaskType string

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

+ func (*ExecutionEnvAssignment) ProtoMessage()

+ func (x *ExecutionEnvAssignment) GetExecutionEnv() *ExecutionEnv

+ func (x *ExecutionEnvAssignment) GetNodeIds() []string

+ func (x *ExecutionEnvAssignment) GetTaskType() string

+ func (x *ExecutionEnvAssignment) ProtoReflect() protoreflect.Message

+ func (x *ExecutionEnvAssignment) Reset()

+ func (x *ExecutionEnvAssignment) String() string

+ type ExecutionEnv_Extant struct

+ Extant *structpb.Struct

+ type ExecutionEnv_Spec struct

+ Spec *structpb.Struct

v1.12.0-b0

Apr 29, 2024

v1.11.1-b1

Mar 29, 2024

v1.11.1-b0

Mar 21, 2024

v1.11.0

Mar 12, 2024

Changes in this version

+ var Granularity_name = map[int32]string

+ var Granularity_value = map[string]int32

+ var Operator_name = map[int32]string

+ var Operator_value = map[string]int32

type ArtifactBindingData

+ TimeTransform *TimeTransform

+ func (x *ArtifactBindingData) GetTimeTransform() *TimeTransform

type ArtifactKey

+ Org string

+ func (x *ArtifactKey) GetOrg() string

+ type Granularity int32

+ const Granularity_DAY

+ const Granularity_HOUR

+ const Granularity_MINUTE

+ const Granularity_MONTH

+ const Granularity_UNSET

+ func (Granularity) Descriptor() protoreflect.EnumDescriptor

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

+ func (Granularity) Type() protoreflect.EnumType

+ func (x Granularity) Enum() *Granularity

+ func (x Granularity) Number() protoreflect.EnumNumber

+ func (x Granularity) String() string

type LabelValue

+ func (x *LabelValue) GetRuntimeBinding() *RuntimeBinding

+ type LabelValue_RuntimeBinding struct

+ RuntimeBinding *RuntimeBinding

type LaunchPlanTemplate

+ FixedInputs *LiteralMap

+ func (x *LaunchPlanTemplate) GetFixedInputs() *LiteralMap

+ type Operator int32

+ const Operator_MINUS

+ const Operator_PLUS

+ func (Operator) Descriptor() protoreflect.EnumDescriptor

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

+ func (Operator) Type() protoreflect.EnumType

+ func (x Operator) Enum() *Operator

+ func (x Operator) Number() protoreflect.EnumNumber

+ func (x Operator) String() string

+ type RuntimeBinding struct

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

+ func (*RuntimeBinding) ProtoMessage()

+ func (x *RuntimeBinding) ProtoReflect() protoreflect.Message

+ func (x *RuntimeBinding) Reset()

+ func (x *RuntimeBinding) String() string

type TaskNodeOverrides

+ ContainerImage string

+ func (x *TaskNodeOverrides) GetContainerImage() string

type TimePartition

+ Granularity Granularity

+ func (x *TimePartition) GetGranularity() Granularity

+ type TimeTransform struct

+ Op Operator

+ Transform string

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

+ func (*TimeTransform) ProtoMessage()

+ func (x *TimeTransform) GetOp() Operator

+ func (x *TimeTransform) GetTransform() string

+ func (x *TimeTransform) ProtoReflect() protoreflect.Message

+ func (x *TimeTransform) Reset()

+ func (x *TimeTransform) String() string

v1.11.0-b1

Mar 5, 2024

v1.11.0-b0

Feb 29, 2024

v1.10.7

Feb 14, 2024

Changes in this version

+ var File_flyteidl_core_artifact_id_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_catalog_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_compiler_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_condition_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_dynamic_job_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_errors_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_execution_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_identifier_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_interface_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_literals_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_metrics_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_security_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_tasks_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_types_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_workflow_closure_proto protoreflect.FileDescriptor

+ var File_flyteidl_core_workflow_proto protoreflect.FileDescriptor

type Alias

+ func (x *Alias) ProtoReflect() protoreflect.Message

type ApproveCondition

+ func (x *ApproveCondition) ProtoReflect() protoreflect.Message

type ArrayNode

+ func (x *ArrayNode) ProtoReflect() protoreflect.Message

+ type ArtifactBindingData struct

+ Index uint32

+ PartitionData isArtifactBindingData_PartitionData

+ Transform string

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

+ func (*ArtifactBindingData) ProtoMessage()

+ func (m *ArtifactBindingData) GetPartitionData() isArtifactBindingData_PartitionData

+ func (x *ArtifactBindingData) GetBindToTimePartition() bool

+ func (x *ArtifactBindingData) GetIndex() uint32

+ func (x *ArtifactBindingData) GetPartitionKey() string

+ func (x *ArtifactBindingData) GetTransform() string

+ func (x *ArtifactBindingData) ProtoReflect() protoreflect.Message

+ func (x *ArtifactBindingData) Reset()

+ func (x *ArtifactBindingData) String() string

+ type ArtifactBindingData_BindToTimePartition struct

+ BindToTimePartition bool

+ type ArtifactBindingData_PartitionKey struct

+ PartitionKey string

+ type ArtifactID struct

+ ArtifactKey *ArtifactKey

+ Partitions *Partitions

+ TimePartition *TimePartition

+ Version string

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

+ func (*ArtifactID) ProtoMessage()

+ func (x *ArtifactID) GetArtifactKey() *ArtifactKey

+ func (x *ArtifactID) GetPartitions() *Partitions

+ func (x *ArtifactID) GetTimePartition() *TimePartition

+ func (x *ArtifactID) GetVersion() string

+ func (x *ArtifactID) ProtoReflect() protoreflect.Message

+ func (x *ArtifactID) Reset()

+ func (x *ArtifactID) String() string

+ type ArtifactKey struct

+ Domain string

+ Name string

+ Project string

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

+ func (*ArtifactKey) ProtoMessage()

+ func (x *ArtifactKey) GetDomain() string

+ func (x *ArtifactKey) GetName() string

+ func (x *ArtifactKey) GetProject() string

+ func (x *ArtifactKey) ProtoReflect() protoreflect.Message

+ func (x *ArtifactKey) Reset()

+ func (x *ArtifactKey) String() string

+ type ArtifactQuery struct

+ Identifier isArtifactQuery_Identifier

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

+ func (*ArtifactQuery) ProtoMessage()

+ func (m *ArtifactQuery) GetIdentifier() isArtifactQuery_Identifier

+ func (x *ArtifactQuery) GetArtifactId() *ArtifactID

+ func (x *ArtifactQuery) GetArtifactTag() *ArtifactTag

+ func (x *ArtifactQuery) GetBinding() *ArtifactBindingData

+ func (x *ArtifactQuery) GetUri() string

+ func (x *ArtifactQuery) ProtoReflect() protoreflect.Message

+ func (x *ArtifactQuery) Reset()

+ func (x *ArtifactQuery) String() string

+ type ArtifactQuery_ArtifactId struct

+ ArtifactId *ArtifactID

+ type ArtifactQuery_ArtifactTag struct

+ ArtifactTag *ArtifactTag

+ type ArtifactQuery_Binding struct

+ Binding *ArtifactBindingData

+ type ArtifactQuery_Uri struct

+ Uri string

+ type ArtifactTag struct

+ ArtifactKey *ArtifactKey

+ Value *LabelValue

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

+ func (*ArtifactTag) ProtoMessage()

+ func (x *ArtifactTag) GetArtifactKey() *ArtifactKey

+ func (x *ArtifactTag) GetValue() *LabelValue

+ func (x *ArtifactTag) ProtoReflect() protoreflect.Message

+ func (x *ArtifactTag) Reset()

+ func (x *ArtifactTag) String() string

type Binary

+ func (x *Binary) ProtoReflect() protoreflect.Message

type Binding

+ func (x *Binding) ProtoReflect() protoreflect.Message

type BindingData

+ func (x *BindingData) ProtoReflect() protoreflect.Message

type BindingDataCollection

+ func (x *BindingDataCollection) ProtoReflect() protoreflect.Message

type BindingDataMap

+ func (x *BindingDataMap) ProtoReflect() protoreflect.Message

type Blob

+ func (x *Blob) ProtoReflect() protoreflect.Message

type BlobMetadata

+ func (x *BlobMetadata) ProtoReflect() protoreflect.Message

type BlobType

+ func (x *BlobType) ProtoReflect() protoreflect.Message

type BlobType_BlobDimensionality

+ func (BlobType_BlobDimensionality) Descriptor() protoreflect.EnumDescriptor

+ func (BlobType_BlobDimensionality) Type() protoreflect.EnumType

+ func (x BlobType_BlobDimensionality) Enum() *BlobType_BlobDimensionality

+ func (x BlobType_BlobDimensionality) Number() protoreflect.EnumNumber

type BooleanExpression

+ func (x *BooleanExpression) ProtoReflect() protoreflect.Message

type BranchNode

+ func (x *BranchNode) ProtoReflect() protoreflect.Message

type CatalogArtifactTag

+ func (x *CatalogArtifactTag) ProtoReflect() protoreflect.Message

type CatalogCacheStatus

+ const CatalogCacheStatus_CACHE_EVICTED

+ func (CatalogCacheStatus) Descriptor() protoreflect.EnumDescriptor

+ func (CatalogCacheStatus) Type() protoreflect.EnumType

+ func (x CatalogCacheStatus) Enum() *CatalogCacheStatus

+ func (x CatalogCacheStatus) Number() protoreflect.EnumNumber

type CatalogMetadata

+ func (x *CatalogMetadata) ProtoReflect() protoreflect.Message

type CatalogReservation

+ func (x *CatalogReservation) ProtoReflect() protoreflect.Message

type CatalogReservation_Status

+ func (CatalogReservation_Status) Descriptor() protoreflect.EnumDescriptor

+ func (CatalogReservation_Status) Type() protoreflect.EnumType

+ func (x CatalogReservation_Status) Enum() *CatalogReservation_Status

+ func (x CatalogReservation_Status) Number() protoreflect.EnumNumber

type ComparisonExpression

+ func (x *ComparisonExpression) ProtoReflect() protoreflect.Message

type ComparisonExpression_Operator

+ func (ComparisonExpression_Operator) Descriptor() protoreflect.EnumDescriptor

+ func (ComparisonExpression_Operator) Type() protoreflect.EnumType

+ func (x ComparisonExpression_Operator) Enum() *ComparisonExpression_Operator

+ func (x ComparisonExpression_Operator) Number() protoreflect.EnumNumber

+ type CompiledLaunchPlan struct

+ Template *LaunchPlanTemplate

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

+ func (*CompiledLaunchPlan) ProtoMessage()

+ func (x *CompiledLaunchPlan) GetTemplate() *LaunchPlanTemplate

+ func (x *CompiledLaunchPlan) ProtoReflect() protoreflect.Message

+ func (x *CompiledLaunchPlan) Reset()

+ func (x *CompiledLaunchPlan) String() string

type CompiledTask

+ func (x *CompiledTask) ProtoReflect() protoreflect.Message

type CompiledWorkflow

+ func (x *CompiledWorkflow) ProtoReflect() protoreflect.Message

type CompiledWorkflowClosure

+ LaunchPlans []*CompiledLaunchPlan

+ func (x *CompiledWorkflowClosure) GetLaunchPlans() []*CompiledLaunchPlan

+ func (x *CompiledWorkflowClosure) ProtoReflect() protoreflect.Message

type ConjunctionExpression

+ func (x *ConjunctionExpression) ProtoReflect() protoreflect.Message

type ConjunctionExpression_LogicalOperator

+ func (ConjunctionExpression_LogicalOperator) Descriptor() protoreflect.EnumDescriptor

+ func (ConjunctionExpression_LogicalOperator) Type() protoreflect.EnumType

+ func (x ConjunctionExpression_LogicalOperator) Enum() *ConjunctionExpression_LogicalOperator

+ func (x ConjunctionExpression_LogicalOperator) Number() protoreflect.EnumNumber

type ConnectionSet

+ func (x *ConnectionSet) ProtoReflect() protoreflect.Message

type ConnectionSet_IdList

+ func (x *ConnectionSet_IdList) ProtoReflect() protoreflect.Message

type Container

+ func (x *Container) ProtoReflect() protoreflect.Message

type ContainerError

+ func (x *ContainerError) ProtoReflect() protoreflect.Message

type ContainerError_Kind

+ func (ContainerError_Kind) Descriptor() protoreflect.EnumDescriptor

+ func (ContainerError_Kind) Type() protoreflect.EnumType

+ func (x ContainerError_Kind) Enum() *ContainerError_Kind

+ func (x ContainerError_Kind) Number() protoreflect.EnumNumber

type ContainerPort

+ func (x *ContainerPort) ProtoReflect() protoreflect.Message

type Container_Architecture

+ func (Container_Architecture) Descriptor() protoreflect.EnumDescriptor

+ func (Container_Architecture) Type() protoreflect.EnumType

+ func (x Container_Architecture) Enum() *Container_Architecture

+ func (x Container_Architecture) Number() protoreflect.EnumNumber

type DataLoadingConfig

+ func (x *DataLoadingConfig) ProtoReflect() protoreflect.Message

type DataLoadingConfig_LiteralMapFormat

+ func (DataLoadingConfig_LiteralMapFormat) Descriptor() protoreflect.EnumDescriptor

+ func (DataLoadingConfig_LiteralMapFormat) Type() protoreflect.EnumType

+ func (x DataLoadingConfig_LiteralMapFormat) Enum() *DataLoadingConfig_LiteralMapFormat

+ func (x DataLoadingConfig_LiteralMapFormat) Number() protoreflect.EnumNumber

type DynamicJobSpec

+ func (x *DynamicJobSpec) ProtoReflect() protoreflect.Message

type EnumType

+ func (x *EnumType) ProtoReflect() protoreflect.Message

type Error

+ func (x *Error) ProtoReflect() protoreflect.Message

type ErrorDocument

+ func (x *ErrorDocument) ProtoReflect() protoreflect.Message

type ExecutionError

+ func (x *ExecutionError) ProtoReflect() protoreflect.Message

type ExecutionError_ErrorKind

+ func (ExecutionError_ErrorKind) Descriptor() protoreflect.EnumDescriptor

+ func (ExecutionError_ErrorKind) Type() protoreflect.EnumType

+ func (x ExecutionError_ErrorKind) Enum() *ExecutionError_ErrorKind

+ func (x ExecutionError_ErrorKind) Number() protoreflect.EnumNumber

+ type ExecutionMetricResult struct

+ Data *structpb.Struct

+ Metric string

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

+ func (*ExecutionMetricResult) ProtoMessage()

+ func (x *ExecutionMetricResult) GetData() *structpb.Struct

+ func (x *ExecutionMetricResult) GetMetric() string

+ func (x *ExecutionMetricResult) ProtoReflect() protoreflect.Message

+ func (x *ExecutionMetricResult) Reset()

+ func (x *ExecutionMetricResult) String() string

type ExtendedResources

+ func (x *ExtendedResources) ProtoReflect() protoreflect.Message

type GPUAccelerator

+ func (x *GPUAccelerator) ProtoReflect() protoreflect.Message

type GateNode

+ func (x *GateNode) ProtoReflect() protoreflect.Message

type IOStrategy

+ func (x *IOStrategy) ProtoReflect() protoreflect.Message

type IOStrategy_DownloadMode

+ func (IOStrategy_DownloadMode) Descriptor() protoreflect.EnumDescriptor

+ func (IOStrategy_DownloadMode) Type() protoreflect.EnumType

+ func (x IOStrategy_DownloadMode) Enum() *IOStrategy_DownloadMode

+ func (x IOStrategy_DownloadMode) Number() protoreflect.EnumNumber

type IOStrategy_UploadMode

+ func (IOStrategy_UploadMode) Descriptor() protoreflect.EnumDescriptor

+ func (IOStrategy_UploadMode) Type() protoreflect.EnumType

+ func (x IOStrategy_UploadMode) Enum() *IOStrategy_UploadMode

+ func (x IOStrategy_UploadMode) Number() protoreflect.EnumNumber

type Identifier

+ Org string

+ func (x *Identifier) GetOrg() string

+ func (x *Identifier) ProtoReflect() protoreflect.Message

type Identity

+ func (x *Identity) ProtoReflect() protoreflect.Message

type IfBlock

+ func (x *IfBlock) ProtoReflect() protoreflect.Message

type IfElseBlock

+ func (x *IfElseBlock) ProtoReflect() protoreflect.Message

+ type InputBindingData struct

+ Var string

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

+ func (*InputBindingData) ProtoMessage()

+ func (x *InputBindingData) GetVar() string

+ func (x *InputBindingData) ProtoReflect() protoreflect.Message

+ func (x *InputBindingData) Reset()

+ func (x *InputBindingData) String() string

type K8SObjectMetadata

+ func (x *K8SObjectMetadata) ProtoReflect() protoreflect.Message

type K8SPod

+ func (x *K8SPod) ProtoReflect() protoreflect.Message

type KeyValuePair

+ func (x *KeyValuePair) ProtoReflect() protoreflect.Message

+ type LabelValue struct

+ Value isLabelValue_Value

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

+ func (*LabelValue) ProtoMessage()

+ func (m *LabelValue) GetValue() isLabelValue_Value

+ func (x *LabelValue) GetInputBinding() *InputBindingData

+ func (x *LabelValue) GetStaticValue() string

+ func (x *LabelValue) GetTimeValue() *timestamppb.Timestamp

+ func (x *LabelValue) GetTriggeredBinding() *ArtifactBindingData

+ func (x *LabelValue) ProtoReflect() protoreflect.Message

+ func (x *LabelValue) Reset()

+ func (x *LabelValue) String() string

+ type LabelValue_InputBinding struct

+ InputBinding *InputBindingData

+ type LabelValue_StaticValue struct

+ StaticValue string

+ type LabelValue_TimeValue struct

+ TimeValue *timestamppb.Timestamp

+ type LabelValue_TriggeredBinding struct

+ TriggeredBinding *ArtifactBindingData

+ type LaunchPlanTemplate struct

+ Id *Identifier

+ Interface *TypedInterface

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

+ func (*LaunchPlanTemplate) ProtoMessage()

+ func (x *LaunchPlanTemplate) GetId() *Identifier

+ func (x *LaunchPlanTemplate) GetInterface() *TypedInterface

+ func (x *LaunchPlanTemplate) ProtoReflect() protoreflect.Message

+ func (x *LaunchPlanTemplate) Reset()

+ func (x *LaunchPlanTemplate) String() string

type Literal

+ Metadata map[string]string

+ func (x *Literal) GetMetadata() map[string]string

+ func (x *Literal) ProtoReflect() protoreflect.Message

type LiteralCollection

+ func (x *LiteralCollection) ProtoReflect() protoreflect.Message

type LiteralMap

+ func (x *LiteralMap) ProtoReflect() protoreflect.Message

type LiteralType

+ func (x *LiteralType) ProtoReflect() protoreflect.Message

type Node

+ func (x *Node) ProtoReflect() protoreflect.Message

type NodeExecution

+ func (x *NodeExecution) ProtoReflect() protoreflect.Message

type NodeExecutionIdentifier

+ func (x *NodeExecutionIdentifier) ProtoReflect() protoreflect.Message

type NodeExecution_Phase

+ func (NodeExecution_Phase) Descriptor() protoreflect.EnumDescriptor

+ func (NodeExecution_Phase) Type() protoreflect.EnumType

+ func (x NodeExecution_Phase) Enum() *NodeExecution_Phase

+ func (x NodeExecution_Phase) Number() protoreflect.EnumNumber

type NodeMetadata

+ CacheSerializableValue isNodeMetadata_CacheSerializableValue

+ CacheVersionValue isNodeMetadata_CacheVersionValue

+ CacheableValue isNodeMetadata_CacheableValue

+ func (m *NodeMetadata) GetCacheSerializableValue() isNodeMetadata_CacheSerializableValue

+ func (m *NodeMetadata) GetCacheVersionValue() isNodeMetadata_CacheVersionValue

+ func (m *NodeMetadata) GetCacheableValue() isNodeMetadata_CacheableValue

+ func (x *NodeMetadata) GetCacheSerializable() bool

+ func (x *NodeMetadata) GetCacheVersion() string

+ func (x *NodeMetadata) GetCacheable() bool

+ func (x *NodeMetadata) ProtoReflect() protoreflect.Message

+ type NodeMetadata_CacheSerializable struct

+ CacheSerializable bool

+ type NodeMetadata_CacheVersion struct

+ CacheVersion string

+ type NodeMetadata_Cacheable struct

+ Cacheable bool

type OAuth2Client

+ func (x *OAuth2Client) ProtoReflect() protoreflect.Message

type OAuth2TokenRequest

+ func (x *OAuth2TokenRequest) ProtoReflect() protoreflect.Message

type OAuth2TokenRequest_Type

+ func (OAuth2TokenRequest_Type) Descriptor() protoreflect.EnumDescriptor

+ func (OAuth2TokenRequest_Type) Type() protoreflect.EnumType

+ func (x OAuth2TokenRequest_Type) Enum() *OAuth2TokenRequest_Type

+ func (x OAuth2TokenRequest_Type) Number() protoreflect.EnumNumber

type Operand

+ func (x *Operand) ProtoReflect() protoreflect.Message

type OutputReference

+ func (x *OutputReference) ProtoReflect() protoreflect.Message

type Parameter

+ func (x *Parameter) GetArtifactId() *ArtifactID

+ func (x *Parameter) GetArtifactQuery() *ArtifactQuery

+ func (x *Parameter) ProtoReflect() protoreflect.Message

type ParameterMap

+ func (x *ParameterMap) ProtoReflect() protoreflect.Message

+ type Parameter_ArtifactId struct

+ ArtifactId *ArtifactID

+ type Parameter_ArtifactQuery struct

+ ArtifactQuery *ArtifactQuery

+ type Partitions struct

+ Value map[string]*LabelValue

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

+ func (*Partitions) ProtoMessage()

+ func (x *Partitions) GetValue() map[string]*LabelValue

+ func (x *Partitions) ProtoReflect() protoreflect.Message

+ func (x *Partitions) Reset()

+ func (x *Partitions) String() string

type Primitive

+ func (x *Primitive) ProtoReflect() protoreflect.Message

type PromiseAttribute

+ func (x *PromiseAttribute) ProtoReflect() protoreflect.Message

type QualityOfService

+ func (x *QualityOfService) ProtoReflect() protoreflect.Message

type QualityOfServiceSpec

+ func (x *QualityOfServiceSpec) ProtoReflect() protoreflect.Message

type QualityOfService_Tier

+ func (QualityOfService_Tier) Descriptor() protoreflect.EnumDescriptor

+ func (QualityOfService_Tier) Type() protoreflect.EnumType

+ func (x QualityOfService_Tier) Enum() *QualityOfService_Tier

+ func (x QualityOfService_Tier) Number() protoreflect.EnumNumber

type ResourceType

+ func (ResourceType) Descriptor() protoreflect.EnumDescriptor

+ func (ResourceType) Type() protoreflect.EnumType

+ func (x ResourceType) Enum() *ResourceType

+ func (x ResourceType) Number() protoreflect.EnumNumber

type Resources

+ func (x *Resources) ProtoReflect() protoreflect.Message

type Resources_ResourceEntry

+ func (x *Resources_ResourceEntry) ProtoReflect() protoreflect.Message

type Resources_ResourceName

+ func (Resources_ResourceName) Descriptor() protoreflect.EnumDescriptor

+ func (Resources_ResourceName) Type() protoreflect.EnumType

+ func (x Resources_ResourceName) Enum() *Resources_ResourceName

+ func (x Resources_ResourceName) Number() protoreflect.EnumNumber

type RetryStrategy

+ func (x *RetryStrategy) ProtoReflect() protoreflect.Message

type RuntimeMetadata

+ func (x *RuntimeMetadata) ProtoReflect() protoreflect.Message

type RuntimeMetadata_RuntimeType

+ func (RuntimeMetadata_RuntimeType) Descriptor() protoreflect.EnumDescriptor

+ func (RuntimeMetadata_RuntimeType) Type() protoreflect.EnumType

+ func (x RuntimeMetadata_RuntimeType) Enum() *RuntimeMetadata_RuntimeType

+ func (x RuntimeMetadata_RuntimeType) Number() protoreflect.EnumNumber

type Scalar

+ func (x *Scalar) ProtoReflect() protoreflect.Message

type Schema

+ func (x *Schema) ProtoReflect() protoreflect.Message

type SchemaType

+ func (x *SchemaType) ProtoReflect() protoreflect.Message

type SchemaType_SchemaColumn

+ func (x *SchemaType_SchemaColumn) ProtoReflect() protoreflect.Message

type SchemaType_SchemaColumn_SchemaColumnType

+ func (SchemaType_SchemaColumn_SchemaColumnType) Descriptor() protoreflect.EnumDescriptor

+ func (SchemaType_SchemaColumn_SchemaColumnType) Type() protoreflect.EnumType

+ func (x SchemaType_SchemaColumn_SchemaColumnType) Enum() *SchemaType_SchemaColumn_SchemaColumnType

+ func (x SchemaType_SchemaColumn_SchemaColumnType) Number() protoreflect.EnumNumber

type Secret

+ func (x *Secret) ProtoReflect() protoreflect.Message

type Secret_MountType

+ func (Secret_MountType) Descriptor() protoreflect.EnumDescriptor

+ func (Secret_MountType) Type() protoreflect.EnumType

+ func (x Secret_MountType) Enum() *Secret_MountType

+ func (x Secret_MountType) Number() protoreflect.EnumNumber

type SecurityContext

+ func (x *SecurityContext) ProtoReflect() protoreflect.Message

type SignalCondition

+ func (x *SignalCondition) ProtoReflect() protoreflect.Message

type SignalIdentifier

+ func (x *SignalIdentifier) ProtoReflect() protoreflect.Message

type SimpleType

+ func (SimpleType) Descriptor() protoreflect.EnumDescriptor

+ func (SimpleType) Type() protoreflect.EnumType

+ func (x SimpleType) Enum() *SimpleType

+ func (x SimpleType) Number() protoreflect.EnumNumber

type SleepCondition

+ func (x *SleepCondition) ProtoReflect() protoreflect.Message

type Span

+ func (x *Span) ProtoReflect() protoreflect.Message

type Sql

+ func (x *Sql) ProtoReflect() protoreflect.Message

type Sql_Dialect

+ func (Sql_Dialect) Descriptor() protoreflect.EnumDescriptor

+ func (Sql_Dialect) Type() protoreflect.EnumType

+ func (x Sql_Dialect) Enum() *Sql_Dialect

+ func (x Sql_Dialect) Number() protoreflect.EnumNumber

type StructuredDataset

+ func (x *StructuredDataset) ProtoReflect() protoreflect.Message

type StructuredDatasetMetadata

+ func (x *StructuredDatasetMetadata) ProtoReflect() protoreflect.Message

type StructuredDatasetType

+ func (x *StructuredDatasetType) ProtoReflect() protoreflect.Message

type StructuredDatasetType_DatasetColumn

+ func (x *StructuredDatasetType_DatasetColumn) ProtoReflect() protoreflect.Message

type TaskExecution

+ func (x *TaskExecution) ProtoReflect() protoreflect.Message

type TaskExecutionIdentifier

+ func (x *TaskExecutionIdentifier) ProtoReflect() protoreflect.Message

type TaskExecution_Phase

+ func (TaskExecution_Phase) Descriptor() protoreflect.EnumDescriptor

+ func (TaskExecution_Phase) Type() protoreflect.EnumType

+ func (x TaskExecution_Phase) Enum() *TaskExecution_Phase

+ func (x TaskExecution_Phase) Number() protoreflect.EnumNumber

type TaskLog

+ func (x *TaskLog) ProtoReflect() protoreflect.Message

type TaskLog_MessageFormat

+ func (TaskLog_MessageFormat) Descriptor() protoreflect.EnumDescriptor

+ func (TaskLog_MessageFormat) Type() protoreflect.EnumType

+ func (x TaskLog_MessageFormat) Enum() *TaskLog_MessageFormat

+ func (x TaskLog_MessageFormat) Number() protoreflect.EnumNumber

type TaskMetadata

+ CacheIgnoreInputVars []string

+ func (x *TaskMetadata) GetCacheIgnoreInputVars() []string

+ func (x *TaskMetadata) ProtoReflect() protoreflect.Message

type TaskNode

+ func (x *TaskNode) ProtoReflect() protoreflect.Message

type TaskNodeOverrides

+ func (x *TaskNodeOverrides) ProtoReflect() protoreflect.Message

type TaskTemplate

+ func (x *TaskTemplate) ProtoReflect() protoreflect.Message

+ type TimePartition struct

+ Value *LabelValue

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

+ func (*TimePartition) ProtoMessage()

+ func (x *TimePartition) GetValue() *LabelValue

+ func (x *TimePartition) ProtoReflect() protoreflect.Message

+ func (x *TimePartition) Reset()

+ func (x *TimePartition) String() string

type TypeAnnotation

+ func (x *TypeAnnotation) ProtoReflect() protoreflect.Message

type TypeStructure

+ func (x *TypeStructure) ProtoReflect() protoreflect.Message

type TypedInterface

+ func (x *TypedInterface) ProtoReflect() protoreflect.Message

type Union

+ func (x *Union) ProtoReflect() protoreflect.Message

type UnionInfo

+ func (x *UnionInfo) ProtoReflect() protoreflect.Message

type UnionType

+ func (x *UnionType) ProtoReflect() protoreflect.Message

type Variable

+ ArtifactPartialId *ArtifactID

+ ArtifactTag *ArtifactTag

+ func (x *Variable) GetArtifactPartialId() *ArtifactID

+ func (x *Variable) GetArtifactTag() *ArtifactTag

+ func (x *Variable) ProtoReflect() protoreflect.Message

type VariableMap

+ func (x *VariableMap) ProtoReflect() protoreflect.Message

type Void

+ func (x *Void) ProtoReflect() protoreflect.Message

type WorkflowClosure

+ func (x *WorkflowClosure) ProtoReflect() protoreflect.Message

type WorkflowExecution

+ func (x *WorkflowExecution) ProtoReflect() protoreflect.Message

type WorkflowExecutionIdentifier

+ Org string

+ func (x *WorkflowExecutionIdentifier) GetOrg() string

+ func (x *WorkflowExecutionIdentifier) ProtoReflect() protoreflect.Message

type WorkflowExecution_Phase

+ func (WorkflowExecution_Phase) Descriptor() protoreflect.EnumDescriptor

+ func (WorkflowExecution_Phase) Type() protoreflect.EnumType

+ func (x WorkflowExecution_Phase) Enum() *WorkflowExecution_Phase

+ func (x WorkflowExecution_Phase) Number() protoreflect.EnumNumber

type WorkflowMetadata

+ func (x *WorkflowMetadata) ProtoReflect() protoreflect.Message

type WorkflowMetadataDefaults

+ func (x *WorkflowMetadataDefaults) ProtoReflect() protoreflect.Message

type WorkflowMetadata_OnFailurePolicy

+ func (WorkflowMetadata_OnFailurePolicy) Descriptor() protoreflect.EnumDescriptor

+ func (WorkflowMetadata_OnFailurePolicy) Type() protoreflect.EnumType

+ func (x WorkflowMetadata_OnFailurePolicy) Enum() *WorkflowMetadata_OnFailurePolicy

+ func (x WorkflowMetadata_OnFailurePolicy) Number() protoreflect.EnumNumber

type WorkflowNode

+ func (x *WorkflowNode) ProtoReflect() protoreflect.Message

type WorkflowTemplate

+ func (x *WorkflowTemplate) ProtoReflect() protoreflect.Message

v1.10.7-b4

Feb 6, 2024

v1.10.7-b3

Jan 31, 2024

v1.10.7-b2

Jan 23, 2024

v1.10.7-b1

Jan 18, 2024

v1.10.7-b0

Jan 8, 2024

v1.10.6

Dec 6, 2023

v1.10.6-b0

Nov 30, 2023

v1.10.5

Oct 26, 2023

v1.10.4

Oct 25, 2023

v1.10.3

Oct 24, 2023

v1.10.2

Oct 23, 2023

v1.10.1

Oct 21, 2023

v1.10.0

Oct 20, 2023

v1.9.37

Oct 20, 2023

v1.9.36

Oct 20, 2023

v1.9.35

Oct 20, 2023

v1.9.34

Oct 19, 2023

v1.9.33

Oct 19, 2023

Changes in this version

type TypeStructure

+ DataclassType map[string]*LiteralType

+ func (m *TypeStructure) GetDataclassType() map[string]*LiteralType

v1.9.32

Oct 19, 2023

v1.9.31

Oct 19, 2023

v1.9.30

Oct 18, 2023

v1.9.29

Oct 18, 2023

v1.9.28

Oct 17, 2023

v1.9.27

Oct 16, 2023

v1.9.26

Oct 16, 2023

v1.9.25

Oct 16, 2023

v1.9.24

Oct 16, 2023

v1.9.23

Oct 16, 2023

v1.9.22

Oct 13, 2023

v1.9.21

Oct 12, 2023

v1.9.20

Oct 12, 2023

Changes in this version

+ type ExtendedResources struct

+ GpuAccelerator *GPUAccelerator

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ExtendedResources) ProtoMessage()

+ func (m *ExtendedResources) GetGpuAccelerator() *GPUAccelerator

+ func (m *ExtendedResources) Reset()

+ func (m *ExtendedResources) String() string

+ func (m *ExtendedResources) Validate() error

+ func (m *ExtendedResources) XXX_DiscardUnknown()

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

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

+ func (m *ExtendedResources) XXX_Size() int

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

+ type ExtendedResourcesValidationError struct

+ func (e ExtendedResourcesValidationError) Cause() error

+ func (e ExtendedResourcesValidationError) Error() string

+ func (e ExtendedResourcesValidationError) ErrorName() string

+ func (e ExtendedResourcesValidationError) Field() string

+ func (e ExtendedResourcesValidationError) Key() bool

+ func (e ExtendedResourcesValidationError) Reason() string

+ type GPUAccelerator struct

+ Device string

+ PartitionSizeValue isGPUAccelerator_PartitionSizeValue

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GPUAccelerator) ProtoMessage()

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

+ func (m *GPUAccelerator) GetDevice() string

+ func (m *GPUAccelerator) GetPartitionSize() string

+ func (m *GPUAccelerator) GetPartitionSizeValue() isGPUAccelerator_PartitionSizeValue

+ func (m *GPUAccelerator) GetUnpartitioned() bool

+ func (m *GPUAccelerator) Reset()

+ func (m *GPUAccelerator) String() string

+ func (m *GPUAccelerator) Validate() error

+ func (m *GPUAccelerator) XXX_DiscardUnknown()

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

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

+ func (m *GPUAccelerator) XXX_Size() int

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

+ type GPUAcceleratorValidationError struct

+ func (e GPUAcceleratorValidationError) Cause() error

+ func (e GPUAcceleratorValidationError) Error() string

+ func (e GPUAcceleratorValidationError) ErrorName() string

+ func (e GPUAcceleratorValidationError) Field() string

+ func (e GPUAcceleratorValidationError) Key() bool

+ func (e GPUAcceleratorValidationError) Reason() string

+ type GPUAccelerator_PartitionSize struct

+ PartitionSize string

+ type GPUAccelerator_Unpartitioned struct

+ Unpartitioned bool

type TaskNodeOverrides

+ ExtendedResources *ExtendedResources

+ func (m *TaskNodeOverrides) GetExtendedResources() *ExtendedResources

type TaskTemplate

+ ExtendedResources *ExtendedResources

+ func (m *TaskTemplate) GetExtendedResources() *ExtendedResources

v1.9.19

Oct 12, 2023

v1.9.18

Oct 11, 2023

v1.9.17

Oct 11, 2023

v1.9.16

Oct 11, 2023

v1.9.15

Oct 10, 2023

v1.9.14

Oct 9, 2023

v1.9.13

Oct 6, 2023

v1.9.12

Oct 6, 2023

v1.9.11

Oct 5, 2023

v1.9.10

Oct 5, 2023

v1.9.9

Oct 5, 2023

v1.9.8

Oct 4, 2023

Changes in this version

+ var BlobType_BlobDimensionality_name = map[int32]string

+ var BlobType_BlobDimensionality_value = map[string]int32

+ var CatalogCacheStatus_name = map[int32]string

+ var CatalogCacheStatus_value = map[string]int32

+ var CatalogReservation_Status_name = map[int32]string

+ var CatalogReservation_Status_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 Container_Architecture_name = map[int32]string

+ var Container_Architecture_value = map[string]int32

+ var DataLoadingConfig_LiteralMapFormat_name = map[int32]string

+ var DataLoadingConfig_LiteralMapFormat_value = map[string]int32

+ var ExecutionError_ErrorKind_name = map[int32]string

+ var ExecutionError_ErrorKind_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

+ var NodeExecution_Phase_name = map[int32]string

+ var NodeExecution_Phase_value = map[string]int32

+ var OAuth2TokenRequest_Type_name = map[int32]string

+ var OAuth2TokenRequest_Type_value = map[string]int32

+ var QualityOfService_Tier_name = map[int32]string

+ var QualityOfService_Tier_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 Secret_MountType_name = map[int32]string

+ var Secret_MountType_value = map[string]int32

+ var SimpleType_name = map[int32]string

+ var SimpleType_value = map[string]int32

+ var Sql_Dialect_name = map[int32]string

+ var Sql_Dialect_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

+ var WorkflowMetadata_OnFailurePolicy_name = map[int32]string

+ var WorkflowMetadata_OnFailurePolicy_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 (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_Merge(src proto.Message)

+ 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 ApproveCondition struct

+ SignalId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ApproveCondition) ProtoMessage()

+ func (m *ApproveCondition) GetSignalId() string

+ func (m *ApproveCondition) Reset()

+ func (m *ApproveCondition) String() string

+ func (m *ApproveCondition) Validate() error

+ func (m *ApproveCondition) XXX_DiscardUnknown()

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

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

+ func (m *ApproveCondition) XXX_Size() int

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

+ type ApproveConditionValidationError struct

+ func (e ApproveConditionValidationError) Cause() error

+ func (e ApproveConditionValidationError) Error() string

+ func (e ApproveConditionValidationError) ErrorName() string

+ func (e ApproveConditionValidationError) Field() string

+ func (e ApproveConditionValidationError) Key() bool

+ func (e ApproveConditionValidationError) Reason() string

+ type ArrayNode struct

+ Node *Node

+ Parallelism uint32

+ SuccessCriteria isArrayNode_SuccessCriteria

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ArrayNode) ProtoMessage()

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

+ func (m *ArrayNode) GetMinSuccessRatio() float32

+ func (m *ArrayNode) GetMinSuccesses() uint32

+ func (m *ArrayNode) GetNode() *Node

+ func (m *ArrayNode) GetParallelism() uint32

+ func (m *ArrayNode) GetSuccessCriteria() isArrayNode_SuccessCriteria

+ func (m *ArrayNode) Reset()

+ func (m *ArrayNode) String() string

+ func (m *ArrayNode) Validate() error

+ func (m *ArrayNode) XXX_DiscardUnknown()

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

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

+ func (m *ArrayNode) XXX_Size() int

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

+ type ArrayNodeValidationError struct

+ func (e ArrayNodeValidationError) Cause() error

+ func (e ArrayNodeValidationError) Error() string

+ func (e ArrayNodeValidationError) ErrorName() string

+ func (e ArrayNodeValidationError) Field() string

+ func (e ArrayNodeValidationError) Key() bool

+ func (e ArrayNodeValidationError) Reason() string

+ type ArrayNode_MinSuccessRatio struct

+ MinSuccessRatio float32

+ type ArrayNode_MinSuccesses struct

+ MinSuccesses uint32

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ func (m *Binding) XXX_Size() int

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

+ type BindingData struct

+ Union *UnionInfo

+ Value isBindingData_Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BindingData) ProtoMessage()

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

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

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

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

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

+ func (m *BindingData) GetUnion() *UnionInfo

+ 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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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_OneofWrappers() []interface{}

+ 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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 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

+ const CatalogCacheStatus_CACHE_SKIPPED

+ 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 CatalogReservation struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CatalogReservation) ProtoMessage()

+ func (m *CatalogReservation) Reset()

+ func (m *CatalogReservation) String() string

+ func (m *CatalogReservation) Validate() error

+ func (m *CatalogReservation) XXX_DiscardUnknown()

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

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

+ func (m *CatalogReservation) XXX_Size() int

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

+ type CatalogReservationValidationError struct

+ func (e CatalogReservationValidationError) Cause() error

+ func (e CatalogReservationValidationError) Error() string

+ func (e CatalogReservationValidationError) ErrorName() string

+ func (e CatalogReservationValidationError) Field() string

+ func (e CatalogReservationValidationError) Key() bool

+ func (e CatalogReservationValidationError) Reason() string

+ type CatalogReservation_Status int32

+ const CatalogReservation_RESERVATION_ACQUIRED

+ const CatalogReservation_RESERVATION_DISABLED

+ const CatalogReservation_RESERVATION_EXISTS

+ const CatalogReservation_RESERVATION_FAILURE

+ const CatalogReservation_RESERVATION_RELEASED

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

+ func (x CatalogReservation_Status) String() 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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

+ Architecture Container_Architecture

+ Args []string

+ Command []string

+ Config []*KeyValuePair

+ DataConfig *DataLoadingConfig

+ 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 (m *Container) GetArchitecture() Container_Architecture

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

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

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

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

+ 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_Merge(src proto.Message)

+ func (m *Container) XXX_Size() int

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

+ type ContainerError struct

+ Code string

+ Kind ContainerError_Kind

+ Message string

+ Origin ExecutionError_ErrorKind

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ContainerError) ProtoMessage()

+ func (m *ContainerError) GetCode() string

+ func (m *ContainerError) GetKind() ContainerError_Kind

+ func (m *ContainerError) GetMessage() string

+ func (m *ContainerError) GetOrigin() ExecutionError_ErrorKind

+ 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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 Container_Architecture int32

+ const Container_AMD64

+ const Container_ARM64

+ const Container_ARM_V6

+ const Container_ARM_V7

+ const Container_UNKNOWN

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

+ func (x Container_Architecture) String() string

+ type DataLoadingConfig struct

+ Enabled bool

+ Format DataLoadingConfig_LiteralMapFormat

+ InputPath string

+ IoStrategy *IOStrategy

+ 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_LiteralMapFormat

+ func (m *DataLoadingConfig) GetInputPath() string

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

+ 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_LiteralMapFormat int32

+ const DataLoadingConfig_JSON

+ const DataLoadingConfig_PROTO

+ const DataLoadingConfig_YAML

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

+ func (x DataLoadingConfig_LiteralMapFormat) String() 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 (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_Merge(src proto.Message)

+ 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 EnumType struct

+ Values []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*EnumType) ProtoMessage()

+ func (m *EnumType) GetValues() []string

+ func (m *EnumType) Reset()

+ func (m *EnumType) String() string

+ func (m *EnumType) Validate() error

+ func (m *EnumType) XXX_DiscardUnknown()

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

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

+ func (m *EnumType) XXX_Size() int

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

+ type EnumTypeValidationError struct

+ func (e EnumTypeValidationError) Cause() error

+ func (e EnumTypeValidationError) Error() string

+ func (e EnumTypeValidationError) ErrorName() string

+ func (e EnumTypeValidationError) Field() string

+ func (e EnumTypeValidationError) Key() bool

+ func (e EnumTypeValidationError) 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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

+ Kind ExecutionError_ErrorKind

+ Message string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ExecutionError) ProtoMessage()

+ func (m *ExecutionError) GetCode() string

+ func (m *ExecutionError) GetErrorUri() string

+ func (m *ExecutionError) GetKind() ExecutionError_ErrorKind

+ 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_Merge(src proto.Message)

+ 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 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 GateNode struct

+ Condition isGateNode_Condition

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GateNode) ProtoMessage()

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

+ func (m *GateNode) GetApprove() *ApproveCondition

+ func (m *GateNode) GetCondition() isGateNode_Condition

+ func (m *GateNode) GetSignal() *SignalCondition

+ func (m *GateNode) GetSleep() *SleepCondition

+ func (m *GateNode) Reset()

+ func (m *GateNode) String() string

+ func (m *GateNode) Validate() error

+ func (m *GateNode) XXX_DiscardUnknown()

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

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

+ func (m *GateNode) XXX_Size() int

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

+ type GateNodeValidationError struct

+ func (e GateNodeValidationError) Cause() error

+ func (e GateNodeValidationError) Error() string

+ func (e GateNodeValidationError) ErrorName() string

+ func (e GateNodeValidationError) Field() string

+ func (e GateNodeValidationError) Key() bool

+ func (e GateNodeValidationError) Reason() string

+ type GateNode_Approve struct

+ Approve *ApproveCondition

+ type GateNode_Signal struct

+ Signal *SignalCondition

+ type GateNode_Sleep struct

+ Sleep *SleepCondition

+ 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

+ 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 (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_Merge(src proto.Message)

+ 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 Identity struct

+ ExecutionIdentity string

+ IamRole string

+ K8SServiceAccount string

+ Oauth2Client *OAuth2Client

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Identity) ProtoMessage()

+ func (m *Identity) GetExecutionIdentity() string

+ func (m *Identity) GetIamRole() string

+ func (m *Identity) GetK8SServiceAccount() string

+ func (m *Identity) GetOauth2Client() *OAuth2Client

+ func (m *Identity) Reset()

+ func (m *Identity) String() string

+ func (m *Identity) Validate() error

+ func (m *Identity) XXX_DiscardUnknown()

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

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

+ func (m *Identity) XXX_Size() int

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

+ type IdentityValidationError struct

+ func (e IdentityValidationError) Cause() error

+ func (e IdentityValidationError) Error() string

+ func (e IdentityValidationError) ErrorName() string

+ func (e IdentityValidationError) Field() string

+ func (e IdentityValidationError) Key() bool

+ func (e IdentityValidationError) 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 (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_Merge(src proto.Message)

+ 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_OneofWrappers() []interface{}

+ 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_Merge(src proto.Message)

+ 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 K8SObjectMetadata struct

+ Annotations map[string]string

+ Labels map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*K8SObjectMetadata) ProtoMessage()

+ func (m *K8SObjectMetadata) GetAnnotations() map[string]string

+ func (m *K8SObjectMetadata) GetLabels() map[string]string

+ func (m *K8SObjectMetadata) Reset()

+ func (m *K8SObjectMetadata) String() string

+ func (m *K8SObjectMetadata) Validate() error

+ func (m *K8SObjectMetadata) XXX_DiscardUnknown()

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

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

+ func (m *K8SObjectMetadata) XXX_Size() int

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

+ type K8SObjectMetadataValidationError struct

+ func (e K8SObjectMetadataValidationError) Cause() error

+ func (e K8SObjectMetadataValidationError) Error() string

+ func (e K8SObjectMetadataValidationError) ErrorName() string

+ func (e K8SObjectMetadataValidationError) Field() string

+ func (e K8SObjectMetadataValidationError) Key() bool

+ func (e K8SObjectMetadataValidationError) Reason() string

+ type K8SPod struct

+ DataConfig *DataLoadingConfig

+ Metadata *K8SObjectMetadata

+ PodSpec *_struct.Struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*K8SPod) ProtoMessage()

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

+ func (m *K8SPod) GetMetadata() *K8SObjectMetadata

+ func (m *K8SPod) GetPodSpec() *_struct.Struct

+ func (m *K8SPod) Reset()

+ func (m *K8SPod) String() string

+ func (m *K8SPod) Validate() error

+ func (m *K8SPod) XXX_DiscardUnknown()

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

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

+ func (m *K8SPod) XXX_Size() int

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

+ type K8SPodValidationError struct

+ func (e K8SPodValidationError) Cause() error

+ func (e K8SPodValidationError) Error() string

+ func (e K8SPodValidationError) ErrorName() string

+ func (e K8SPodValidationError) Field() string

+ func (e K8SPodValidationError) Key() bool

+ func (e K8SPodValidationError) Reason() string

+ 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 (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_Merge(src proto.Message)

+ 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

+ Hash string

+ Value isLiteral_Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Literal) ProtoMessage()

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

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

+ func (m *Literal) GetHash() string

+ 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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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

+ Annotation *TypeAnnotation

+ Metadata *_struct.Struct

+ Structure *TypeStructure

+ Type isLiteralType_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LiteralType) ProtoMessage()

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

+ func (m *LiteralType) GetAnnotation() *TypeAnnotation

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

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

+ func (m *LiteralType) GetEnumType() *EnumType

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

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

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

+ func (m *LiteralType) GetSimple() SimpleType

+ func (m *LiteralType) GetStructure() *TypeStructure

+ func (m *LiteralType) GetStructuredDatasetType() *StructuredDatasetType

+ func (m *LiteralType) GetType() isLiteralType_Type

+ func (m *LiteralType) GetUnionType() *UnionType

+ 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_Merge(src proto.Message)

+ 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_EnumType struct

+ EnumType *EnumType

+ type LiteralType_MapValueType struct

+ MapValueType *LiteralType

+ type LiteralType_Schema struct

+ Schema *SchemaType

+ type LiteralType_Simple struct

+ Simple SimpleType

+ type LiteralType_StructuredDatasetType struct

+ StructuredDatasetType *StructuredDatasetType

+ type LiteralType_UnionType struct

+ UnionType *UnionType

+ 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_OneofWrappers() []interface{}

+ func (m *Node) GetArrayNode() *ArrayNode

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

+ func (m *Node) GetGateNode() *GateNode

+ 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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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_DYNAMIC_RUNNING

+ const NodeExecution_FAILED

+ const NodeExecution_FAILING

+ const NodeExecution_QUEUED

+ const NodeExecution_RECOVERED

+ 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

+ InterruptibleValue isNodeMetadata_InterruptibleValue

+ 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 (*NodeMetadata) XXX_OneofWrappers() []interface{}

+ func (m *NodeMetadata) GetInterruptible() bool

+ func (m *NodeMetadata) GetInterruptibleValue() isNodeMetadata_InterruptibleValue

+ 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_Merge(src proto.Message)

+ 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 NodeMetadata_Interruptible struct

+ Interruptible bool

+ 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_ArrayNode struct

+ ArrayNode *ArrayNode

+ type Node_BranchNode struct

+ BranchNode *BranchNode

+ type Node_GateNode struct

+ GateNode *GateNode

+ type Node_TaskNode struct

+ TaskNode *TaskNode

+ type Node_WorkflowNode struct

+ WorkflowNode *WorkflowNode

+ type OAuth2Client struct

+ ClientId string

+ ClientSecret *Secret

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*OAuth2Client) ProtoMessage()

+ func (m *OAuth2Client) GetClientId() string

+ func (m *OAuth2Client) GetClientSecret() *Secret

+ func (m *OAuth2Client) Reset()

+ func (m *OAuth2Client) String() string

+ func (m *OAuth2Client) Validate() error

+ func (m *OAuth2Client) XXX_DiscardUnknown()

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

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

+ func (m *OAuth2Client) XXX_Size() int

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

+ type OAuth2ClientValidationError struct

+ func (e OAuth2ClientValidationError) Cause() error

+ func (e OAuth2ClientValidationError) Error() string

+ func (e OAuth2ClientValidationError) ErrorName() string

+ func (e OAuth2ClientValidationError) Field() string

+ func (e OAuth2ClientValidationError) Key() bool

+ func (e OAuth2ClientValidationError) Reason() string

+ type OAuth2TokenRequest struct

+ Client *OAuth2Client

+ IdpDiscoveryEndpoint string

+ Name string

+ TokenEndpoint string

+ Type OAuth2TokenRequest_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*OAuth2TokenRequest) ProtoMessage()

+ func (m *OAuth2TokenRequest) GetClient() *OAuth2Client

+ func (m *OAuth2TokenRequest) GetIdpDiscoveryEndpoint() string

+ func (m *OAuth2TokenRequest) GetName() string

+ func (m *OAuth2TokenRequest) GetTokenEndpoint() string

+ func (m *OAuth2TokenRequest) GetType() OAuth2TokenRequest_Type

+ func (m *OAuth2TokenRequest) Reset()

+ func (m *OAuth2TokenRequest) String() string

+ func (m *OAuth2TokenRequest) Validate() error

+ func (m *OAuth2TokenRequest) XXX_DiscardUnknown()

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

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

+ func (m *OAuth2TokenRequest) XXX_Size() int

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

+ type OAuth2TokenRequestValidationError struct

+ func (e OAuth2TokenRequestValidationError) Cause() error

+ func (e OAuth2TokenRequestValidationError) Error() string

+ func (e OAuth2TokenRequestValidationError) ErrorName() string

+ func (e OAuth2TokenRequestValidationError) Field() string

+ func (e OAuth2TokenRequestValidationError) Key() bool

+ func (e OAuth2TokenRequestValidationError) Reason() string

+ type OAuth2TokenRequest_Type int32

+ const OAuth2TokenRequest_CLIENT_CREDENTIALS

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

+ func (x OAuth2TokenRequest_Type) String() string

+ 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_OneofWrappers() []interface{}

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

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

+ 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_Merge(src proto.Message)

+ 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_Scalar struct

+ Scalar *Scalar

+ type Operand_Var struct

+ Var string

+ type OutputReference struct

+ AttrPath []*PromiseAttribute

+ NodeId string

+ Var string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*OutputReference) ProtoMessage()

+ func (m *OutputReference) GetAttrPath() []*PromiseAttribute

+ 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_Merge(src proto.Message)

+ 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_OneofWrappers() []interface{}

+ 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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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_OneofWrappers() []interface{}

+ 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_Merge(src proto.Message)

+ 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 PromiseAttribute struct

+ Value isPromiseAttribute_Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PromiseAttribute) ProtoMessage()

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

+ func (m *PromiseAttribute) GetIntValue() int32

+ func (m *PromiseAttribute) GetStringValue() string

+ func (m *PromiseAttribute) GetValue() isPromiseAttribute_Value

+ func (m *PromiseAttribute) Reset()

+ func (m *PromiseAttribute) String() string

+ func (m *PromiseAttribute) Validate() error

+ func (m *PromiseAttribute) XXX_DiscardUnknown()

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

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

+ func (m *PromiseAttribute) XXX_Size() int

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

+ type PromiseAttributeValidationError struct

+ func (e PromiseAttributeValidationError) Cause() error

+ func (e PromiseAttributeValidationError) Error() string

+ func (e PromiseAttributeValidationError) ErrorName() string

+ func (e PromiseAttributeValidationError) Field() string

+ func (e PromiseAttributeValidationError) Key() bool

+ func (e PromiseAttributeValidationError) Reason() string

+ type PromiseAttribute_IntValue struct

+ IntValue int32

+ type PromiseAttribute_StringValue struct

+ StringValue string

+ 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 ResourceType int32

+ const ResourceType_DATASET

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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_EPHEMERAL_STORAGE

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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_OneofWrappers() []interface{}

+ 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) GetStructuredDataset() *StructuredDataset

+ func (m *Scalar) GetUnion() *Union

+ 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_Merge(src proto.Message)

+ 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 Scalar_StructuredDataset struct

+ StructuredDataset *StructuredDataset

+ type Scalar_Union struct

+ Union *Union

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 Secret struct

+ Group string

+ GroupVersion string

+ Key string

+ MountRequirement Secret_MountType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Secret) ProtoMessage()

+ func (m *Secret) GetGroup() string

+ func (m *Secret) GetGroupVersion() string

+ func (m *Secret) GetKey() string

+ func (m *Secret) GetMountRequirement() Secret_MountType

+ func (m *Secret) Reset()

+ func (m *Secret) String() string

+ func (m *Secret) Validate() error

+ func (m *Secret) XXX_DiscardUnknown()

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

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

+ func (m *Secret) XXX_Size() int

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

+ type SecretValidationError struct

+ func (e SecretValidationError) Cause() error

+ func (e SecretValidationError) Error() string

+ func (e SecretValidationError) ErrorName() string

+ func (e SecretValidationError) Field() string

+ func (e SecretValidationError) Key() bool

+ func (e SecretValidationError) Reason() string

+ type Secret_MountType int32

+ const Secret_ANY

+ const Secret_ENV_VAR

+ const Secret_FILE

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

+ func (x Secret_MountType) String() string

+ type SecurityContext struct

+ RunAs *Identity

+ Secrets []*Secret

+ Tokens []*OAuth2TokenRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SecurityContext) ProtoMessage()

+ func (m *SecurityContext) GetRunAs() *Identity

+ func (m *SecurityContext) GetSecrets() []*Secret

+ func (m *SecurityContext) GetTokens() []*OAuth2TokenRequest

+ func (m *SecurityContext) Reset()

+ func (m *SecurityContext) String() string

+ func (m *SecurityContext) Validate() error

+ func (m *SecurityContext) XXX_DiscardUnknown()

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

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

+ func (m *SecurityContext) XXX_Size() int

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

+ type SecurityContextValidationError struct

+ func (e SecurityContextValidationError) Cause() error

+ func (e SecurityContextValidationError) Error() string

+ func (e SecurityContextValidationError) ErrorName() string

+ func (e SecurityContextValidationError) Field() string

+ func (e SecurityContextValidationError) Key() bool

+ func (e SecurityContextValidationError) Reason() string

+ type SignalCondition struct

+ OutputVariableName string

+ SignalId string

+ Type *LiteralType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SignalCondition) ProtoMessage()

+ func (m *SignalCondition) GetOutputVariableName() string

+ func (m *SignalCondition) GetSignalId() string

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

+ func (m *SignalCondition) Reset()

+ func (m *SignalCondition) String() string

+ func (m *SignalCondition) Validate() error

+ func (m *SignalCondition) XXX_DiscardUnknown()

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

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

+ func (m *SignalCondition) XXX_Size() int

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

+ type SignalConditionValidationError struct

+ func (e SignalConditionValidationError) Cause() error

+ func (e SignalConditionValidationError) Error() string

+ func (e SignalConditionValidationError) ErrorName() string

+ func (e SignalConditionValidationError) Field() string

+ func (e SignalConditionValidationError) Key() bool

+ func (e SignalConditionValidationError) Reason() string

+ type SignalIdentifier struct

+ ExecutionId *WorkflowExecutionIdentifier

+ SignalId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SignalIdentifier) ProtoMessage()

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

+ func (m *SignalIdentifier) GetSignalId() string

+ func (m *SignalIdentifier) Reset()

+ func (m *SignalIdentifier) String() string

+ func (m *SignalIdentifier) Validate() error

+ func (m *SignalIdentifier) XXX_DiscardUnknown()

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

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

+ func (m *SignalIdentifier) XXX_Size() int

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

+ type SignalIdentifierValidationError struct

+ func (e SignalIdentifierValidationError) Cause() error

+ func (e SignalIdentifierValidationError) Error() string

+ func (e SignalIdentifierValidationError) ErrorName() string

+ func (e SignalIdentifierValidationError) Field() string

+ func (e SignalIdentifierValidationError) Key() bool

+ func (e SignalIdentifierValidationError) 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 SleepCondition struct

+ Duration *duration.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SleepCondition) ProtoMessage()

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

+ func (m *SleepCondition) Reset()

+ func (m *SleepCondition) String() string

+ func (m *SleepCondition) Validate() error

+ func (m *SleepCondition) XXX_DiscardUnknown()

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

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

+ func (m *SleepCondition) XXX_Size() int

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

+ type SleepConditionValidationError struct

+ func (e SleepConditionValidationError) Cause() error

+ func (e SleepConditionValidationError) Error() string

+ func (e SleepConditionValidationError) ErrorName() string

+ func (e SleepConditionValidationError) Field() string

+ func (e SleepConditionValidationError) Key() bool

+ func (e SleepConditionValidationError) Reason() string

+ type Span struct

+ EndTime *timestamp.Timestamp

+ Id isSpan_Id

+ Spans []*Span

+ StartTime *timestamp.Timestamp

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Span) ProtoMessage()

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

+ func (m *Span) GetEndTime() *timestamp.Timestamp

+ func (m *Span) GetId() isSpan_Id

+ func (m *Span) GetNodeId() *NodeExecutionIdentifier

+ func (m *Span) GetOperationId() string

+ func (m *Span) GetSpans() []*Span

+ func (m *Span) GetStartTime() *timestamp.Timestamp

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

+ func (m *Span) GetWorkflowId() *WorkflowExecutionIdentifier

+ func (m *Span) Reset()

+ func (m *Span) String() string

+ func (m *Span) Validate() error

+ func (m *Span) XXX_DiscardUnknown()

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

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

+ func (m *Span) XXX_Size() int

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

+ type SpanValidationError struct

+ func (e SpanValidationError) Cause() error

+ func (e SpanValidationError) Error() string

+ func (e SpanValidationError) ErrorName() string

+ func (e SpanValidationError) Field() string

+ func (e SpanValidationError) Key() bool

+ func (e SpanValidationError) Reason() string

+ type Span_NodeId struct

+ NodeId *NodeExecutionIdentifier

+ type Span_OperationId struct

+ OperationId string

+ type Span_TaskId struct

+ TaskId *TaskExecutionIdentifier

+ type Span_WorkflowId struct

+ WorkflowId *WorkflowExecutionIdentifier

+ type Sql struct

+ Dialect Sql_Dialect

+ Statement string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Sql) ProtoMessage()

+ func (m *Sql) GetDialect() Sql_Dialect

+ func (m *Sql) GetStatement() string

+ func (m *Sql) Reset()

+ func (m *Sql) String() string

+ func (m *Sql) Validate() error

+ func (m *Sql) XXX_DiscardUnknown()

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

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

+ func (m *Sql) XXX_Size() int

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

+ type SqlValidationError struct

+ func (e SqlValidationError) Cause() error

+ func (e SqlValidationError) Error() string

+ func (e SqlValidationError) ErrorName() string

+ func (e SqlValidationError) Field() string

+ func (e SqlValidationError) Key() bool

+ func (e SqlValidationError) Reason() string

+ type Sql_Dialect int32

+ const Sql_ANSI

+ const Sql_HIVE

+ const Sql_OTHER

+ const Sql_UNDEFINED

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

+ func (x Sql_Dialect) String() string

+ type StructuredDataset struct

+ Metadata *StructuredDatasetMetadata

+ Uri string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StructuredDataset) ProtoMessage()

+ func (m *StructuredDataset) GetMetadata() *StructuredDatasetMetadata

+ func (m *StructuredDataset) GetUri() string

+ func (m *StructuredDataset) Reset()

+ func (m *StructuredDataset) String() string

+ func (m *StructuredDataset) Validate() error

+ func (m *StructuredDataset) XXX_DiscardUnknown()

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

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

+ func (m *StructuredDataset) XXX_Size() int

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

+ type StructuredDatasetMetadata struct

+ StructuredDatasetType *StructuredDatasetType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StructuredDatasetMetadata) ProtoMessage()

+ func (m *StructuredDatasetMetadata) GetStructuredDatasetType() *StructuredDatasetType

+ func (m *StructuredDatasetMetadata) Reset()

+ func (m *StructuredDatasetMetadata) String() string

+ func (m *StructuredDatasetMetadata) Validate() error

+ func (m *StructuredDatasetMetadata) XXX_DiscardUnknown()

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

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

+ func (m *StructuredDatasetMetadata) XXX_Size() int

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

+ type StructuredDatasetMetadataValidationError struct

+ func (e StructuredDatasetMetadataValidationError) Cause() error

+ func (e StructuredDatasetMetadataValidationError) Error() string

+ func (e StructuredDatasetMetadataValidationError) ErrorName() string

+ func (e StructuredDatasetMetadataValidationError) Field() string

+ func (e StructuredDatasetMetadataValidationError) Key() bool

+ func (e StructuredDatasetMetadataValidationError) Reason() string

+ type StructuredDatasetType struct

+ Columns []*StructuredDatasetType_DatasetColumn

+ ExternalSchemaBytes []byte

+ ExternalSchemaType string

+ Format string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StructuredDatasetType) ProtoMessage()

+ func (m *StructuredDatasetType) GetColumns() []*StructuredDatasetType_DatasetColumn

+ func (m *StructuredDatasetType) GetExternalSchemaBytes() []byte

+ func (m *StructuredDatasetType) GetExternalSchemaType() string

+ func (m *StructuredDatasetType) GetFormat() string

+ func (m *StructuredDatasetType) Reset()

+ func (m *StructuredDatasetType) String() string

+ func (m *StructuredDatasetType) Validate() error

+ func (m *StructuredDatasetType) XXX_DiscardUnknown()

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

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

+ func (m *StructuredDatasetType) XXX_Size() int

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

+ type StructuredDatasetTypeValidationError struct

+ func (e StructuredDatasetTypeValidationError) Cause() error

+ func (e StructuredDatasetTypeValidationError) Error() string

+ func (e StructuredDatasetTypeValidationError) ErrorName() string

+ func (e StructuredDatasetTypeValidationError) Field() string

+ func (e StructuredDatasetTypeValidationError) Key() bool

+ func (e StructuredDatasetTypeValidationError) Reason() string

+ type StructuredDatasetType_DatasetColumn struct

+ LiteralType *LiteralType

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StructuredDatasetType_DatasetColumn) ProtoMessage()

+ func (m *StructuredDatasetType_DatasetColumn) GetLiteralType() *LiteralType

+ func (m *StructuredDatasetType_DatasetColumn) GetName() string

+ func (m *StructuredDatasetType_DatasetColumn) Reset()

+ func (m *StructuredDatasetType_DatasetColumn) String() string

+ func (m *StructuredDatasetType_DatasetColumn) Validate() error

+ func (m *StructuredDatasetType_DatasetColumn) XXX_DiscardUnknown()

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

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

+ func (m *StructuredDatasetType_DatasetColumn) XXX_Size() int

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

+ type StructuredDatasetType_DatasetColumnValidationError struct

+ func (e StructuredDatasetType_DatasetColumnValidationError) Cause() error

+ func (e StructuredDatasetType_DatasetColumnValidationError) Error() string

+ func (e StructuredDatasetType_DatasetColumnValidationError) ErrorName() string

+ func (e StructuredDatasetType_DatasetColumnValidationError) Field() string

+ func (e StructuredDatasetType_DatasetColumnValidationError) Key() bool

+ func (e StructuredDatasetType_DatasetColumnValidationError) Reason() string

+ type StructuredDatasetValidationError struct

+ func (e StructuredDatasetValidationError) Cause() error

+ func (e StructuredDatasetValidationError) Error() string

+ func (e StructuredDatasetValidationError) ErrorName() string

+ func (e StructuredDatasetValidationError) Field() string

+ func (e StructuredDatasetValidationError) Key() bool

+ func (e StructuredDatasetValidationError) Reason() string

+ type TaskExecution struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskExecution) ProtoMessage()

+ 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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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_INITIALIZING

+ const TaskExecution_QUEUED

+ const TaskExecution_RUNNING

+ const TaskExecution_SUCCEEDED

+ const TaskExecution_UNDEFINED

+ const TaskExecution_WAITING_FOR_RESOURCES

+ 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 (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_Merge(src proto.Message)

+ 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

+ CacheSerializable bool

+ DeprecatedErrorMessage string

+ Discoverable bool

+ DiscoveryVersion string

+ GeneratesDeck bool

+ InterruptibleValue isTaskMetadata_InterruptibleValue

+ PodTemplateName string

+ Retries *RetryStrategy

+ Runtime *RuntimeMetadata

+ Tags map[string]string

+ Timeout *duration.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskMetadata) ProtoMessage()

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

+ func (m *TaskMetadata) GetCacheSerializable() bool

+ func (m *TaskMetadata) GetDeprecatedErrorMessage() string

+ func (m *TaskMetadata) GetDiscoverable() bool

+ func (m *TaskMetadata) GetDiscoveryVersion() string

+ func (m *TaskMetadata) GetGeneratesDeck() bool

+ func (m *TaskMetadata) GetInterruptible() bool

+ func (m *TaskMetadata) GetInterruptibleValue() isTaskMetadata_InterruptibleValue

+ func (m *TaskMetadata) GetPodTemplateName() string

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

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

+ func (m *TaskMetadata) GetTags() map[string]string

+ 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_Merge(src proto.Message)

+ 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 TaskMetadata_Interruptible struct

+ Interruptible bool

+ type TaskNode struct

+ Overrides *TaskNodeOverrides

+ Reference isTaskNode_Reference

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskNode) ProtoMessage()

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

+ func (m *TaskNode) GetOverrides() *TaskNodeOverrides

+ 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_Merge(src proto.Message)

+ func (m *TaskNode) XXX_Size() int

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

+ type TaskNodeOverrides struct

+ Resources *Resources

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskNodeOverrides) ProtoMessage()

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

+ func (m *TaskNodeOverrides) Reset()

+ func (m *TaskNodeOverrides) String() string

+ func (m *TaskNodeOverrides) Validate() error

+ func (m *TaskNodeOverrides) XXX_DiscardUnknown()

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

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

+ func (m *TaskNodeOverrides) XXX_Size() int

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

+ type TaskNodeOverridesValidationError struct

+ func (e TaskNodeOverridesValidationError) Cause() error

+ func (e TaskNodeOverridesValidationError) Error() string

+ func (e TaskNodeOverridesValidationError) ErrorName() string

+ func (e TaskNodeOverridesValidationError) Field() string

+ func (e TaskNodeOverridesValidationError) Key() bool

+ func (e TaskNodeOverridesValidationError) Reason() string

+ 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

+ Config map[string]string

+ Custom *_struct.Struct

+ Id *Identifier

+ Interface *TypedInterface

+ Metadata *TaskMetadata

+ SecurityContext *SecurityContext

+ Target isTaskTemplate_Target

+ TaskTypeVersion int32

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TaskTemplate) ProtoMessage()

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

+ func (m *TaskTemplate) GetConfig() map[string]string

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

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

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

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

+ func (m *TaskTemplate) GetK8SPod() *K8SPod

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

+ func (m *TaskTemplate) GetSecurityContext() *SecurityContext

+ func (m *TaskTemplate) GetSql() *Sql

+ func (m *TaskTemplate) GetTarget() isTaskTemplate_Target

+ func (m *TaskTemplate) GetTaskTypeVersion() int32

+ 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_Merge(src proto.Message)

+ 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 TaskTemplate_K8SPod struct

+ K8SPod *K8SPod

+ type TaskTemplate_Sql struct

+ Sql *Sql

+ type TypeAnnotation struct

+ Annotations *_struct.Struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TypeAnnotation) ProtoMessage()

+ func (m *TypeAnnotation) GetAnnotations() *_struct.Struct

+ func (m *TypeAnnotation) Reset()

+ func (m *TypeAnnotation) String() string

+ func (m *TypeAnnotation) Validate() error

+ func (m *TypeAnnotation) XXX_DiscardUnknown()

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

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

+ func (m *TypeAnnotation) XXX_Size() int

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

+ type TypeAnnotationValidationError struct

+ func (e TypeAnnotationValidationError) Cause() error

+ func (e TypeAnnotationValidationError) Error() string

+ func (e TypeAnnotationValidationError) ErrorName() string

+ func (e TypeAnnotationValidationError) Field() string

+ func (e TypeAnnotationValidationError) Key() bool

+ func (e TypeAnnotationValidationError) Reason() string

+ type TypeStructure struct

+ Tag string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TypeStructure) ProtoMessage()

+ func (m *TypeStructure) GetTag() string

+ func (m *TypeStructure) Reset()

+ func (m *TypeStructure) String() string

+ func (m *TypeStructure) Validate() error

+ func (m *TypeStructure) XXX_DiscardUnknown()

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

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

+ func (m *TypeStructure) XXX_Size() int

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

+ type TypeStructureValidationError struct

+ func (e TypeStructureValidationError) Cause() error

+ func (e TypeStructureValidationError) Error() string

+ func (e TypeStructureValidationError) ErrorName() string

+ func (e TypeStructureValidationError) Field() string

+ func (e TypeStructureValidationError) Key() bool

+ func (e TypeStructureValidationError) Reason() string

+ 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 (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_Merge(src proto.Message)

+ 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 Union struct

+ Type *LiteralType

+ Value *Literal

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Union) ProtoMessage()

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

+ func (m *Union) GetValue() *Literal

+ func (m *Union) Reset()

+ func (m *Union) String() string

+ func (m *Union) Validate() error

+ func (m *Union) XXX_DiscardUnknown()

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

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

+ func (m *Union) XXX_Size() int

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

+ type UnionInfo struct

+ TargetType *LiteralType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UnionInfo) ProtoMessage()

+ func (m *UnionInfo) GetTargetType() *LiteralType

+ func (m *UnionInfo) Reset()

+ func (m *UnionInfo) String() string

+ func (m *UnionInfo) Validate() error

+ func (m *UnionInfo) XXX_DiscardUnknown()

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

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

+ func (m *UnionInfo) XXX_Size() int

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

+ type UnionInfoValidationError struct

+ func (e UnionInfoValidationError) Cause() error

+ func (e UnionInfoValidationError) Error() string

+ func (e UnionInfoValidationError) ErrorName() string

+ func (e UnionInfoValidationError) Field() string

+ func (e UnionInfoValidationError) Key() bool

+ func (e UnionInfoValidationError) Reason() string

+ type UnionType struct

+ Variants []*LiteralType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UnionType) ProtoMessage()

+ func (m *UnionType) GetVariants() []*LiteralType

+ func (m *UnionType) Reset()

+ func (m *UnionType) String() string

+ func (m *UnionType) Validate() error

+ func (m *UnionType) XXX_DiscardUnknown()

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

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

+ func (m *UnionType) XXX_Size() int

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

+ type UnionTypeValidationError struct

+ func (e UnionTypeValidationError) Cause() error

+ func (e UnionTypeValidationError) Error() string

+ func (e UnionTypeValidationError) ErrorName() string

+ func (e UnionTypeValidationError) Field() string

+ func (e UnionTypeValidationError) Key() bool

+ func (e UnionTypeValidationError) Reason() string

+ type UnionValidationError struct

+ func (e UnionValidationError) Cause() error

+ func (e UnionValidationError) Error() string

+ func (e UnionValidationError) ErrorName() string

+ func (e UnionValidationError) Field() string

+ func (e UnionValidationError) Key() bool

+ func (e UnionValidationError) 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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 (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_Merge(src proto.Message)

+ 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_ABORTING

+ 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

+ OnFailure WorkflowMetadata_OnFailurePolicy

+ QualityOfService *QualityOfService

+ Tags map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WorkflowMetadata) ProtoMessage()

+ func (m *WorkflowMetadata) GetOnFailure() WorkflowMetadata_OnFailurePolicy

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

+ func (m *WorkflowMetadata) GetTags() map[string]string

+ 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_Merge(src proto.Message)

+ func (m *WorkflowMetadata) XXX_Size() int

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

+ 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 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 WorkflowMetadata_OnFailurePolicy int32

+ const WorkflowMetadata_FAIL_AFTER_EXECUTABLE_NODES_COMPLETE

+ const WorkflowMetadata_FAIL_IMMEDIATELY

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

+ func (x WorkflowMetadata_OnFailurePolicy) String() 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_OneofWrappers() []interface{}

+ 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_Merge(src proto.Message)

+ 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

+ MetadataDefaults *WorkflowMetadataDefaults

+ Nodes []*Node

+ Outputs []*Binding

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*WorkflowTemplate) ProtoMessage()

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

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

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

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

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

+ 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_Merge(src proto.Message)

+ 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