Versions in this module Expand all Collapse all v1 v1.0.15 Apr 20, 2023 Changes in this version + var TaskExecutionMetadata_InstanceClass_name = map[int32]string + var TaskExecutionMetadata_InstanceClass_value = map[string]int32 + type DynamicWorkflowNodeMetadata struct + CompiledWorkflow *core.CompiledWorkflowClosure + DynamicJobSpecUri string + Id *core.Identifier + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DynamicWorkflowNodeMetadata) Descriptor() ([]byte, []int) + func (*DynamicWorkflowNodeMetadata) ProtoMessage() + func (m *DynamicWorkflowNodeMetadata) GetCompiledWorkflow() *core.CompiledWorkflowClosure + func (m *DynamicWorkflowNodeMetadata) GetDynamicJobSpecUri() string + func (m *DynamicWorkflowNodeMetadata) GetId() *core.Identifier + func (m *DynamicWorkflowNodeMetadata) Reset() + func (m *DynamicWorkflowNodeMetadata) String() string + func (m *DynamicWorkflowNodeMetadata) Validate() error + func (m *DynamicWorkflowNodeMetadata) XXX_DiscardUnknown() + func (m *DynamicWorkflowNodeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DynamicWorkflowNodeMetadata) XXX_Merge(src proto.Message) + func (m *DynamicWorkflowNodeMetadata) XXX_Size() int + func (m *DynamicWorkflowNodeMetadata) XXX_Unmarshal(b []byte) error + type DynamicWorkflowNodeMetadataValidationError struct + func (e DynamicWorkflowNodeMetadataValidationError) Cause() error + func (e DynamicWorkflowNodeMetadataValidationError) Error() string + func (e DynamicWorkflowNodeMetadataValidationError) ErrorName() string + func (e DynamicWorkflowNodeMetadataValidationError) Field() string + func (e DynamicWorkflowNodeMetadataValidationError) Key() bool + func (e DynamicWorkflowNodeMetadataValidationError) Reason() string + type ExternalResourceInfo struct + CacheStatus core.CatalogCacheStatus + ExternalId string + Index uint32 + Logs []*core.TaskLog + Phase core.TaskExecution_Phase + RetryAttempt uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExternalResourceInfo) Descriptor() ([]byte, []int) + func (*ExternalResourceInfo) ProtoMessage() + func (m *ExternalResourceInfo) GetCacheStatus() core.CatalogCacheStatus + func (m *ExternalResourceInfo) GetExternalId() string + func (m *ExternalResourceInfo) GetIndex() uint32 + func (m *ExternalResourceInfo) GetLogs() []*core.TaskLog + func (m *ExternalResourceInfo) GetPhase() core.TaskExecution_Phase + func (m *ExternalResourceInfo) GetRetryAttempt() uint32 + func (m *ExternalResourceInfo) Reset() + func (m *ExternalResourceInfo) String() string + func (m *ExternalResourceInfo) Validate() error + func (m *ExternalResourceInfo) XXX_DiscardUnknown() + func (m *ExternalResourceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExternalResourceInfo) XXX_Merge(src proto.Message) + func (m *ExternalResourceInfo) XXX_Size() int + func (m *ExternalResourceInfo) XXX_Unmarshal(b []byte) error + type ExternalResourceInfoValidationError struct + func (e ExternalResourceInfoValidationError) Cause() error + func (e ExternalResourceInfoValidationError) Error() string + func (e ExternalResourceInfoValidationError) ErrorName() string + func (e ExternalResourceInfoValidationError) Field() string + func (e ExternalResourceInfoValidationError) Key() bool + func (e ExternalResourceInfoValidationError) Reason() string + type NodeExecutionEvent struct + DeckUri string + EventVersion int32 + Id *core.NodeExecutionIdentifier + InputValue isNodeExecutionEvent_InputValue + IsDynamic bool + IsParent bool + NodeName string + OccurredAt *timestamp.Timestamp + OutputResult isNodeExecutionEvent_OutputResult + ParentNodeMetadata *ParentNodeExecutionMetadata + ParentTaskMetadata *ParentTaskExecutionMetadata + Phase core.NodeExecution_Phase + ProducerId string + ReportedAt *timestamp.Timestamp + RetryGroup string + SpecNodeId string + TargetMetadata isNodeExecutionEvent_TargetMetadata + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodeExecutionEvent) Descriptor() ([]byte, []int) + func (*NodeExecutionEvent) ProtoMessage() + func (*NodeExecutionEvent) XXX_OneofWrappers() []interface{} + func (m *NodeExecutionEvent) GetDeckUri() string + func (m *NodeExecutionEvent) GetError() *core.ExecutionError + func (m *NodeExecutionEvent) GetEventVersion() int32 + func (m *NodeExecutionEvent) GetId() *core.NodeExecutionIdentifier + func (m *NodeExecutionEvent) GetInputData() *core.LiteralMap + func (m *NodeExecutionEvent) GetInputUri() string + func (m *NodeExecutionEvent) GetInputValue() isNodeExecutionEvent_InputValue + func (m *NodeExecutionEvent) GetIsDynamic() bool + func (m *NodeExecutionEvent) GetIsParent() bool + func (m *NodeExecutionEvent) GetNodeName() string + func (m *NodeExecutionEvent) GetOccurredAt() *timestamp.Timestamp + func (m *NodeExecutionEvent) GetOutputData() *core.LiteralMap + func (m *NodeExecutionEvent) GetOutputResult() isNodeExecutionEvent_OutputResult + func (m *NodeExecutionEvent) GetOutputUri() string + func (m *NodeExecutionEvent) GetParentNodeMetadata() *ParentNodeExecutionMetadata + func (m *NodeExecutionEvent) GetParentTaskMetadata() *ParentTaskExecutionMetadata + func (m *NodeExecutionEvent) GetPhase() core.NodeExecution_Phase + func (m *NodeExecutionEvent) GetProducerId() string + func (m *NodeExecutionEvent) GetReportedAt() *timestamp.Timestamp + func (m *NodeExecutionEvent) GetRetryGroup() string + func (m *NodeExecutionEvent) GetSpecNodeId() string + func (m *NodeExecutionEvent) GetTargetMetadata() isNodeExecutionEvent_TargetMetadata + func (m *NodeExecutionEvent) GetTaskNodeMetadata() *TaskNodeMetadata + func (m *NodeExecutionEvent) GetWorkflowNodeMetadata() *WorkflowNodeMetadata + func (m *NodeExecutionEvent) Reset() + func (m *NodeExecutionEvent) String() string + func (m *NodeExecutionEvent) Validate() error + func (m *NodeExecutionEvent) XXX_DiscardUnknown() + func (m *NodeExecutionEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeExecutionEvent) XXX_Merge(src proto.Message) + func (m *NodeExecutionEvent) XXX_Size() int + func (m *NodeExecutionEvent) XXX_Unmarshal(b []byte) error + type NodeExecutionEventValidationError struct + func (e NodeExecutionEventValidationError) Cause() error + func (e NodeExecutionEventValidationError) Error() string + func (e NodeExecutionEventValidationError) ErrorName() string + func (e NodeExecutionEventValidationError) Field() string + func (e NodeExecutionEventValidationError) Key() bool + func (e NodeExecutionEventValidationError) Reason() string + type NodeExecutionEvent_Error struct + Error *core.ExecutionError + type NodeExecutionEvent_InputData struct + InputData *core.LiteralMap + type NodeExecutionEvent_InputUri struct + InputUri string + type NodeExecutionEvent_OutputData struct + OutputData *core.LiteralMap + type NodeExecutionEvent_OutputUri struct + OutputUri string + type NodeExecutionEvent_TaskNodeMetadata struct + TaskNodeMetadata *TaskNodeMetadata + type NodeExecutionEvent_WorkflowNodeMetadata struct + WorkflowNodeMetadata *WorkflowNodeMetadata + type ParentNodeExecutionMetadata struct + NodeId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ParentNodeExecutionMetadata) Descriptor() ([]byte, []int) + func (*ParentNodeExecutionMetadata) ProtoMessage() + func (m *ParentNodeExecutionMetadata) GetNodeId() string + func (m *ParentNodeExecutionMetadata) Reset() + func (m *ParentNodeExecutionMetadata) String() string + func (m *ParentNodeExecutionMetadata) Validate() error + func (m *ParentNodeExecutionMetadata) XXX_DiscardUnknown() + func (m *ParentNodeExecutionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ParentNodeExecutionMetadata) XXX_Merge(src proto.Message) + func (m *ParentNodeExecutionMetadata) XXX_Size() int + func (m *ParentNodeExecutionMetadata) XXX_Unmarshal(b []byte) error + type ParentNodeExecutionMetadataValidationError struct + func (e ParentNodeExecutionMetadataValidationError) Cause() error + func (e ParentNodeExecutionMetadataValidationError) Error() string + func (e ParentNodeExecutionMetadataValidationError) ErrorName() string + func (e ParentNodeExecutionMetadataValidationError) Field() string + func (e ParentNodeExecutionMetadataValidationError) Key() bool + func (e ParentNodeExecutionMetadataValidationError) Reason() string + type ParentTaskExecutionMetadata struct + Id *core.TaskExecutionIdentifier + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ParentTaskExecutionMetadata) Descriptor() ([]byte, []int) + func (*ParentTaskExecutionMetadata) ProtoMessage() + func (m *ParentTaskExecutionMetadata) GetId() *core.TaskExecutionIdentifier + func (m *ParentTaskExecutionMetadata) Reset() + func (m *ParentTaskExecutionMetadata) String() string + func (m *ParentTaskExecutionMetadata) Validate() error + func (m *ParentTaskExecutionMetadata) XXX_DiscardUnknown() + func (m *ParentTaskExecutionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ParentTaskExecutionMetadata) XXX_Merge(src proto.Message) + func (m *ParentTaskExecutionMetadata) XXX_Size() int + func (m *ParentTaskExecutionMetadata) XXX_Unmarshal(b []byte) error + type ParentTaskExecutionMetadataValidationError struct + func (e ParentTaskExecutionMetadataValidationError) Cause() error + func (e ParentTaskExecutionMetadataValidationError) Error() string + func (e ParentTaskExecutionMetadataValidationError) ErrorName() string + func (e ParentTaskExecutionMetadataValidationError) Field() string + func (e ParentTaskExecutionMetadataValidationError) Key() bool + func (e ParentTaskExecutionMetadataValidationError) Reason() string + type ResourcePoolInfo struct + AllocationToken string + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResourcePoolInfo) Descriptor() ([]byte, []int) + func (*ResourcePoolInfo) ProtoMessage() + func (m *ResourcePoolInfo) GetAllocationToken() string + func (m *ResourcePoolInfo) GetNamespace() string + func (m *ResourcePoolInfo) Reset() + func (m *ResourcePoolInfo) String() string + func (m *ResourcePoolInfo) Validate() error + func (m *ResourcePoolInfo) XXX_DiscardUnknown() + func (m *ResourcePoolInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResourcePoolInfo) XXX_Merge(src proto.Message) + func (m *ResourcePoolInfo) XXX_Size() int + func (m *ResourcePoolInfo) XXX_Unmarshal(b []byte) error + type ResourcePoolInfoValidationError struct + func (e ResourcePoolInfoValidationError) Cause() error + func (e ResourcePoolInfoValidationError) Error() string + func (e ResourcePoolInfoValidationError) ErrorName() string + func (e ResourcePoolInfoValidationError) Field() string + func (e ResourcePoolInfoValidationError) Key() bool + func (e ResourcePoolInfoValidationError) Reason() string + type TaskExecutionEvent struct + CustomInfo *_struct.Struct + EventVersion int32 + InputValue isTaskExecutionEvent_InputValue + Logs []*core.TaskLog + Metadata *TaskExecutionMetadata + OccurredAt *timestamp.Timestamp + OutputResult isTaskExecutionEvent_OutputResult + ParentNodeExecutionId *core.NodeExecutionIdentifier + Phase core.TaskExecution_Phase + PhaseVersion uint32 + ProducerId string + Reason string + ReportedAt *timestamp.Timestamp + RetryAttempt uint32 + TaskId *core.Identifier + TaskType string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TaskExecutionEvent) Descriptor() ([]byte, []int) + func (*TaskExecutionEvent) ProtoMessage() + func (*TaskExecutionEvent) XXX_OneofWrappers() []interface{} + func (m *TaskExecutionEvent) GetCustomInfo() *_struct.Struct + func (m *TaskExecutionEvent) GetError() *core.ExecutionError + func (m *TaskExecutionEvent) GetEventVersion() int32 + func (m *TaskExecutionEvent) GetInputData() *core.LiteralMap + func (m *TaskExecutionEvent) GetInputUri() string + func (m *TaskExecutionEvent) GetInputValue() isTaskExecutionEvent_InputValue + func (m *TaskExecutionEvent) GetLogs() []*core.TaskLog + func (m *TaskExecutionEvent) GetMetadata() *TaskExecutionMetadata + func (m *TaskExecutionEvent) GetOccurredAt() *timestamp.Timestamp + func (m *TaskExecutionEvent) GetOutputData() *core.LiteralMap + func (m *TaskExecutionEvent) GetOutputResult() isTaskExecutionEvent_OutputResult + func (m *TaskExecutionEvent) GetOutputUri() string + func (m *TaskExecutionEvent) GetParentNodeExecutionId() *core.NodeExecutionIdentifier + func (m *TaskExecutionEvent) GetPhase() core.TaskExecution_Phase + func (m *TaskExecutionEvent) GetPhaseVersion() uint32 + func (m *TaskExecutionEvent) GetProducerId() string + func (m *TaskExecutionEvent) GetReason() string + func (m *TaskExecutionEvent) GetReportedAt() *timestamp.Timestamp + func (m *TaskExecutionEvent) GetRetryAttempt() uint32 + func (m *TaskExecutionEvent) GetTaskId() *core.Identifier + func (m *TaskExecutionEvent) GetTaskType() string + func (m *TaskExecutionEvent) Reset() + func (m *TaskExecutionEvent) String() string + func (m *TaskExecutionEvent) Validate() error + func (m *TaskExecutionEvent) XXX_DiscardUnknown() + func (m *TaskExecutionEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TaskExecutionEvent) XXX_Merge(src proto.Message) + func (m *TaskExecutionEvent) XXX_Size() int + func (m *TaskExecutionEvent) XXX_Unmarshal(b []byte) error + type TaskExecutionEventValidationError struct + func (e TaskExecutionEventValidationError) Cause() error + func (e TaskExecutionEventValidationError) Error() string + func (e TaskExecutionEventValidationError) ErrorName() string + func (e TaskExecutionEventValidationError) Field() string + func (e TaskExecutionEventValidationError) Key() bool + func (e TaskExecutionEventValidationError) Reason() string + type TaskExecutionEvent_Error struct + Error *core.ExecutionError + type TaskExecutionEvent_InputData struct + InputData *core.LiteralMap + type TaskExecutionEvent_InputUri struct + InputUri string + type TaskExecutionEvent_OutputData struct + OutputData *core.LiteralMap + type TaskExecutionEvent_OutputUri struct + OutputUri string + type TaskExecutionMetadata struct + ExternalResources []*ExternalResourceInfo + GeneratedName string + InstanceClass TaskExecutionMetadata_InstanceClass + PluginIdentifier string + ResourcePoolInfo []*ResourcePoolInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TaskExecutionMetadata) Descriptor() ([]byte, []int) + func (*TaskExecutionMetadata) ProtoMessage() + func (m *TaskExecutionMetadata) GetExternalResources() []*ExternalResourceInfo + func (m *TaskExecutionMetadata) GetGeneratedName() string + func (m *TaskExecutionMetadata) GetInstanceClass() TaskExecutionMetadata_InstanceClass + func (m *TaskExecutionMetadata) GetPluginIdentifier() string + func (m *TaskExecutionMetadata) GetResourcePoolInfo() []*ResourcePoolInfo + func (m *TaskExecutionMetadata) Reset() + func (m *TaskExecutionMetadata) String() string + func (m *TaskExecutionMetadata) Validate() error + func (m *TaskExecutionMetadata) XXX_DiscardUnknown() + func (m *TaskExecutionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TaskExecutionMetadata) XXX_Merge(src proto.Message) + func (m *TaskExecutionMetadata) XXX_Size() int + func (m *TaskExecutionMetadata) XXX_Unmarshal(b []byte) error + type TaskExecutionMetadataValidationError struct + func (e TaskExecutionMetadataValidationError) Cause() error + func (e TaskExecutionMetadataValidationError) Error() string + func (e TaskExecutionMetadataValidationError) ErrorName() string + func (e TaskExecutionMetadataValidationError) Field() string + func (e TaskExecutionMetadataValidationError) Key() bool + func (e TaskExecutionMetadataValidationError) Reason() string + type TaskExecutionMetadata_InstanceClass int32 + const TaskExecutionMetadata_DEFAULT + const TaskExecutionMetadata_INTERRUPTIBLE + func (TaskExecutionMetadata_InstanceClass) EnumDescriptor() ([]byte, []int) + func (x TaskExecutionMetadata_InstanceClass) String() string + type TaskNodeMetadata struct + CacheStatus core.CatalogCacheStatus + CatalogKey *core.CatalogMetadata + CheckpointUri string + DynamicWorkflow *DynamicWorkflowNodeMetadata + ReservationStatus core.CatalogReservation_Status + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TaskNodeMetadata) Descriptor() ([]byte, []int) + func (*TaskNodeMetadata) ProtoMessage() + func (m *TaskNodeMetadata) GetCacheStatus() core.CatalogCacheStatus + func (m *TaskNodeMetadata) GetCatalogKey() *core.CatalogMetadata + func (m *TaskNodeMetadata) GetCheckpointUri() string + func (m *TaskNodeMetadata) GetDynamicWorkflow() *DynamicWorkflowNodeMetadata + func (m *TaskNodeMetadata) GetReservationStatus() core.CatalogReservation_Status + func (m *TaskNodeMetadata) Reset() + func (m *TaskNodeMetadata) String() string + func (m *TaskNodeMetadata) Validate() error + func (m *TaskNodeMetadata) XXX_DiscardUnknown() + func (m *TaskNodeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TaskNodeMetadata) XXX_Merge(src proto.Message) + func (m *TaskNodeMetadata) XXX_Size() int + func (m *TaskNodeMetadata) XXX_Unmarshal(b []byte) error + type TaskNodeMetadataValidationError struct + func (e TaskNodeMetadataValidationError) Cause() error + func (e TaskNodeMetadataValidationError) Error() string + func (e TaskNodeMetadataValidationError) ErrorName() string + func (e TaskNodeMetadataValidationError) Field() string + func (e TaskNodeMetadataValidationError) Key() bool + func (e TaskNodeMetadataValidationError) Reason() string + type WorkflowExecutionEvent struct + ExecutionId *core.WorkflowExecutionIdentifier + OccurredAt *timestamp.Timestamp + OutputResult isWorkflowExecutionEvent_OutputResult + Phase core.WorkflowExecution_Phase + ProducerId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowExecutionEvent) Descriptor() ([]byte, []int) + func (*WorkflowExecutionEvent) ProtoMessage() + func (*WorkflowExecutionEvent) XXX_OneofWrappers() []interface{} + func (m *WorkflowExecutionEvent) GetError() *core.ExecutionError + func (m *WorkflowExecutionEvent) GetExecutionId() *core.WorkflowExecutionIdentifier + func (m *WorkflowExecutionEvent) GetOccurredAt() *timestamp.Timestamp + func (m *WorkflowExecutionEvent) GetOutputData() *core.LiteralMap + func (m *WorkflowExecutionEvent) GetOutputResult() isWorkflowExecutionEvent_OutputResult + func (m *WorkflowExecutionEvent) GetOutputUri() string + func (m *WorkflowExecutionEvent) GetPhase() core.WorkflowExecution_Phase + func (m *WorkflowExecutionEvent) GetProducerId() string + func (m *WorkflowExecutionEvent) Reset() + func (m *WorkflowExecutionEvent) String() string + func (m *WorkflowExecutionEvent) Validate() error + func (m *WorkflowExecutionEvent) XXX_DiscardUnknown() + func (m *WorkflowExecutionEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkflowExecutionEvent) XXX_Merge(src proto.Message) + func (m *WorkflowExecutionEvent) XXX_Size() int + func (m *WorkflowExecutionEvent) XXX_Unmarshal(b []byte) error + type WorkflowExecutionEventValidationError struct + func (e WorkflowExecutionEventValidationError) Cause() error + func (e WorkflowExecutionEventValidationError) Error() string + func (e WorkflowExecutionEventValidationError) ErrorName() string + func (e WorkflowExecutionEventValidationError) Field() string + func (e WorkflowExecutionEventValidationError) Key() bool + func (e WorkflowExecutionEventValidationError) Reason() string + type WorkflowExecutionEvent_Error struct + Error *core.ExecutionError + type WorkflowExecutionEvent_OutputData struct + OutputData *core.LiteralMap + type WorkflowExecutionEvent_OutputUri struct + OutputUri string + type WorkflowNodeMetadata struct + ExecutionId *core.WorkflowExecutionIdentifier + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkflowNodeMetadata) Descriptor() ([]byte, []int) + func (*WorkflowNodeMetadata) ProtoMessage() + func (m *WorkflowNodeMetadata) GetExecutionId() *core.WorkflowExecutionIdentifier + func (m *WorkflowNodeMetadata) Reset() + func (m *WorkflowNodeMetadata) String() string + func (m *WorkflowNodeMetadata) Validate() error + func (m *WorkflowNodeMetadata) XXX_DiscardUnknown() + func (m *WorkflowNodeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkflowNodeMetadata) XXX_Merge(src proto.Message) + func (m *WorkflowNodeMetadata) XXX_Size() int + func (m *WorkflowNodeMetadata) XXX_Unmarshal(b []byte) error + type WorkflowNodeMetadataValidationError struct + func (e WorkflowNodeMetadataValidationError) Cause() error + func (e WorkflowNodeMetadataValidationError) Error() string + func (e WorkflowNodeMetadataValidationError) ErrorName() string + func (e WorkflowNodeMetadataValidationError) Field() string + func (e WorkflowNodeMetadataValidationError) Key() bool + func (e WorkflowNodeMetadataValidationError) Reason() string