Documentation ¶
Overview ¶
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Index ¶
- Variables
- type ArchivalState
- func (ArchivalState) Descriptor() protoreflect.EnumDescriptor
- func (x ArchivalState) Enum() *ArchivalState
- func (ArchivalState) EnumDescriptor() ([]byte, []int)deprecated
- func (x ArchivalState) Number() protoreflect.EnumNumber
- func (x ArchivalState) String() string
- func (ArchivalState) Type() protoreflect.EnumType
- type BatchOperationState
- func (BatchOperationState) Descriptor() protoreflect.EnumDescriptor
- func (x BatchOperationState) Enum() *BatchOperationState
- func (BatchOperationState) EnumDescriptor() ([]byte, []int)deprecated
- func (x BatchOperationState) Number() protoreflect.EnumNumber
- func (x BatchOperationState) String() string
- func (BatchOperationState) Type() protoreflect.EnumType
- type BatchOperationType
- func (BatchOperationType) Descriptor() protoreflect.EnumDescriptor
- func (x BatchOperationType) Enum() *BatchOperationType
- func (BatchOperationType) EnumDescriptor() ([]byte, []int)deprecated
- func (x BatchOperationType) Number() protoreflect.EnumNumber
- func (x BatchOperationType) String() string
- func (BatchOperationType) Type() protoreflect.EnumType
- type BuildIdTaskReachability
- func (BuildIdTaskReachability) Descriptor() protoreflect.EnumDescriptor
- func (x BuildIdTaskReachability) Enum() *BuildIdTaskReachability
- func (BuildIdTaskReachability) EnumDescriptor() ([]byte, []int)deprecated
- func (x BuildIdTaskReachability) Number() protoreflect.EnumNumber
- func (x BuildIdTaskReachability) String() string
- func (BuildIdTaskReachability) Type() protoreflect.EnumType
- type CallbackState
- func (CallbackState) Descriptor() protoreflect.EnumDescriptor
- func (x CallbackState) Enum() *CallbackState
- func (CallbackState) EnumDescriptor() ([]byte, []int)deprecated
- func (x CallbackState) Number() protoreflect.EnumNumber
- func (x CallbackState) String() string
- func (CallbackState) Type() protoreflect.EnumType
- type CancelExternalWorkflowExecutionFailedCause
- func (CancelExternalWorkflowExecutionFailedCause) Descriptor() protoreflect.EnumDescriptor
- func (x CancelExternalWorkflowExecutionFailedCause) Enum() *CancelExternalWorkflowExecutionFailedCause
- func (CancelExternalWorkflowExecutionFailedCause) EnumDescriptor() ([]byte, []int)deprecated
- func (x CancelExternalWorkflowExecutionFailedCause) Number() protoreflect.EnumNumber
- func (x CancelExternalWorkflowExecutionFailedCause) String() string
- func (CancelExternalWorkflowExecutionFailedCause) Type() protoreflect.EnumType
- type CommandType
- type ContinueAsNewInitiator
- func (ContinueAsNewInitiator) Descriptor() protoreflect.EnumDescriptor
- func (x ContinueAsNewInitiator) Enum() *ContinueAsNewInitiator
- func (ContinueAsNewInitiator) EnumDescriptor() ([]byte, []int)deprecated
- func (x ContinueAsNewInitiator) Number() protoreflect.EnumNumber
- func (x ContinueAsNewInitiator) String() string
- func (ContinueAsNewInitiator) Type() protoreflect.EnumType
- type DescribeTaskQueueMode
- func (DescribeTaskQueueMode) Descriptor() protoreflect.EnumDescriptor
- func (x DescribeTaskQueueMode) Enum() *DescribeTaskQueueMode
- func (DescribeTaskQueueMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x DescribeTaskQueueMode) Number() protoreflect.EnumNumber
- func (x DescribeTaskQueueMode) String() string
- func (DescribeTaskQueueMode) Type() protoreflect.EnumType
- type EncodingType
- func (EncodingType) Descriptor() protoreflect.EnumDescriptor
- func (x EncodingType) Enum() *EncodingType
- func (EncodingType) EnumDescriptor() ([]byte, []int)deprecated
- func (x EncodingType) Number() protoreflect.EnumNumber
- func (x EncodingType) String() string
- func (EncodingType) Type() protoreflect.EnumType
- type EventType
- type HistoryEventFilterType
- func (HistoryEventFilterType) Descriptor() protoreflect.EnumDescriptor
- func (x HistoryEventFilterType) Enum() *HistoryEventFilterType
- func (HistoryEventFilterType) EnumDescriptor() ([]byte, []int)deprecated
- func (x HistoryEventFilterType) Number() protoreflect.EnumNumber
- func (x HistoryEventFilterType) String() string
- func (HistoryEventFilterType) Type() protoreflect.EnumType
- type IndexedValueType
- func (IndexedValueType) Descriptor() protoreflect.EnumDescriptor
- func (x IndexedValueType) Enum() *IndexedValueType
- func (IndexedValueType) EnumDescriptor() ([]byte, []int)deprecated
- func (x IndexedValueType) Number() protoreflect.EnumNumber
- func (x IndexedValueType) String() string
- func (IndexedValueType) Type() protoreflect.EnumType
- type NamespaceState
- func (NamespaceState) Descriptor() protoreflect.EnumDescriptor
- func (x NamespaceState) Enum() *NamespaceState
- func (NamespaceState) EnumDescriptor() ([]byte, []int)deprecated
- func (x NamespaceState) Number() protoreflect.EnumNumber
- func (x NamespaceState) String() string
- func (NamespaceState) Type() protoreflect.EnumType
- type NexusOperationCancellationState
- func (NexusOperationCancellationState) Descriptor() protoreflect.EnumDescriptor
- func (x NexusOperationCancellationState) Enum() *NexusOperationCancellationState
- func (NexusOperationCancellationState) EnumDescriptor() ([]byte, []int)
- func (x NexusOperationCancellationState) Number() protoreflect.EnumNumber
- func (x NexusOperationCancellationState) String() string
- func (NexusOperationCancellationState) Type() protoreflect.EnumType
- type ParentClosePolicy
- func (ParentClosePolicy) Descriptor() protoreflect.EnumDescriptor
- func (x ParentClosePolicy) Enum() *ParentClosePolicy
- func (ParentClosePolicy) EnumDescriptor() ([]byte, []int)deprecated
- func (x ParentClosePolicy) Number() protoreflect.EnumNumber
- func (x ParentClosePolicy) String() string
- func (ParentClosePolicy) Type() protoreflect.EnumType
- type PendingActivityState
- func (PendingActivityState) Descriptor() protoreflect.EnumDescriptor
- func (x PendingActivityState) Enum() *PendingActivityState
- func (PendingActivityState) EnumDescriptor() ([]byte, []int)deprecated
- func (x PendingActivityState) Number() protoreflect.EnumNumber
- func (x PendingActivityState) String() string
- func (PendingActivityState) Type() protoreflect.EnumType
- type PendingNexusOperationState
- func (PendingNexusOperationState) Descriptor() protoreflect.EnumDescriptor
- func (x PendingNexusOperationState) Enum() *PendingNexusOperationState
- func (PendingNexusOperationState) EnumDescriptor() ([]byte, []int)deprecated
- func (x PendingNexusOperationState) Number() protoreflect.EnumNumber
- func (x PendingNexusOperationState) String() string
- func (PendingNexusOperationState) Type() protoreflect.EnumType
- type PendingWorkflowTaskState
- func (PendingWorkflowTaskState) Descriptor() protoreflect.EnumDescriptor
- func (x PendingWorkflowTaskState) Enum() *PendingWorkflowTaskState
- func (PendingWorkflowTaskState) EnumDescriptor() ([]byte, []int)deprecated
- func (x PendingWorkflowTaskState) Number() protoreflect.EnumNumber
- func (x PendingWorkflowTaskState) String() string
- func (PendingWorkflowTaskState) Type() protoreflect.EnumType
- type QueryRejectCondition
- func (QueryRejectCondition) Descriptor() protoreflect.EnumDescriptor
- func (x QueryRejectCondition) Enum() *QueryRejectCondition
- func (QueryRejectCondition) EnumDescriptor() ([]byte, []int)deprecated
- func (x QueryRejectCondition) Number() protoreflect.EnumNumber
- func (x QueryRejectCondition) String() string
- func (QueryRejectCondition) Type() protoreflect.EnumType
- type QueryResultType
- func (QueryResultType) Descriptor() protoreflect.EnumDescriptor
- func (x QueryResultType) Enum() *QueryResultType
- func (QueryResultType) EnumDescriptor() ([]byte, []int)deprecated
- func (x QueryResultType) Number() protoreflect.EnumNumber
- func (x QueryResultType) String() string
- func (QueryResultType) Type() protoreflect.EnumType
- type ReplicationState
- func (ReplicationState) Descriptor() protoreflect.EnumDescriptor
- func (x ReplicationState) Enum() *ReplicationState
- func (ReplicationState) EnumDescriptor() ([]byte, []int)deprecated
- func (x ReplicationState) Number() protoreflect.EnumNumber
- func (x ReplicationState) String() string
- func (ReplicationState) Type() protoreflect.EnumType
- type ResetReapplyExcludeType
- func (ResetReapplyExcludeType) Descriptor() protoreflect.EnumDescriptor
- func (x ResetReapplyExcludeType) Enum() *ResetReapplyExcludeType
- func (ResetReapplyExcludeType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ResetReapplyExcludeType) Number() protoreflect.EnumNumber
- func (x ResetReapplyExcludeType) String() string
- func (ResetReapplyExcludeType) Type() protoreflect.EnumType
- type ResetReapplyType
- func (ResetReapplyType) Descriptor() protoreflect.EnumDescriptor
- func (x ResetReapplyType) Enum() *ResetReapplyType
- func (ResetReapplyType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ResetReapplyType) Number() protoreflect.EnumNumber
- func (x ResetReapplyType) String() string
- func (ResetReapplyType) Type() protoreflect.EnumType
- type ResetType
- type ResourceExhaustedCause
- func (ResourceExhaustedCause) Descriptor() protoreflect.EnumDescriptor
- func (x ResourceExhaustedCause) Enum() *ResourceExhaustedCause
- func (ResourceExhaustedCause) EnumDescriptor() ([]byte, []int)
- func (x ResourceExhaustedCause) Number() protoreflect.EnumNumber
- func (x ResourceExhaustedCause) String() string
- func (ResourceExhaustedCause) Type() protoreflect.EnumType
- type ResourceExhaustedScope
- func (ResourceExhaustedScope) Descriptor() protoreflect.EnumDescriptor
- func (x ResourceExhaustedScope) Enum() *ResourceExhaustedScope
- func (ResourceExhaustedScope) EnumDescriptor() ([]byte, []int)deprecated
- func (x ResourceExhaustedScope) Number() protoreflect.EnumNumber
- func (x ResourceExhaustedScope) String() string
- func (ResourceExhaustedScope) Type() protoreflect.EnumType
- type RetryState
- type ScheduleOverlapPolicy
- func (ScheduleOverlapPolicy) Descriptor() protoreflect.EnumDescriptor
- func (x ScheduleOverlapPolicy) Enum() *ScheduleOverlapPolicy
- func (ScheduleOverlapPolicy) EnumDescriptor() ([]byte, []int)deprecated
- func (x ScheduleOverlapPolicy) Number() protoreflect.EnumNumber
- func (x ScheduleOverlapPolicy) String() string
- func (ScheduleOverlapPolicy) Type() protoreflect.EnumType
- type Severity
- type SignalExternalWorkflowExecutionFailedCause
- func (SignalExternalWorkflowExecutionFailedCause) Descriptor() protoreflect.EnumDescriptor
- func (x SignalExternalWorkflowExecutionFailedCause) Enum() *SignalExternalWorkflowExecutionFailedCause
- func (SignalExternalWorkflowExecutionFailedCause) EnumDescriptor() ([]byte, []int)deprecated
- func (x SignalExternalWorkflowExecutionFailedCause) Number() protoreflect.EnumNumber
- func (x SignalExternalWorkflowExecutionFailedCause) String() string
- func (SignalExternalWorkflowExecutionFailedCause) Type() protoreflect.EnumType
- type StartChildWorkflowExecutionFailedCause
- func (StartChildWorkflowExecutionFailedCause) Descriptor() protoreflect.EnumDescriptor
- func (x StartChildWorkflowExecutionFailedCause) Enum() *StartChildWorkflowExecutionFailedCause
- func (StartChildWorkflowExecutionFailedCause) EnumDescriptor() ([]byte, []int)
- func (x StartChildWorkflowExecutionFailedCause) Number() protoreflect.EnumNumber
- func (x StartChildWorkflowExecutionFailedCause) String() string
- func (StartChildWorkflowExecutionFailedCause) Type() protoreflect.EnumType
- type TaskQueueKind
- func (TaskQueueKind) Descriptor() protoreflect.EnumDescriptor
- func (x TaskQueueKind) Enum() *TaskQueueKind
- func (TaskQueueKind) EnumDescriptor() ([]byte, []int)deprecated
- func (x TaskQueueKind) Number() protoreflect.EnumNumber
- func (x TaskQueueKind) String() string
- func (TaskQueueKind) Type() protoreflect.EnumType
- type TaskQueueType
- func (TaskQueueType) Descriptor() protoreflect.EnumDescriptor
- func (x TaskQueueType) Enum() *TaskQueueType
- func (TaskQueueType) EnumDescriptor() ([]byte, []int)deprecated
- func (x TaskQueueType) Number() protoreflect.EnumNumber
- func (x TaskQueueType) String() string
- func (TaskQueueType) Type() protoreflect.EnumType
- type TaskReachability
- func (TaskReachability) Descriptor() protoreflect.EnumDescriptor
- func (x TaskReachability) Enum() *TaskReachability
- func (TaskReachability) EnumDescriptor() ([]byte, []int)deprecated
- func (x TaskReachability) Number() protoreflect.EnumNumber
- func (x TaskReachability) String() string
- func (TaskReachability) Type() protoreflect.EnumType
- type TimeoutType
- func (TimeoutType) Descriptor() protoreflect.EnumDescriptor
- func (x TimeoutType) Enum() *TimeoutType
- func (TimeoutType) EnumDescriptor() ([]byte, []int)deprecated
- func (x TimeoutType) Number() protoreflect.EnumNumber
- func (x TimeoutType) String() string
- func (TimeoutType) Type() protoreflect.EnumType
- type UpdateAdmittedEventOrigin
- func (UpdateAdmittedEventOrigin) Descriptor() protoreflect.EnumDescriptor
- func (x UpdateAdmittedEventOrigin) Enum() *UpdateAdmittedEventOrigin
- func (UpdateAdmittedEventOrigin) EnumDescriptor() ([]byte, []int)deprecated
- func (x UpdateAdmittedEventOrigin) Number() protoreflect.EnumNumber
- func (x UpdateAdmittedEventOrigin) String() string
- func (UpdateAdmittedEventOrigin) Type() protoreflect.EnumType
- type UpdateWorkflowExecutionLifecycleStage
- func (UpdateWorkflowExecutionLifecycleStage) Descriptor() protoreflect.EnumDescriptor
- func (x UpdateWorkflowExecutionLifecycleStage) Enum() *UpdateWorkflowExecutionLifecycleStage
- func (UpdateWorkflowExecutionLifecycleStage) EnumDescriptor() ([]byte, []int)deprecated
- func (x UpdateWorkflowExecutionLifecycleStage) Number() protoreflect.EnumNumber
- func (x UpdateWorkflowExecutionLifecycleStage) String() string
- func (UpdateWorkflowExecutionLifecycleStage) Type() protoreflect.EnumType
- type WorkflowExecutionStatus
- func (WorkflowExecutionStatus) Descriptor() protoreflect.EnumDescriptor
- func (x WorkflowExecutionStatus) Enum() *WorkflowExecutionStatus
- func (WorkflowExecutionStatus) EnumDescriptor() ([]byte, []int)
- func (x WorkflowExecutionStatus) Number() protoreflect.EnumNumber
- func (x WorkflowExecutionStatus) String() string
- func (WorkflowExecutionStatus) Type() protoreflect.EnumType
- type WorkflowIdConflictPolicy
- func (WorkflowIdConflictPolicy) Descriptor() protoreflect.EnumDescriptor
- func (x WorkflowIdConflictPolicy) Enum() *WorkflowIdConflictPolicy
- func (WorkflowIdConflictPolicy) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkflowIdConflictPolicy) Number() protoreflect.EnumNumber
- func (x WorkflowIdConflictPolicy) String() string
- func (WorkflowIdConflictPolicy) Type() protoreflect.EnumType
- type WorkflowIdReusePolicy
- func (WorkflowIdReusePolicy) Descriptor() protoreflect.EnumDescriptor
- func (x WorkflowIdReusePolicy) Enum() *WorkflowIdReusePolicy
- func (WorkflowIdReusePolicy) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkflowIdReusePolicy) Number() protoreflect.EnumNumber
- func (x WorkflowIdReusePolicy) String() string
- func (WorkflowIdReusePolicy) Type() protoreflect.EnumType
- type WorkflowTaskFailedCause
- func (WorkflowTaskFailedCause) Descriptor() protoreflect.EnumDescriptor
- func (x WorkflowTaskFailedCause) Enum() *WorkflowTaskFailedCause
- func (WorkflowTaskFailedCause) EnumDescriptor() ([]byte, []int)
- func (x WorkflowTaskFailedCause) Number() protoreflect.EnumNumber
- func (x WorkflowTaskFailedCause) String() string
- func (WorkflowTaskFailedCause) Type() protoreflect.EnumType
Constants ¶
This section is empty.
Variables ¶
var ( BatchOperationType_name = map[int32]string{ 0: "BATCH_OPERATION_TYPE_UNSPECIFIED", 1: "BATCH_OPERATION_TYPE_TERMINATE", 2: "BATCH_OPERATION_TYPE_CANCEL", 3: "BATCH_OPERATION_TYPE_SIGNAL", 4: "BATCH_OPERATION_TYPE_DELETE", 5: "BATCH_OPERATION_TYPE_RESET", } BatchOperationType_value = map[string]int32{ "BATCH_OPERATION_TYPE_UNSPECIFIED": 0, "BATCH_OPERATION_TYPE_TERMINATE": 1, "BATCH_OPERATION_TYPE_CANCEL": 2, "BATCH_OPERATION_TYPE_SIGNAL": 3, "BATCH_OPERATION_TYPE_DELETE": 4, "BATCH_OPERATION_TYPE_RESET": 5, } )
Enum value maps for BatchOperationType.
var ( BatchOperationState_name = map[int32]string{ 0: "BATCH_OPERATION_STATE_UNSPECIFIED", 1: "BATCH_OPERATION_STATE_RUNNING", 2: "BATCH_OPERATION_STATE_COMPLETED", 3: "BATCH_OPERATION_STATE_FAILED", } BatchOperationState_value = map[string]int32{ "BATCH_OPERATION_STATE_UNSPECIFIED": 0, "BATCH_OPERATION_STATE_RUNNING": 1, "BATCH_OPERATION_STATE_COMPLETED": 2, "BATCH_OPERATION_STATE_FAILED": 3, } )
Enum value maps for BatchOperationState.
var ( CommandType_name = map[int32]string{ 0: "COMMAND_TYPE_UNSPECIFIED", 1: "COMMAND_TYPE_SCHEDULE_ACTIVITY_TASK", 2: "COMMAND_TYPE_REQUEST_CANCEL_ACTIVITY_TASK", 3: "COMMAND_TYPE_START_TIMER", 4: "COMMAND_TYPE_COMPLETE_WORKFLOW_EXECUTION", 5: "COMMAND_TYPE_FAIL_WORKFLOW_EXECUTION", 6: "COMMAND_TYPE_CANCEL_TIMER", 7: "COMMAND_TYPE_CANCEL_WORKFLOW_EXECUTION", 8: "COMMAND_TYPE_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION", 9: "COMMAND_TYPE_RECORD_MARKER", 10: "COMMAND_TYPE_CONTINUE_AS_NEW_WORKFLOW_EXECUTION", 11: "COMMAND_TYPE_START_CHILD_WORKFLOW_EXECUTION", 12: "COMMAND_TYPE_SIGNAL_EXTERNAL_WORKFLOW_EXECUTION", 13: "COMMAND_TYPE_UPSERT_WORKFLOW_SEARCH_ATTRIBUTES", 14: "COMMAND_TYPE_PROTOCOL_MESSAGE", 16: "COMMAND_TYPE_MODIFY_WORKFLOW_PROPERTIES", 17: "COMMAND_TYPE_SCHEDULE_NEXUS_OPERATION", 18: "COMMAND_TYPE_REQUEST_CANCEL_NEXUS_OPERATION", } CommandType_value = map[string]int32{ "COMMAND_TYPE_UNSPECIFIED": 0, "COMMAND_TYPE_SCHEDULE_ACTIVITY_TASK": 1, "COMMAND_TYPE_REQUEST_CANCEL_ACTIVITY_TASK": 2, "COMMAND_TYPE_START_TIMER": 3, "COMMAND_TYPE_COMPLETE_WORKFLOW_EXECUTION": 4, "COMMAND_TYPE_FAIL_WORKFLOW_EXECUTION": 5, "COMMAND_TYPE_CANCEL_TIMER": 6, "COMMAND_TYPE_CANCEL_WORKFLOW_EXECUTION": 7, "COMMAND_TYPE_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION": 8, "COMMAND_TYPE_RECORD_MARKER": 9, "COMMAND_TYPE_CONTINUE_AS_NEW_WORKFLOW_EXECUTION": 10, "COMMAND_TYPE_START_CHILD_WORKFLOW_EXECUTION": 11, "COMMAND_TYPE_SIGNAL_EXTERNAL_WORKFLOW_EXECUTION": 12, "COMMAND_TYPE_UPSERT_WORKFLOW_SEARCH_ATTRIBUTES": 13, "COMMAND_TYPE_PROTOCOL_MESSAGE": 14, "COMMAND_TYPE_MODIFY_WORKFLOW_PROPERTIES": 16, "COMMAND_TYPE_SCHEDULE_NEXUS_OPERATION": 17, "COMMAND_TYPE_REQUEST_CANCEL_NEXUS_OPERATION": 18, } )
Enum value maps for CommandType.
var ( EncodingType_name = map[int32]string{ 0: "ENCODING_TYPE_UNSPECIFIED", 1: "ENCODING_TYPE_PROTO3", 2: "ENCODING_TYPE_JSON", } EncodingType_value = map[string]int32{ "ENCODING_TYPE_UNSPECIFIED": 0, "ENCODING_TYPE_PROTO3": 1, "ENCODING_TYPE_JSON": 2, } )
Enum value maps for EncodingType.
var ( IndexedValueType_name = map[int32]string{ 0: "INDEXED_VALUE_TYPE_UNSPECIFIED", 1: "INDEXED_VALUE_TYPE_TEXT", 2: "INDEXED_VALUE_TYPE_KEYWORD", 3: "INDEXED_VALUE_TYPE_INT", 4: "INDEXED_VALUE_TYPE_DOUBLE", 5: "INDEXED_VALUE_TYPE_BOOL", 6: "INDEXED_VALUE_TYPE_DATETIME", 7: "INDEXED_VALUE_TYPE_KEYWORD_LIST", } IndexedValueType_value = map[string]int32{ "INDEXED_VALUE_TYPE_UNSPECIFIED": 0, "INDEXED_VALUE_TYPE_TEXT": 1, "INDEXED_VALUE_TYPE_KEYWORD": 2, "INDEXED_VALUE_TYPE_INT": 3, "INDEXED_VALUE_TYPE_DOUBLE": 4, "INDEXED_VALUE_TYPE_BOOL": 5, "INDEXED_VALUE_TYPE_DATETIME": 6, "INDEXED_VALUE_TYPE_KEYWORD_LIST": 7, } )
Enum value maps for IndexedValueType.
var ( Severity_name = map[int32]string{ 0: "SEVERITY_UNSPECIFIED", 1: "SEVERITY_HIGH", 2: "SEVERITY_MEDIUM", 3: "SEVERITY_LOW", } Severity_value = map[string]int32{ "SEVERITY_UNSPECIFIED": 0, "SEVERITY_HIGH": 1, "SEVERITY_MEDIUM": 2, "SEVERITY_LOW": 3, } )
Enum value maps for Severity.
var ( CallbackState_name = map[int32]string{ 0: "CALLBACK_STATE_UNSPECIFIED", 1: "CALLBACK_STATE_STANDBY", 2: "CALLBACK_STATE_SCHEDULED", 3: "CALLBACK_STATE_BACKING_OFF", 4: "CALLBACK_STATE_FAILED", 5: "CALLBACK_STATE_SUCCEEDED", 6: "CALLBACK_STATE_BLOCKED", } CallbackState_value = map[string]int32{ "CALLBACK_STATE_UNSPECIFIED": 0, "CALLBACK_STATE_STANDBY": 1, "CALLBACK_STATE_SCHEDULED": 2, "CALLBACK_STATE_BACKING_OFF": 3, "CALLBACK_STATE_FAILED": 4, "CALLBACK_STATE_SUCCEEDED": 5, "CALLBACK_STATE_BLOCKED": 6, } )
Enum value maps for CallbackState.
var ( PendingNexusOperationState_name = map[int32]string{ 0: "PENDING_NEXUS_OPERATION_STATE_UNSPECIFIED", 1: "PENDING_NEXUS_OPERATION_STATE_SCHEDULED", 2: "PENDING_NEXUS_OPERATION_STATE_BACKING_OFF", 3: "PENDING_NEXUS_OPERATION_STATE_STARTED", 4: "PENDING_NEXUS_OPERATION_STATE_BLOCKED", } PendingNexusOperationState_value = map[string]int32{ "PENDING_NEXUS_OPERATION_STATE_UNSPECIFIED": 0, "PENDING_NEXUS_OPERATION_STATE_SCHEDULED": 1, "PENDING_NEXUS_OPERATION_STATE_BACKING_OFF": 2, "PENDING_NEXUS_OPERATION_STATE_STARTED": 3, "PENDING_NEXUS_OPERATION_STATE_BLOCKED": 4, } )
Enum value maps for PendingNexusOperationState.
var ( NexusOperationCancellationState_name = map[int32]string{ 0: "NEXUS_OPERATION_CANCELLATION_STATE_UNSPECIFIED", 1: "NEXUS_OPERATION_CANCELLATION_STATE_SCHEDULED", 2: "NEXUS_OPERATION_CANCELLATION_STATE_BACKING_OFF", 3: "NEXUS_OPERATION_CANCELLATION_STATE_SUCCEEDED", 4: "NEXUS_OPERATION_CANCELLATION_STATE_FAILED", 5: "NEXUS_OPERATION_CANCELLATION_STATE_TIMED_OUT", 6: "NEXUS_OPERATION_CANCELLATION_STATE_BLOCKED", } NexusOperationCancellationState_value = map[string]int32{ "NEXUS_OPERATION_CANCELLATION_STATE_UNSPECIFIED": 0, "NEXUS_OPERATION_CANCELLATION_STATE_SCHEDULED": 1, "NEXUS_OPERATION_CANCELLATION_STATE_BACKING_OFF": 2, "NEXUS_OPERATION_CANCELLATION_STATE_SUCCEEDED": 3, "NEXUS_OPERATION_CANCELLATION_STATE_FAILED": 4, "NEXUS_OPERATION_CANCELLATION_STATE_TIMED_OUT": 5, "NEXUS_OPERATION_CANCELLATION_STATE_BLOCKED": 6, } )
Enum value maps for NexusOperationCancellationState.
var ( EventType_name = map[int32]string{ 0: "EVENT_TYPE_UNSPECIFIED", 1: "EVENT_TYPE_WORKFLOW_EXECUTION_STARTED", 2: "EVENT_TYPE_WORKFLOW_EXECUTION_COMPLETED", 3: "EVENT_TYPE_WORKFLOW_EXECUTION_FAILED", 4: "EVENT_TYPE_WORKFLOW_EXECUTION_TIMED_OUT", 5: "EVENT_TYPE_WORKFLOW_TASK_SCHEDULED", 6: "EVENT_TYPE_WORKFLOW_TASK_STARTED", 7: "EVENT_TYPE_WORKFLOW_TASK_COMPLETED", 8: "EVENT_TYPE_WORKFLOW_TASK_TIMED_OUT", 9: "EVENT_TYPE_WORKFLOW_TASK_FAILED", 10: "EVENT_TYPE_ACTIVITY_TASK_SCHEDULED", 11: "EVENT_TYPE_ACTIVITY_TASK_STARTED", 12: "EVENT_TYPE_ACTIVITY_TASK_COMPLETED", 13: "EVENT_TYPE_ACTIVITY_TASK_FAILED", 14: "EVENT_TYPE_ACTIVITY_TASK_TIMED_OUT", 15: "EVENT_TYPE_ACTIVITY_TASK_CANCEL_REQUESTED", 16: "EVENT_TYPE_ACTIVITY_TASK_CANCELED", 17: "EVENT_TYPE_TIMER_STARTED", 18: "EVENT_TYPE_TIMER_FIRED", 19: "EVENT_TYPE_TIMER_CANCELED", 20: "EVENT_TYPE_WORKFLOW_EXECUTION_CANCEL_REQUESTED", 21: "EVENT_TYPE_WORKFLOW_EXECUTION_CANCELED", 22: "EVENT_TYPE_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED", 23: "EVENT_TYPE_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED", 24: "EVENT_TYPE_EXTERNAL_WORKFLOW_EXECUTION_CANCEL_REQUESTED", 25: "EVENT_TYPE_MARKER_RECORDED", 26: "EVENT_TYPE_WORKFLOW_EXECUTION_SIGNALED", 27: "EVENT_TYPE_WORKFLOW_EXECUTION_TERMINATED", 28: "EVENT_TYPE_WORKFLOW_EXECUTION_CONTINUED_AS_NEW", 29: "EVENT_TYPE_START_CHILD_WORKFLOW_EXECUTION_INITIATED", 30: "EVENT_TYPE_START_CHILD_WORKFLOW_EXECUTION_FAILED", 31: "EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_STARTED", 32: "EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_COMPLETED", 33: "EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_FAILED", 34: "EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_CANCELED", 35: "EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_TIMED_OUT", 36: "EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_TERMINATED", 37: "EVENT_TYPE_SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED", 38: "EVENT_TYPE_SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED", 39: "EVENT_TYPE_EXTERNAL_WORKFLOW_EXECUTION_SIGNALED", 40: "EVENT_TYPE_UPSERT_WORKFLOW_SEARCH_ATTRIBUTES", 47: "EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_ADMITTED", 41: "EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_ACCEPTED", 42: "EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_REJECTED", 43: "EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_COMPLETED", 44: "EVENT_TYPE_WORKFLOW_PROPERTIES_MODIFIED_EXTERNALLY", 45: "EVENT_TYPE_ACTIVITY_PROPERTIES_MODIFIED_EXTERNALLY", 46: "EVENT_TYPE_WORKFLOW_PROPERTIES_MODIFIED", 48: "EVENT_TYPE_NEXUS_OPERATION_SCHEDULED", 49: "EVENT_TYPE_NEXUS_OPERATION_STARTED", 50: "EVENT_TYPE_NEXUS_OPERATION_COMPLETED", 51: "EVENT_TYPE_NEXUS_OPERATION_FAILED", 52: "EVENT_TYPE_NEXUS_OPERATION_CANCELED", 53: "EVENT_TYPE_NEXUS_OPERATION_TIMED_OUT", 54: "EVENT_TYPE_NEXUS_OPERATION_CANCEL_REQUESTED", } EventType_value = map[string]int32{ "EVENT_TYPE_UNSPECIFIED": 0, "EVENT_TYPE_WORKFLOW_EXECUTION_STARTED": 1, "EVENT_TYPE_WORKFLOW_EXECUTION_COMPLETED": 2, "EVENT_TYPE_WORKFLOW_EXECUTION_FAILED": 3, "EVENT_TYPE_WORKFLOW_EXECUTION_TIMED_OUT": 4, "EVENT_TYPE_WORKFLOW_TASK_SCHEDULED": 5, "EVENT_TYPE_WORKFLOW_TASK_STARTED": 6, "EVENT_TYPE_WORKFLOW_TASK_COMPLETED": 7, "EVENT_TYPE_WORKFLOW_TASK_TIMED_OUT": 8, "EVENT_TYPE_WORKFLOW_TASK_FAILED": 9, "EVENT_TYPE_ACTIVITY_TASK_SCHEDULED": 10, "EVENT_TYPE_ACTIVITY_TASK_STARTED": 11, "EVENT_TYPE_ACTIVITY_TASK_COMPLETED": 12, "EVENT_TYPE_ACTIVITY_TASK_FAILED": 13, "EVENT_TYPE_ACTIVITY_TASK_TIMED_OUT": 14, "EVENT_TYPE_ACTIVITY_TASK_CANCEL_REQUESTED": 15, "EVENT_TYPE_ACTIVITY_TASK_CANCELED": 16, "EVENT_TYPE_TIMER_STARTED": 17, "EVENT_TYPE_TIMER_FIRED": 18, "EVENT_TYPE_TIMER_CANCELED": 19, "EVENT_TYPE_WORKFLOW_EXECUTION_CANCEL_REQUESTED": 20, "EVENT_TYPE_WORKFLOW_EXECUTION_CANCELED": 21, "EVENT_TYPE_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED": 22, "EVENT_TYPE_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED": 23, "EVENT_TYPE_EXTERNAL_WORKFLOW_EXECUTION_CANCEL_REQUESTED": 24, "EVENT_TYPE_MARKER_RECORDED": 25, "EVENT_TYPE_WORKFLOW_EXECUTION_SIGNALED": 26, "EVENT_TYPE_WORKFLOW_EXECUTION_TERMINATED": 27, "EVENT_TYPE_WORKFLOW_EXECUTION_CONTINUED_AS_NEW": 28, "EVENT_TYPE_START_CHILD_WORKFLOW_EXECUTION_INITIATED": 29, "EVENT_TYPE_START_CHILD_WORKFLOW_EXECUTION_FAILED": 30, "EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_STARTED": 31, "EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_COMPLETED": 32, "EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_FAILED": 33, "EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_CANCELED": 34, "EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_TIMED_OUT": 35, "EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_TERMINATED": 36, "EVENT_TYPE_SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED": 37, "EVENT_TYPE_SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED": 38, "EVENT_TYPE_EXTERNAL_WORKFLOW_EXECUTION_SIGNALED": 39, "EVENT_TYPE_UPSERT_WORKFLOW_SEARCH_ATTRIBUTES": 40, "EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_ADMITTED": 47, "EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_ACCEPTED": 41, "EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_REJECTED": 42, "EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_COMPLETED": 43, "EVENT_TYPE_WORKFLOW_PROPERTIES_MODIFIED_EXTERNALLY": 44, "EVENT_TYPE_ACTIVITY_PROPERTIES_MODIFIED_EXTERNALLY": 45, "EVENT_TYPE_WORKFLOW_PROPERTIES_MODIFIED": 46, "EVENT_TYPE_NEXUS_OPERATION_SCHEDULED": 48, "EVENT_TYPE_NEXUS_OPERATION_STARTED": 49, "EVENT_TYPE_NEXUS_OPERATION_COMPLETED": 50, "EVENT_TYPE_NEXUS_OPERATION_FAILED": 51, "EVENT_TYPE_NEXUS_OPERATION_CANCELED": 52, "EVENT_TYPE_NEXUS_OPERATION_TIMED_OUT": 53, "EVENT_TYPE_NEXUS_OPERATION_CANCEL_REQUESTED": 54, } )
Enum value maps for EventType.
var ( WorkflowTaskFailedCause_name = map[int32]string{ 0: "WORKFLOW_TASK_FAILED_CAUSE_UNSPECIFIED", 1: "WORKFLOW_TASK_FAILED_CAUSE_UNHANDLED_COMMAND", 2: "WORKFLOW_TASK_FAILED_CAUSE_BAD_SCHEDULE_ACTIVITY_ATTRIBUTES", 3: "WORKFLOW_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES", 4: "WORKFLOW_TASK_FAILED_CAUSE_BAD_START_TIMER_ATTRIBUTES", 5: "WORKFLOW_TASK_FAILED_CAUSE_BAD_CANCEL_TIMER_ATTRIBUTES", 6: "WORKFLOW_TASK_FAILED_CAUSE_BAD_RECORD_MARKER_ATTRIBUTES", 7: "WORKFLOW_TASK_FAILED_CAUSE_BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES", 8: "WORKFLOW_TASK_FAILED_CAUSE_BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES", 9: "WORKFLOW_TASK_FAILED_CAUSE_BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES", 10: "WORKFLOW_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES", 11: "WORKFLOW_TASK_FAILED_CAUSE_BAD_CONTINUE_AS_NEW_ATTRIBUTES", 12: "WORKFLOW_TASK_FAILED_CAUSE_START_TIMER_DUPLICATE_ID", 13: "WORKFLOW_TASK_FAILED_CAUSE_RESET_STICKY_TASK_QUEUE", 14: "WORKFLOW_TASK_FAILED_CAUSE_WORKFLOW_WORKER_UNHANDLED_FAILURE", 15: "WORKFLOW_TASK_FAILED_CAUSE_BAD_SIGNAL_WORKFLOW_EXECUTION_ATTRIBUTES", 16: "WORKFLOW_TASK_FAILED_CAUSE_BAD_START_CHILD_EXECUTION_ATTRIBUTES", 17: "WORKFLOW_TASK_FAILED_CAUSE_FORCE_CLOSE_COMMAND", 18: "WORKFLOW_TASK_FAILED_CAUSE_FAILOVER_CLOSE_COMMAND", 19: "WORKFLOW_TASK_FAILED_CAUSE_BAD_SIGNAL_INPUT_SIZE", 20: "WORKFLOW_TASK_FAILED_CAUSE_RESET_WORKFLOW", 21: "WORKFLOW_TASK_FAILED_CAUSE_BAD_BINARY", 22: "WORKFLOW_TASK_FAILED_CAUSE_SCHEDULE_ACTIVITY_DUPLICATE_ID", 23: "WORKFLOW_TASK_FAILED_CAUSE_BAD_SEARCH_ATTRIBUTES", 24: "WORKFLOW_TASK_FAILED_CAUSE_NON_DETERMINISTIC_ERROR", 25: "WORKFLOW_TASK_FAILED_CAUSE_BAD_MODIFY_WORKFLOW_PROPERTIES_ATTRIBUTES", 26: "WORKFLOW_TASK_FAILED_CAUSE_PENDING_CHILD_WORKFLOWS_LIMIT_EXCEEDED", 27: "WORKFLOW_TASK_FAILED_CAUSE_PENDING_ACTIVITIES_LIMIT_EXCEEDED", 28: "WORKFLOW_TASK_FAILED_CAUSE_PENDING_SIGNALS_LIMIT_EXCEEDED", 29: "WORKFLOW_TASK_FAILED_CAUSE_PENDING_REQUEST_CANCEL_LIMIT_EXCEEDED", 30: "WORKFLOW_TASK_FAILED_CAUSE_BAD_UPDATE_WORKFLOW_EXECUTION_MESSAGE", 31: "WORKFLOW_TASK_FAILED_CAUSE_UNHANDLED_UPDATE", 32: "WORKFLOW_TASK_FAILED_CAUSE_BAD_SCHEDULE_NEXUS_OPERATION_ATTRIBUTES", 33: "WORKFLOW_TASK_FAILED_CAUSE_PENDING_NEXUS_OPERATIONS_LIMIT_EXCEEDED", 34: "WORKFLOW_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_NEXUS_OPERATION_ATTRIBUTES", 35: "WORKFLOW_TASK_FAILED_CAUSE_FEATURE_DISABLED", } WorkflowTaskFailedCause_value = map[string]int32{ "WORKFLOW_TASK_FAILED_CAUSE_UNSPECIFIED": 0, "WORKFLOW_TASK_FAILED_CAUSE_UNHANDLED_COMMAND": 1, "WORKFLOW_TASK_FAILED_CAUSE_BAD_SCHEDULE_ACTIVITY_ATTRIBUTES": 2, "WORKFLOW_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES": 3, "WORKFLOW_TASK_FAILED_CAUSE_BAD_START_TIMER_ATTRIBUTES": 4, "WORKFLOW_TASK_FAILED_CAUSE_BAD_CANCEL_TIMER_ATTRIBUTES": 5, "WORKFLOW_TASK_FAILED_CAUSE_BAD_RECORD_MARKER_ATTRIBUTES": 6, "WORKFLOW_TASK_FAILED_CAUSE_BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES": 7, "WORKFLOW_TASK_FAILED_CAUSE_BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES": 8, "WORKFLOW_TASK_FAILED_CAUSE_BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES": 9, "WORKFLOW_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES": 10, "WORKFLOW_TASK_FAILED_CAUSE_BAD_CONTINUE_AS_NEW_ATTRIBUTES": 11, "WORKFLOW_TASK_FAILED_CAUSE_START_TIMER_DUPLICATE_ID": 12, "WORKFLOW_TASK_FAILED_CAUSE_RESET_STICKY_TASK_QUEUE": 13, "WORKFLOW_TASK_FAILED_CAUSE_WORKFLOW_WORKER_UNHANDLED_FAILURE": 14, "WORKFLOW_TASK_FAILED_CAUSE_BAD_SIGNAL_WORKFLOW_EXECUTION_ATTRIBUTES": 15, "WORKFLOW_TASK_FAILED_CAUSE_BAD_START_CHILD_EXECUTION_ATTRIBUTES": 16, "WORKFLOW_TASK_FAILED_CAUSE_FORCE_CLOSE_COMMAND": 17, "WORKFLOW_TASK_FAILED_CAUSE_FAILOVER_CLOSE_COMMAND": 18, "WORKFLOW_TASK_FAILED_CAUSE_BAD_SIGNAL_INPUT_SIZE": 19, "WORKFLOW_TASK_FAILED_CAUSE_RESET_WORKFLOW": 20, "WORKFLOW_TASK_FAILED_CAUSE_BAD_BINARY": 21, "WORKFLOW_TASK_FAILED_CAUSE_SCHEDULE_ACTIVITY_DUPLICATE_ID": 22, "WORKFLOW_TASK_FAILED_CAUSE_BAD_SEARCH_ATTRIBUTES": 23, "WORKFLOW_TASK_FAILED_CAUSE_NON_DETERMINISTIC_ERROR": 24, "WORKFLOW_TASK_FAILED_CAUSE_BAD_MODIFY_WORKFLOW_PROPERTIES_ATTRIBUTES": 25, "WORKFLOW_TASK_FAILED_CAUSE_PENDING_CHILD_WORKFLOWS_LIMIT_EXCEEDED": 26, "WORKFLOW_TASK_FAILED_CAUSE_PENDING_ACTIVITIES_LIMIT_EXCEEDED": 27, "WORKFLOW_TASK_FAILED_CAUSE_PENDING_SIGNALS_LIMIT_EXCEEDED": 28, "WORKFLOW_TASK_FAILED_CAUSE_PENDING_REQUEST_CANCEL_LIMIT_EXCEEDED": 29, "WORKFLOW_TASK_FAILED_CAUSE_BAD_UPDATE_WORKFLOW_EXECUTION_MESSAGE": 30, "WORKFLOW_TASK_FAILED_CAUSE_UNHANDLED_UPDATE": 31, "WORKFLOW_TASK_FAILED_CAUSE_BAD_SCHEDULE_NEXUS_OPERATION_ATTRIBUTES": 32, "WORKFLOW_TASK_FAILED_CAUSE_PENDING_NEXUS_OPERATIONS_LIMIT_EXCEEDED": 33, "WORKFLOW_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_NEXUS_OPERATION_ATTRIBUTES": 34, "WORKFLOW_TASK_FAILED_CAUSE_FEATURE_DISABLED": 35, } )
Enum value maps for WorkflowTaskFailedCause.
var ( StartChildWorkflowExecutionFailedCause_name = map[int32]string{ 0: "START_CHILD_WORKFLOW_EXECUTION_FAILED_CAUSE_UNSPECIFIED", 1: "START_CHILD_WORKFLOW_EXECUTION_FAILED_CAUSE_WORKFLOW_ALREADY_EXISTS", 2: "START_CHILD_WORKFLOW_EXECUTION_FAILED_CAUSE_NAMESPACE_NOT_FOUND", } StartChildWorkflowExecutionFailedCause_value = map[string]int32{ "START_CHILD_WORKFLOW_EXECUTION_FAILED_CAUSE_UNSPECIFIED": 0, "START_CHILD_WORKFLOW_EXECUTION_FAILED_CAUSE_WORKFLOW_ALREADY_EXISTS": 1, "START_CHILD_WORKFLOW_EXECUTION_FAILED_CAUSE_NAMESPACE_NOT_FOUND": 2, } )
var ( CancelExternalWorkflowExecutionFailedCause_name = map[int32]string{ 0: "CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_UNSPECIFIED", 1: "CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_EXTERNAL_WORKFLOW_EXECUTION_NOT_FOUND", 2: "CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_NAMESPACE_NOT_FOUND", } CancelExternalWorkflowExecutionFailedCause_value = map[string]int32{ "CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_UNSPECIFIED": 0, "CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_EXTERNAL_WORKFLOW_EXECUTION_NOT_FOUND": 1, "CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_NAMESPACE_NOT_FOUND": 2, } )
var ( SignalExternalWorkflowExecutionFailedCause_name = map[int32]string{ 0: "SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_UNSPECIFIED", 1: "SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_EXTERNAL_WORKFLOW_EXECUTION_NOT_FOUND", 2: "SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_NAMESPACE_NOT_FOUND", 3: "SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_SIGNAL_COUNT_LIMIT_EXCEEDED", } SignalExternalWorkflowExecutionFailedCause_value = map[string]int32{ "SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_UNSPECIFIED": 0, "SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_EXTERNAL_WORKFLOW_EXECUTION_NOT_FOUND": 1, "SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_NAMESPACE_NOT_FOUND": 2, "SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_SIGNAL_COUNT_LIMIT_EXCEEDED": 3, } )
Enum value maps for SignalExternalWorkflowExecutionFailedCause.
var ( ResourceExhaustedCause_name = map[int32]string{ 0: "RESOURCE_EXHAUSTED_CAUSE_UNSPECIFIED", 1: "RESOURCE_EXHAUSTED_CAUSE_RPS_LIMIT", 2: "RESOURCE_EXHAUSTED_CAUSE_CONCURRENT_LIMIT", 3: "RESOURCE_EXHAUSTED_CAUSE_SYSTEM_OVERLOADED", 4: "RESOURCE_EXHAUSTED_CAUSE_PERSISTENCE_LIMIT", 5: "RESOURCE_EXHAUSTED_CAUSE_BUSY_WORKFLOW", 6: "RESOURCE_EXHAUSTED_CAUSE_APS_LIMIT", 7: "RESOURCE_EXHAUSTED_CAUSE_PERSISTENCE_STORAGE_LIMIT", 8: "RESOURCE_EXHAUSTED_CAUSE_CIRCUIT_BREAKER_OPEN", } ResourceExhaustedCause_value = map[string]int32{ "RESOURCE_EXHAUSTED_CAUSE_UNSPECIFIED": 0, "RESOURCE_EXHAUSTED_CAUSE_RPS_LIMIT": 1, "RESOURCE_EXHAUSTED_CAUSE_CONCURRENT_LIMIT": 2, "RESOURCE_EXHAUSTED_CAUSE_SYSTEM_OVERLOADED": 3, "RESOURCE_EXHAUSTED_CAUSE_PERSISTENCE_LIMIT": 4, "RESOURCE_EXHAUSTED_CAUSE_BUSY_WORKFLOW": 5, "RESOURCE_EXHAUSTED_CAUSE_APS_LIMIT": 6, "RESOURCE_EXHAUSTED_CAUSE_PERSISTENCE_STORAGE_LIMIT": 7, "RESOURCE_EXHAUSTED_CAUSE_CIRCUIT_BREAKER_OPEN": 8, } )
Enum value maps for ResourceExhaustedCause.
var ( ResourceExhaustedScope_name = map[int32]string{ 0: "RESOURCE_EXHAUSTED_SCOPE_UNSPECIFIED", 1: "RESOURCE_EXHAUSTED_SCOPE_NAMESPACE", 2: "RESOURCE_EXHAUSTED_SCOPE_SYSTEM", } ResourceExhaustedScope_value = map[string]int32{ "RESOURCE_EXHAUSTED_SCOPE_UNSPECIFIED": 0, "RESOURCE_EXHAUSTED_SCOPE_NAMESPACE": 1, "RESOURCE_EXHAUSTED_SCOPE_SYSTEM": 2, } )
Enum value maps for ResourceExhaustedScope.
var ( NamespaceState_name = map[int32]string{ 0: "NAMESPACE_STATE_UNSPECIFIED", 1: "NAMESPACE_STATE_REGISTERED", 2: "NAMESPACE_STATE_DEPRECATED", 3: "NAMESPACE_STATE_DELETED", } NamespaceState_value = map[string]int32{ "NAMESPACE_STATE_UNSPECIFIED": 0, "NAMESPACE_STATE_REGISTERED": 1, "NAMESPACE_STATE_DEPRECATED": 2, "NAMESPACE_STATE_DELETED": 3, } )
Enum value maps for NamespaceState.
var ( ArchivalState_name = map[int32]string{ 0: "ARCHIVAL_STATE_UNSPECIFIED", 1: "ARCHIVAL_STATE_DISABLED", 2: "ARCHIVAL_STATE_ENABLED", } ArchivalState_value = map[string]int32{ "ARCHIVAL_STATE_UNSPECIFIED": 0, "ARCHIVAL_STATE_DISABLED": 1, "ARCHIVAL_STATE_ENABLED": 2, } )
Enum value maps for ArchivalState.
var ( ReplicationState_name = map[int32]string{ 0: "REPLICATION_STATE_UNSPECIFIED", 1: "REPLICATION_STATE_NORMAL", 2: "REPLICATION_STATE_HANDOVER", } ReplicationState_value = map[string]int32{ "REPLICATION_STATE_UNSPECIFIED": 0, "REPLICATION_STATE_NORMAL": 1, "REPLICATION_STATE_HANDOVER": 2, } )
Enum value maps for ReplicationState.
var ( QueryResultType_name = map[int32]string{ 0: "QUERY_RESULT_TYPE_UNSPECIFIED", 1: "QUERY_RESULT_TYPE_ANSWERED", 2: "QUERY_RESULT_TYPE_FAILED", } QueryResultType_value = map[string]int32{ "QUERY_RESULT_TYPE_UNSPECIFIED": 0, "QUERY_RESULT_TYPE_ANSWERED": 1, "QUERY_RESULT_TYPE_FAILED": 2, } )
Enum value maps for QueryResultType.
var ( QueryRejectCondition_name = map[int32]string{ 0: "QUERY_REJECT_CONDITION_UNSPECIFIED", 1: "QUERY_REJECT_CONDITION_NONE", 2: "QUERY_REJECT_CONDITION_NOT_OPEN", 3: "QUERY_REJECT_CONDITION_NOT_COMPLETED_CLEANLY", } QueryRejectCondition_value = map[string]int32{ "QUERY_REJECT_CONDITION_UNSPECIFIED": 0, "QUERY_REJECT_CONDITION_NONE": 1, "QUERY_REJECT_CONDITION_NOT_OPEN": 2, "QUERY_REJECT_CONDITION_NOT_COMPLETED_CLEANLY": 3, } )
Enum value maps for QueryRejectCondition.
var ( ResetReapplyExcludeType_name = map[int32]string{ 0: "RESET_REAPPLY_EXCLUDE_TYPE_UNSPECIFIED", 1: "RESET_REAPPLY_EXCLUDE_TYPE_SIGNAL", 2: "RESET_REAPPLY_EXCLUDE_TYPE_UPDATE", 3: "RESET_REAPPLY_EXCLUDE_TYPE_NEXUS", } ResetReapplyExcludeType_value = map[string]int32{ "RESET_REAPPLY_EXCLUDE_TYPE_UNSPECIFIED": 0, "RESET_REAPPLY_EXCLUDE_TYPE_SIGNAL": 1, "RESET_REAPPLY_EXCLUDE_TYPE_UPDATE": 2, "RESET_REAPPLY_EXCLUDE_TYPE_NEXUS": 3, } )
Enum value maps for ResetReapplyExcludeType.
var ( ResetReapplyType_name = map[int32]string{ 0: "RESET_REAPPLY_TYPE_UNSPECIFIED", 1: "RESET_REAPPLY_TYPE_SIGNAL", 2: "RESET_REAPPLY_TYPE_NONE", 3: "RESET_REAPPLY_TYPE_ALL_ELIGIBLE", } ResetReapplyType_value = map[string]int32{ "RESET_REAPPLY_TYPE_UNSPECIFIED": 0, "RESET_REAPPLY_TYPE_SIGNAL": 1, "RESET_REAPPLY_TYPE_NONE": 2, "RESET_REAPPLY_TYPE_ALL_ELIGIBLE": 3, } )
Enum value maps for ResetReapplyType.
var ( ResetType_name = map[int32]string{ 0: "RESET_TYPE_UNSPECIFIED", 1: "RESET_TYPE_FIRST_WORKFLOW_TASK", 2: "RESET_TYPE_LAST_WORKFLOW_TASK", } ResetType_value = map[string]int32{ "RESET_TYPE_UNSPECIFIED": 0, "RESET_TYPE_FIRST_WORKFLOW_TASK": 1, "RESET_TYPE_LAST_WORKFLOW_TASK": 2, } )
Enum value maps for ResetType.
var ( ScheduleOverlapPolicy_name = map[int32]string{ 0: "SCHEDULE_OVERLAP_POLICY_UNSPECIFIED", 1: "SCHEDULE_OVERLAP_POLICY_SKIP", 2: "SCHEDULE_OVERLAP_POLICY_BUFFER_ONE", 3: "SCHEDULE_OVERLAP_POLICY_BUFFER_ALL", 4: "SCHEDULE_OVERLAP_POLICY_CANCEL_OTHER", 5: "SCHEDULE_OVERLAP_POLICY_TERMINATE_OTHER", 6: "SCHEDULE_OVERLAP_POLICY_ALLOW_ALL", } ScheduleOverlapPolicy_value = map[string]int32{ "SCHEDULE_OVERLAP_POLICY_UNSPECIFIED": 0, "SCHEDULE_OVERLAP_POLICY_SKIP": 1, "SCHEDULE_OVERLAP_POLICY_BUFFER_ONE": 2, "SCHEDULE_OVERLAP_POLICY_BUFFER_ALL": 3, "SCHEDULE_OVERLAP_POLICY_CANCEL_OTHER": 4, "SCHEDULE_OVERLAP_POLICY_TERMINATE_OTHER": 5, "SCHEDULE_OVERLAP_POLICY_ALLOW_ALL": 6, } )
Enum value maps for ScheduleOverlapPolicy.
var ( TaskQueueKind_name = map[int32]string{ 0: "TASK_QUEUE_KIND_UNSPECIFIED", 1: "TASK_QUEUE_KIND_NORMAL", 2: "TASK_QUEUE_KIND_STICKY", } TaskQueueKind_value = map[string]int32{ "TASK_QUEUE_KIND_UNSPECIFIED": 0, "TASK_QUEUE_KIND_NORMAL": 1, "TASK_QUEUE_KIND_STICKY": 2, } )
Enum value maps for TaskQueueKind.
var ( TaskQueueType_name = map[int32]string{ 0: "TASK_QUEUE_TYPE_UNSPECIFIED", 1: "TASK_QUEUE_TYPE_WORKFLOW", 2: "TASK_QUEUE_TYPE_ACTIVITY", 3: "TASK_QUEUE_TYPE_NEXUS", } TaskQueueType_value = map[string]int32{ "TASK_QUEUE_TYPE_UNSPECIFIED": 0, "TASK_QUEUE_TYPE_WORKFLOW": 1, "TASK_QUEUE_TYPE_ACTIVITY": 2, "TASK_QUEUE_TYPE_NEXUS": 3, } )
Enum value maps for TaskQueueType.
var ( TaskReachability_name = map[int32]string{ 0: "TASK_REACHABILITY_UNSPECIFIED", 1: "TASK_REACHABILITY_NEW_WORKFLOWS", 2: "TASK_REACHABILITY_EXISTING_WORKFLOWS", 3: "TASK_REACHABILITY_OPEN_WORKFLOWS", 4: "TASK_REACHABILITY_CLOSED_WORKFLOWS", } TaskReachability_value = map[string]int32{ "TASK_REACHABILITY_UNSPECIFIED": 0, "TASK_REACHABILITY_NEW_WORKFLOWS": 1, "TASK_REACHABILITY_EXISTING_WORKFLOWS": 2, "TASK_REACHABILITY_OPEN_WORKFLOWS": 3, "TASK_REACHABILITY_CLOSED_WORKFLOWS": 4, } )
Enum value maps for TaskReachability.
var ( BuildIdTaskReachability_name = map[int32]string{ 0: "BUILD_ID_TASK_REACHABILITY_UNSPECIFIED", 1: "BUILD_ID_TASK_REACHABILITY_REACHABLE", 2: "BUILD_ID_TASK_REACHABILITY_CLOSED_WORKFLOWS_ONLY", 3: "BUILD_ID_TASK_REACHABILITY_UNREACHABLE", } BuildIdTaskReachability_value = map[string]int32{ "BUILD_ID_TASK_REACHABILITY_UNSPECIFIED": 0, "BUILD_ID_TASK_REACHABILITY_REACHABLE": 1, "BUILD_ID_TASK_REACHABILITY_CLOSED_WORKFLOWS_ONLY": 2, "BUILD_ID_TASK_REACHABILITY_UNREACHABLE": 3, } )
Enum value maps for BuildIdTaskReachability.
var ( DescribeTaskQueueMode_name = map[int32]string{ 0: "DESCRIBE_TASK_QUEUE_MODE_UNSPECIFIED", 1: "DESCRIBE_TASK_QUEUE_MODE_ENHANCED", } DescribeTaskQueueMode_value = map[string]int32{ "DESCRIBE_TASK_QUEUE_MODE_UNSPECIFIED": 0, "DESCRIBE_TASK_QUEUE_MODE_ENHANCED": 1, } )
Enum value maps for DescribeTaskQueueMode.
var ( UpdateWorkflowExecutionLifecycleStage_name = map[int32]string{ 0: "UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_UNSPECIFIED", 1: "UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_ADMITTED", 2: "UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_ACCEPTED", 3: "UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_COMPLETED", } UpdateWorkflowExecutionLifecycleStage_value = map[string]int32{ "UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_UNSPECIFIED": 0, "UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_ADMITTED": 1, "UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_ACCEPTED": 2, "UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_COMPLETED": 3, } )
Enum value maps for UpdateWorkflowExecutionLifecycleStage.
var ( UpdateAdmittedEventOrigin_name = map[int32]string{ 0: "UPDATE_ADMITTED_EVENT_ORIGIN_UNSPECIFIED", 1: "UPDATE_ADMITTED_EVENT_ORIGIN_REAPPLY", } UpdateAdmittedEventOrigin_value = map[string]int32{ "UPDATE_ADMITTED_EVENT_ORIGIN_UNSPECIFIED": 0, "UPDATE_ADMITTED_EVENT_ORIGIN_REAPPLY": 1, } )
Enum value maps for UpdateAdmittedEventOrigin.
var ( WorkflowIdReusePolicy_name = map[int32]string{ 0: "WORKFLOW_ID_REUSE_POLICY_UNSPECIFIED", 1: "WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE", 2: "WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE_FAILED_ONLY", 3: "WORKFLOW_ID_REUSE_POLICY_REJECT_DUPLICATE", 4: "WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING", } WorkflowIdReusePolicy_value = map[string]int32{ "WORKFLOW_ID_REUSE_POLICY_UNSPECIFIED": 0, "WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE": 1, "WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE_FAILED_ONLY": 2, "WORKFLOW_ID_REUSE_POLICY_REJECT_DUPLICATE": 3, "WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING": 4, } )
Enum value maps for WorkflowIdReusePolicy.
var ( WorkflowIdConflictPolicy_name = map[int32]string{ 0: "WORKFLOW_ID_CONFLICT_POLICY_UNSPECIFIED", 1: "WORKFLOW_ID_CONFLICT_POLICY_FAIL", 2: "WORKFLOW_ID_CONFLICT_POLICY_USE_EXISTING", 3: "WORKFLOW_ID_CONFLICT_POLICY_TERMINATE_EXISTING", } WorkflowIdConflictPolicy_value = map[string]int32{ "WORKFLOW_ID_CONFLICT_POLICY_UNSPECIFIED": 0, "WORKFLOW_ID_CONFLICT_POLICY_FAIL": 1, "WORKFLOW_ID_CONFLICT_POLICY_USE_EXISTING": 2, "WORKFLOW_ID_CONFLICT_POLICY_TERMINATE_EXISTING": 3, } )
Enum value maps for WorkflowIdConflictPolicy.
var ( ParentClosePolicy_name = map[int32]string{ 0: "PARENT_CLOSE_POLICY_UNSPECIFIED", 1: "PARENT_CLOSE_POLICY_TERMINATE", 2: "PARENT_CLOSE_POLICY_ABANDON", 3: "PARENT_CLOSE_POLICY_REQUEST_CANCEL", } ParentClosePolicy_value = map[string]int32{ "PARENT_CLOSE_POLICY_UNSPECIFIED": 0, "PARENT_CLOSE_POLICY_TERMINATE": 1, "PARENT_CLOSE_POLICY_ABANDON": 2, "PARENT_CLOSE_POLICY_REQUEST_CANCEL": 3, } )
Enum value maps for ParentClosePolicy.
var ( ContinueAsNewInitiator_name = map[int32]string{ 0: "CONTINUE_AS_NEW_INITIATOR_UNSPECIFIED", 1: "CONTINUE_AS_NEW_INITIATOR_WORKFLOW", 2: "CONTINUE_AS_NEW_INITIATOR_RETRY", 3: "CONTINUE_AS_NEW_INITIATOR_CRON_SCHEDULE", } ContinueAsNewInitiator_value = map[string]int32{ "CONTINUE_AS_NEW_INITIATOR_UNSPECIFIED": 0, "CONTINUE_AS_NEW_INITIATOR_WORKFLOW": 1, "CONTINUE_AS_NEW_INITIATOR_RETRY": 2, "CONTINUE_AS_NEW_INITIATOR_CRON_SCHEDULE": 3, } )
Enum value maps for ContinueAsNewInitiator.
var ( WorkflowExecutionStatus_name = map[int32]string{ 0: "WORKFLOW_EXECUTION_STATUS_UNSPECIFIED", 1: "WORKFLOW_EXECUTION_STATUS_RUNNING", 2: "WORKFLOW_EXECUTION_STATUS_COMPLETED", 3: "WORKFLOW_EXECUTION_STATUS_FAILED", 4: "WORKFLOW_EXECUTION_STATUS_CANCELED", 5: "WORKFLOW_EXECUTION_STATUS_TERMINATED", 6: "WORKFLOW_EXECUTION_STATUS_CONTINUED_AS_NEW", 7: "WORKFLOW_EXECUTION_STATUS_TIMED_OUT", } WorkflowExecutionStatus_value = map[string]int32{ "WORKFLOW_EXECUTION_STATUS_UNSPECIFIED": 0, "WORKFLOW_EXECUTION_STATUS_RUNNING": 1, "WORKFLOW_EXECUTION_STATUS_COMPLETED": 2, "WORKFLOW_EXECUTION_STATUS_FAILED": 3, "WORKFLOW_EXECUTION_STATUS_CANCELED": 4, "WORKFLOW_EXECUTION_STATUS_TERMINATED": 5, "WORKFLOW_EXECUTION_STATUS_CONTINUED_AS_NEW": 6, "WORKFLOW_EXECUTION_STATUS_TIMED_OUT": 7, } )
Enum value maps for WorkflowExecutionStatus.
var ( PendingActivityState_name = map[int32]string{ 0: "PENDING_ACTIVITY_STATE_UNSPECIFIED", 1: "PENDING_ACTIVITY_STATE_SCHEDULED", 2: "PENDING_ACTIVITY_STATE_STARTED", 3: "PENDING_ACTIVITY_STATE_CANCEL_REQUESTED", } PendingActivityState_value = map[string]int32{ "PENDING_ACTIVITY_STATE_UNSPECIFIED": 0, "PENDING_ACTIVITY_STATE_SCHEDULED": 1, "PENDING_ACTIVITY_STATE_STARTED": 2, "PENDING_ACTIVITY_STATE_CANCEL_REQUESTED": 3, } )
Enum value maps for PendingActivityState.
var ( PendingWorkflowTaskState_name = map[int32]string{ 0: "PENDING_WORKFLOW_TASK_STATE_UNSPECIFIED", 1: "PENDING_WORKFLOW_TASK_STATE_SCHEDULED", 2: "PENDING_WORKFLOW_TASK_STATE_STARTED", } PendingWorkflowTaskState_value = map[string]int32{ "PENDING_WORKFLOW_TASK_STATE_UNSPECIFIED": 0, "PENDING_WORKFLOW_TASK_STATE_SCHEDULED": 1, "PENDING_WORKFLOW_TASK_STATE_STARTED": 2, } )
Enum value maps for PendingWorkflowTaskState.
var ( HistoryEventFilterType_name = map[int32]string{ 0: "HISTORY_EVENT_FILTER_TYPE_UNSPECIFIED", 1: "HISTORY_EVENT_FILTER_TYPE_ALL_EVENT", 2: "HISTORY_EVENT_FILTER_TYPE_CLOSE_EVENT", } HistoryEventFilterType_value = map[string]int32{ "HISTORY_EVENT_FILTER_TYPE_UNSPECIFIED": 0, "HISTORY_EVENT_FILTER_TYPE_ALL_EVENT": 1, "HISTORY_EVENT_FILTER_TYPE_CLOSE_EVENT": 2, } )
Enum value maps for HistoryEventFilterType.
var ( RetryState_name = map[int32]string{ 0: "RETRY_STATE_UNSPECIFIED", 1: "RETRY_STATE_IN_PROGRESS", 2: "RETRY_STATE_NON_RETRYABLE_FAILURE", 3: "RETRY_STATE_TIMEOUT", 4: "RETRY_STATE_MAXIMUM_ATTEMPTS_REACHED", 5: "RETRY_STATE_RETRY_POLICY_NOT_SET", 6: "RETRY_STATE_INTERNAL_SERVER_ERROR", 7: "RETRY_STATE_CANCEL_REQUESTED", } RetryState_value = map[string]int32{ "RETRY_STATE_UNSPECIFIED": 0, "RETRY_STATE_IN_PROGRESS": 1, "RETRY_STATE_NON_RETRYABLE_FAILURE": 2, "RETRY_STATE_TIMEOUT": 3, "RETRY_STATE_MAXIMUM_ATTEMPTS_REACHED": 4, "RETRY_STATE_RETRY_POLICY_NOT_SET": 5, "RETRY_STATE_INTERNAL_SERVER_ERROR": 6, "RETRY_STATE_CANCEL_REQUESTED": 7, } )
Enum value maps for RetryState.
var ( TimeoutType_name = map[int32]string{ 0: "TIMEOUT_TYPE_UNSPECIFIED", 1: "TIMEOUT_TYPE_START_TO_CLOSE", 2: "TIMEOUT_TYPE_SCHEDULE_TO_START", 3: "TIMEOUT_TYPE_SCHEDULE_TO_CLOSE", 4: "TIMEOUT_TYPE_HEARTBEAT", } TimeoutType_value = map[string]int32{ "TIMEOUT_TYPE_UNSPECIFIED": 0, "TIMEOUT_TYPE_START_TO_CLOSE": 1, "TIMEOUT_TYPE_SCHEDULE_TO_START": 2, "TIMEOUT_TYPE_SCHEDULE_TO_CLOSE": 3, "TIMEOUT_TYPE_HEARTBEAT": 4, } )
Enum value maps for TimeoutType.
var (
ArchivalState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Disabled": 1,
"Enabled": 2,
}
)
var (
BatchOperationState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Running": 1,
"Completed": 2,
"Failed": 3,
}
)
var (
BatchOperationType_shorthandValue = map[string]int32{
"Unspecified": 0,
"Terminate": 1,
"Cancel": 2,
"Signal": 3,
"Delete": 4,
"Reset": 5,
}
)
var (
BuildIdTaskReachability_shorthandValue = map[string]int32{
"Unspecified": 0,
"Reachable": 1,
"ClosedWorkflowsOnly": 2,
"Unreachable": 3,
}
)
var (
CallbackState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Standby": 1,
"Scheduled": 2,
"BackingOff": 3,
"Failed": 4,
"Succeeded": 5,
"Blocked": 6,
}
)
var (
CancelExternalWorkflowExecutionFailedCause_shorthandValue = map[string]int32{
"Unspecified": 0,
"ExternalWorkflowExecutionNotFound": 1,
"NamespaceNotFound": 2,
}
)
var (
CommandType_shorthandValue = map[string]int32{
"Unspecified": 0,
"ScheduleActivityTask": 1,
"RequestCancelActivityTask": 2,
"StartTimer": 3,
"CompleteWorkflowExecution": 4,
"FailWorkflowExecution": 5,
"CancelTimer": 6,
"CancelWorkflowExecution": 7,
"RequestCancelExternalWorkflowExecution": 8,
"RecordMarker": 9,
"ContinueAsNewWorkflowExecution": 10,
"StartChildWorkflowExecution": 11,
"SignalExternalWorkflowExecution": 12,
"UpsertWorkflowSearchAttributes": 13,
"ProtocolMessage": 14,
"ModifyWorkflowProperties": 16,
"ScheduleNexusOperation": 17,
"RequestCancelNexusOperation": 18,
}
)
var (
ContinueAsNewInitiator_shorthandValue = map[string]int32{
"Unspecified": 0,
"Workflow": 1,
"Retry": 2,
"CronSchedule": 3,
}
)
var (
DescribeTaskQueueMode_shorthandValue = map[string]int32{
"Unspecified": 0,
"Enhanced": 1,
}
)
var (
EncodingType_shorthandValue = map[string]int32{
"Unspecified": 0,
"Proto3": 1,
"Json": 2,
}
)
var (
EventType_shorthandValue = map[string]int32{
"Unspecified": 0,
"WorkflowExecutionStarted": 1,
"WorkflowExecutionCompleted": 2,
"WorkflowExecutionFailed": 3,
"WorkflowExecutionTimedOut": 4,
"WorkflowTaskScheduled": 5,
"WorkflowTaskStarted": 6,
"WorkflowTaskCompleted": 7,
"WorkflowTaskTimedOut": 8,
"WorkflowTaskFailed": 9,
"ActivityTaskScheduled": 10,
"ActivityTaskStarted": 11,
"ActivityTaskCompleted": 12,
"ActivityTaskFailed": 13,
"ActivityTaskTimedOut": 14,
"ActivityTaskCancelRequested": 15,
"ActivityTaskCanceled": 16,
"TimerStarted": 17,
"TimerFired": 18,
"TimerCanceled": 19,
"WorkflowExecutionCancelRequested": 20,
"WorkflowExecutionCanceled": 21,
"RequestCancelExternalWorkflowExecutionInitiated": 22,
"RequestCancelExternalWorkflowExecutionFailed": 23,
"ExternalWorkflowExecutionCancelRequested": 24,
"MarkerRecorded": 25,
"WorkflowExecutionSignaled": 26,
"WorkflowExecutionTerminated": 27,
"WorkflowExecutionContinuedAsNew": 28,
"StartChildWorkflowExecutionInitiated": 29,
"StartChildWorkflowExecutionFailed": 30,
"ChildWorkflowExecutionStarted": 31,
"ChildWorkflowExecutionCompleted": 32,
"ChildWorkflowExecutionFailed": 33,
"ChildWorkflowExecutionCanceled": 34,
"ChildWorkflowExecutionTimedOut": 35,
"ChildWorkflowExecutionTerminated": 36,
"SignalExternalWorkflowExecutionInitiated": 37,
"SignalExternalWorkflowExecutionFailed": 38,
"ExternalWorkflowExecutionSignaled": 39,
"UpsertWorkflowSearchAttributes": 40,
"WorkflowExecutionUpdateAdmitted": 47,
"WorkflowExecutionUpdateAccepted": 41,
"WorkflowExecutionUpdateRejected": 42,
"WorkflowExecutionUpdateCompleted": 43,
"WorkflowPropertiesModifiedExternally": 44,
"ActivityPropertiesModifiedExternally": 45,
"WorkflowPropertiesModified": 46,
"NexusOperationScheduled": 48,
"NexusOperationStarted": 49,
"NexusOperationCompleted": 50,
"NexusOperationFailed": 51,
"NexusOperationCanceled": 52,
"NexusOperationTimedOut": 53,
"NexusOperationCancelRequested": 54,
}
)
var File_temporal_api_enums_v1_batch_operation_proto protoreflect.FileDescriptor
var File_temporal_api_enums_v1_command_type_proto protoreflect.FileDescriptor
var File_temporal_api_enums_v1_common_proto protoreflect.FileDescriptor
var File_temporal_api_enums_v1_event_type_proto protoreflect.FileDescriptor
var File_temporal_api_enums_v1_failed_cause_proto protoreflect.FileDescriptor
var File_temporal_api_enums_v1_namespace_proto protoreflect.FileDescriptor
var File_temporal_api_enums_v1_query_proto protoreflect.FileDescriptor
var File_temporal_api_enums_v1_reset_proto protoreflect.FileDescriptor
var File_temporal_api_enums_v1_schedule_proto protoreflect.FileDescriptor
var File_temporal_api_enums_v1_task_queue_proto protoreflect.FileDescriptor
var File_temporal_api_enums_v1_update_proto protoreflect.FileDescriptor
var File_temporal_api_enums_v1_workflow_proto protoreflect.FileDescriptor
var (
HistoryEventFilterType_shorthandValue = map[string]int32{
"Unspecified": 0,
"AllEvent": 1,
"CloseEvent": 2,
}
)
var (
IndexedValueType_shorthandValue = map[string]int32{
"Unspecified": 0,
"Text": 1,
"Keyword": 2,
"Int": 3,
"Double": 4,
"Bool": 5,
"Datetime": 6,
"KeywordList": 7,
}
)
var (
NamespaceState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Registered": 1,
"Deprecated": 2,
"Deleted": 3,
}
)
var (
NexusOperationCancellationState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Scheduled": 1,
"BackingOff": 2,
"Succeeded": 3,
"Failed": 4,
"TimedOut": 5,
"Blocked": 6,
}
)
var (
ParentClosePolicy_shorthandValue = map[string]int32{
"Unspecified": 0,
"Terminate": 1,
"Abandon": 2,
"RequestCancel": 3,
}
)
var (
PendingActivityState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Scheduled": 1,
"Started": 2,
"CancelRequested": 3,
}
)
var (
PendingNexusOperationState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Scheduled": 1,
"BackingOff": 2,
"Started": 3,
"Blocked": 4,
}
)
var (
PendingWorkflowTaskState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Scheduled": 1,
"Started": 2,
}
)
var (
QueryRejectCondition_shorthandValue = map[string]int32{
"Unspecified": 0,
"None": 1,
"NotOpen": 2,
"NotCompletedCleanly": 3,
}
)
var (
QueryResultType_shorthandValue = map[string]int32{
"Unspecified": 0,
"Answered": 1,
"Failed": 2,
}
)
var (
ReplicationState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Normal": 1,
"Handover": 2,
}
)
var (
ResetReapplyExcludeType_shorthandValue = map[string]int32{
"Unspecified": 0,
"Signal": 1,
"Update": 2,
"Nexus": 3,
}
)
var (
ResetReapplyType_shorthandValue = map[string]int32{
"Unspecified": 0,
"Signal": 1,
"None": 2,
"AllEligible": 3,
}
)
var (
ResetType_shorthandValue = map[string]int32{
"Unspecified": 0,
"FirstWorkflowTask": 1,
"LastWorkflowTask": 2,
}
)
var (
ResourceExhaustedCause_shorthandValue = map[string]int32{
"Unspecified": 0,
"RpsLimit": 1,
"ConcurrentLimit": 2,
"SystemOverloaded": 3,
"PersistenceLimit": 4,
"BusyWorkflow": 5,
"ApsLimit": 6,
"PersistenceStorageLimit": 7,
"CircuitBreakerOpen": 8,
}
)
var (
ResourceExhaustedScope_shorthandValue = map[string]int32{
"Unspecified": 0,
"Namespace": 1,
"System": 2,
}
)
var (
RetryState_shorthandValue = map[string]int32{
"Unspecified": 0,
"InProgress": 1,
"NonRetryableFailure": 2,
"Timeout": 3,
"MaximumAttemptsReached": 4,
"RetryPolicyNotSet": 5,
"InternalServerError": 6,
"CancelRequested": 7,
}
)
var (
ScheduleOverlapPolicy_shorthandValue = map[string]int32{
"Unspecified": 0,
"Skip": 1,
"BufferOne": 2,
"BufferAll": 3,
"CancelOther": 4,
"TerminateOther": 5,
"AllowAll": 6,
}
)
var (
Severity_shorthandValue = map[string]int32{
"Unspecified": 0,
"High": 1,
"Medium": 2,
"Low": 3,
}
)
var (
SignalExternalWorkflowExecutionFailedCause_shorthandValue = map[string]int32{
"Unspecified": 0,
"ExternalWorkflowExecutionNotFound": 1,
"NamespaceNotFound": 2,
"SignalCountLimitExceeded": 3,
}
)
var (
StartChildWorkflowExecutionFailedCause_shorthandValue = map[string]int32{
"Unspecified": 0,
"WorkflowAlreadyExists": 1,
"NamespaceNotFound": 2,
}
)
var (
TaskQueueKind_shorthandValue = map[string]int32{
"Unspecified": 0,
"Normal": 1,
"Sticky": 2,
}
)
var (
TaskQueueType_shorthandValue = map[string]int32{
"Unspecified": 0,
"Workflow": 1,
"Activity": 2,
"Nexus": 3,
}
)
var (
TaskReachability_shorthandValue = map[string]int32{
"Unspecified": 0,
"NewWorkflows": 1,
"ExistingWorkflows": 2,
"OpenWorkflows": 3,
"ClosedWorkflows": 4,
}
)
var (
TimeoutType_shorthandValue = map[string]int32{
"Unspecified": 0,
"StartToClose": 1,
"ScheduleToStart": 2,
"ScheduleToClose": 3,
"Heartbeat": 4,
}
)
var (
UpdateAdmittedEventOrigin_shorthandValue = map[string]int32{
"Unspecified": 0,
"Reapply": 1,
}
)
var (
UpdateWorkflowExecutionLifecycleStage_shorthandValue = map[string]int32{
"Unspecified": 0,
"Admitted": 1,
"Accepted": 2,
"Completed": 3,
}
)
var (
WorkflowExecutionStatus_shorthandValue = map[string]int32{
"Unspecified": 0,
"Running": 1,
"Completed": 2,
"Failed": 3,
"Canceled": 4,
"Terminated": 5,
"ContinuedAsNew": 6,
"TimedOut": 7,
}
)
var (
WorkflowIdConflictPolicy_shorthandValue = map[string]int32{
"Unspecified": 0,
"Fail": 1,
"UseExisting": 2,
"TerminateExisting": 3,
}
)
var (
WorkflowIdReusePolicy_shorthandValue = map[string]int32{
"Unspecified": 0,
"AllowDuplicate": 1,
"AllowDuplicateFailedOnly": 2,
"RejectDuplicate": 3,
"TerminateIfRunning": 4,
}
)
var (
WorkflowTaskFailedCause_shorthandValue = map[string]int32{
"Unspecified": 0,
"UnhandledCommand": 1,
"BadScheduleActivityAttributes": 2,
"BadRequestCancelActivityAttributes": 3,
"BadStartTimerAttributes": 4,
"BadCancelTimerAttributes": 5,
"BadRecordMarkerAttributes": 6,
"BadCompleteWorkflowExecutionAttributes": 7,
"BadFailWorkflowExecutionAttributes": 8,
"BadCancelWorkflowExecutionAttributes": 9,
"BadRequestCancelExternalWorkflowExecutionAttributes": 10,
"BadContinueAsNewAttributes": 11,
"StartTimerDuplicateId": 12,
"ResetStickyTaskQueue": 13,
"WorkflowWorkerUnhandledFailure": 14,
"BadSignalWorkflowExecutionAttributes": 15,
"BadStartChildExecutionAttributes": 16,
"ForceCloseCommand": 17,
"FailoverCloseCommand": 18,
"BadSignalInputSize": 19,
"ResetWorkflow": 20,
"BadBinary": 21,
"ScheduleActivityDuplicateId": 22,
"BadSearchAttributes": 23,
"NonDeterministicError": 24,
"BadModifyWorkflowPropertiesAttributes": 25,
"PendingChildWorkflowsLimitExceeded": 26,
"PendingActivitiesLimitExceeded": 27,
"PendingSignalsLimitExceeded": 28,
"PendingRequestCancelLimitExceeded": 29,
"BadUpdateWorkflowExecutionMessage": 30,
"UnhandledUpdate": 31,
"BadScheduleNexusOperationAttributes": 32,
"PendingNexusOperationsLimitExceeded": 33,
"BadRequestCancelNexusOperationAttributes": 34,
"FeatureDisabled": 35,
}
)
Functions ¶
This section is empty.
Types ¶
type ArchivalState ¶
type ArchivalState int32
const ( ARCHIVAL_STATE_UNSPECIFIED ArchivalState = 0 ARCHIVAL_STATE_DISABLED ArchivalState = 1 ARCHIVAL_STATE_ENABLED ArchivalState = 2 )
func ArchivalStateFromString ¶ added in v1.26.1
func ArchivalStateFromString(s string) (ArchivalState, error)
ArchivalStateFromString parses a ArchivalState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to ArchivalState
func (ArchivalState) Descriptor ¶ added in v1.26.1
func (ArchivalState) Descriptor() protoreflect.EnumDescriptor
func (ArchivalState) Enum ¶ added in v1.26.1
func (x ArchivalState) Enum() *ArchivalState
func (ArchivalState) EnumDescriptor
deprecated
func (ArchivalState) EnumDescriptor() ([]byte, []int)
Deprecated: Use ArchivalState.Descriptor instead.
func (ArchivalState) Number ¶ added in v1.26.1
func (x ArchivalState) Number() protoreflect.EnumNumber
func (ArchivalState) String ¶
func (x ArchivalState) String() string
func (ArchivalState) Type ¶ added in v1.26.1
func (ArchivalState) Type() protoreflect.EnumType
type BatchOperationState ¶ added in v1.12.0
type BatchOperationState int32
const ( BATCH_OPERATION_STATE_UNSPECIFIED BatchOperationState = 0 BATCH_OPERATION_STATE_RUNNING BatchOperationState = 1 BATCH_OPERATION_STATE_COMPLETED BatchOperationState = 2 BATCH_OPERATION_STATE_FAILED BatchOperationState = 3 )
func BatchOperationStateFromString ¶ added in v1.26.1
func BatchOperationStateFromString(s string) (BatchOperationState, error)
BatchOperationStateFromString parses a BatchOperationState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to BatchOperationState
func (BatchOperationState) Descriptor ¶ added in v1.26.1
func (BatchOperationState) Descriptor() protoreflect.EnumDescriptor
func (BatchOperationState) Enum ¶ added in v1.26.1
func (x BatchOperationState) Enum() *BatchOperationState
func (BatchOperationState) EnumDescriptor
deprecated
added in
v1.12.0
func (BatchOperationState) EnumDescriptor() ([]byte, []int)
Deprecated: Use BatchOperationState.Descriptor instead.
func (BatchOperationState) Number ¶ added in v1.26.1
func (x BatchOperationState) Number() protoreflect.EnumNumber
func (BatchOperationState) String ¶ added in v1.12.0
func (x BatchOperationState) String() string
func (BatchOperationState) Type ¶ added in v1.26.1
func (BatchOperationState) Type() protoreflect.EnumType
type BatchOperationType ¶ added in v1.12.0
type BatchOperationType int32
const ( BATCH_OPERATION_TYPE_UNSPECIFIED BatchOperationType = 0 BATCH_OPERATION_TYPE_TERMINATE BatchOperationType = 1 BATCH_OPERATION_TYPE_CANCEL BatchOperationType = 2 BATCH_OPERATION_TYPE_SIGNAL BatchOperationType = 3 BATCH_OPERATION_TYPE_DELETE BatchOperationType = 4 BATCH_OPERATION_TYPE_RESET BatchOperationType = 5 )
func BatchOperationTypeFromString ¶ added in v1.26.1
func BatchOperationTypeFromString(s string) (BatchOperationType, error)
BatchOperationTypeFromString parses a BatchOperationType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to BatchOperationType
func (BatchOperationType) Descriptor ¶ added in v1.26.1
func (BatchOperationType) Descriptor() protoreflect.EnumDescriptor
func (BatchOperationType) Enum ¶ added in v1.26.1
func (x BatchOperationType) Enum() *BatchOperationType
func (BatchOperationType) EnumDescriptor
deprecated
added in
v1.12.0
func (BatchOperationType) EnumDescriptor() ([]byte, []int)
Deprecated: Use BatchOperationType.Descriptor instead.
func (BatchOperationType) Number ¶ added in v1.26.1
func (x BatchOperationType) Number() protoreflect.EnumNumber
func (BatchOperationType) String ¶ added in v1.12.0
func (x BatchOperationType) String() string
func (BatchOperationType) Type ¶ added in v1.26.1
func (BatchOperationType) Type() protoreflect.EnumType
type BuildIdTaskReachability ¶ added in v1.32.0
type BuildIdTaskReachability int32
Specifies which category of tasks may reach a versioned worker of a certain Build ID.
Task Reachability is eventually consistent; there may be a delay (up to few minutes) until it converges to the most accurate value but it is designed in a way to take the more conservative side until it converges. For example REACHABLE is more conservative than CLOSED_WORKFLOWS_ONLY.
Note: future activities who inherit their workflow's Build ID but not its Task Queue will not be accounted for reachability as server cannot know if they'll happen as they do not use assignment rules of their Task Queue. Same goes for Child Workflows or Continue-As-New Workflows who inherit the parent/previous workflow's Build ID but not its Task Queue. In those cases, make sure to query reachability for the parent/previous workflow's Task Queue as well.
const ( // Task reachability is not reported BUILD_ID_TASK_REACHABILITY_UNSPECIFIED BuildIdTaskReachability = 0 // Build ID may be used by new workflows or activities (base on versioning rules), or there MAY // be open workflows or backlogged activities assigned to it. BUILD_ID_TASK_REACHABILITY_REACHABLE BuildIdTaskReachability = 1 // Build ID does not have open workflows and is not reachable by new workflows, // but MAY have closed workflows within the namespace retention period. // Not applicable to activity-only task queues. BUILD_ID_TASK_REACHABILITY_CLOSED_WORKFLOWS_ONLY BuildIdTaskReachability = 2 // Build ID is not used for new executions, nor it has been used by any existing execution // within the retention period. BUILD_ID_TASK_REACHABILITY_UNREACHABLE BuildIdTaskReachability = 3 )
func BuildIdTaskReachabilityFromString ¶ added in v1.32.0
func BuildIdTaskReachabilityFromString(s string) (BuildIdTaskReachability, error)
BuildIdTaskReachabilityFromString parses a BuildIdTaskReachability value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to BuildIdTaskReachability
func (BuildIdTaskReachability) Descriptor ¶ added in v1.32.0
func (BuildIdTaskReachability) Descriptor() protoreflect.EnumDescriptor
func (BuildIdTaskReachability) Enum ¶ added in v1.32.0
func (x BuildIdTaskReachability) Enum() *BuildIdTaskReachability
func (BuildIdTaskReachability) EnumDescriptor
deprecated
added in
v1.32.0
func (BuildIdTaskReachability) EnumDescriptor() ([]byte, []int)
Deprecated: Use BuildIdTaskReachability.Descriptor instead.
func (BuildIdTaskReachability) Number ¶ added in v1.32.0
func (x BuildIdTaskReachability) Number() protoreflect.EnumNumber
func (BuildIdTaskReachability) String ¶ added in v1.32.0
func (x BuildIdTaskReachability) String() string
func (BuildIdTaskReachability) Type ¶ added in v1.32.0
func (BuildIdTaskReachability) Type() protoreflect.EnumType
type CallbackState ¶ added in v1.27.0
type CallbackState int32
State of a callback.
const ( // Default value, unspecified state. CALLBACK_STATE_UNSPECIFIED CallbackState = 0 // Callback is standing by, waiting to be triggered. CALLBACK_STATE_STANDBY CallbackState = 1 // Callback is in the queue waiting to be executed or is currently executing. CALLBACK_STATE_SCHEDULED CallbackState = 2 // Callback has failed with a retryable error and is backing off before the next attempt. CALLBACK_STATE_BACKING_OFF CallbackState = 3 // Callback has failed. CALLBACK_STATE_FAILED CallbackState = 4 // Callback has succeeded. CALLBACK_STATE_SUCCEEDED CallbackState = 5 // Callback is blocked (eg: by circuit breaker). CALLBACK_STATE_BLOCKED CallbackState = 6 )
func CallbackStateFromString ¶ added in v1.27.0
func CallbackStateFromString(s string) (CallbackState, error)
CallbackStateFromString parses a CallbackState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to CallbackState
func (CallbackState) Descriptor ¶ added in v1.27.0
func (CallbackState) Descriptor() protoreflect.EnumDescriptor
func (CallbackState) Enum ¶ added in v1.27.0
func (x CallbackState) Enum() *CallbackState
func (CallbackState) EnumDescriptor
deprecated
added in
v1.27.0
func (CallbackState) EnumDescriptor() ([]byte, []int)
Deprecated: Use CallbackState.Descriptor instead.
func (CallbackState) Number ¶ added in v1.27.0
func (x CallbackState) Number() protoreflect.EnumNumber
func (CallbackState) String ¶ added in v1.27.0
func (x CallbackState) String() string
func (CallbackState) Type ¶ added in v1.27.0
func (CallbackState) Type() protoreflect.EnumType
type CancelExternalWorkflowExecutionFailedCause ¶
type CancelExternalWorkflowExecutionFailedCause int32
const ( CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_UNSPECIFIED CancelExternalWorkflowExecutionFailedCause = 0 CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_EXTERNAL_WORKFLOW_EXECUTION_NOT_FOUND CancelExternalWorkflowExecutionFailedCause = 1 CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_NAMESPACE_NOT_FOUND CancelExternalWorkflowExecutionFailedCause = 2 )
func CancelExternalWorkflowExecutionFailedCauseFromString ¶ added in v1.26.1
func CancelExternalWorkflowExecutionFailedCauseFromString(s string) (CancelExternalWorkflowExecutionFailedCause, error)
CancelExternalWorkflowExecutionFailedCauseFromString parses a CancelExternalWorkflowExecutionFailedCause value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to CancelExternalWorkflowExecutionFailedCause
func (CancelExternalWorkflowExecutionFailedCause) Descriptor ¶ added in v1.26.1
func (CancelExternalWorkflowExecutionFailedCause) Descriptor() protoreflect.EnumDescriptor
func (CancelExternalWorkflowExecutionFailedCause) EnumDescriptor
deprecated
func (CancelExternalWorkflowExecutionFailedCause) EnumDescriptor() ([]byte, []int)
Deprecated: Use CancelExternalWorkflowExecutionFailedCause.Descriptor instead.
func (CancelExternalWorkflowExecutionFailedCause) Number ¶ added in v1.26.1
func (x CancelExternalWorkflowExecutionFailedCause) Number() protoreflect.EnumNumber
func (CancelExternalWorkflowExecutionFailedCause) String ¶
func (x CancelExternalWorkflowExecutionFailedCause) String() string
func (CancelExternalWorkflowExecutionFailedCause) Type ¶ added in v1.26.1
func (CancelExternalWorkflowExecutionFailedCause) Type() protoreflect.EnumType
type CommandType ¶
type CommandType int32
Whenever this list of command types is changed do change the function shouldBufferEvent in mutableStateBuilder.go to make sure to do the correct event ordering.
const ( COMMAND_TYPE_UNSPECIFIED CommandType = 0 COMMAND_TYPE_SCHEDULE_ACTIVITY_TASK CommandType = 1 COMMAND_TYPE_REQUEST_CANCEL_ACTIVITY_TASK CommandType = 2 COMMAND_TYPE_START_TIMER CommandType = 3 COMMAND_TYPE_COMPLETE_WORKFLOW_EXECUTION CommandType = 4 COMMAND_TYPE_FAIL_WORKFLOW_EXECUTION CommandType = 5 COMMAND_TYPE_CANCEL_TIMER CommandType = 6 COMMAND_TYPE_CANCEL_WORKFLOW_EXECUTION CommandType = 7 COMMAND_TYPE_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION CommandType = 8 COMMAND_TYPE_RECORD_MARKER CommandType = 9 COMMAND_TYPE_CONTINUE_AS_NEW_WORKFLOW_EXECUTION CommandType = 10 COMMAND_TYPE_START_CHILD_WORKFLOW_EXECUTION CommandType = 11 COMMAND_TYPE_SIGNAL_EXTERNAL_WORKFLOW_EXECUTION CommandType = 12 COMMAND_TYPE_UPSERT_WORKFLOW_SEARCH_ATTRIBUTES CommandType = 13 COMMAND_TYPE_PROTOCOL_MESSAGE CommandType = 14 COMMAND_TYPE_MODIFY_WORKFLOW_PROPERTIES CommandType = 16 COMMAND_TYPE_SCHEDULE_NEXUS_OPERATION CommandType = 17 COMMAND_TYPE_REQUEST_CANCEL_NEXUS_OPERATION CommandType = 18 )
func CommandTypeFromString ¶ added in v1.26.1
func CommandTypeFromString(s string) (CommandType, error)
CommandTypeFromString parses a CommandType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to CommandType
func (CommandType) Descriptor ¶ added in v1.26.1
func (CommandType) Descriptor() protoreflect.EnumDescriptor
func (CommandType) Enum ¶ added in v1.26.1
func (x CommandType) Enum() *CommandType
func (CommandType) EnumDescriptor ¶
func (CommandType) EnumDescriptor() ([]byte, []int)
func (CommandType) Number ¶ added in v1.26.1
func (x CommandType) Number() protoreflect.EnumNumber
func (CommandType) String ¶
func (x CommandType) String() string
func (CommandType) Type ¶ added in v1.26.1
func (CommandType) Type() protoreflect.EnumType
type ContinueAsNewInitiator ¶
type ContinueAsNewInitiator int32
const ( CONTINUE_AS_NEW_INITIATOR_UNSPECIFIED ContinueAsNewInitiator = 0 // The workflow itself requested to continue as new CONTINUE_AS_NEW_INITIATOR_WORKFLOW ContinueAsNewInitiator = 1 // The workflow continued as new because it is retrying CONTINUE_AS_NEW_INITIATOR_RETRY ContinueAsNewInitiator = 2 // The workflow continued as new because cron has triggered a new execution CONTINUE_AS_NEW_INITIATOR_CRON_SCHEDULE ContinueAsNewInitiator = 3 )
func ContinueAsNewInitiatorFromString ¶ added in v1.26.1
func ContinueAsNewInitiatorFromString(s string) (ContinueAsNewInitiator, error)
ContinueAsNewInitiatorFromString parses a ContinueAsNewInitiator value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to ContinueAsNewInitiator
func (ContinueAsNewInitiator) Descriptor ¶ added in v1.26.1
func (ContinueAsNewInitiator) Descriptor() protoreflect.EnumDescriptor
func (ContinueAsNewInitiator) Enum ¶ added in v1.26.1
func (x ContinueAsNewInitiator) Enum() *ContinueAsNewInitiator
func (ContinueAsNewInitiator) EnumDescriptor
deprecated
func (ContinueAsNewInitiator) EnumDescriptor() ([]byte, []int)
Deprecated: Use ContinueAsNewInitiator.Descriptor instead.
func (ContinueAsNewInitiator) Number ¶ added in v1.26.1
func (x ContinueAsNewInitiator) Number() protoreflect.EnumNumber
func (ContinueAsNewInitiator) String ¶
func (x ContinueAsNewInitiator) String() string
func (ContinueAsNewInitiator) Type ¶ added in v1.26.1
func (ContinueAsNewInitiator) Type() protoreflect.EnumType
type DescribeTaskQueueMode ¶ added in v1.32.0
type DescribeTaskQueueMode int32
const ( // Unspecified means legacy behavior. DESCRIBE_TASK_QUEUE_MODE_UNSPECIFIED DescribeTaskQueueMode = 0 // Enhanced mode reports aggregated results for all partitions, supports Build IDs, and reports richer info. DESCRIBE_TASK_QUEUE_MODE_ENHANCED DescribeTaskQueueMode = 1 )
func DescribeTaskQueueModeFromString ¶ added in v1.32.0
func DescribeTaskQueueModeFromString(s string) (DescribeTaskQueueMode, error)
DescribeTaskQueueModeFromString parses a DescribeTaskQueueMode value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to DescribeTaskQueueMode
func (DescribeTaskQueueMode) Descriptor ¶ added in v1.32.0
func (DescribeTaskQueueMode) Descriptor() protoreflect.EnumDescriptor
func (DescribeTaskQueueMode) Enum ¶ added in v1.32.0
func (x DescribeTaskQueueMode) Enum() *DescribeTaskQueueMode
func (DescribeTaskQueueMode) EnumDescriptor
deprecated
added in
v1.32.0
func (DescribeTaskQueueMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use DescribeTaskQueueMode.Descriptor instead.
func (DescribeTaskQueueMode) Number ¶ added in v1.32.0
func (x DescribeTaskQueueMode) Number() protoreflect.EnumNumber
func (DescribeTaskQueueMode) String ¶ added in v1.32.0
func (x DescribeTaskQueueMode) String() string
func (DescribeTaskQueueMode) Type ¶ added in v1.32.0
func (DescribeTaskQueueMode) Type() protoreflect.EnumType
type EncodingType ¶
type EncodingType int32
const ( ENCODING_TYPE_UNSPECIFIED EncodingType = 0 ENCODING_TYPE_PROTO3 EncodingType = 1 ENCODING_TYPE_JSON EncodingType = 2 )
func EncodingTypeFromString ¶ added in v1.26.1
func EncodingTypeFromString(s string) (EncodingType, error)
EncodingTypeFromString parses a EncodingType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to EncodingType
func (EncodingType) Descriptor ¶ added in v1.26.1
func (EncodingType) Descriptor() protoreflect.EnumDescriptor
func (EncodingType) Enum ¶ added in v1.26.1
func (x EncodingType) Enum() *EncodingType
func (EncodingType) EnumDescriptor
deprecated
func (EncodingType) EnumDescriptor() ([]byte, []int)
Deprecated: Use EncodingType.Descriptor instead.
func (EncodingType) Number ¶ added in v1.26.1
func (x EncodingType) Number() protoreflect.EnumNumber
func (EncodingType) String ¶
func (x EncodingType) String() string
func (EncodingType) Type ¶ added in v1.26.1
func (EncodingType) Type() protoreflect.EnumType
type EventType ¶
type EventType int32
Whenever this list of events is changed do change the function shouldBufferEvent in mutableStateBuilder.go to make sure to do the correct event ordering
const ( // Place holder and should never appear in a Workflow execution history EVENT_TYPE_UNSPECIFIED EventType = 0 // Workflow execution has been triggered/started // It contains Workflow execution inputs, as well as Workflow timeout configurations EVENT_TYPE_WORKFLOW_EXECUTION_STARTED EventType = 1 // Workflow execution has successfully completed and contains Workflow execution results EVENT_TYPE_WORKFLOW_EXECUTION_COMPLETED EventType = 2 // Workflow execution has unsuccessfully completed and contains the Workflow execution error EVENT_TYPE_WORKFLOW_EXECUTION_FAILED EventType = 3 // Workflow execution has timed out by the Temporal Server // Usually due to the Workflow having not been completed within timeout settings EVENT_TYPE_WORKFLOW_EXECUTION_TIMED_OUT EventType = 4 // Workflow Task has been scheduled and the SDK client should now be able to process any new history events EVENT_TYPE_WORKFLOW_TASK_SCHEDULED EventType = 5 // Workflow Task has started and the SDK client has picked up the Workflow Task and is processing new history events EVENT_TYPE_WORKFLOW_TASK_STARTED EventType = 6 // Workflow Task has completed // The SDK client picked up the Workflow Task and processed new history events // SDK client may or may not ask the Temporal Server to do additional work, such as: // EVENT_TYPE_ACTIVITY_TASK_SCHEDULED // EVENT_TYPE_TIMER_STARTED // EVENT_TYPE_UPSERT_WORKFLOW_SEARCH_ATTRIBUTES // EVENT_TYPE_MARKER_RECORDED // EVENT_TYPE_START_CHILD_WORKFLOW_EXECUTION_INITIATED // EVENT_TYPE_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED // EVENT_TYPE_SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED // EVENT_TYPE_WORKFLOW_EXECUTION_COMPLETED // EVENT_TYPE_WORKFLOW_EXECUTION_FAILED // EVENT_TYPE_WORKFLOW_EXECUTION_CANCELED // EVENT_TYPE_WORKFLOW_EXECUTION_CONTINUED_AS_NEW EVENT_TYPE_WORKFLOW_TASK_COMPLETED EventType = 7 // Workflow Task encountered a timeout // Either an SDK client with a local cache was not available at the time, or it took too long for the SDK client to process the task EVENT_TYPE_WORKFLOW_TASK_TIMED_OUT EventType = 8 // Workflow Task encountered a failure // Usually this means that the Workflow was non-deterministic // However, the Workflow reset functionality also uses this event EVENT_TYPE_WORKFLOW_TASK_FAILED EventType = 9 // Activity Task was scheduled // The SDK client should pick up this activity task and execute // This event type contains activity inputs, as well as activity timeout configurations EVENT_TYPE_ACTIVITY_TASK_SCHEDULED EventType = 10 // Activity Task has started executing // The SDK client has picked up the Activity Task and is processing the Activity invocation EVENT_TYPE_ACTIVITY_TASK_STARTED EventType = 11 // Activity Task has finished successfully // The SDK client has picked up and successfully completed the Activity Task // This event type contains Activity execution results EVENT_TYPE_ACTIVITY_TASK_COMPLETED EventType = 12 // Activity Task has finished unsuccessfully // The SDK picked up the Activity Task but unsuccessfully completed it // This event type contains Activity execution errors EVENT_TYPE_ACTIVITY_TASK_FAILED EventType = 13 // Activity has timed out according to the Temporal Server // Activity did not complete within the timeout settings EVENT_TYPE_ACTIVITY_TASK_TIMED_OUT EventType = 14 // A request to cancel the Activity has occurred // The SDK client will be able to confirm cancellation of an Activity during an Activity heartbeat EVENT_TYPE_ACTIVITY_TASK_CANCEL_REQUESTED EventType = 15 // Activity has been cancelled EVENT_TYPE_ACTIVITY_TASK_CANCELED EventType = 16 // A timer has started EVENT_TYPE_TIMER_STARTED EventType = 17 // A timer has fired EVENT_TYPE_TIMER_FIRED EventType = 18 // A time has been cancelled EVENT_TYPE_TIMER_CANCELED EventType = 19 // A request has been made to cancel the Workflow execution EVENT_TYPE_WORKFLOW_EXECUTION_CANCEL_REQUESTED EventType = 20 // SDK client has confirmed the cancellation request and the Workflow execution has been cancelled EVENT_TYPE_WORKFLOW_EXECUTION_CANCELED EventType = 21 // Workflow has requested that the Temporal Server try to cancel another Workflow EVENT_TYPE_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED EventType = 22 // Temporal Server could not cancel the targeted Workflow // This is usually because the target Workflow could not be found EVENT_TYPE_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED EventType = 23 // Temporal Server has successfully requested the cancellation of the target Workflow EVENT_TYPE_EXTERNAL_WORKFLOW_EXECUTION_CANCEL_REQUESTED EventType = 24 // A marker has been recorded. // This event type is transparent to the Temporal Server // The Server will only store it and will not try to understand it. EVENT_TYPE_MARKER_RECORDED EventType = 25 // Workflow has received a Signal event // The event type contains the Signal name, as well as a Signal payload EVENT_TYPE_WORKFLOW_EXECUTION_SIGNALED EventType = 26 // Workflow execution has been forcefully terminated // This is usually because the terminate Workflow API was called EVENT_TYPE_WORKFLOW_EXECUTION_TERMINATED EventType = 27 // Workflow has successfully completed and a new Workflow has been started within the same transaction // Contains last Workflow execution results as well as new Workflow execution inputs EVENT_TYPE_WORKFLOW_EXECUTION_CONTINUED_AS_NEW EventType = 28 // Temporal Server will try to start a child Workflow EVENT_TYPE_START_CHILD_WORKFLOW_EXECUTION_INITIATED EventType = 29 // Child Workflow execution cannot be started/triggered // Usually due to a child Workflow ID collision EVENT_TYPE_START_CHILD_WORKFLOW_EXECUTION_FAILED EventType = 30 // Child Workflow execution has successfully started/triggered EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_STARTED EventType = 31 // Child Workflow execution has successfully completed EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_COMPLETED EventType = 32 // Child Workflow execution has unsuccessfully completed EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_FAILED EventType = 33 // Child Workflow execution has been cancelled EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_CANCELED EventType = 34 // Child Workflow execution has timed out by the Temporal Server EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_TIMED_OUT EventType = 35 // Child Workflow execution has been terminated EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_TERMINATED EventType = 36 // Temporal Server will try to Signal the targeted Workflow // Contains the Signal name, as well as a Signal payload EVENT_TYPE_SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED EventType = 37 // Temporal Server cannot Signal the targeted Workflow // Usually because the Workflow could not be found EVENT_TYPE_SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED EventType = 38 // Temporal Server has successfully Signaled the targeted Workflow EVENT_TYPE_EXTERNAL_WORKFLOW_EXECUTION_SIGNALED EventType = 39 // Workflow search attributes should be updated and synchronized with the visibility store EVENT_TYPE_UPSERT_WORKFLOW_SEARCH_ATTRIBUTES EventType = 40 // An update was admitted. Note that not all admitted updates result in this // event. See UpdateAdmittedEventOrigin for situations in which this event // is created. EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_ADMITTED EventType = 47 // An update was accepted (i.e. passed validation, perhaps because no validator was defined) EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_ACCEPTED EventType = 41 // This event is never written to history. EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_REJECTED EventType = 42 // An update completed EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_COMPLETED EventType = 43 // Some property or properties of the workflow as a whole have changed by non-workflow code. // The distinction of external vs. command-based modification is important so the SDK can // maintain determinism when using the command-based approach. EVENT_TYPE_WORKFLOW_PROPERTIES_MODIFIED_EXTERNALLY EventType = 44 // Some property or properties of an already-scheduled activity have changed by non-workflow code. // The distinction of external vs. command-based modification is important so the SDK can // maintain determinism when using the command-based approach. EVENT_TYPE_ACTIVITY_PROPERTIES_MODIFIED_EXTERNALLY EventType = 45 // Workflow properties modified by user workflow code EVENT_TYPE_WORKFLOW_PROPERTIES_MODIFIED EventType = 46 // A Nexus operation was scheduled using a ScheduleNexusOperation command. EVENT_TYPE_NEXUS_OPERATION_SCHEDULED EventType = 48 // An asynchronous Nexus operation was started by a Nexus handler. EVENT_TYPE_NEXUS_OPERATION_STARTED EventType = 49 // A Nexus operation completed successfully. EVENT_TYPE_NEXUS_OPERATION_COMPLETED EventType = 50 // A Nexus operation failed. EVENT_TYPE_NEXUS_OPERATION_FAILED EventType = 51 // A Nexus operation completed as canceled. EVENT_TYPE_NEXUS_OPERATION_CANCELED EventType = 52 // A Nexus operation timed out. EVENT_TYPE_NEXUS_OPERATION_TIMED_OUT EventType = 53 // A Nexus operation was requested to be canceled using a RequestCancelNexusOperation command. EVENT_TYPE_NEXUS_OPERATION_CANCEL_REQUESTED EventType = 54 )
func EventTypeFromString ¶ added in v1.26.1
EventTypeFromString parses a EventType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to EventType
func (EventType) Descriptor ¶ added in v1.26.1
func (EventType) Descriptor() protoreflect.EnumDescriptor
func (EventType) EnumDescriptor ¶
func (EventType) Number ¶ added in v1.26.1
func (x EventType) Number() protoreflect.EnumNumber
func (EventType) Type ¶ added in v1.26.1
func (EventType) Type() protoreflect.EnumType
type HistoryEventFilterType ¶
type HistoryEventFilterType int32
const ( HISTORY_EVENT_FILTER_TYPE_UNSPECIFIED HistoryEventFilterType = 0 HISTORY_EVENT_FILTER_TYPE_ALL_EVENT HistoryEventFilterType = 1 HISTORY_EVENT_FILTER_TYPE_CLOSE_EVENT HistoryEventFilterType = 2 )
func HistoryEventFilterTypeFromString ¶ added in v1.26.1
func HistoryEventFilterTypeFromString(s string) (HistoryEventFilterType, error)
HistoryEventFilterTypeFromString parses a HistoryEventFilterType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to HistoryEventFilterType
func (HistoryEventFilterType) Descriptor ¶ added in v1.26.1
func (HistoryEventFilterType) Descriptor() protoreflect.EnumDescriptor
func (HistoryEventFilterType) Enum ¶ added in v1.26.1
func (x HistoryEventFilterType) Enum() *HistoryEventFilterType
func (HistoryEventFilterType) EnumDescriptor
deprecated
func (HistoryEventFilterType) EnumDescriptor() ([]byte, []int)
Deprecated: Use HistoryEventFilterType.Descriptor instead.
func (HistoryEventFilterType) Number ¶ added in v1.26.1
func (x HistoryEventFilterType) Number() protoreflect.EnumNumber
func (HistoryEventFilterType) String ¶
func (x HistoryEventFilterType) String() string
func (HistoryEventFilterType) Type ¶ added in v1.26.1
func (HistoryEventFilterType) Type() protoreflect.EnumType
type IndexedValueType ¶
type IndexedValueType int32
const ( INDEXED_VALUE_TYPE_UNSPECIFIED IndexedValueType = 0 INDEXED_VALUE_TYPE_TEXT IndexedValueType = 1 INDEXED_VALUE_TYPE_KEYWORD IndexedValueType = 2 INDEXED_VALUE_TYPE_INT IndexedValueType = 3 INDEXED_VALUE_TYPE_DOUBLE IndexedValueType = 4 INDEXED_VALUE_TYPE_BOOL IndexedValueType = 5 INDEXED_VALUE_TYPE_DATETIME IndexedValueType = 6 INDEXED_VALUE_TYPE_KEYWORD_LIST IndexedValueType = 7 )
func IndexedValueTypeFromString ¶ added in v1.26.1
func IndexedValueTypeFromString(s string) (IndexedValueType, error)
IndexedValueTypeFromString parses a IndexedValueType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to IndexedValueType
func (IndexedValueType) Descriptor ¶ added in v1.26.1
func (IndexedValueType) Descriptor() protoreflect.EnumDescriptor
func (IndexedValueType) Enum ¶ added in v1.26.1
func (x IndexedValueType) Enum() *IndexedValueType
func (IndexedValueType) EnumDescriptor
deprecated
func (IndexedValueType) EnumDescriptor() ([]byte, []int)
Deprecated: Use IndexedValueType.Descriptor instead.
func (IndexedValueType) Number ¶ added in v1.26.1
func (x IndexedValueType) Number() protoreflect.EnumNumber
func (IndexedValueType) String ¶
func (x IndexedValueType) String() string
func (IndexedValueType) Type ¶ added in v1.26.1
func (IndexedValueType) Type() protoreflect.EnumType
type NamespaceState ¶
type NamespaceState int32
const ( NAMESPACE_STATE_UNSPECIFIED NamespaceState = 0 NAMESPACE_STATE_REGISTERED NamespaceState = 1 NAMESPACE_STATE_DEPRECATED NamespaceState = 2 NAMESPACE_STATE_DELETED NamespaceState = 3 )
func NamespaceStateFromString ¶ added in v1.26.1
func NamespaceStateFromString(s string) (NamespaceState, error)
NamespaceStateFromString parses a NamespaceState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to NamespaceState
func (NamespaceState) Descriptor ¶ added in v1.26.1
func (NamespaceState) Descriptor() protoreflect.EnumDescriptor
func (NamespaceState) Enum ¶ added in v1.26.1
func (x NamespaceState) Enum() *NamespaceState
func (NamespaceState) EnumDescriptor
deprecated
func (NamespaceState) EnumDescriptor() ([]byte, []int)
Deprecated: Use NamespaceState.Descriptor instead.
func (NamespaceState) Number ¶ added in v1.26.1
func (x NamespaceState) Number() protoreflect.EnumNumber
func (NamespaceState) String ¶
func (x NamespaceState) String() string
func (NamespaceState) Type ¶ added in v1.26.1
func (NamespaceState) Type() protoreflect.EnumType
type NexusOperationCancellationState ¶ added in v1.32.1
type NexusOperationCancellationState int32
State of a Nexus operation cancellation.
const ( // Default value, unspecified state. NEXUS_OPERATION_CANCELLATION_STATE_UNSPECIFIED NexusOperationCancellationState = 0 // Cancellation request is in the queue waiting to be executed or is currently executing. NEXUS_OPERATION_CANCELLATION_STATE_SCHEDULED NexusOperationCancellationState = 1 // Cancellation request has failed with a retryable error and is backing off before the next attempt. NEXUS_OPERATION_CANCELLATION_STATE_BACKING_OFF NexusOperationCancellationState = 2 // Cancellation request succeeded. NEXUS_OPERATION_CANCELLATION_STATE_SUCCEEDED NexusOperationCancellationState = 3 // Cancellation request failed with a non-retryable error. NEXUS_OPERATION_CANCELLATION_STATE_FAILED NexusOperationCancellationState = 4 // The associated operation timed out - exceeded the user supplied schedule-to-close timeout. NEXUS_OPERATION_CANCELLATION_STATE_TIMED_OUT NexusOperationCancellationState = 5 // Cancellation request is blocked (eg: by circuit breaker). NEXUS_OPERATION_CANCELLATION_STATE_BLOCKED NexusOperationCancellationState = 6 )
func NexusOperationCancellationStateFromString ¶ added in v1.32.1
func NexusOperationCancellationStateFromString(s string) (NexusOperationCancellationState, error)
NexusOperationCancellationStateFromString parses a NexusOperationCancellationState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to NexusOperationCancellationState
func (NexusOperationCancellationState) Descriptor ¶ added in v1.32.1
func (NexusOperationCancellationState) Descriptor() protoreflect.EnumDescriptor
func (NexusOperationCancellationState) Enum ¶ added in v1.32.1
func (x NexusOperationCancellationState) Enum() *NexusOperationCancellationState
func (NexusOperationCancellationState) EnumDescriptor ¶ added in v1.32.1
func (NexusOperationCancellationState) EnumDescriptor() ([]byte, []int)
func (NexusOperationCancellationState) Number ¶ added in v1.32.1
func (x NexusOperationCancellationState) Number() protoreflect.EnumNumber
func (NexusOperationCancellationState) String ¶ added in v1.32.1
func (x NexusOperationCancellationState) String() string
func (NexusOperationCancellationState) Type ¶ added in v1.32.1
func (NexusOperationCancellationState) Type() protoreflect.EnumType
type ParentClosePolicy ¶
type ParentClosePolicy int32
Defines how child workflows will react to their parent completing
const ( PARENT_CLOSE_POLICY_UNSPECIFIED ParentClosePolicy = 0 // The child workflow will also terminate PARENT_CLOSE_POLICY_TERMINATE ParentClosePolicy = 1 // The child workflow will do nothing PARENT_CLOSE_POLICY_ABANDON ParentClosePolicy = 2 // Cancellation will be requested of the child workflow PARENT_CLOSE_POLICY_REQUEST_CANCEL ParentClosePolicy = 3 )
func ParentClosePolicyFromString ¶ added in v1.26.1
func ParentClosePolicyFromString(s string) (ParentClosePolicy, error)
ParentClosePolicyFromString parses a ParentClosePolicy value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to ParentClosePolicy
func (ParentClosePolicy) Descriptor ¶ added in v1.26.1
func (ParentClosePolicy) Descriptor() protoreflect.EnumDescriptor
func (ParentClosePolicy) Enum ¶ added in v1.26.1
func (x ParentClosePolicy) Enum() *ParentClosePolicy
func (ParentClosePolicy) EnumDescriptor
deprecated
func (ParentClosePolicy) EnumDescriptor() ([]byte, []int)
Deprecated: Use ParentClosePolicy.Descriptor instead.
func (ParentClosePolicy) Number ¶ added in v1.26.1
func (x ParentClosePolicy) Number() protoreflect.EnumNumber
func (ParentClosePolicy) String ¶
func (x ParentClosePolicy) String() string
func (ParentClosePolicy) Type ¶ added in v1.26.1
func (ParentClosePolicy) Type() protoreflect.EnumType
type PendingActivityState ¶
type PendingActivityState int32
const ( PENDING_ACTIVITY_STATE_UNSPECIFIED PendingActivityState = 0 PENDING_ACTIVITY_STATE_SCHEDULED PendingActivityState = 1 PENDING_ACTIVITY_STATE_STARTED PendingActivityState = 2 PENDING_ACTIVITY_STATE_CANCEL_REQUESTED PendingActivityState = 3 )
func PendingActivityStateFromString ¶ added in v1.26.1
func PendingActivityStateFromString(s string) (PendingActivityState, error)
PendingActivityStateFromString parses a PendingActivityState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to PendingActivityState
func (PendingActivityState) Descriptor ¶ added in v1.26.1
func (PendingActivityState) Descriptor() protoreflect.EnumDescriptor
func (PendingActivityState) Enum ¶ added in v1.26.1
func (x PendingActivityState) Enum() *PendingActivityState
func (PendingActivityState) EnumDescriptor
deprecated
func (PendingActivityState) EnumDescriptor() ([]byte, []int)
Deprecated: Use PendingActivityState.Descriptor instead.
func (PendingActivityState) Number ¶ added in v1.26.1
func (x PendingActivityState) Number() protoreflect.EnumNumber
func (PendingActivityState) String ¶
func (x PendingActivityState) String() string
func (PendingActivityState) Type ¶ added in v1.26.1
func (PendingActivityState) Type() protoreflect.EnumType
type PendingNexusOperationState ¶ added in v1.32.1
type PendingNexusOperationState int32
State of a pending Nexus operation.
const ( // Default value, unspecified state. PENDING_NEXUS_OPERATION_STATE_UNSPECIFIED PendingNexusOperationState = 0 // Operation is in the queue waiting to be executed or is currently executing. PENDING_NEXUS_OPERATION_STATE_SCHEDULED PendingNexusOperationState = 1 // Operation has failed with a retryable error and is backing off before the next attempt. PENDING_NEXUS_OPERATION_STATE_BACKING_OFF PendingNexusOperationState = 2 // Operation was started and will complete asynchronously. PENDING_NEXUS_OPERATION_STATE_STARTED PendingNexusOperationState = 3 // Operation is blocked (eg: by circuit breaker). PENDING_NEXUS_OPERATION_STATE_BLOCKED PendingNexusOperationState = 4 )
func PendingNexusOperationStateFromString ¶ added in v1.32.1
func PendingNexusOperationStateFromString(s string) (PendingNexusOperationState, error)
PendingNexusOperationStateFromString parses a PendingNexusOperationState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to PendingNexusOperationState
func (PendingNexusOperationState) Descriptor ¶ added in v1.32.1
func (PendingNexusOperationState) Descriptor() protoreflect.EnumDescriptor
func (PendingNexusOperationState) Enum ¶ added in v1.32.1
func (x PendingNexusOperationState) Enum() *PendingNexusOperationState
func (PendingNexusOperationState) EnumDescriptor
deprecated
added in
v1.32.1
func (PendingNexusOperationState) EnumDescriptor() ([]byte, []int)
Deprecated: Use PendingNexusOperationState.Descriptor instead.
func (PendingNexusOperationState) Number ¶ added in v1.32.1
func (x PendingNexusOperationState) Number() protoreflect.EnumNumber
func (PendingNexusOperationState) String ¶ added in v1.32.1
func (x PendingNexusOperationState) String() string
func (PendingNexusOperationState) Type ¶ added in v1.32.1
func (PendingNexusOperationState) Type() protoreflect.EnumType
type PendingWorkflowTaskState ¶ added in v1.8.0
type PendingWorkflowTaskState int32
const ( PENDING_WORKFLOW_TASK_STATE_UNSPECIFIED PendingWorkflowTaskState = 0 PENDING_WORKFLOW_TASK_STATE_SCHEDULED PendingWorkflowTaskState = 1 PENDING_WORKFLOW_TASK_STATE_STARTED PendingWorkflowTaskState = 2 )
func PendingWorkflowTaskStateFromString ¶ added in v1.26.1
func PendingWorkflowTaskStateFromString(s string) (PendingWorkflowTaskState, error)
PendingWorkflowTaskStateFromString parses a PendingWorkflowTaskState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to PendingWorkflowTaskState
func (PendingWorkflowTaskState) Descriptor ¶ added in v1.26.1
func (PendingWorkflowTaskState) Descriptor() protoreflect.EnumDescriptor
func (PendingWorkflowTaskState) Enum ¶ added in v1.26.1
func (x PendingWorkflowTaskState) Enum() *PendingWorkflowTaskState
func (PendingWorkflowTaskState) EnumDescriptor
deprecated
added in
v1.8.0
func (PendingWorkflowTaskState) EnumDescriptor() ([]byte, []int)
Deprecated: Use PendingWorkflowTaskState.Descriptor instead.
func (PendingWorkflowTaskState) Number ¶ added in v1.26.1
func (x PendingWorkflowTaskState) Number() protoreflect.EnumNumber
func (PendingWorkflowTaskState) String ¶ added in v1.8.0
func (x PendingWorkflowTaskState) String() string
func (PendingWorkflowTaskState) Type ¶ added in v1.26.1
func (PendingWorkflowTaskState) Type() protoreflect.EnumType
type QueryRejectCondition ¶
type QueryRejectCondition int32
const ( QUERY_REJECT_CONDITION_UNSPECIFIED QueryRejectCondition = 0 // None indicates that query should not be rejected. QUERY_REJECT_CONDITION_NONE QueryRejectCondition = 1 // NotOpen indicates that query should be rejected if workflow is not open. QUERY_REJECT_CONDITION_NOT_OPEN QueryRejectCondition = 2 // NotCompletedCleanly indicates that query should be rejected if workflow did not complete cleanly. QUERY_REJECT_CONDITION_NOT_COMPLETED_CLEANLY QueryRejectCondition = 3 )
func QueryRejectConditionFromString ¶ added in v1.26.1
func QueryRejectConditionFromString(s string) (QueryRejectCondition, error)
QueryRejectConditionFromString parses a QueryRejectCondition value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to QueryRejectCondition
func (QueryRejectCondition) Descriptor ¶ added in v1.26.1
func (QueryRejectCondition) Descriptor() protoreflect.EnumDescriptor
func (QueryRejectCondition) Enum ¶ added in v1.26.1
func (x QueryRejectCondition) Enum() *QueryRejectCondition
func (QueryRejectCondition) EnumDescriptor
deprecated
func (QueryRejectCondition) EnumDescriptor() ([]byte, []int)
Deprecated: Use QueryRejectCondition.Descriptor instead.
func (QueryRejectCondition) Number ¶ added in v1.26.1
func (x QueryRejectCondition) Number() protoreflect.EnumNumber
func (QueryRejectCondition) String ¶
func (x QueryRejectCondition) String() string
func (QueryRejectCondition) Type ¶ added in v1.26.1
func (QueryRejectCondition) Type() protoreflect.EnumType
type QueryResultType ¶
type QueryResultType int32
const ( QUERY_RESULT_TYPE_UNSPECIFIED QueryResultType = 0 QUERY_RESULT_TYPE_ANSWERED QueryResultType = 1 QUERY_RESULT_TYPE_FAILED QueryResultType = 2 )
func QueryResultTypeFromString ¶ added in v1.26.1
func QueryResultTypeFromString(s string) (QueryResultType, error)
QueryResultTypeFromString parses a QueryResultType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to QueryResultType
func (QueryResultType) Descriptor ¶ added in v1.26.1
func (QueryResultType) Descriptor() protoreflect.EnumDescriptor
func (QueryResultType) Enum ¶ added in v1.26.1
func (x QueryResultType) Enum() *QueryResultType
func (QueryResultType) EnumDescriptor
deprecated
func (QueryResultType) EnumDescriptor() ([]byte, []int)
Deprecated: Use QueryResultType.Descriptor instead.
func (QueryResultType) Number ¶ added in v1.26.1
func (x QueryResultType) Number() protoreflect.EnumNumber
func (QueryResultType) String ¶
func (x QueryResultType) String() string
func (QueryResultType) Type ¶ added in v1.26.1
func (QueryResultType) Type() protoreflect.EnumType
type ReplicationState ¶ added in v1.7.0
type ReplicationState int32
const ( REPLICATION_STATE_UNSPECIFIED ReplicationState = 0 REPLICATION_STATE_NORMAL ReplicationState = 1 REPLICATION_STATE_HANDOVER ReplicationState = 2 )
func ReplicationStateFromString ¶ added in v1.26.1
func ReplicationStateFromString(s string) (ReplicationState, error)
ReplicationStateFromString parses a ReplicationState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to ReplicationState
func (ReplicationState) Descriptor ¶ added in v1.26.1
func (ReplicationState) Descriptor() protoreflect.EnumDescriptor
func (ReplicationState) Enum ¶ added in v1.26.1
func (x ReplicationState) Enum() *ReplicationState
func (ReplicationState) EnumDescriptor
deprecated
added in
v1.7.0
func (ReplicationState) EnumDescriptor() ([]byte, []int)
Deprecated: Use ReplicationState.Descriptor instead.
func (ReplicationState) Number ¶ added in v1.26.1
func (x ReplicationState) Number() protoreflect.EnumNumber
func (ReplicationState) String ¶ added in v1.7.0
func (x ReplicationState) String() string
func (ReplicationState) Type ¶ added in v1.26.1
func (ReplicationState) Type() protoreflect.EnumType
type ResetReapplyExcludeType ¶ added in v1.27.0
type ResetReapplyExcludeType int32
Event types to exclude when reapplying events beyond the reset point.
const ( RESET_REAPPLY_EXCLUDE_TYPE_UNSPECIFIED ResetReapplyExcludeType = 0 // Exclude signals when reapplying events beyond the reset point. RESET_REAPPLY_EXCLUDE_TYPE_SIGNAL ResetReapplyExcludeType = 1 // Exclude updates when reapplying events beyond the reset point. RESET_REAPPLY_EXCLUDE_TYPE_UPDATE ResetReapplyExcludeType = 2 // Exclude nexus events when reapplying events beyond the reset point. RESET_REAPPLY_EXCLUDE_TYPE_NEXUS ResetReapplyExcludeType = 3 )
func ResetReapplyExcludeTypeFromString ¶ added in v1.27.0
func ResetReapplyExcludeTypeFromString(s string) (ResetReapplyExcludeType, error)
ResetReapplyExcludeTypeFromString parses a ResetReapplyExcludeType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to ResetReapplyExcludeType
func (ResetReapplyExcludeType) Descriptor ¶ added in v1.27.0
func (ResetReapplyExcludeType) Descriptor() protoreflect.EnumDescriptor
func (ResetReapplyExcludeType) Enum ¶ added in v1.27.0
func (x ResetReapplyExcludeType) Enum() *ResetReapplyExcludeType
func (ResetReapplyExcludeType) EnumDescriptor
deprecated
added in
v1.27.0
func (ResetReapplyExcludeType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ResetReapplyExcludeType.Descriptor instead.
func (ResetReapplyExcludeType) Number ¶ added in v1.27.0
func (x ResetReapplyExcludeType) Number() protoreflect.EnumNumber
func (ResetReapplyExcludeType) String ¶ added in v1.27.0
func (x ResetReapplyExcludeType) String() string
func (ResetReapplyExcludeType) Type ¶ added in v1.27.0
func (ResetReapplyExcludeType) Type() protoreflect.EnumType
type ResetReapplyType ¶ added in v1.5.0
type ResetReapplyType int32
Event types to include when reapplying events. Deprecated: applications should use ResetReapplyExcludeType to specify exclusions from this set, and new event types should be added to ResetReapplyExcludeType instead of here.
const ( RESET_REAPPLY_TYPE_UNSPECIFIED ResetReapplyType = 0 // Signals are reapplied when workflow is reset. RESET_REAPPLY_TYPE_SIGNAL ResetReapplyType = 1 // No events are reapplied when workflow is reset. RESET_REAPPLY_TYPE_NONE ResetReapplyType = 2 // All eligible events are reapplied when workflow is reset. RESET_REAPPLY_TYPE_ALL_ELIGIBLE ResetReapplyType = 3 )
func ResetReapplyTypeFromString ¶ added in v1.26.1
func ResetReapplyTypeFromString(s string) (ResetReapplyType, error)
ResetReapplyTypeFromString parses a ResetReapplyType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to ResetReapplyType
func (ResetReapplyType) Descriptor ¶ added in v1.26.1
func (ResetReapplyType) Descriptor() protoreflect.EnumDescriptor
func (ResetReapplyType) Enum ¶ added in v1.26.1
func (x ResetReapplyType) Enum() *ResetReapplyType
func (ResetReapplyType) EnumDescriptor
deprecated
added in
v1.5.0
func (ResetReapplyType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ResetReapplyType.Descriptor instead.
func (ResetReapplyType) Number ¶ added in v1.26.1
func (x ResetReapplyType) Number() protoreflect.EnumNumber
func (ResetReapplyType) String ¶ added in v1.5.0
func (x ResetReapplyType) String() string
func (ResetReapplyType) Type ¶ added in v1.26.1
func (ResetReapplyType) Type() protoreflect.EnumType
type ResetType ¶ added in v1.21.0
type ResetType int32
Reset type options. Deprecated, see temporal.api.common.v1.ResetOptions.
const ( RESET_TYPE_UNSPECIFIED ResetType = 0 // Resets to event of the first workflow task completed, or if it does not exist, the event after task scheduled. RESET_TYPE_FIRST_WORKFLOW_TASK ResetType = 1 // Resets to event of the last workflow task completed, or if it does not exist, the event after task scheduled. RESET_TYPE_LAST_WORKFLOW_TASK ResetType = 2 )
func ResetTypeFromString ¶ added in v1.26.1
ResetTypeFromString parses a ResetType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to ResetType
func (ResetType) Descriptor ¶ added in v1.26.1
func (ResetType) Descriptor() protoreflect.EnumDescriptor
func (ResetType) EnumDescriptor
deprecated
added in
v1.21.0
func (ResetType) Number ¶ added in v1.26.1
func (x ResetType) Number() protoreflect.EnumNumber
func (ResetType) Type ¶ added in v1.26.1
func (ResetType) Type() protoreflect.EnumType
type ResourceExhaustedCause ¶ added in v1.8.0
type ResourceExhaustedCause int32
const ( RESOURCE_EXHAUSTED_CAUSE_UNSPECIFIED ResourceExhaustedCause = 0 // Caller exceeds request per second limit. RESOURCE_EXHAUSTED_CAUSE_RPS_LIMIT ResourceExhaustedCause = 1 // Caller exceeds max concurrent request limit. RESOURCE_EXHAUSTED_CAUSE_CONCURRENT_LIMIT ResourceExhaustedCause = 2 // System overloaded. RESOURCE_EXHAUSTED_CAUSE_SYSTEM_OVERLOADED ResourceExhaustedCause = 3 // Namespace exceeds persistence rate limit. RESOURCE_EXHAUSTED_CAUSE_PERSISTENCE_LIMIT ResourceExhaustedCause = 4 // Workflow is busy RESOURCE_EXHAUSTED_CAUSE_BUSY_WORKFLOW ResourceExhaustedCause = 5 // Caller exceeds action per second limit. RESOURCE_EXHAUSTED_CAUSE_APS_LIMIT ResourceExhaustedCause = 6 // Persistence storage limit exceeded. RESOURCE_EXHAUSTED_CAUSE_PERSISTENCE_STORAGE_LIMIT ResourceExhaustedCause = 7 // Circuit breaker is open/half-open. RESOURCE_EXHAUSTED_CAUSE_CIRCUIT_BREAKER_OPEN ResourceExhaustedCause = 8 )
func ResourceExhaustedCauseFromString ¶ added in v1.26.1
func ResourceExhaustedCauseFromString(s string) (ResourceExhaustedCause, error)
ResourceExhaustedCauseFromString parses a ResourceExhaustedCause value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to ResourceExhaustedCause
func (ResourceExhaustedCause) Descriptor ¶ added in v1.26.1
func (ResourceExhaustedCause) Descriptor() protoreflect.EnumDescriptor
func (ResourceExhaustedCause) Enum ¶ added in v1.26.1
func (x ResourceExhaustedCause) Enum() *ResourceExhaustedCause
func (ResourceExhaustedCause) EnumDescriptor ¶ added in v1.8.0
func (ResourceExhaustedCause) EnumDescriptor() ([]byte, []int)
func (ResourceExhaustedCause) Number ¶ added in v1.26.1
func (x ResourceExhaustedCause) Number() protoreflect.EnumNumber
func (ResourceExhaustedCause) String ¶ added in v1.8.0
func (x ResourceExhaustedCause) String() string
func (ResourceExhaustedCause) Type ¶ added in v1.26.1
func (ResourceExhaustedCause) Type() protoreflect.EnumType
type ResourceExhaustedScope ¶ added in v1.31.0
type ResourceExhaustedScope int32
const ( RESOURCE_EXHAUSTED_SCOPE_UNSPECIFIED ResourceExhaustedScope = 0 // Exhausted resource is a system-level resource. RESOURCE_EXHAUSTED_SCOPE_NAMESPACE ResourceExhaustedScope = 1 // Exhausted resource is a namespace-level resource. RESOURCE_EXHAUSTED_SCOPE_SYSTEM ResourceExhaustedScope = 2 )
func ResourceExhaustedScopeFromString ¶ added in v1.31.0
func ResourceExhaustedScopeFromString(s string) (ResourceExhaustedScope, error)
ResourceExhaustedScopeFromString parses a ResourceExhaustedScope value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to ResourceExhaustedScope
func (ResourceExhaustedScope) Descriptor ¶ added in v1.31.0
func (ResourceExhaustedScope) Descriptor() protoreflect.EnumDescriptor
func (ResourceExhaustedScope) Enum ¶ added in v1.31.0
func (x ResourceExhaustedScope) Enum() *ResourceExhaustedScope
func (ResourceExhaustedScope) EnumDescriptor
deprecated
added in
v1.31.0
func (ResourceExhaustedScope) EnumDescriptor() ([]byte, []int)
Deprecated: Use ResourceExhaustedScope.Descriptor instead.
func (ResourceExhaustedScope) Number ¶ added in v1.31.0
func (x ResourceExhaustedScope) Number() protoreflect.EnumNumber
func (ResourceExhaustedScope) String ¶ added in v1.31.0
func (x ResourceExhaustedScope) String() string
func (ResourceExhaustedScope) Type ¶ added in v1.31.0
func (ResourceExhaustedScope) Type() protoreflect.EnumType
type RetryState ¶
type RetryState int32
const ( RETRY_STATE_UNSPECIFIED RetryState = 0 RETRY_STATE_IN_PROGRESS RetryState = 1 RETRY_STATE_NON_RETRYABLE_FAILURE RetryState = 2 RETRY_STATE_TIMEOUT RetryState = 3 RETRY_STATE_MAXIMUM_ATTEMPTS_REACHED RetryState = 4 RETRY_STATE_RETRY_POLICY_NOT_SET RetryState = 5 RETRY_STATE_INTERNAL_SERVER_ERROR RetryState = 6 RETRY_STATE_CANCEL_REQUESTED RetryState = 7 )
func RetryStateFromString ¶ added in v1.26.1
func RetryStateFromString(s string) (RetryState, error)
RetryStateFromString parses a RetryState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to RetryState
func (RetryState) Descriptor ¶ added in v1.26.1
func (RetryState) Descriptor() protoreflect.EnumDescriptor
func (RetryState) Enum ¶ added in v1.26.1
func (x RetryState) Enum() *RetryState
func (RetryState) EnumDescriptor ¶
func (RetryState) EnumDescriptor() ([]byte, []int)
func (RetryState) Number ¶ added in v1.26.1
func (x RetryState) Number() protoreflect.EnumNumber
func (RetryState) String ¶
func (x RetryState) String() string
func (RetryState) Type ¶ added in v1.26.1
func (RetryState) Type() protoreflect.EnumType
type ScheduleOverlapPolicy ¶ added in v1.8.0
type ScheduleOverlapPolicy int32
ScheduleOverlapPolicy controls what happens when a workflow would be started by a schedule, and is already running.
const ( SCHEDULE_OVERLAP_POLICY_UNSPECIFIED ScheduleOverlapPolicy = 0 // SCHEDULE_OVERLAP_POLICY_SKIP (default) means don't start anything. When the // workflow completes, the next scheduled event after that time will be considered. SCHEDULE_OVERLAP_POLICY_SKIP ScheduleOverlapPolicy = 1 // SCHEDULE_OVERLAP_POLICY_BUFFER_ONE means start the workflow again soon as the // current one completes, but only buffer one start in this way. If another start is // supposed to happen when the workflow is running, and one is already buffered, then // only the first one will be started after the running workflow finishes. SCHEDULE_OVERLAP_POLICY_BUFFER_ONE ScheduleOverlapPolicy = 2 // SCHEDULE_OVERLAP_POLICY_BUFFER_ALL means buffer up any number of starts to all // happen sequentially, immediately after the running workflow completes. SCHEDULE_OVERLAP_POLICY_BUFFER_ALL ScheduleOverlapPolicy = 3 // SCHEDULE_OVERLAP_POLICY_CANCEL_OTHER means that if there is another workflow // running, cancel it, and start the new one after the old one completes cancellation. SCHEDULE_OVERLAP_POLICY_CANCEL_OTHER ScheduleOverlapPolicy = 4 // SCHEDULE_OVERLAP_POLICY_TERMINATE_OTHER means that if there is another workflow // running, terminate it and start the new one immediately. SCHEDULE_OVERLAP_POLICY_TERMINATE_OTHER ScheduleOverlapPolicy = 5 // SCHEDULE_OVERLAP_POLICY_ALLOW_ALL means start any number of concurrent workflows. // Note that with this policy, last completion result and last failure will not be // available since workflows are not sequential. SCHEDULE_OVERLAP_POLICY_ALLOW_ALL ScheduleOverlapPolicy = 6 )
func ScheduleOverlapPolicyFromString ¶ added in v1.26.1
func ScheduleOverlapPolicyFromString(s string) (ScheduleOverlapPolicy, error)
ScheduleOverlapPolicyFromString parses a ScheduleOverlapPolicy value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to ScheduleOverlapPolicy
func (ScheduleOverlapPolicy) Descriptor ¶ added in v1.26.1
func (ScheduleOverlapPolicy) Descriptor() protoreflect.EnumDescriptor
func (ScheduleOverlapPolicy) Enum ¶ added in v1.26.1
func (x ScheduleOverlapPolicy) Enum() *ScheduleOverlapPolicy
func (ScheduleOverlapPolicy) EnumDescriptor
deprecated
added in
v1.8.0
func (ScheduleOverlapPolicy) EnumDescriptor() ([]byte, []int)
Deprecated: Use ScheduleOverlapPolicy.Descriptor instead.
func (ScheduleOverlapPolicy) Number ¶ added in v1.26.1
func (x ScheduleOverlapPolicy) Number() protoreflect.EnumNumber
func (ScheduleOverlapPolicy) String ¶ added in v1.8.0
func (x ScheduleOverlapPolicy) String() string
func (ScheduleOverlapPolicy) Type ¶ added in v1.26.1
func (ScheduleOverlapPolicy) Type() protoreflect.EnumType
type Severity ¶ added in v1.1.0
type Severity int32
func SeverityFromString ¶ added in v1.26.1
SeverityFromString parses a Severity value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to Severity
func (Severity) Descriptor ¶ added in v1.26.1
func (Severity) Descriptor() protoreflect.EnumDescriptor
func (Severity) EnumDescriptor
deprecated
added in
v1.1.0
func (Severity) Number ¶ added in v1.26.1
func (x Severity) Number() protoreflect.EnumNumber
func (Severity) Type ¶ added in v1.26.1
func (Severity) Type() protoreflect.EnumType
type SignalExternalWorkflowExecutionFailedCause ¶
type SignalExternalWorkflowExecutionFailedCause int32
const ( SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_UNSPECIFIED SignalExternalWorkflowExecutionFailedCause = 0 SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_EXTERNAL_WORKFLOW_EXECUTION_NOT_FOUND SignalExternalWorkflowExecutionFailedCause = 1 SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_NAMESPACE_NOT_FOUND SignalExternalWorkflowExecutionFailedCause = 2 // Signal count limit is per workflow and controlled by server dynamic config "history.maximumSignalsPerExecution" SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_SIGNAL_COUNT_LIMIT_EXCEEDED SignalExternalWorkflowExecutionFailedCause = 3 )
func SignalExternalWorkflowExecutionFailedCauseFromString ¶ added in v1.26.1
func SignalExternalWorkflowExecutionFailedCauseFromString(s string) (SignalExternalWorkflowExecutionFailedCause, error)
SignalExternalWorkflowExecutionFailedCauseFromString parses a SignalExternalWorkflowExecutionFailedCause value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to SignalExternalWorkflowExecutionFailedCause
func (SignalExternalWorkflowExecutionFailedCause) Descriptor ¶ added in v1.26.1
func (SignalExternalWorkflowExecutionFailedCause) Descriptor() protoreflect.EnumDescriptor
func (SignalExternalWorkflowExecutionFailedCause) EnumDescriptor
deprecated
func (SignalExternalWorkflowExecutionFailedCause) EnumDescriptor() ([]byte, []int)
Deprecated: Use SignalExternalWorkflowExecutionFailedCause.Descriptor instead.
func (SignalExternalWorkflowExecutionFailedCause) Number ¶ added in v1.26.1
func (x SignalExternalWorkflowExecutionFailedCause) Number() protoreflect.EnumNumber
func (SignalExternalWorkflowExecutionFailedCause) String ¶
func (x SignalExternalWorkflowExecutionFailedCause) String() string
func (SignalExternalWorkflowExecutionFailedCause) Type ¶ added in v1.26.1
func (SignalExternalWorkflowExecutionFailedCause) Type() protoreflect.EnumType
type StartChildWorkflowExecutionFailedCause ¶
type StartChildWorkflowExecutionFailedCause int32
const ( START_CHILD_WORKFLOW_EXECUTION_FAILED_CAUSE_UNSPECIFIED StartChildWorkflowExecutionFailedCause = 0 START_CHILD_WORKFLOW_EXECUTION_FAILED_CAUSE_WORKFLOW_ALREADY_EXISTS StartChildWorkflowExecutionFailedCause = 1 START_CHILD_WORKFLOW_EXECUTION_FAILED_CAUSE_NAMESPACE_NOT_FOUND StartChildWorkflowExecutionFailedCause = 2 )
func StartChildWorkflowExecutionFailedCauseFromString ¶ added in v1.26.1
func StartChildWorkflowExecutionFailedCauseFromString(s string) (StartChildWorkflowExecutionFailedCause, error)
StartChildWorkflowExecutionFailedCauseFromString parses a StartChildWorkflowExecutionFailedCause value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to StartChildWorkflowExecutionFailedCause
func (StartChildWorkflowExecutionFailedCause) Descriptor ¶ added in v1.26.1
func (StartChildWorkflowExecutionFailedCause) Descriptor() protoreflect.EnumDescriptor
func (StartChildWorkflowExecutionFailedCause) EnumDescriptor ¶
func (StartChildWorkflowExecutionFailedCause) EnumDescriptor() ([]byte, []int)
func (StartChildWorkflowExecutionFailedCause) Number ¶ added in v1.26.1
func (x StartChildWorkflowExecutionFailedCause) Number() protoreflect.EnumNumber
func (StartChildWorkflowExecutionFailedCause) String ¶
func (x StartChildWorkflowExecutionFailedCause) String() string
func (StartChildWorkflowExecutionFailedCause) Type ¶ added in v1.26.1
func (StartChildWorkflowExecutionFailedCause) Type() protoreflect.EnumType
type TaskQueueKind ¶
type TaskQueueKind int32
const ( TASK_QUEUE_KIND_UNSPECIFIED TaskQueueKind = 0 // Tasks from a normal workflow task queue always include complete workflow history // // The task queue specified by the user is always a normal task queue. There can be as many // workers as desired for a single normal task queue. All those workers may pick up tasks from // that queue. TASK_QUEUE_KIND_NORMAL TaskQueueKind = 1 // A sticky queue only includes new history since the last workflow task, and they are // per-worker. // // Sticky queues are created dynamically by each worker during their start up. They only exist // for the lifetime of the worker process. Tasks in a sticky task queue are only available to // the worker that created the sticky queue. // // Sticky queues are only for workflow tasks. There are no sticky task queues for activities. TASK_QUEUE_KIND_STICKY TaskQueueKind = 2 )
func TaskQueueKindFromString ¶ added in v1.26.1
func TaskQueueKindFromString(s string) (TaskQueueKind, error)
TaskQueueKindFromString parses a TaskQueueKind value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to TaskQueueKind
func (TaskQueueKind) Descriptor ¶ added in v1.26.1
func (TaskQueueKind) Descriptor() protoreflect.EnumDescriptor
func (TaskQueueKind) Enum ¶ added in v1.26.1
func (x TaskQueueKind) Enum() *TaskQueueKind
func (TaskQueueKind) EnumDescriptor
deprecated
func (TaskQueueKind) EnumDescriptor() ([]byte, []int)
Deprecated: Use TaskQueueKind.Descriptor instead.
func (TaskQueueKind) Number ¶ added in v1.26.1
func (x TaskQueueKind) Number() protoreflect.EnumNumber
func (TaskQueueKind) String ¶
func (x TaskQueueKind) String() string
func (TaskQueueKind) Type ¶ added in v1.26.1
func (TaskQueueKind) Type() protoreflect.EnumType
type TaskQueueType ¶
type TaskQueueType int32
const ( TASK_QUEUE_TYPE_UNSPECIFIED TaskQueueType = 0 // Workflow type of task queue. TASK_QUEUE_TYPE_WORKFLOW TaskQueueType = 1 // Activity type of task queue. TASK_QUEUE_TYPE_ACTIVITY TaskQueueType = 2 // Task queue type for dispatching Nexus requests. TASK_QUEUE_TYPE_NEXUS TaskQueueType = 3 )
func TaskQueueTypeFromString ¶ added in v1.26.1
func TaskQueueTypeFromString(s string) (TaskQueueType, error)
TaskQueueTypeFromString parses a TaskQueueType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to TaskQueueType
func (TaskQueueType) Descriptor ¶ added in v1.26.1
func (TaskQueueType) Descriptor() protoreflect.EnumDescriptor
func (TaskQueueType) Enum ¶ added in v1.26.1
func (x TaskQueueType) Enum() *TaskQueueType
func (TaskQueueType) EnumDescriptor
deprecated
func (TaskQueueType) EnumDescriptor() ([]byte, []int)
Deprecated: Use TaskQueueType.Descriptor instead.
func (TaskQueueType) Number ¶ added in v1.26.1
func (x TaskQueueType) Number() protoreflect.EnumNumber
func (TaskQueueType) String ¶
func (x TaskQueueType) String() string
func (TaskQueueType) Type ¶ added in v1.26.1
func (TaskQueueType) Type() protoreflect.EnumType
type TaskReachability ¶ added in v1.21.0
type TaskReachability int32
Specifies which category of tasks may reach a worker on a versioned task queue. Used both in a reachability query and its response. Deprecated.
const ( TASK_REACHABILITY_UNSPECIFIED TaskReachability = 0 // There's a possiblity for a worker to receive new workflow tasks. Workers should *not* be retired. TASK_REACHABILITY_NEW_WORKFLOWS TaskReachability = 1 // There's a possiblity for a worker to receive existing workflow and activity tasks from existing workflows. Workers // should *not* be retired. // This enum value does not distinguish between open and closed workflows. TASK_REACHABILITY_EXISTING_WORKFLOWS TaskReachability = 2 // There's a possiblity for a worker to receive existing workflow and activity tasks from open workflows. Workers // should *not* be retired. TASK_REACHABILITY_OPEN_WORKFLOWS TaskReachability = 3 // There's a possiblity for a worker to receive existing workflow tasks from closed workflows. Workers may be // retired dependending on application requirements. For example, if there's no need to query closed workflows. TASK_REACHABILITY_CLOSED_WORKFLOWS TaskReachability = 4 )
func TaskReachabilityFromString ¶ added in v1.26.1
func TaskReachabilityFromString(s string) (TaskReachability, error)
TaskReachabilityFromString parses a TaskReachability value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to TaskReachability
func (TaskReachability) Descriptor ¶ added in v1.26.1
func (TaskReachability) Descriptor() protoreflect.EnumDescriptor
func (TaskReachability) Enum ¶ added in v1.26.1
func (x TaskReachability) Enum() *TaskReachability
func (TaskReachability) EnumDescriptor
deprecated
added in
v1.21.0
func (TaskReachability) EnumDescriptor() ([]byte, []int)
Deprecated: Use TaskReachability.Descriptor instead.
func (TaskReachability) Number ¶ added in v1.26.1
func (x TaskReachability) Number() protoreflect.EnumNumber
func (TaskReachability) String ¶ added in v1.21.0
func (x TaskReachability) String() string
func (TaskReachability) Type ¶ added in v1.26.1
func (TaskReachability) Type() protoreflect.EnumType
type TimeoutType ¶
type TimeoutType int32
const ( TIMEOUT_TYPE_UNSPECIFIED TimeoutType = 0 TIMEOUT_TYPE_START_TO_CLOSE TimeoutType = 1 TIMEOUT_TYPE_SCHEDULE_TO_START TimeoutType = 2 TIMEOUT_TYPE_SCHEDULE_TO_CLOSE TimeoutType = 3 TIMEOUT_TYPE_HEARTBEAT TimeoutType = 4 )
func TimeoutTypeFromString ¶ added in v1.26.1
func TimeoutTypeFromString(s string) (TimeoutType, error)
TimeoutTypeFromString parses a TimeoutType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to TimeoutType
func (TimeoutType) Descriptor ¶ added in v1.26.1
func (TimeoutType) Descriptor() protoreflect.EnumDescriptor
func (TimeoutType) Enum ¶ added in v1.26.1
func (x TimeoutType) Enum() *TimeoutType
func (TimeoutType) EnumDescriptor
deprecated
func (TimeoutType) EnumDescriptor() ([]byte, []int)
Deprecated: Use TimeoutType.Descriptor instead.
func (TimeoutType) Number ¶ added in v1.26.1
func (x TimeoutType) Number() protoreflect.EnumNumber
func (TimeoutType) String ¶
func (x TimeoutType) String() string
func (TimeoutType) Type ¶ added in v1.26.1
func (TimeoutType) Type() protoreflect.EnumType
type UpdateAdmittedEventOrigin ¶ added in v1.31.0
type UpdateAdmittedEventOrigin int32
Records why a WorkflowExecutionUpdateAdmittedEvent was written to history. Note that not all admitted Updates result in this event.
const ( UPDATE_ADMITTED_EVENT_ORIGIN_UNSPECIFIED UpdateAdmittedEventOrigin = 0 // The UpdateAdmitted event was created when reapplying events during reset // or replication. I.e. an accepted Update on one branch of Workflow history // was converted into an admitted Update on a different branch. UPDATE_ADMITTED_EVENT_ORIGIN_REAPPLY UpdateAdmittedEventOrigin = 1 )
func UpdateAdmittedEventOriginFromString ¶ added in v1.31.0
func UpdateAdmittedEventOriginFromString(s string) (UpdateAdmittedEventOrigin, error)
UpdateAdmittedEventOriginFromString parses a UpdateAdmittedEventOrigin value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to UpdateAdmittedEventOrigin
func (UpdateAdmittedEventOrigin) Descriptor ¶ added in v1.31.0
func (UpdateAdmittedEventOrigin) Descriptor() protoreflect.EnumDescriptor
func (UpdateAdmittedEventOrigin) Enum ¶ added in v1.31.0
func (x UpdateAdmittedEventOrigin) Enum() *UpdateAdmittedEventOrigin
func (UpdateAdmittedEventOrigin) EnumDescriptor
deprecated
added in
v1.31.0
func (UpdateAdmittedEventOrigin) EnumDescriptor() ([]byte, []int)
Deprecated: Use UpdateAdmittedEventOrigin.Descriptor instead.
func (UpdateAdmittedEventOrigin) Number ¶ added in v1.31.0
func (x UpdateAdmittedEventOrigin) Number() protoreflect.EnumNumber
func (UpdateAdmittedEventOrigin) String ¶ added in v1.31.0
func (x UpdateAdmittedEventOrigin) String() string
func (UpdateAdmittedEventOrigin) Type ¶ added in v1.31.0
func (UpdateAdmittedEventOrigin) Type() protoreflect.EnumType
type UpdateWorkflowExecutionLifecycleStage ¶ added in v1.16.0
type UpdateWorkflowExecutionLifecycleStage int32
UpdateWorkflowExecutionLifecycleStage is specified by clients invoking Workflow Updates and used to indicate to the server how long the client wishes to wait for a return value from the API. If any value other than UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_COMPLETED is sent by the client then the API will complete before the Update is finished and will return a handle to the running Update so that it can later be polled for completion. If specified stage wasn't reached before server timeout, server returns actual stage reached.
const ( // An unspecified value for this enum. UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_UNSPECIFIED UpdateWorkflowExecutionLifecycleStage = 0 // The API call will not return until the Update request has been admitted // by the server - it may be the case that due to a considerations like load // or resource limits that an Update is made to wait before the server will // indicate that it has been received and will be processed. This value // does not wait for any sort of acknowledgement from a worker. UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_ADMITTED UpdateWorkflowExecutionLifecycleStage = 1 // The API call will not return until the Update has passed validation on a worker. UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_ACCEPTED UpdateWorkflowExecutionLifecycleStage = 2 // The API call will not return until the Update has executed to completion // on a worker and has either been rejected or returned a value or an error. UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_COMPLETED UpdateWorkflowExecutionLifecycleStage = 3 )
func UpdateWorkflowExecutionLifecycleStageFromString ¶ added in v1.26.1
func UpdateWorkflowExecutionLifecycleStageFromString(s string) (UpdateWorkflowExecutionLifecycleStage, error)
UpdateWorkflowExecutionLifecycleStageFromString parses a UpdateWorkflowExecutionLifecycleStage value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to UpdateWorkflowExecutionLifecycleStage
func (UpdateWorkflowExecutionLifecycleStage) Descriptor ¶ added in v1.26.1
func (UpdateWorkflowExecutionLifecycleStage) Descriptor() protoreflect.EnumDescriptor
func (UpdateWorkflowExecutionLifecycleStage) EnumDescriptor
deprecated
added in
v1.16.0
func (UpdateWorkflowExecutionLifecycleStage) EnumDescriptor() ([]byte, []int)
Deprecated: Use UpdateWorkflowExecutionLifecycleStage.Descriptor instead.
func (UpdateWorkflowExecutionLifecycleStage) Number ¶ added in v1.26.1
func (x UpdateWorkflowExecutionLifecycleStage) Number() protoreflect.EnumNumber
func (UpdateWorkflowExecutionLifecycleStage) String ¶ added in v1.16.0
func (x UpdateWorkflowExecutionLifecycleStage) String() string
func (UpdateWorkflowExecutionLifecycleStage) Type ¶ added in v1.26.1
func (UpdateWorkflowExecutionLifecycleStage) Type() protoreflect.EnumType
type WorkflowExecutionStatus ¶
type WorkflowExecutionStatus int32
(-- api-linter: core::0216::synonyms=disabled
aip.dev/not-precedent: There is WorkflowExecutionState already in another package. --)
const ( WORKFLOW_EXECUTION_STATUS_UNSPECIFIED WorkflowExecutionStatus = 0 // Value 1 is hardcoded in SQL persistence. WORKFLOW_EXECUTION_STATUS_RUNNING WorkflowExecutionStatus = 1 WORKFLOW_EXECUTION_STATUS_COMPLETED WorkflowExecutionStatus = 2 WORKFLOW_EXECUTION_STATUS_FAILED WorkflowExecutionStatus = 3 WORKFLOW_EXECUTION_STATUS_CANCELED WorkflowExecutionStatus = 4 WORKFLOW_EXECUTION_STATUS_TERMINATED WorkflowExecutionStatus = 5 WORKFLOW_EXECUTION_STATUS_CONTINUED_AS_NEW WorkflowExecutionStatus = 6 WORKFLOW_EXECUTION_STATUS_TIMED_OUT WorkflowExecutionStatus = 7 )
func WorkflowExecutionStatusFromString ¶ added in v1.26.1
func WorkflowExecutionStatusFromString(s string) (WorkflowExecutionStatus, error)
WorkflowExecutionStatusFromString parses a WorkflowExecutionStatus value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to WorkflowExecutionStatus
func (WorkflowExecutionStatus) Descriptor ¶ added in v1.26.1
func (WorkflowExecutionStatus) Descriptor() protoreflect.EnumDescriptor
func (WorkflowExecutionStatus) Enum ¶ added in v1.26.1
func (x WorkflowExecutionStatus) Enum() *WorkflowExecutionStatus
func (WorkflowExecutionStatus) EnumDescriptor ¶
func (WorkflowExecutionStatus) EnumDescriptor() ([]byte, []int)
func (WorkflowExecutionStatus) Number ¶ added in v1.26.1
func (x WorkflowExecutionStatus) Number() protoreflect.EnumNumber
func (WorkflowExecutionStatus) String ¶
func (x WorkflowExecutionStatus) String() string
func (WorkflowExecutionStatus) Type ¶ added in v1.26.1
func (WorkflowExecutionStatus) Type() protoreflect.EnumType
type WorkflowIdConflictPolicy ¶ added in v1.30.0
type WorkflowIdConflictPolicy int32
Defines what to do when trying to start a workflow with the same workflow id as a *running* workflow. Note that it is *never* valid to have two actively running instances of the same workflow id.
See `WorkflowIdReusePolicy` for handling workflow id duplication with a *closed* workflow.
const ( WORKFLOW_ID_CONFLICT_POLICY_UNSPECIFIED WorkflowIdConflictPolicy = 0 // Don't start a new workflow; instead return `WorkflowExecutionAlreadyStartedFailure`. WORKFLOW_ID_CONFLICT_POLICY_FAIL WorkflowIdConflictPolicy = 1 // Don't start a new workflow; instead return a workflow handle for the running workflow. WORKFLOW_ID_CONFLICT_POLICY_USE_EXISTING WorkflowIdConflictPolicy = 2 // Terminate the running workflow before starting a new one. WORKFLOW_ID_CONFLICT_POLICY_TERMINATE_EXISTING WorkflowIdConflictPolicy = 3 )
func WorkflowIdConflictPolicyFromString ¶ added in v1.30.0
func WorkflowIdConflictPolicyFromString(s string) (WorkflowIdConflictPolicy, error)
WorkflowIdConflictPolicyFromString parses a WorkflowIdConflictPolicy value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to WorkflowIdConflictPolicy
func (WorkflowIdConflictPolicy) Descriptor ¶ added in v1.30.0
func (WorkflowIdConflictPolicy) Descriptor() protoreflect.EnumDescriptor
func (WorkflowIdConflictPolicy) Enum ¶ added in v1.30.0
func (x WorkflowIdConflictPolicy) Enum() *WorkflowIdConflictPolicy
func (WorkflowIdConflictPolicy) EnumDescriptor
deprecated
added in
v1.30.0
func (WorkflowIdConflictPolicy) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkflowIdConflictPolicy.Descriptor instead.
func (WorkflowIdConflictPolicy) Number ¶ added in v1.30.0
func (x WorkflowIdConflictPolicy) Number() protoreflect.EnumNumber
func (WorkflowIdConflictPolicy) String ¶ added in v1.30.0
func (x WorkflowIdConflictPolicy) String() string
func (WorkflowIdConflictPolicy) Type ¶ added in v1.30.0
func (WorkflowIdConflictPolicy) Type() protoreflect.EnumType
type WorkflowIdReusePolicy ¶
type WorkflowIdReusePolicy int32
Defines whether to allow re-using a workflow id from a previously *closed* workflow. If the request is denied, a `WorkflowExecutionAlreadyStartedFailure` is returned.
See `WorkflowIdConflictPolicy` for handling workflow id duplication with a *running* workflow.
const ( WORKFLOW_ID_REUSE_POLICY_UNSPECIFIED WorkflowIdReusePolicy = 0 // Allow starting a workflow execution using the same workflow id. WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE WorkflowIdReusePolicy = 1 // Allow starting a workflow execution using the same workflow id, only when the last // execution's final state is one of [terminated, cancelled, timed out, failed]. WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE_FAILED_ONLY WorkflowIdReusePolicy = 2 // Do not permit re-use of the workflow id for this workflow. Future start workflow requests // could potentially change the policy, allowing re-use of the workflow id. WORKFLOW_ID_REUSE_POLICY_REJECT_DUPLICATE WorkflowIdReusePolicy = 3 // This option belongs in WorkflowIdConflictPolicy but is here for backwards compatibility. // If specified, it acts like ALLOW_DUPLICATE, but also the WorkflowId*Conflict*Policy on // the request is treated as WORKFLOW_ID_CONFLICT_POLICY_TERMINATE_EXISTING. // If no running workflow, then the behavior is the same as ALLOW_DUPLICATE. WORKFLOW_ID_REUSE_POLICY_TERMINATE_IF_RUNNING WorkflowIdReusePolicy = 4 )
func WorkflowIdReusePolicyFromString ¶ added in v1.26.1
func WorkflowIdReusePolicyFromString(s string) (WorkflowIdReusePolicy, error)
WorkflowIdReusePolicyFromString parses a WorkflowIdReusePolicy value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to WorkflowIdReusePolicy
func (WorkflowIdReusePolicy) Descriptor ¶ added in v1.26.1
func (WorkflowIdReusePolicy) Descriptor() protoreflect.EnumDescriptor
func (WorkflowIdReusePolicy) Enum ¶ added in v1.26.1
func (x WorkflowIdReusePolicy) Enum() *WorkflowIdReusePolicy
func (WorkflowIdReusePolicy) EnumDescriptor
deprecated
func (WorkflowIdReusePolicy) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkflowIdReusePolicy.Descriptor instead.
func (WorkflowIdReusePolicy) Number ¶ added in v1.26.1
func (x WorkflowIdReusePolicy) Number() protoreflect.EnumNumber
func (WorkflowIdReusePolicy) String ¶
func (x WorkflowIdReusePolicy) String() string
func (WorkflowIdReusePolicy) Type ¶ added in v1.26.1
func (WorkflowIdReusePolicy) Type() protoreflect.EnumType
type WorkflowTaskFailedCause ¶
type WorkflowTaskFailedCause int32
Workflow tasks can fail for various reasons. Note that some of these reasons can only originate from the server, and some of them can only originate from the SDK/worker.
const ( WORKFLOW_TASK_FAILED_CAUSE_UNSPECIFIED WorkflowTaskFailedCause = 0 // Between starting and completing the workflow task (with a workflow completion command), some // new command (like a signal) was processed into workflow history. The outstanding task will be // failed with this reason, and a worker must pick up a new task. WORKFLOW_TASK_FAILED_CAUSE_UNHANDLED_COMMAND WorkflowTaskFailedCause = 1 WORKFLOW_TASK_FAILED_CAUSE_BAD_SCHEDULE_ACTIVITY_ATTRIBUTES WorkflowTaskFailedCause = 2 WORKFLOW_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES WorkflowTaskFailedCause = 3 WORKFLOW_TASK_FAILED_CAUSE_BAD_START_TIMER_ATTRIBUTES WorkflowTaskFailedCause = 4 WORKFLOW_TASK_FAILED_CAUSE_BAD_CANCEL_TIMER_ATTRIBUTES WorkflowTaskFailedCause = 5 WORKFLOW_TASK_FAILED_CAUSE_BAD_RECORD_MARKER_ATTRIBUTES WorkflowTaskFailedCause = 6 WORKFLOW_TASK_FAILED_CAUSE_BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES WorkflowTaskFailedCause = 7 WORKFLOW_TASK_FAILED_CAUSE_BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES WorkflowTaskFailedCause = 8 WORKFLOW_TASK_FAILED_CAUSE_BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES WorkflowTaskFailedCause = 9 WORKFLOW_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES WorkflowTaskFailedCause = 10 WORKFLOW_TASK_FAILED_CAUSE_BAD_CONTINUE_AS_NEW_ATTRIBUTES WorkflowTaskFailedCause = 11 WORKFLOW_TASK_FAILED_CAUSE_START_TIMER_DUPLICATE_ID WorkflowTaskFailedCause = 12 // The worker wishes to fail the task and have the next one be generated on a normal, not sticky // queue. Generally workers should prefer to use the explicit `ResetStickyTaskQueue` RPC call. WORKFLOW_TASK_FAILED_CAUSE_RESET_STICKY_TASK_QUEUE WorkflowTaskFailedCause = 13 WORKFLOW_TASK_FAILED_CAUSE_WORKFLOW_WORKER_UNHANDLED_FAILURE WorkflowTaskFailedCause = 14 WORKFLOW_TASK_FAILED_CAUSE_BAD_SIGNAL_WORKFLOW_EXECUTION_ATTRIBUTES WorkflowTaskFailedCause = 15 WORKFLOW_TASK_FAILED_CAUSE_BAD_START_CHILD_EXECUTION_ATTRIBUTES WorkflowTaskFailedCause = 16 WORKFLOW_TASK_FAILED_CAUSE_FORCE_CLOSE_COMMAND WorkflowTaskFailedCause = 17 WORKFLOW_TASK_FAILED_CAUSE_FAILOVER_CLOSE_COMMAND WorkflowTaskFailedCause = 18 WORKFLOW_TASK_FAILED_CAUSE_BAD_SIGNAL_INPUT_SIZE WorkflowTaskFailedCause = 19 WORKFLOW_TASK_FAILED_CAUSE_RESET_WORKFLOW WorkflowTaskFailedCause = 20 WORKFLOW_TASK_FAILED_CAUSE_BAD_BINARY WorkflowTaskFailedCause = 21 WORKFLOW_TASK_FAILED_CAUSE_SCHEDULE_ACTIVITY_DUPLICATE_ID WorkflowTaskFailedCause = 22 WORKFLOW_TASK_FAILED_CAUSE_BAD_SEARCH_ATTRIBUTES WorkflowTaskFailedCause = 23 // The worker encountered a mismatch while replaying history between what was expected, and // what the workflow code actually did. WORKFLOW_TASK_FAILED_CAUSE_NON_DETERMINISTIC_ERROR WorkflowTaskFailedCause = 24 WORKFLOW_TASK_FAILED_CAUSE_BAD_MODIFY_WORKFLOW_PROPERTIES_ATTRIBUTES WorkflowTaskFailedCause = 25 // We send the below error codes to users when their requests would violate a size constraint // of their workflow. We do this to ensure that the state of their workflow does not become too // large because that can cause severe performance degradation. You can modify the thresholds for // each of these errors within your dynamic config. // // Spawning a new child workflow would cause this workflow to exceed its limit of pending child // workflows. WORKFLOW_TASK_FAILED_CAUSE_PENDING_CHILD_WORKFLOWS_LIMIT_EXCEEDED WorkflowTaskFailedCause = 26 // Starting a new activity would cause this workflow to exceed its limit of pending activities // that we track. WORKFLOW_TASK_FAILED_CAUSE_PENDING_ACTIVITIES_LIMIT_EXCEEDED WorkflowTaskFailedCause = 27 // A workflow has a buffer of signals that have not yet reached their destination. We return this // error when sending a new signal would exceed the capacity of this buffer. WORKFLOW_TASK_FAILED_CAUSE_PENDING_SIGNALS_LIMIT_EXCEEDED WorkflowTaskFailedCause = 28 // Similarly, we have a buffer of pending requests to cancel other workflows. We return this error // when our capacity for pending cancel requests is already reached. WORKFLOW_TASK_FAILED_CAUSE_PENDING_REQUEST_CANCEL_LIMIT_EXCEEDED WorkflowTaskFailedCause = 29 // Workflow execution update message (update.Acceptance, update.Rejection, or update.Response) // has wrong format, or missing required fields. WORKFLOW_TASK_FAILED_CAUSE_BAD_UPDATE_WORKFLOW_EXECUTION_MESSAGE WorkflowTaskFailedCause = 30 // Similar to WORKFLOW_TASK_FAILED_CAUSE_UNHANDLED_COMMAND, but for updates. WORKFLOW_TASK_FAILED_CAUSE_UNHANDLED_UPDATE WorkflowTaskFailedCause = 31 // A workflow task completed with an invalid ScheduleNexusOperation command. WORKFLOW_TASK_FAILED_CAUSE_BAD_SCHEDULE_NEXUS_OPERATION_ATTRIBUTES WorkflowTaskFailedCause = 32 // A workflow task completed requesting to schedule a Nexus Operation exceeding the server configured limit. WORKFLOW_TASK_FAILED_CAUSE_PENDING_NEXUS_OPERATIONS_LIMIT_EXCEEDED WorkflowTaskFailedCause = 33 // A workflow task completed with an invalid RequestCancelNexusOperation command. WORKFLOW_TASK_FAILED_CAUSE_BAD_REQUEST_CANCEL_NEXUS_OPERATION_ATTRIBUTES WorkflowTaskFailedCause = 34 // A workflow task completed requesting a feature that's disabled on the server (either system wide or - typically - // for the workflow's namespace). // Check the workflow task failure message for more information. WORKFLOW_TASK_FAILED_CAUSE_FEATURE_DISABLED WorkflowTaskFailedCause = 35 )
func WorkflowTaskFailedCauseFromString ¶ added in v1.26.1
func WorkflowTaskFailedCauseFromString(s string) (WorkflowTaskFailedCause, error)
WorkflowTaskFailedCauseFromString parses a WorkflowTaskFailedCause value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to WorkflowTaskFailedCause
func (WorkflowTaskFailedCause) Descriptor ¶ added in v1.26.1
func (WorkflowTaskFailedCause) Descriptor() protoreflect.EnumDescriptor
func (WorkflowTaskFailedCause) Enum ¶ added in v1.26.1
func (x WorkflowTaskFailedCause) Enum() *WorkflowTaskFailedCause
func (WorkflowTaskFailedCause) EnumDescriptor ¶
func (WorkflowTaskFailedCause) EnumDescriptor() ([]byte, []int)
func (WorkflowTaskFailedCause) Number ¶ added in v1.26.1
func (x WorkflowTaskFailedCause) Number() protoreflect.EnumNumber
func (WorkflowTaskFailedCause) String ¶
func (x WorkflowTaskFailedCause) String() string
func (WorkflowTaskFailedCause) Type ¶ added in v1.26.1
func (WorkflowTaskFailedCause) Type() protoreflect.EnumType
Source Files ¶
- batch_operation.go-helpers.pb.go
- batch_operation.pb.go
- command_type.go-helpers.pb.go
- command_type.pb.go
- common.go-helpers.pb.go
- common.pb.go
- event_type.go-helpers.pb.go
- event_type.pb.go
- failed_cause.go-helpers.pb.go
- failed_cause.pb.go
- namespace.go-helpers.pb.go
- namespace.pb.go
- query.go-helpers.pb.go
- query.pb.go
- reset.go-helpers.pb.go
- reset.pb.go
- schedule.go-helpers.pb.go
- schedule.pb.go
- task_queue.go-helpers.pb.go
- task_queue.pb.go
- update.go-helpers.pb.go
- update.pb.go
- workflow.go-helpers.pb.go
- workflow.pb.go