Versions in this module Expand all Collapse all v1 v1.0.15 Apr 20, 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 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 + 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) 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) 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_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) 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_Var struct + Var string + type OutputReference struct + NodeId string + Var string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OutputReference) Descriptor() ([]byte, []int) + func (*OutputReference) ProtoMessage() + func (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 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
Go to main page