Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 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 File_kozmoidl_core_artifact_id_proto protoreflect.FileDescriptor + var File_kozmoidl_core_catalog_proto protoreflect.FileDescriptor + var File_kozmoidl_core_compiler_proto protoreflect.FileDescriptor + var File_kozmoidl_core_condition_proto protoreflect.FileDescriptor + var File_kozmoidl_core_dynamic_job_proto protoreflect.FileDescriptor + var File_kozmoidl_core_errors_proto protoreflect.FileDescriptor + var File_kozmoidl_core_execution_proto protoreflect.FileDescriptor + var File_kozmoidl_core_identifier_proto protoreflect.FileDescriptor + var File_kozmoidl_core_interface_proto protoreflect.FileDescriptor + var File_kozmoidl_core_literals_proto protoreflect.FileDescriptor + var File_kozmoidl_core_metrics_proto protoreflect.FileDescriptor + var File_kozmoidl_core_security_proto protoreflect.FileDescriptor + var File_kozmoidl_core_tasks_proto protoreflect.FileDescriptor + var File_kozmoidl_core_types_proto protoreflect.FileDescriptor + var File_kozmoidl_core_workflow_closure_proto protoreflect.FileDescriptor + var File_kozmoidl_core_workflow_proto protoreflect.FileDescriptor + 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 + func (*Alias) Descriptor() ([]byte, []int) + func (*Alias) ProtoMessage() + func (x *Alias) GetAlias() string + func (x *Alias) GetVar() string + func (x *Alias) ProtoReflect() protoreflect.Message + func (x *Alias) Reset() + func (x *Alias) String() string + type ApproveCondition struct + SignalId string + func (*ApproveCondition) Descriptor() ([]byte, []int) + func (*ApproveCondition) ProtoMessage() + func (x *ApproveCondition) GetSignalId() string + func (x *ApproveCondition) ProtoReflect() protoreflect.Message + func (x *ApproveCondition) Reset() + func (x *ApproveCondition) String() string + type ArrayNode struct + Node *Node + Parallelism uint32 + SuccessCriteria isArrayNode_SuccessCriteria + func (*ArrayNode) Descriptor() ([]byte, []int) + func (*ArrayNode) ProtoMessage() + func (m *ArrayNode) GetSuccessCriteria() isArrayNode_SuccessCriteria + func (x *ArrayNode) GetMinSuccessRatio() float32 + func (x *ArrayNode) GetMinSuccesses() uint32 + func (x *ArrayNode) GetNode() *Node + func (x *ArrayNode) GetParallelism() uint32 + func (x *ArrayNode) ProtoReflect() protoreflect.Message + func (x *ArrayNode) Reset() + func (x *ArrayNode) String() string + type ArrayNode_MinSuccessRatio struct + MinSuccessRatio float32 + type ArrayNode_MinSuccesses struct + MinSuccesses uint32 + type ArtifactBindingData struct + Index uint32 + PartitionData isArtifactBindingData_PartitionData + Transform string + func (*ArtifactBindingData) Descriptor() ([]byte, []int) + func (*ArtifactBindingData) ProtoMessage() + func (m *ArtifactBindingData) GetPartitionData() isArtifactBindingData_PartitionData + func (x *ArtifactBindingData) GetBindToTimePartition() bool + func (x *ArtifactBindingData) GetIndex() uint32 + func (x *ArtifactBindingData) GetPartitionKey() string + func (x *ArtifactBindingData) GetTransform() string + func (x *ArtifactBindingData) ProtoReflect() protoreflect.Message + func (x *ArtifactBindingData) Reset() + func (x *ArtifactBindingData) String() string + type ArtifactBindingData_BindToTimePartition struct + BindToTimePartition bool + type ArtifactBindingData_PartitionKey struct + PartitionKey string + type ArtifactID struct + ArtifactKey *ArtifactKey + Partitions *Partitions + TimePartition *TimePartition + Version string + func (*ArtifactID) Descriptor() ([]byte, []int) + func (*ArtifactID) ProtoMessage() + func (x *ArtifactID) GetArtifactKey() *ArtifactKey + func (x *ArtifactID) GetPartitions() *Partitions + func (x *ArtifactID) GetTimePartition() *TimePartition + func (x *ArtifactID) GetVersion() string + func (x *ArtifactID) ProtoReflect() protoreflect.Message + func (x *ArtifactID) Reset() + func (x *ArtifactID) String() string + type ArtifactKey struct + Domain string + Name string + Org string + Project string + func (*ArtifactKey) Descriptor() ([]byte, []int) + func (*ArtifactKey) ProtoMessage() + func (x *ArtifactKey) GetDomain() string + func (x *ArtifactKey) GetName() string + func (x *ArtifactKey) GetOrg() string + func (x *ArtifactKey) GetProject() string + func (x *ArtifactKey) ProtoReflect() protoreflect.Message + func (x *ArtifactKey) Reset() + func (x *ArtifactKey) String() string + type ArtifactQuery struct + Identifier isArtifactQuery_Identifier + func (*ArtifactQuery) Descriptor() ([]byte, []int) + func (*ArtifactQuery) ProtoMessage() + func (m *ArtifactQuery) GetIdentifier() isArtifactQuery_Identifier + func (x *ArtifactQuery) GetArtifactId() *ArtifactID + func (x *ArtifactQuery) GetArtifactTag() *ArtifactTag + func (x *ArtifactQuery) GetBinding() *ArtifactBindingData + func (x *ArtifactQuery) GetUri() string + func (x *ArtifactQuery) ProtoReflect() protoreflect.Message + func (x *ArtifactQuery) Reset() + func (x *ArtifactQuery) String() string + type ArtifactQuery_ArtifactId struct + ArtifactId *ArtifactID + type ArtifactQuery_ArtifactTag struct + ArtifactTag *ArtifactTag + type ArtifactQuery_Binding struct + Binding *ArtifactBindingData + type ArtifactQuery_Uri struct + Uri string + type ArtifactTag struct + ArtifactKey *ArtifactKey + Value *LabelValue + func (*ArtifactTag) Descriptor() ([]byte, []int) + func (*ArtifactTag) ProtoMessage() + func (x *ArtifactTag) GetArtifactKey() *ArtifactKey + func (x *ArtifactTag) GetValue() *LabelValue + func (x *ArtifactTag) ProtoReflect() protoreflect.Message + func (x *ArtifactTag) Reset() + func (x *ArtifactTag) String() string + type Binary struct + Tag string + Value []byte + func (*Binary) Descriptor() ([]byte, []int) + func (*Binary) ProtoMessage() + func (x *Binary) GetTag() string + func (x *Binary) GetValue() []byte + func (x *Binary) ProtoReflect() protoreflect.Message + func (x *Binary) Reset() + func (x *Binary) String() string + type Binding struct + Binding *BindingData + Var string + func (*Binding) Descriptor() ([]byte, []int) + func (*Binding) ProtoMessage() + func (x *Binding) GetBinding() *BindingData + func (x *Binding) GetVar() string + func (x *Binding) ProtoReflect() protoreflect.Message + func (x *Binding) Reset() + func (x *Binding) String() string + type BindingData struct + Union *UnionInfo + Value isBindingData_Value + func (*BindingData) Descriptor() ([]byte, []int) + func (*BindingData) ProtoMessage() + func (m *BindingData) GetValue() isBindingData_Value + func (x *BindingData) GetCollection() *BindingDataCollection + func (x *BindingData) GetMap() *BindingDataMap + func (x *BindingData) GetPromise() *OutputReference + func (x *BindingData) GetScalar() *Scalar + func (x *BindingData) GetUnion() *UnionInfo + func (x *BindingData) ProtoReflect() protoreflect.Message + func (x *BindingData) Reset() + func (x *BindingData) String() string + type BindingDataCollection struct + Bindings []*BindingData + func (*BindingDataCollection) Descriptor() ([]byte, []int) + func (*BindingDataCollection) ProtoMessage() + func (x *BindingDataCollection) GetBindings() []*BindingData + func (x *BindingDataCollection) ProtoReflect() protoreflect.Message + func (x *BindingDataCollection) Reset() + func (x *BindingDataCollection) String() string + type BindingDataMap struct + Bindings map[string]*BindingData + func (*BindingDataMap) Descriptor() ([]byte, []int) + func (*BindingDataMap) ProtoMessage() + func (x *BindingDataMap) GetBindings() map[string]*BindingData + func (x *BindingDataMap) ProtoReflect() protoreflect.Message + func (x *BindingDataMap) Reset() + func (x *BindingDataMap) String() 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 Blob struct + Metadata *BlobMetadata + Uri string + func (*Blob) Descriptor() ([]byte, []int) + func (*Blob) ProtoMessage() + func (x *Blob) GetMetadata() *BlobMetadata + func (x *Blob) GetUri() string + func (x *Blob) ProtoReflect() protoreflect.Message + func (x *Blob) Reset() + func (x *Blob) String() string + type BlobMetadata struct + Type *BlobType + func (*BlobMetadata) Descriptor() ([]byte, []int) + func (*BlobMetadata) ProtoMessage() + func (x *BlobMetadata) GetType() *BlobType + func (x *BlobMetadata) ProtoReflect() protoreflect.Message + func (x *BlobMetadata) Reset() + func (x *BlobMetadata) String() string + type BlobType struct + Dimensionality BlobType_BlobDimensionality + Format string + func (*BlobType) Descriptor() ([]byte, []int) + func (*BlobType) ProtoMessage() + func (x *BlobType) GetDimensionality() BlobType_BlobDimensionality + func (x *BlobType) GetFormat() string + func (x *BlobType) ProtoReflect() protoreflect.Message + func (x *BlobType) Reset() + func (x *BlobType) String() string + type BlobType_BlobDimensionality int32 + const BlobType_MULTIPART + const BlobType_SINGLE + func (BlobType_BlobDimensionality) Descriptor() protoreflect.EnumDescriptor + func (BlobType_BlobDimensionality) EnumDescriptor() ([]byte, []int) + func (BlobType_BlobDimensionality) Type() protoreflect.EnumType + func (x BlobType_BlobDimensionality) Enum() *BlobType_BlobDimensionality + func (x BlobType_BlobDimensionality) Number() protoreflect.EnumNumber + func (x BlobType_BlobDimensionality) String() string + type BooleanExpression struct + Expr isBooleanExpression_Expr + func (*BooleanExpression) Descriptor() ([]byte, []int) + func (*BooleanExpression) ProtoMessage() + func (m *BooleanExpression) GetExpr() isBooleanExpression_Expr + func (x *BooleanExpression) GetComparison() *ComparisonExpression + func (x *BooleanExpression) GetConjunction() *ConjunctionExpression + func (x *BooleanExpression) ProtoReflect() protoreflect.Message + func (x *BooleanExpression) Reset() + func (x *BooleanExpression) String() string + type BooleanExpression_Comparison struct + Comparison *ComparisonExpression + type BooleanExpression_Conjunction struct + Conjunction *ConjunctionExpression + type BranchNode struct + IfElse *IfElseBlock + func (*BranchNode) Descriptor() ([]byte, []int) + func (*BranchNode) ProtoMessage() + func (x *BranchNode) GetIfElse() *IfElseBlock + func (x *BranchNode) ProtoReflect() protoreflect.Message + func (x *BranchNode) Reset() + func (x *BranchNode) String() string + type CatalogArtifactTag struct + ArtifactId string + Name string + func (*CatalogArtifactTag) Descriptor() ([]byte, []int) + func (*CatalogArtifactTag) ProtoMessage() + func (x *CatalogArtifactTag) GetArtifactId() string + func (x *CatalogArtifactTag) GetName() string + func (x *CatalogArtifactTag) ProtoReflect() protoreflect.Message + func (x *CatalogArtifactTag) Reset() + func (x *CatalogArtifactTag) String() string + type CatalogCacheStatus int32 + const CatalogCacheStatus_CACHE_DISABLED + const CatalogCacheStatus_CACHE_EVICTED + 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) Descriptor() protoreflect.EnumDescriptor + func (CatalogCacheStatus) EnumDescriptor() ([]byte, []int) + func (CatalogCacheStatus) Type() protoreflect.EnumType + func (x CatalogCacheStatus) Enum() *CatalogCacheStatus + func (x CatalogCacheStatus) Number() protoreflect.EnumNumber + func (x CatalogCacheStatus) String() string + type CatalogMetadata struct + ArtifactTag *CatalogArtifactTag + DatasetId *Identifier + SourceExecution isCatalogMetadata_SourceExecution + func (*CatalogMetadata) Descriptor() ([]byte, []int) + func (*CatalogMetadata) ProtoMessage() + func (m *CatalogMetadata) GetSourceExecution() isCatalogMetadata_SourceExecution + func (x *CatalogMetadata) GetArtifactTag() *CatalogArtifactTag + func (x *CatalogMetadata) GetDatasetId() *Identifier + func (x *CatalogMetadata) GetSourceTaskExecution() *TaskExecutionIdentifier + func (x *CatalogMetadata) ProtoReflect() protoreflect.Message + func (x *CatalogMetadata) Reset() + func (x *CatalogMetadata) String() string + type CatalogMetadata_SourceTaskExecution struct + SourceTaskExecution *TaskExecutionIdentifier + type CatalogReservation struct + func (*CatalogReservation) Descriptor() ([]byte, []int) + func (*CatalogReservation) ProtoMessage() + func (x *CatalogReservation) ProtoReflect() protoreflect.Message + func (x *CatalogReservation) Reset() + func (x *CatalogReservation) String() 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) Descriptor() protoreflect.EnumDescriptor + func (CatalogReservation_Status) EnumDescriptor() ([]byte, []int) + func (CatalogReservation_Status) Type() protoreflect.EnumType + func (x CatalogReservation_Status) Enum() *CatalogReservation_Status + func (x CatalogReservation_Status) Number() protoreflect.EnumNumber + func (x CatalogReservation_Status) String() string + type ComparisonExpression struct + LeftValue *Operand + Operator ComparisonExpression_Operator + RightValue *Operand + func (*ComparisonExpression) Descriptor() ([]byte, []int) + func (*ComparisonExpression) ProtoMessage() + func (x *ComparisonExpression) GetLeftValue() *Operand + func (x *ComparisonExpression) GetOperator() ComparisonExpression_Operator + func (x *ComparisonExpression) GetRightValue() *Operand + func (x *ComparisonExpression) ProtoReflect() protoreflect.Message + func (x *ComparisonExpression) Reset() + func (x *ComparisonExpression) String() 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) Descriptor() protoreflect.EnumDescriptor + func (ComparisonExpression_Operator) EnumDescriptor() ([]byte, []int) + func (ComparisonExpression_Operator) Type() protoreflect.EnumType + func (x ComparisonExpression_Operator) Enum() *ComparisonExpression_Operator + func (x ComparisonExpression_Operator) Number() protoreflect.EnumNumber + func (x ComparisonExpression_Operator) String() string + type CompiledLaunchPlan struct + Template *LaunchPlanTemplate + func (*CompiledLaunchPlan) Descriptor() ([]byte, []int) + func (*CompiledLaunchPlan) ProtoMessage() + func (x *CompiledLaunchPlan) GetTemplate() *LaunchPlanTemplate + func (x *CompiledLaunchPlan) ProtoReflect() protoreflect.Message + func (x *CompiledLaunchPlan) Reset() + func (x *CompiledLaunchPlan) String() string + type CompiledTask struct + Template *TaskTemplate + func (*CompiledTask) Descriptor() ([]byte, []int) + func (*CompiledTask) ProtoMessage() + func (x *CompiledTask) GetTemplate() *TaskTemplate + func (x *CompiledTask) ProtoReflect() protoreflect.Message + func (x *CompiledTask) Reset() + func (x *CompiledTask) String() string + type CompiledWorkflow struct + Connections *ConnectionSet + Template *WorkflowTemplate + func (*CompiledWorkflow) Descriptor() ([]byte, []int) + func (*CompiledWorkflow) ProtoMessage() + func (x *CompiledWorkflow) GetConnections() *ConnectionSet + func (x *CompiledWorkflow) GetTemplate() *WorkflowTemplate + func (x *CompiledWorkflow) ProtoReflect() protoreflect.Message + func (x *CompiledWorkflow) Reset() + func (x *CompiledWorkflow) String() string + type CompiledWorkflowClosure struct + LaunchPlans []*CompiledLaunchPlan + Primary *CompiledWorkflow + SubWorkflows []*CompiledWorkflow + Tasks []*CompiledTask + func (*CompiledWorkflowClosure) Descriptor() ([]byte, []int) + func (*CompiledWorkflowClosure) ProtoMessage() + func (x *CompiledWorkflowClosure) GetLaunchPlans() []*CompiledLaunchPlan + func (x *CompiledWorkflowClosure) GetPrimary() *CompiledWorkflow + func (x *CompiledWorkflowClosure) GetSubWorkflows() []*CompiledWorkflow + func (x *CompiledWorkflowClosure) GetTasks() []*CompiledTask + func (x *CompiledWorkflowClosure) ProtoReflect() protoreflect.Message + func (x *CompiledWorkflowClosure) Reset() + func (x *CompiledWorkflowClosure) String() string + type ConjunctionExpression struct + LeftExpression *BooleanExpression + Operator ConjunctionExpression_LogicalOperator + RightExpression *BooleanExpression + func (*ConjunctionExpression) Descriptor() ([]byte, []int) + func (*ConjunctionExpression) ProtoMessage() + func (x *ConjunctionExpression) GetLeftExpression() *BooleanExpression + func (x *ConjunctionExpression) GetOperator() ConjunctionExpression_LogicalOperator + func (x *ConjunctionExpression) GetRightExpression() *BooleanExpression + func (x *ConjunctionExpression) ProtoReflect() protoreflect.Message + func (x *ConjunctionExpression) Reset() + func (x *ConjunctionExpression) String() string + type ConjunctionExpression_LogicalOperator int32 + const ConjunctionExpression_AND + const ConjunctionExpression_OR + func (ConjunctionExpression_LogicalOperator) Descriptor() protoreflect.EnumDescriptor + func (ConjunctionExpression_LogicalOperator) EnumDescriptor() ([]byte, []int) + func (ConjunctionExpression_LogicalOperator) Type() protoreflect.EnumType + func (x ConjunctionExpression_LogicalOperator) Enum() *ConjunctionExpression_LogicalOperator + func (x ConjunctionExpression_LogicalOperator) Number() protoreflect.EnumNumber + func (x ConjunctionExpression_LogicalOperator) String() string + type ConnectionSet struct + Downstream map[string]*ConnectionSet_IdList + Upstream map[string]*ConnectionSet_IdList + func (*ConnectionSet) Descriptor() ([]byte, []int) + func (*ConnectionSet) ProtoMessage() + func (x *ConnectionSet) GetDownstream() map[string]*ConnectionSet_IdList + func (x *ConnectionSet) GetUpstream() map[string]*ConnectionSet_IdList + func (x *ConnectionSet) ProtoReflect() protoreflect.Message + func (x *ConnectionSet) Reset() + func (x *ConnectionSet) String() string + type ConnectionSet_IdList struct + Ids []string + func (*ConnectionSet_IdList) Descriptor() ([]byte, []int) + func (*ConnectionSet_IdList) ProtoMessage() + func (x *ConnectionSet_IdList) GetIds() []string + func (x *ConnectionSet_IdList) ProtoReflect() protoreflect.Message + func (x *ConnectionSet_IdList) Reset() + func (x *ConnectionSet_IdList) String() string + type Container struct + Architecture Container_Architecture + Args []string + Command []string + Config []*KeyValuePair + DataConfig *DataLoadingConfig + Env []*KeyValuePair + Image string + Ports []*ContainerPort + Resources *Resources + func (*Container) Descriptor() ([]byte, []int) + func (*Container) ProtoMessage() + func (x *Container) GetArchitecture() Container_Architecture + func (x *Container) GetArgs() []string + func (x *Container) GetCommand() []string + func (x *Container) GetConfig() []*KeyValuePair + func (x *Container) GetDataConfig() *DataLoadingConfig + func (x *Container) GetEnv() []*KeyValuePair + func (x *Container) GetImage() string + func (x *Container) GetPorts() []*ContainerPort + func (x *Container) GetResources() *Resources + func (x *Container) ProtoReflect() protoreflect.Message + func (x *Container) Reset() + func (x *Container) String() string + type ContainerError struct + Code string + Kind ContainerError_Kind + Message string + Origin ExecutionError_ErrorKind + func (*ContainerError) Descriptor() ([]byte, []int) + func (*ContainerError) ProtoMessage() + func (x *ContainerError) GetCode() string + func (x *ContainerError) GetKind() ContainerError_Kind + func (x *ContainerError) GetMessage() string + func (x *ContainerError) GetOrigin() ExecutionError_ErrorKind + func (x *ContainerError) ProtoReflect() protoreflect.Message + func (x *ContainerError) Reset() + func (x *ContainerError) String() string + type ContainerError_Kind int32 + const ContainerError_NON_RECOVERABLE + const ContainerError_RECOVERABLE + func (ContainerError_Kind) Descriptor() protoreflect.EnumDescriptor + func (ContainerError_Kind) EnumDescriptor() ([]byte, []int) + func (ContainerError_Kind) Type() protoreflect.EnumType + func (x ContainerError_Kind) Enum() *ContainerError_Kind + func (x ContainerError_Kind) Number() protoreflect.EnumNumber + func (x ContainerError_Kind) String() string + type ContainerPort struct + ContainerPort uint32 + func (*ContainerPort) Descriptor() ([]byte, []int) + func (*ContainerPort) ProtoMessage() + func (x *ContainerPort) GetContainerPort() uint32 + func (x *ContainerPort) ProtoReflect() protoreflect.Message + func (x *ContainerPort) Reset() + func (x *ContainerPort) String() 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) Descriptor() protoreflect.EnumDescriptor + func (Container_Architecture) EnumDescriptor() ([]byte, []int) + func (Container_Architecture) Type() protoreflect.EnumType + func (x Container_Architecture) Enum() *Container_Architecture + func (x Container_Architecture) Number() protoreflect.EnumNumber + func (x Container_Architecture) String() string + type DataLoadingConfig struct + Enabled bool + Format DataLoadingConfig_LiteralMapFormat + InputPath string + IoStrategy *IOStrategy + OutputPath string + func (*DataLoadingConfig) Descriptor() ([]byte, []int) + func (*DataLoadingConfig) ProtoMessage() + func (x *DataLoadingConfig) GetEnabled() bool + func (x *DataLoadingConfig) GetFormat() DataLoadingConfig_LiteralMapFormat + func (x *DataLoadingConfig) GetInputPath() string + func (x *DataLoadingConfig) GetIoStrategy() *IOStrategy + func (x *DataLoadingConfig) GetOutputPath() string + func (x *DataLoadingConfig) ProtoReflect() protoreflect.Message + func (x *DataLoadingConfig) Reset() + func (x *DataLoadingConfig) String() string + type DataLoadingConfig_LiteralMapFormat int32 + const DataLoadingConfig_JSON + const DataLoadingConfig_PROTO + const DataLoadingConfig_YAML + func (DataLoadingConfig_LiteralMapFormat) Descriptor() protoreflect.EnumDescriptor + func (DataLoadingConfig_LiteralMapFormat) EnumDescriptor() ([]byte, []int) + func (DataLoadingConfig_LiteralMapFormat) Type() protoreflect.EnumType + func (x DataLoadingConfig_LiteralMapFormat) Enum() *DataLoadingConfig_LiteralMapFormat + func (x DataLoadingConfig_LiteralMapFormat) Number() protoreflect.EnumNumber + func (x DataLoadingConfig_LiteralMapFormat) String() string + type DynamicJobSpec struct + MinSuccesses int64 + Nodes []*Node + Outputs []*Binding + Subworkflows []*WorkflowTemplate + Tasks []*TaskTemplate + func (*DynamicJobSpec) Descriptor() ([]byte, []int) + func (*DynamicJobSpec) ProtoMessage() + func (x *DynamicJobSpec) GetMinSuccesses() int64 + func (x *DynamicJobSpec) GetNodes() []*Node + func (x *DynamicJobSpec) GetOutputs() []*Binding + func (x *DynamicJobSpec) GetSubworkflows() []*WorkflowTemplate + func (x *DynamicJobSpec) GetTasks() []*TaskTemplate + func (x *DynamicJobSpec) ProtoReflect() protoreflect.Message + func (x *DynamicJobSpec) Reset() + func (x *DynamicJobSpec) String() string + type EnumType struct + Values []string + func (*EnumType) Descriptor() ([]byte, []int) + func (*EnumType) ProtoMessage() + func (x *EnumType) GetValues() []string + func (x *EnumType) ProtoReflect() protoreflect.Message + func (x *EnumType) Reset() + func (x *EnumType) String() string + type Error struct + FailedNodeId string + Message string + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (x *Error) GetFailedNodeId() string + func (x *Error) GetMessage() string + func (x *Error) ProtoReflect() protoreflect.Message + func (x *Error) Reset() + func (x *Error) String() string + type ErrorDocument struct + Error *ContainerError + func (*ErrorDocument) Descriptor() ([]byte, []int) + func (*ErrorDocument) ProtoMessage() + func (x *ErrorDocument) GetError() *ContainerError + func (x *ErrorDocument) ProtoReflect() protoreflect.Message + func (x *ErrorDocument) Reset() + func (x *ErrorDocument) String() string + type ExecutionError struct + Code string + ErrorUri string + Kind ExecutionError_ErrorKind + Message string + func (*ExecutionError) Descriptor() ([]byte, []int) + func (*ExecutionError) ProtoMessage() + func (x *ExecutionError) GetCode() string + func (x *ExecutionError) GetErrorUri() string + func (x *ExecutionError) GetKind() ExecutionError_ErrorKind + func (x *ExecutionError) GetMessage() string + func (x *ExecutionError) ProtoReflect() protoreflect.Message + func (x *ExecutionError) Reset() + func (x *ExecutionError) String() string + type ExecutionError_ErrorKind int32 + const ExecutionError_SYSTEM + const ExecutionError_UNKNOWN + const ExecutionError_USER + func (ExecutionError_ErrorKind) Descriptor() protoreflect.EnumDescriptor + func (ExecutionError_ErrorKind) EnumDescriptor() ([]byte, []int) + func (ExecutionError_ErrorKind) Type() protoreflect.EnumType + func (x ExecutionError_ErrorKind) Enum() *ExecutionError_ErrorKind + func (x ExecutionError_ErrorKind) Number() protoreflect.EnumNumber + func (x ExecutionError_ErrorKind) String() string + type ExecutionMetricResult struct + Data *structpb.Struct + Metric string + func (*ExecutionMetricResult) Descriptor() ([]byte, []int) + func (*ExecutionMetricResult) ProtoMessage() + func (x *ExecutionMetricResult) GetData() *structpb.Struct + func (x *ExecutionMetricResult) GetMetric() string + func (x *ExecutionMetricResult) ProtoReflect() protoreflect.Message + func (x *ExecutionMetricResult) Reset() + func (x *ExecutionMetricResult) String() string + type ExtendedResources struct + GpuAccelerator *GPUAccelerator + func (*ExtendedResources) Descriptor() ([]byte, []int) + func (*ExtendedResources) ProtoMessage() + func (x *ExtendedResources) GetGpuAccelerator() *GPUAccelerator + func (x *ExtendedResources) ProtoReflect() protoreflect.Message + func (x *ExtendedResources) Reset() + func (x *ExtendedResources) String() string + type GPUAccelerator struct + Device string + PartitionSizeValue isGPUAccelerator_PartitionSizeValue + func (*GPUAccelerator) Descriptor() ([]byte, []int) + func (*GPUAccelerator) ProtoMessage() + func (m *GPUAccelerator) GetPartitionSizeValue() isGPUAccelerator_PartitionSizeValue + func (x *GPUAccelerator) GetDevice() string + func (x *GPUAccelerator) GetPartitionSize() string + func (x *GPUAccelerator) GetUnpartitioned() bool + func (x *GPUAccelerator) ProtoReflect() protoreflect.Message + func (x *GPUAccelerator) Reset() + func (x *GPUAccelerator) String() string + type GPUAccelerator_PartitionSize struct + PartitionSize string + type GPUAccelerator_Unpartitioned struct + Unpartitioned bool + type GateNode struct + Condition isGateNode_Condition + func (*GateNode) Descriptor() ([]byte, []int) + func (*GateNode) ProtoMessage() + func (m *GateNode) GetCondition() isGateNode_Condition + func (x *GateNode) GetApprove() *ApproveCondition + func (x *GateNode) GetSignal() *SignalCondition + func (x *GateNode) GetSleep() *SleepCondition + func (x *GateNode) ProtoReflect() protoreflect.Message + func (x *GateNode) Reset() + func (x *GateNode) String() 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 + func (*IOStrategy) Descriptor() ([]byte, []int) + func (*IOStrategy) ProtoMessage() + func (x *IOStrategy) GetDownloadMode() IOStrategy_DownloadMode + func (x *IOStrategy) GetUploadMode() IOStrategy_UploadMode + func (x *IOStrategy) ProtoReflect() protoreflect.Message + func (x *IOStrategy) Reset() + func (x *IOStrategy) String() string + type IOStrategy_DownloadMode int32 + const IOStrategy_DOWNLOAD_EAGER + const IOStrategy_DOWNLOAD_STREAM + const IOStrategy_DO_NOT_DOWNLOAD + func (IOStrategy_DownloadMode) Descriptor() protoreflect.EnumDescriptor + func (IOStrategy_DownloadMode) EnumDescriptor() ([]byte, []int) + func (IOStrategy_DownloadMode) Type() protoreflect.EnumType + func (x IOStrategy_DownloadMode) Enum() *IOStrategy_DownloadMode + func (x IOStrategy_DownloadMode) Number() protoreflect.EnumNumber + 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) Descriptor() protoreflect.EnumDescriptor + func (IOStrategy_UploadMode) EnumDescriptor() ([]byte, []int) + func (IOStrategy_UploadMode) Type() protoreflect.EnumType + func (x IOStrategy_UploadMode) Enum() *IOStrategy_UploadMode + func (x IOStrategy_UploadMode) Number() protoreflect.EnumNumber + func (x IOStrategy_UploadMode) String() string + type Identifier struct + Domain string + Name string + Org string + Project string + ResourceType ResourceType + Version string + func (*Identifier) Descriptor() ([]byte, []int) + func (*Identifier) ProtoMessage() + func (x *Identifier) GetDomain() string + func (x *Identifier) GetName() string + func (x *Identifier) GetOrg() string + func (x *Identifier) GetProject() string + func (x *Identifier) GetResourceType() ResourceType + func (x *Identifier) GetVersion() string + func (x *Identifier) ProtoReflect() protoreflect.Message + func (x *Identifier) Reset() + func (x *Identifier) String() string + type Identity struct + ExecutionIdentity string + IamRole string + K8SServiceAccount string + Oauth2Client *OAuth2Client + func (*Identity) Descriptor() ([]byte, []int) + func (*Identity) ProtoMessage() + func (x *Identity) GetExecutionIdentity() string + func (x *Identity) GetIamRole() string + func (x *Identity) GetK8SServiceAccount() string + func (x *Identity) GetOauth2Client() *OAuth2Client + func (x *Identity) ProtoReflect() protoreflect.Message + func (x *Identity) Reset() + func (x *Identity) String() string + type IfBlock struct + Condition *BooleanExpression + ThenNode *Node + func (*IfBlock) Descriptor() ([]byte, []int) + func (*IfBlock) ProtoMessage() + func (x *IfBlock) GetCondition() *BooleanExpression + func (x *IfBlock) GetThenNode() *Node + func (x *IfBlock) ProtoReflect() protoreflect.Message + func (x *IfBlock) Reset() + func (x *IfBlock) String() string + type IfElseBlock struct + Case *IfBlock + Default isIfElseBlock_Default + Other []*IfBlock + func (*IfElseBlock) Descriptor() ([]byte, []int) + func (*IfElseBlock) ProtoMessage() + func (m *IfElseBlock) GetDefault() isIfElseBlock_Default + func (x *IfElseBlock) GetCase() *IfBlock + func (x *IfElseBlock) GetElseNode() *Node + func (x *IfElseBlock) GetError() *Error + func (x *IfElseBlock) GetOther() []*IfBlock + func (x *IfElseBlock) ProtoReflect() protoreflect.Message + func (x *IfElseBlock) Reset() + func (x *IfElseBlock) String() string + type IfElseBlock_ElseNode struct + ElseNode *Node + type IfElseBlock_Error struct + Error *Error + type InputBindingData struct + Var string + func (*InputBindingData) Descriptor() ([]byte, []int) + func (*InputBindingData) ProtoMessage() + func (x *InputBindingData) GetVar() string + func (x *InputBindingData) ProtoReflect() protoreflect.Message + func (x *InputBindingData) Reset() + func (x *InputBindingData) String() string + type K8SObjectMetadata struct + Annotations map[string]string + Labels map[string]string + func (*K8SObjectMetadata) Descriptor() ([]byte, []int) + func (*K8SObjectMetadata) ProtoMessage() + func (x *K8SObjectMetadata) GetAnnotations() map[string]string + func (x *K8SObjectMetadata) GetLabels() map[string]string + func (x *K8SObjectMetadata) ProtoReflect() protoreflect.Message + func (x *K8SObjectMetadata) Reset() + func (x *K8SObjectMetadata) String() string + type K8SPod struct + DataConfig *DataLoadingConfig + Metadata *K8SObjectMetadata + PodSpec *structpb.Struct + func (*K8SPod) Descriptor() ([]byte, []int) + func (*K8SPod) ProtoMessage() + func (x *K8SPod) GetDataConfig() *DataLoadingConfig + func (x *K8SPod) GetMetadata() *K8SObjectMetadata + func (x *K8SPod) GetPodSpec() *structpb.Struct + func (x *K8SPod) ProtoReflect() protoreflect.Message + func (x *K8SPod) Reset() + func (x *K8SPod) String() string + type KeyValuePair struct + Key string + Value string + func (*KeyValuePair) Descriptor() ([]byte, []int) + func (*KeyValuePair) ProtoMessage() + func (x *KeyValuePair) GetKey() string + func (x *KeyValuePair) GetValue() string + func (x *KeyValuePair) ProtoReflect() protoreflect.Message + func (x *KeyValuePair) Reset() + func (x *KeyValuePair) String() string + type LabelValue struct + Value isLabelValue_Value + func (*LabelValue) Descriptor() ([]byte, []int) + func (*LabelValue) ProtoMessage() + func (m *LabelValue) GetValue() isLabelValue_Value + func (x *LabelValue) GetInputBinding() *InputBindingData + func (x *LabelValue) GetStaticValue() string + func (x *LabelValue) GetTimeValue() *timestamppb.Timestamp + func (x *LabelValue) GetTriggeredBinding() *ArtifactBindingData + func (x *LabelValue) ProtoReflect() protoreflect.Message + func (x *LabelValue) Reset() + func (x *LabelValue) String() string + type LabelValue_InputBinding struct + InputBinding *InputBindingData + type LabelValue_StaticValue struct + StaticValue string + type LabelValue_TimeValue struct + TimeValue *timestamppb.Timestamp + type LabelValue_TriggeredBinding struct + TriggeredBinding *ArtifactBindingData + type LaunchPlanTemplate struct + FixedInputs *LiteralMap + Id *Identifier + Interface *TypedInterface + func (*LaunchPlanTemplate) Descriptor() ([]byte, []int) + func (*LaunchPlanTemplate) ProtoMessage() + func (x *LaunchPlanTemplate) GetFixedInputs() *LiteralMap + func (x *LaunchPlanTemplate) GetId() *Identifier + func (x *LaunchPlanTemplate) GetInterface() *TypedInterface + func (x *LaunchPlanTemplate) ProtoReflect() protoreflect.Message + func (x *LaunchPlanTemplate) Reset() + func (x *LaunchPlanTemplate) String() string + type Literal struct + Hash string + Metadata map[string]string + Value isLiteral_Value + func (*Literal) Descriptor() ([]byte, []int) + func (*Literal) ProtoMessage() + func (m *Literal) GetValue() isLiteral_Value + func (x *Literal) GetCollection() *LiteralCollection + func (x *Literal) GetHash() string + func (x *Literal) GetMap() *LiteralMap + func (x *Literal) GetMetadata() map[string]string + func (x *Literal) GetScalar() *Scalar + func (x *Literal) ProtoReflect() protoreflect.Message + func (x *Literal) Reset() + func (x *Literal) String() string + type LiteralCollection struct + Literals []*Literal + func (*LiteralCollection) Descriptor() ([]byte, []int) + func (*LiteralCollection) ProtoMessage() + func (x *LiteralCollection) GetLiterals() []*Literal + func (x *LiteralCollection) ProtoReflect() protoreflect.Message + func (x *LiteralCollection) Reset() + func (x *LiteralCollection) String() string + type LiteralMap struct + Literals map[string]*Literal + func (*LiteralMap) Descriptor() ([]byte, []int) + func (*LiteralMap) ProtoMessage() + func (x *LiteralMap) GetLiterals() map[string]*Literal + func (x *LiteralMap) ProtoReflect() protoreflect.Message + func (x *LiteralMap) Reset() + func (x *LiteralMap) String() string + type LiteralType struct + Annotation *TypeAnnotation + Metadata *structpb.Struct + Structure *TypeStructure + Type isLiteralType_Type + func (*LiteralType) Descriptor() ([]byte, []int) + func (*LiteralType) ProtoMessage() + func (m *LiteralType) GetType() isLiteralType_Type + func (x *LiteralType) GetAnnotation() *TypeAnnotation + func (x *LiteralType) GetBlob() *BlobType + func (x *LiteralType) GetCollectionType() *LiteralType + func (x *LiteralType) GetEnumType() *EnumType + func (x *LiteralType) GetMapValueType() *LiteralType + func (x *LiteralType) GetMetadata() *structpb.Struct + func (x *LiteralType) GetSchema() *SchemaType + func (x *LiteralType) GetSimple() SimpleType + func (x *LiteralType) GetStructure() *TypeStructure + func (x *LiteralType) GetStructuredDatasetType() *StructuredDatasetType + func (x *LiteralType) GetUnionType() *UnionType + func (x *LiteralType) ProtoReflect() protoreflect.Message + func (x *LiteralType) Reset() + func (x *LiteralType) String() 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 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 + func (*Node) Descriptor() ([]byte, []int) + func (*Node) ProtoMessage() + func (m *Node) GetTarget() isNode_Target + func (x *Node) GetArrayNode() *ArrayNode + func (x *Node) GetBranchNode() *BranchNode + func (x *Node) GetGateNode() *GateNode + func (x *Node) GetId() string + func (x *Node) GetInputs() []*Binding + func (x *Node) GetMetadata() *NodeMetadata + func (x *Node) GetOutputAliases() []*Alias + func (x *Node) GetTaskNode() *TaskNode + func (x *Node) GetUpstreamNodeIds() []string + func (x *Node) GetWorkflowNode() *WorkflowNode + func (x *Node) ProtoReflect() protoreflect.Message + func (x *Node) Reset() + func (x *Node) String() string + type NodeExecution struct + func (*NodeExecution) Descriptor() ([]byte, []int) + func (*NodeExecution) ProtoMessage() + func (x *NodeExecution) ProtoReflect() protoreflect.Message + func (x *NodeExecution) Reset() + func (x *NodeExecution) String() string + type NodeExecutionIdentifier struct + ExecutionId *WorkflowExecutionIdentifier + NodeId string + func (*NodeExecutionIdentifier) Descriptor() ([]byte, []int) + func (*NodeExecutionIdentifier) ProtoMessage() + func (x *NodeExecutionIdentifier) GetExecutionId() *WorkflowExecutionIdentifier + func (x *NodeExecutionIdentifier) GetNodeId() string + func (x *NodeExecutionIdentifier) ProtoReflect() protoreflect.Message + func (x *NodeExecutionIdentifier) Reset() + func (x *NodeExecutionIdentifier) String() 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) Descriptor() protoreflect.EnumDescriptor + func (NodeExecution_Phase) EnumDescriptor() ([]byte, []int) + func (NodeExecution_Phase) Type() protoreflect.EnumType + func (x NodeExecution_Phase) Enum() *NodeExecution_Phase + func (x NodeExecution_Phase) Number() protoreflect.EnumNumber + func (x NodeExecution_Phase) String() string + type NodeMetadata struct + CacheSerializableValue isNodeMetadata_CacheSerializableValue + CacheVersionValue isNodeMetadata_CacheVersionValue + CacheableValue isNodeMetadata_CacheableValue + InterruptibleValue isNodeMetadata_InterruptibleValue + Name string + Retries *RetryStrategy + Timeout *durationpb.Duration + func (*NodeMetadata) Descriptor() ([]byte, []int) + func (*NodeMetadata) ProtoMessage() + func (m *NodeMetadata) GetCacheSerializableValue() isNodeMetadata_CacheSerializableValue + func (m *NodeMetadata) GetCacheVersionValue() isNodeMetadata_CacheVersionValue + func (m *NodeMetadata) GetCacheableValue() isNodeMetadata_CacheableValue + func (m *NodeMetadata) GetInterruptibleValue() isNodeMetadata_InterruptibleValue + func (x *NodeMetadata) GetCacheSerializable() bool + func (x *NodeMetadata) GetCacheVersion() string + func (x *NodeMetadata) GetCacheable() bool + func (x *NodeMetadata) GetInterruptible() bool + func (x *NodeMetadata) GetName() string + func (x *NodeMetadata) GetRetries() *RetryStrategy + func (x *NodeMetadata) GetTimeout() *durationpb.Duration + func (x *NodeMetadata) ProtoReflect() protoreflect.Message + func (x *NodeMetadata) Reset() + func (x *NodeMetadata) String() string + type NodeMetadata_CacheSerializable struct + CacheSerializable bool + type NodeMetadata_CacheVersion struct + CacheVersion string + type NodeMetadata_Cacheable struct + Cacheable bool + type NodeMetadata_Interruptible struct + Interruptible bool + type Node_ArrayNode struct + ArrayNode *ArrayNode + type Node_BranchNode struct + BranchNode *BranchNode + type Node_GateNode struct + GateNode *GateNode + type Node_TaskNode struct + TaskNode *TaskNode + type Node_WorkflowNode struct + WorkflowNode *WorkflowNode + type OAuth2Client struct + ClientId string + ClientSecret *Secret + func (*OAuth2Client) Descriptor() ([]byte, []int) + func (*OAuth2Client) ProtoMessage() + func (x *OAuth2Client) GetClientId() string + func (x *OAuth2Client) GetClientSecret() *Secret + func (x *OAuth2Client) ProtoReflect() protoreflect.Message + func (x *OAuth2Client) Reset() + func (x *OAuth2Client) String() string + type OAuth2TokenRequest struct + Client *OAuth2Client + IdpDiscoveryEndpoint string + Name string + TokenEndpoint string + Type OAuth2TokenRequest_Type + func (*OAuth2TokenRequest) Descriptor() ([]byte, []int) + func (*OAuth2TokenRequest) ProtoMessage() + func (x *OAuth2TokenRequest) GetClient() *OAuth2Client + func (x *OAuth2TokenRequest) GetIdpDiscoveryEndpoint() string + func (x *OAuth2TokenRequest) GetName() string + func (x *OAuth2TokenRequest) GetTokenEndpoint() string + func (x *OAuth2TokenRequest) GetType() OAuth2TokenRequest_Type + func (x *OAuth2TokenRequest) ProtoReflect() protoreflect.Message + func (x *OAuth2TokenRequest) Reset() + func (x *OAuth2TokenRequest) String() string + type OAuth2TokenRequest_Type int32 + const OAuth2TokenRequest_CLIENT_CREDENTIALS + func (OAuth2TokenRequest_Type) Descriptor() protoreflect.EnumDescriptor + func (OAuth2TokenRequest_Type) EnumDescriptor() ([]byte, []int) + func (OAuth2TokenRequest_Type) Type() protoreflect.EnumType + func (x OAuth2TokenRequest_Type) Enum() *OAuth2TokenRequest_Type + func (x OAuth2TokenRequest_Type) Number() protoreflect.EnumNumber + func (x OAuth2TokenRequest_Type) String() string + type Operand struct + Val isOperand_Val + func (*Operand) Descriptor() ([]byte, []int) + func (*Operand) ProtoMessage() + func (m *Operand) GetVal() isOperand_Val + func (x *Operand) GetPrimitive() *Primitive + func (x *Operand) GetScalar() *Scalar + func (x *Operand) GetVar() string + func (x *Operand) ProtoReflect() protoreflect.Message + func (x *Operand) Reset() + func (x *Operand) String() string + type Operand_Primitive struct + Primitive *Primitive + type Operand_Scalar struct + Scalar *Scalar + type Operand_Var struct + Var string + type OutputReference struct + AttrPath []*PromiseAttribute + NodeId string + Var string + func (*OutputReference) Descriptor() ([]byte, []int) + func (*OutputReference) ProtoMessage() + func (x *OutputReference) GetAttrPath() []*PromiseAttribute + func (x *OutputReference) GetNodeId() string + func (x *OutputReference) GetVar() string + func (x *OutputReference) ProtoReflect() protoreflect.Message + func (x *OutputReference) Reset() + func (x *OutputReference) String() string + type Parameter struct + Behavior isParameter_Behavior + Var *Variable + func (*Parameter) Descriptor() ([]byte, []int) + func (*Parameter) ProtoMessage() + func (m *Parameter) GetBehavior() isParameter_Behavior + func (x *Parameter) GetArtifactId() *ArtifactID + func (x *Parameter) GetArtifactQuery() *ArtifactQuery + func (x *Parameter) GetDefault() *Literal + func (x *Parameter) GetRequired() bool + func (x *Parameter) GetVar() *Variable + func (x *Parameter) ProtoReflect() protoreflect.Message + func (x *Parameter) Reset() + func (x *Parameter) String() string + type ParameterMap struct + Parameters map[string]*Parameter + func (*ParameterMap) Descriptor() ([]byte, []int) + func (*ParameterMap) ProtoMessage() + func (x *ParameterMap) GetParameters() map[string]*Parameter + func (x *ParameterMap) ProtoReflect() protoreflect.Message + func (x *ParameterMap) Reset() + func (x *ParameterMap) String() string + type Parameter_ArtifactId struct + ArtifactId *ArtifactID + type Parameter_ArtifactQuery struct + ArtifactQuery *ArtifactQuery + type Parameter_Default struct + Default *Literal + type Parameter_Required struct + Required bool + type Partitions struct + Value map[string]*LabelValue + func (*Partitions) Descriptor() ([]byte, []int) + func (*Partitions) ProtoMessage() + func (x *Partitions) GetValue() map[string]*LabelValue + func (x *Partitions) ProtoReflect() protoreflect.Message + func (x *Partitions) Reset() + func (x *Partitions) String() string + type Primitive struct + Value isPrimitive_Value + func (*Primitive) Descriptor() ([]byte, []int) + func (*Primitive) ProtoMessage() + func (m *Primitive) GetValue() isPrimitive_Value + func (x *Primitive) GetBoolean() bool + func (x *Primitive) GetDatetime() *timestamppb.Timestamp + func (x *Primitive) GetDuration() *durationpb.Duration + func (x *Primitive) GetFloatValue() float64 + func (x *Primitive) GetInteger() int64 + func (x *Primitive) GetStringValue() string + func (x *Primitive) ProtoReflect() protoreflect.Message + func (x *Primitive) Reset() + func (x *Primitive) String() string + type Primitive_Boolean struct + Boolean bool + type Primitive_Datetime struct + Datetime *timestamppb.Timestamp + type Primitive_Duration struct + Duration *durationpb.Duration + type Primitive_FloatValue struct + FloatValue float64 + type Primitive_Integer struct + Integer int64 + type Primitive_StringValue struct + StringValue string + type PromiseAttribute struct + Value isPromiseAttribute_Value + func (*PromiseAttribute) Descriptor() ([]byte, []int) + func (*PromiseAttribute) ProtoMessage() + func (m *PromiseAttribute) GetValue() isPromiseAttribute_Value + func (x *PromiseAttribute) GetIntValue() int32 + func (x *PromiseAttribute) GetStringValue() string + func (x *PromiseAttribute) ProtoReflect() protoreflect.Message + func (x *PromiseAttribute) Reset() + func (x *PromiseAttribute) String() string + type PromiseAttribute_IntValue struct + IntValue int32 + type PromiseAttribute_StringValue struct + StringValue string + type QualityOfService struct + Designation isQualityOfService_Designation + func (*QualityOfService) Descriptor() ([]byte, []int) + func (*QualityOfService) ProtoMessage() + func (m *QualityOfService) GetDesignation() isQualityOfService_Designation + func (x *QualityOfService) GetSpec() *QualityOfServiceSpec + func (x *QualityOfService) GetTier() QualityOfService_Tier + func (x *QualityOfService) ProtoReflect() protoreflect.Message + func (x *QualityOfService) Reset() + func (x *QualityOfService) String() string + type QualityOfServiceSpec struct + QueueingBudget *durationpb.Duration + func (*QualityOfServiceSpec) Descriptor() ([]byte, []int) + func (*QualityOfServiceSpec) ProtoMessage() + func (x *QualityOfServiceSpec) GetQueueingBudget() *durationpb.Duration + func (x *QualityOfServiceSpec) ProtoReflect() protoreflect.Message + func (x *QualityOfServiceSpec) Reset() + func (x *QualityOfServiceSpec) String() 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) Descriptor() protoreflect.EnumDescriptor + func (QualityOfService_Tier) EnumDescriptor() ([]byte, []int) + func (QualityOfService_Tier) Type() protoreflect.EnumType + func (x QualityOfService_Tier) Enum() *QualityOfService_Tier + func (x QualityOfService_Tier) Number() protoreflect.EnumNumber + 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) Descriptor() protoreflect.EnumDescriptor + func (ResourceType) EnumDescriptor() ([]byte, []int) + func (ResourceType) Type() protoreflect.EnumType + func (x ResourceType) Enum() *ResourceType + func (x ResourceType) Number() protoreflect.EnumNumber + func (x ResourceType) String() string + type Resources struct + Limits []*Resources_ResourceEntry + Requests []*Resources_ResourceEntry + func (*Resources) Descriptor() ([]byte, []int) + func (*Resources) ProtoMessage() + func (x *Resources) GetLimits() []*Resources_ResourceEntry + func (x *Resources) GetRequests() []*Resources_ResourceEntry + func (x *Resources) ProtoReflect() protoreflect.Message + func (x *Resources) Reset() + func (x *Resources) String() string + type Resources_ResourceEntry struct + Name Resources_ResourceName + Value string + func (*Resources_ResourceEntry) Descriptor() ([]byte, []int) + func (*Resources_ResourceEntry) ProtoMessage() + func (x *Resources_ResourceEntry) GetName() Resources_ResourceName + func (x *Resources_ResourceEntry) GetValue() string + func (x *Resources_ResourceEntry) ProtoReflect() protoreflect.Message + func (x *Resources_ResourceEntry) Reset() + func (x *Resources_ResourceEntry) String() 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) Descriptor() protoreflect.EnumDescriptor + func (Resources_ResourceName) EnumDescriptor() ([]byte, []int) + func (Resources_ResourceName) Type() protoreflect.EnumType + func (x Resources_ResourceName) Enum() *Resources_ResourceName + func (x Resources_ResourceName) Number() protoreflect.EnumNumber + func (x Resources_ResourceName) String() string + type RetryStrategy struct + Retries uint32 + func (*RetryStrategy) Descriptor() ([]byte, []int) + func (*RetryStrategy) ProtoMessage() + func (x *RetryStrategy) GetRetries() uint32 + func (x *RetryStrategy) ProtoReflect() protoreflect.Message + func (x *RetryStrategy) Reset() + func (x *RetryStrategy) String() string + type RuntimeMetadata struct + Flavor string + Type RuntimeMetadata_RuntimeType + Version string + func (*RuntimeMetadata) Descriptor() ([]byte, []int) + func (*RuntimeMetadata) ProtoMessage() + func (x *RuntimeMetadata) GetFlavor() string + func (x *RuntimeMetadata) GetType() RuntimeMetadata_RuntimeType + func (x *RuntimeMetadata) GetVersion() string + func (x *RuntimeMetadata) ProtoReflect() protoreflect.Message + func (x *RuntimeMetadata) Reset() + func (x *RuntimeMetadata) String() string + type RuntimeMetadata_RuntimeType int32 + const RuntimeMetadata_KOZMO_SDK + const RuntimeMetadata_OTHER + func (RuntimeMetadata_RuntimeType) Descriptor() protoreflect.EnumDescriptor + func (RuntimeMetadata_RuntimeType) EnumDescriptor() ([]byte, []int) + func (RuntimeMetadata_RuntimeType) Type() protoreflect.EnumType + func (x RuntimeMetadata_RuntimeType) Enum() *RuntimeMetadata_RuntimeType + func (x RuntimeMetadata_RuntimeType) Number() protoreflect.EnumNumber + func (x RuntimeMetadata_RuntimeType) String() string + type Scalar struct + Value isScalar_Value + func (*Scalar) Descriptor() ([]byte, []int) + func (*Scalar) ProtoMessage() + func (m *Scalar) GetValue() isScalar_Value + func (x *Scalar) GetBinary() *Binary + func (x *Scalar) GetBlob() *Blob + func (x *Scalar) GetError() *Error + func (x *Scalar) GetGeneric() *structpb.Struct + func (x *Scalar) GetNoneType() *Void + func (x *Scalar) GetPrimitive() *Primitive + func (x *Scalar) GetSchema() *Schema + func (x *Scalar) GetStructuredDataset() *StructuredDataset + func (x *Scalar) GetUnion() *Union + func (x *Scalar) ProtoReflect() protoreflect.Message + func (x *Scalar) Reset() + func (x *Scalar) String() string + type Scalar_Binary struct + Binary *Binary + type Scalar_Blob struct + Blob *Blob + type Scalar_Error struct + Error *Error + type Scalar_Generic struct + Generic *structpb.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 + func (*Schema) Descriptor() ([]byte, []int) + func (*Schema) ProtoMessage() + func (x *Schema) GetType() *SchemaType + func (x *Schema) GetUri() string + func (x *Schema) ProtoReflect() protoreflect.Message + func (x *Schema) Reset() + func (x *Schema) String() string + type SchemaType struct + Columns []*SchemaType_SchemaColumn + func (*SchemaType) Descriptor() ([]byte, []int) + func (*SchemaType) ProtoMessage() + func (x *SchemaType) GetColumns() []*SchemaType_SchemaColumn + func (x *SchemaType) ProtoReflect() protoreflect.Message + func (x *SchemaType) Reset() + func (x *SchemaType) String() string + type SchemaType_SchemaColumn struct + Name string + Type SchemaType_SchemaColumn_SchemaColumnType + func (*SchemaType_SchemaColumn) Descriptor() ([]byte, []int) + func (*SchemaType_SchemaColumn) ProtoMessage() + func (x *SchemaType_SchemaColumn) GetName() string + func (x *SchemaType_SchemaColumn) GetType() SchemaType_SchemaColumn_SchemaColumnType + func (x *SchemaType_SchemaColumn) ProtoReflect() protoreflect.Message + func (x *SchemaType_SchemaColumn) Reset() + func (x *SchemaType_SchemaColumn) String() 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) Descriptor() protoreflect.EnumDescriptor + func (SchemaType_SchemaColumn_SchemaColumnType) EnumDescriptor() ([]byte, []int) + func (SchemaType_SchemaColumn_SchemaColumnType) Type() protoreflect.EnumType + func (x SchemaType_SchemaColumn_SchemaColumnType) Enum() *SchemaType_SchemaColumn_SchemaColumnType + func (x SchemaType_SchemaColumn_SchemaColumnType) Number() protoreflect.EnumNumber + func (x SchemaType_SchemaColumn_SchemaColumnType) String() string + type Secret struct + Group string + GroupVersion string + Key string + MountRequirement Secret_MountType + func (*Secret) Descriptor() ([]byte, []int) + func (*Secret) ProtoMessage() + func (x *Secret) GetGroup() string + func (x *Secret) GetGroupVersion() string + func (x *Secret) GetKey() string + func (x *Secret) GetMountRequirement() Secret_MountType + func (x *Secret) ProtoReflect() protoreflect.Message + func (x *Secret) Reset() + func (x *Secret) String() string + type Secret_MountType int32 + const Secret_ANY + const Secret_ENV_VAR + const Secret_FILE + func (Secret_MountType) Descriptor() protoreflect.EnumDescriptor + func (Secret_MountType) EnumDescriptor() ([]byte, []int) + func (Secret_MountType) Type() protoreflect.EnumType + func (x Secret_MountType) Enum() *Secret_MountType + func (x Secret_MountType) Number() protoreflect.EnumNumber + func (x Secret_MountType) String() string + type SecurityContext struct + RunAs *Identity + Secrets []*Secret + Tokens []*OAuth2TokenRequest + func (*SecurityContext) Descriptor() ([]byte, []int) + func (*SecurityContext) ProtoMessage() + func (x *SecurityContext) GetRunAs() *Identity + func (x *SecurityContext) GetSecrets() []*Secret + func (x *SecurityContext) GetTokens() []*OAuth2TokenRequest + func (x *SecurityContext) ProtoReflect() protoreflect.Message + func (x *SecurityContext) Reset() + func (x *SecurityContext) String() string + type SignalCondition struct + OutputVariableName string + SignalId string + Type *LiteralType + func (*SignalCondition) Descriptor() ([]byte, []int) + func (*SignalCondition) ProtoMessage() + func (x *SignalCondition) GetOutputVariableName() string + func (x *SignalCondition) GetSignalId() string + func (x *SignalCondition) GetType() *LiteralType + func (x *SignalCondition) ProtoReflect() protoreflect.Message + func (x *SignalCondition) Reset() + func (x *SignalCondition) String() string + type SignalIdentifier struct + ExecutionId *WorkflowExecutionIdentifier + SignalId string + func (*SignalIdentifier) Descriptor() ([]byte, []int) + func (*SignalIdentifier) ProtoMessage() + func (x *SignalIdentifier) GetExecutionId() *WorkflowExecutionIdentifier + func (x *SignalIdentifier) GetSignalId() string + func (x *SignalIdentifier) ProtoReflect() protoreflect.Message + func (x *SignalIdentifier) Reset() + func (x *SignalIdentifier) String() 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) Descriptor() protoreflect.EnumDescriptor + func (SimpleType) EnumDescriptor() ([]byte, []int) + func (SimpleType) Type() protoreflect.EnumType + func (x SimpleType) Enum() *SimpleType + func (x SimpleType) Number() protoreflect.EnumNumber + func (x SimpleType) String() string + type SleepCondition struct + Duration *durationpb.Duration + func (*SleepCondition) Descriptor() ([]byte, []int) + func (*SleepCondition) ProtoMessage() + func (x *SleepCondition) GetDuration() *durationpb.Duration + func (x *SleepCondition) ProtoReflect() protoreflect.Message + func (x *SleepCondition) Reset() + func (x *SleepCondition) String() string + type Span struct + EndTime *timestamppb.Timestamp + Id isSpan_Id + Spans []*Span + StartTime *timestamppb.Timestamp + func (*Span) Descriptor() ([]byte, []int) + func (*Span) ProtoMessage() + func (m *Span) GetId() isSpan_Id + func (x *Span) GetEndTime() *timestamppb.Timestamp + func (x *Span) GetNodeId() *NodeExecutionIdentifier + func (x *Span) GetOperationId() string + func (x *Span) GetSpans() []*Span + func (x *Span) GetStartTime() *timestamppb.Timestamp + func (x *Span) GetTaskId() *TaskExecutionIdentifier + func (x *Span) GetWorkflowId() *WorkflowExecutionIdentifier + func (x *Span) ProtoReflect() protoreflect.Message + func (x *Span) Reset() + func (x *Span) String() 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 + func (*Sql) Descriptor() ([]byte, []int) + func (*Sql) ProtoMessage() + func (x *Sql) GetDialect() Sql_Dialect + func (x *Sql) GetStatement() string + func (x *Sql) ProtoReflect() protoreflect.Message + func (x *Sql) Reset() + func (x *Sql) String() string + type Sql_Dialect int32 + const Sql_ANSI + const Sql_HIVE + const Sql_OTHER + const Sql_UNDEFINED + func (Sql_Dialect) Descriptor() protoreflect.EnumDescriptor + func (Sql_Dialect) EnumDescriptor() ([]byte, []int) + func (Sql_Dialect) Type() protoreflect.EnumType + func (x Sql_Dialect) Enum() *Sql_Dialect + func (x Sql_Dialect) Number() protoreflect.EnumNumber + func (x Sql_Dialect) String() string + type StructuredDataset struct + Metadata *StructuredDatasetMetadata + Uri string + func (*StructuredDataset) Descriptor() ([]byte, []int) + func (*StructuredDataset) ProtoMessage() + func (x *StructuredDataset) GetMetadata() *StructuredDatasetMetadata + func (x *StructuredDataset) GetUri() string + func (x *StructuredDataset) ProtoReflect() protoreflect.Message + func (x *StructuredDataset) Reset() + func (x *StructuredDataset) String() string + type StructuredDatasetMetadata struct + StructuredDatasetType *StructuredDatasetType + func (*StructuredDatasetMetadata) Descriptor() ([]byte, []int) + func (*StructuredDatasetMetadata) ProtoMessage() + func (x *StructuredDatasetMetadata) GetStructuredDatasetType() *StructuredDatasetType + func (x *StructuredDatasetMetadata) ProtoReflect() protoreflect.Message + func (x *StructuredDatasetMetadata) Reset() + func (x *StructuredDatasetMetadata) String() string + type StructuredDatasetType struct + Columns []*StructuredDatasetType_DatasetColumn + ExternalSchemaBytes []byte + ExternalSchemaType string + Format string + func (*StructuredDatasetType) Descriptor() ([]byte, []int) + func (*StructuredDatasetType) ProtoMessage() + func (x *StructuredDatasetType) GetColumns() []*StructuredDatasetType_DatasetColumn + func (x *StructuredDatasetType) GetExternalSchemaBytes() []byte + func (x *StructuredDatasetType) GetExternalSchemaType() string + func (x *StructuredDatasetType) GetFormat() string + func (x *StructuredDatasetType) ProtoReflect() protoreflect.Message + func (x *StructuredDatasetType) Reset() + func (x *StructuredDatasetType) String() string + type StructuredDatasetType_DatasetColumn struct + LiteralType *LiteralType + Name string + func (*StructuredDatasetType_DatasetColumn) Descriptor() ([]byte, []int) + func (*StructuredDatasetType_DatasetColumn) ProtoMessage() + func (x *StructuredDatasetType_DatasetColumn) GetLiteralType() *LiteralType + func (x *StructuredDatasetType_DatasetColumn) GetName() string + func (x *StructuredDatasetType_DatasetColumn) ProtoReflect() protoreflect.Message + func (x *StructuredDatasetType_DatasetColumn) Reset() + func (x *StructuredDatasetType_DatasetColumn) String() string + type TaskExecution struct + func (*TaskExecution) Descriptor() ([]byte, []int) + func (*TaskExecution) ProtoMessage() + func (x *TaskExecution) ProtoReflect() protoreflect.Message + func (x *TaskExecution) Reset() + func (x *TaskExecution) String() string + type TaskExecutionIdentifier struct + NodeExecutionId *NodeExecutionIdentifier + RetryAttempt uint32 + TaskId *Identifier + func (*TaskExecutionIdentifier) Descriptor() ([]byte, []int) + func (*TaskExecutionIdentifier) ProtoMessage() + func (x *TaskExecutionIdentifier) GetNodeExecutionId() *NodeExecutionIdentifier + func (x *TaskExecutionIdentifier) GetRetryAttempt() uint32 + func (x *TaskExecutionIdentifier) GetTaskId() *Identifier + func (x *TaskExecutionIdentifier) ProtoReflect() protoreflect.Message + func (x *TaskExecutionIdentifier) Reset() + func (x *TaskExecutionIdentifier) String() 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) Descriptor() protoreflect.EnumDescriptor + func (TaskExecution_Phase) EnumDescriptor() ([]byte, []int) + func (TaskExecution_Phase) Type() protoreflect.EnumType + func (x TaskExecution_Phase) Enum() *TaskExecution_Phase + func (x TaskExecution_Phase) Number() protoreflect.EnumNumber + func (x TaskExecution_Phase) String() string + type TaskLog struct + MessageFormat TaskLog_MessageFormat + Name string + Ttl *durationpb.Duration + Uri string + func (*TaskLog) Descriptor() ([]byte, []int) + func (*TaskLog) ProtoMessage() + func (x *TaskLog) GetMessageFormat() TaskLog_MessageFormat + func (x *TaskLog) GetName() string + func (x *TaskLog) GetTtl() *durationpb.Duration + func (x *TaskLog) GetUri() string + func (x *TaskLog) ProtoReflect() protoreflect.Message + func (x *TaskLog) Reset() + func (x *TaskLog) String() string + type TaskLog_MessageFormat int32 + const TaskLog_CSV + const TaskLog_JSON + const TaskLog_UNKNOWN + func (TaskLog_MessageFormat) Descriptor() protoreflect.EnumDescriptor + func (TaskLog_MessageFormat) EnumDescriptor() ([]byte, []int) + func (TaskLog_MessageFormat) Type() protoreflect.EnumType + func (x TaskLog_MessageFormat) Enum() *TaskLog_MessageFormat + func (x TaskLog_MessageFormat) Number() protoreflect.EnumNumber + func (x TaskLog_MessageFormat) String() string + type TaskMetadata struct + CacheIgnoreInputVars []string + CacheSerializable bool + DeprecatedErrorMessage string + Discoverable bool + DiscoveryVersion string + GeneratesDeck bool + InterruptibleValue isTaskMetadata_InterruptibleValue + PodTemplateName string + Retries *RetryStrategy + Runtime *RuntimeMetadata + Tags map[string]string + Timeout *durationpb.Duration + func (*TaskMetadata) Descriptor() ([]byte, []int) + func (*TaskMetadata) ProtoMessage() + func (m *TaskMetadata) GetInterruptibleValue() isTaskMetadata_InterruptibleValue + func (x *TaskMetadata) GetCacheIgnoreInputVars() []string + func (x *TaskMetadata) GetCacheSerializable() bool + func (x *TaskMetadata) GetDeprecatedErrorMessage() string + func (x *TaskMetadata) GetDiscoverable() bool + func (x *TaskMetadata) GetDiscoveryVersion() string + func (x *TaskMetadata) GetGeneratesDeck() bool + func (x *TaskMetadata) GetInterruptible() bool + func (x *TaskMetadata) GetPodTemplateName() string + func (x *TaskMetadata) GetRetries() *RetryStrategy + func (x *TaskMetadata) GetRuntime() *RuntimeMetadata + func (x *TaskMetadata) GetTags() map[string]string + func (x *TaskMetadata) GetTimeout() *durationpb.Duration + func (x *TaskMetadata) ProtoReflect() protoreflect.Message + func (x *TaskMetadata) Reset() + func (x *TaskMetadata) String() string + type TaskMetadata_Interruptible struct + Interruptible bool + type TaskNode struct + Overrides *TaskNodeOverrides + Reference isTaskNode_Reference + func (*TaskNode) Descriptor() ([]byte, []int) + func (*TaskNode) ProtoMessage() + func (m *TaskNode) GetReference() isTaskNode_Reference + func (x *TaskNode) GetOverrides() *TaskNodeOverrides + func (x *TaskNode) GetReferenceId() *Identifier + func (x *TaskNode) ProtoReflect() protoreflect.Message + func (x *TaskNode) Reset() + func (x *TaskNode) String() string + type TaskNodeOverrides struct + ExtendedResources *ExtendedResources + Resources *Resources + func (*TaskNodeOverrides) Descriptor() ([]byte, []int) + func (*TaskNodeOverrides) ProtoMessage() + func (x *TaskNodeOverrides) GetExtendedResources() *ExtendedResources + func (x *TaskNodeOverrides) GetResources() *Resources + func (x *TaskNodeOverrides) ProtoReflect() protoreflect.Message + func (x *TaskNodeOverrides) Reset() + func (x *TaskNodeOverrides) String() string + type TaskNode_ReferenceId struct + ReferenceId *Identifier + type TaskTemplate struct + Config map[string]string + Custom *structpb.Struct + ExtendedResources *ExtendedResources + Id *Identifier + Interface *TypedInterface + Metadata *TaskMetadata + SecurityContext *SecurityContext + Target isTaskTemplate_Target + TaskTypeVersion int32 + Type string + func (*TaskTemplate) Descriptor() ([]byte, []int) + func (*TaskTemplate) ProtoMessage() + func (m *TaskTemplate) GetTarget() isTaskTemplate_Target + func (x *TaskTemplate) GetConfig() map[string]string + func (x *TaskTemplate) GetContainer() *Container + func (x *TaskTemplate) GetCustom() *structpb.Struct + func (x *TaskTemplate) GetExtendedResources() *ExtendedResources + func (x *TaskTemplate) GetId() *Identifier + func (x *TaskTemplate) GetInterface() *TypedInterface + func (x *TaskTemplate) GetK8SPod() *K8SPod + func (x *TaskTemplate) GetMetadata() *TaskMetadata + func (x *TaskTemplate) GetSecurityContext() *SecurityContext + func (x *TaskTemplate) GetSql() *Sql + func (x *TaskTemplate) GetTaskTypeVersion() int32 + func (x *TaskTemplate) GetType() string + func (x *TaskTemplate) ProtoReflect() protoreflect.Message + func (x *TaskTemplate) Reset() + func (x *TaskTemplate) String() string + type TaskTemplate_Container struct + Container *Container + type TaskTemplate_K8SPod struct + K8SPod *K8SPod + type TaskTemplate_Sql struct + Sql *Sql + type TimePartition struct + Value *LabelValue + func (*TimePartition) Descriptor() ([]byte, []int) + func (*TimePartition) ProtoMessage() + func (x *TimePartition) GetValue() *LabelValue + func (x *TimePartition) ProtoReflect() protoreflect.Message + func (x *TimePartition) Reset() + func (x *TimePartition) String() string + type TypeAnnotation struct + Annotations *structpb.Struct + func (*TypeAnnotation) Descriptor() ([]byte, []int) + func (*TypeAnnotation) ProtoMessage() + func (x *TypeAnnotation) GetAnnotations() *structpb.Struct + func (x *TypeAnnotation) ProtoReflect() protoreflect.Message + func (x *TypeAnnotation) Reset() + func (x *TypeAnnotation) String() string + type TypeStructure struct + DataclassType map[string]*LiteralType + Tag string + func (*TypeStructure) Descriptor() ([]byte, []int) + func (*TypeStructure) ProtoMessage() + func (x *TypeStructure) GetDataclassType() map[string]*LiteralType + func (x *TypeStructure) GetTag() string + func (x *TypeStructure) ProtoReflect() protoreflect.Message + func (x *TypeStructure) Reset() + func (x *TypeStructure) String() string + type TypedInterface struct + Inputs *VariableMap + Outputs *VariableMap + func (*TypedInterface) Descriptor() ([]byte, []int) + func (*TypedInterface) ProtoMessage() + func (x *TypedInterface) GetInputs() *VariableMap + func (x *TypedInterface) GetOutputs() *VariableMap + func (x *TypedInterface) ProtoReflect() protoreflect.Message + func (x *TypedInterface) Reset() + func (x *TypedInterface) String() string + type Union struct + Type *LiteralType + Value *Literal + func (*Union) Descriptor() ([]byte, []int) + func (*Union) ProtoMessage() + func (x *Union) GetType() *LiteralType + func (x *Union) GetValue() *Literal + func (x *Union) ProtoReflect() protoreflect.Message + func (x *Union) Reset() + func (x *Union) String() string + type UnionInfo struct + TargetType *LiteralType + func (*UnionInfo) Descriptor() ([]byte, []int) + func (*UnionInfo) ProtoMessage() + func (x *UnionInfo) GetTargetType() *LiteralType + func (x *UnionInfo) ProtoReflect() protoreflect.Message + func (x *UnionInfo) Reset() + func (x *UnionInfo) String() string + type UnionType struct + Variants []*LiteralType + func (*UnionType) Descriptor() ([]byte, []int) + func (*UnionType) ProtoMessage() + func (x *UnionType) GetVariants() []*LiteralType + func (x *UnionType) ProtoReflect() protoreflect.Message + func (x *UnionType) Reset() + func (x *UnionType) String() string + type Variable struct + ArtifactPartialId *ArtifactID + ArtifactTag *ArtifactTag + Description string + Type *LiteralType + func (*Variable) Descriptor() ([]byte, []int) + func (*Variable) ProtoMessage() + func (x *Variable) GetArtifactPartialId() *ArtifactID + func (x *Variable) GetArtifactTag() *ArtifactTag + func (x *Variable) GetDescription() string + func (x *Variable) GetType() *LiteralType + func (x *Variable) ProtoReflect() protoreflect.Message + func (x *Variable) Reset() + func (x *Variable) String() string + type VariableMap struct + Variables map[string]*Variable + func (*VariableMap) Descriptor() ([]byte, []int) + func (*VariableMap) ProtoMessage() + func (x *VariableMap) GetVariables() map[string]*Variable + func (x *VariableMap) ProtoReflect() protoreflect.Message + func (x *VariableMap) Reset() + func (x *VariableMap) String() string + type Void struct + func (*Void) Descriptor() ([]byte, []int) + func (*Void) ProtoMessage() + func (x *Void) ProtoReflect() protoreflect.Message + func (x *Void) Reset() + func (x *Void) String() string + type WorkflowClosure struct + Tasks []*TaskTemplate + Workflow *WorkflowTemplate + func (*WorkflowClosure) Descriptor() ([]byte, []int) + func (*WorkflowClosure) ProtoMessage() + func (x *WorkflowClosure) GetTasks() []*TaskTemplate + func (x *WorkflowClosure) GetWorkflow() *WorkflowTemplate + func (x *WorkflowClosure) ProtoReflect() protoreflect.Message + func (x *WorkflowClosure) Reset() + func (x *WorkflowClosure) String() string + type WorkflowExecution struct + func (*WorkflowExecution) Descriptor() ([]byte, []int) + func (*WorkflowExecution) ProtoMessage() + func (x *WorkflowExecution) ProtoReflect() protoreflect.Message + func (x *WorkflowExecution) Reset() + func (x *WorkflowExecution) String() string + type WorkflowExecutionIdentifier struct + Domain string + Name string + Org string + Project string + func (*WorkflowExecutionIdentifier) Descriptor() ([]byte, []int) + func (*WorkflowExecutionIdentifier) ProtoMessage() + func (x *WorkflowExecutionIdentifier) GetDomain() string + func (x *WorkflowExecutionIdentifier) GetName() string + func (x *WorkflowExecutionIdentifier) GetOrg() string + func (x *WorkflowExecutionIdentifier) GetProject() string + func (x *WorkflowExecutionIdentifier) ProtoReflect() protoreflect.Message + func (x *WorkflowExecutionIdentifier) Reset() + func (x *WorkflowExecutionIdentifier) String() 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) Descriptor() protoreflect.EnumDescriptor + func (WorkflowExecution_Phase) EnumDescriptor() ([]byte, []int) + func (WorkflowExecution_Phase) Type() protoreflect.EnumType + func (x WorkflowExecution_Phase) Enum() *WorkflowExecution_Phase + func (x WorkflowExecution_Phase) Number() protoreflect.EnumNumber + func (x WorkflowExecution_Phase) String() string + type WorkflowMetadata struct + OnFailure WorkflowMetadata_OnFailurePolicy + QualityOfService *QualityOfService + Tags map[string]string + func (*WorkflowMetadata) Descriptor() ([]byte, []int) + func (*WorkflowMetadata) ProtoMessage() + func (x *WorkflowMetadata) GetOnFailure() WorkflowMetadata_OnFailurePolicy + func (x *WorkflowMetadata) GetQualityOfService() *QualityOfService + func (x *WorkflowMetadata) GetTags() map[string]string + func (x *WorkflowMetadata) ProtoReflect() protoreflect.Message + func (x *WorkflowMetadata) Reset() + func (x *WorkflowMetadata) String() string + type WorkflowMetadataDefaults struct + Interruptible bool + func (*WorkflowMetadataDefaults) Descriptor() ([]byte, []int) + func (*WorkflowMetadataDefaults) ProtoMessage() + func (x *WorkflowMetadataDefaults) GetInterruptible() bool + func (x *WorkflowMetadataDefaults) ProtoReflect() protoreflect.Message + func (x *WorkflowMetadataDefaults) Reset() + func (x *WorkflowMetadataDefaults) String() string + type WorkflowMetadata_OnFailurePolicy int32 + const WorkflowMetadata_FAIL_AFTER_EXECUTABLE_NODES_COMPLETE + const WorkflowMetadata_FAIL_IMMEDIATELY + func (WorkflowMetadata_OnFailurePolicy) Descriptor() protoreflect.EnumDescriptor + func (WorkflowMetadata_OnFailurePolicy) EnumDescriptor() ([]byte, []int) + func (WorkflowMetadata_OnFailurePolicy) Type() protoreflect.EnumType + func (x WorkflowMetadata_OnFailurePolicy) Enum() *WorkflowMetadata_OnFailurePolicy + func (x WorkflowMetadata_OnFailurePolicy) Number() protoreflect.EnumNumber + func (x WorkflowMetadata_OnFailurePolicy) String() string + type WorkflowNode struct + Reference isWorkflowNode_Reference + func (*WorkflowNode) Descriptor() ([]byte, []int) + func (*WorkflowNode) ProtoMessage() + func (m *WorkflowNode) GetReference() isWorkflowNode_Reference + func (x *WorkflowNode) GetLaunchplanRef() *Identifier + func (x *WorkflowNode) GetSubWorkflowRef() *Identifier + func (x *WorkflowNode) ProtoReflect() protoreflect.Message + func (x *WorkflowNode) Reset() + func (x *WorkflowNode) String() 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 + func (*WorkflowTemplate) Descriptor() ([]byte, []int) + func (*WorkflowTemplate) ProtoMessage() + func (x *WorkflowTemplate) GetFailureNode() *Node + func (x *WorkflowTemplate) GetId() *Identifier + func (x *WorkflowTemplate) GetInterface() *TypedInterface + func (x *WorkflowTemplate) GetMetadata() *WorkflowMetadata + func (x *WorkflowTemplate) GetMetadataDefaults() *WorkflowMetadataDefaults + func (x *WorkflowTemplate) GetNodes() []*Node + func (x *WorkflowTemplate) GetOutputs() []*Binding + func (x *WorkflowTemplate) ProtoReflect() protoreflect.Message + func (x *WorkflowTemplate) Reset() + func (x *WorkflowTemplate) String() string
Go to main page