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 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 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 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 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 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 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 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 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", } 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, } )
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 ( 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", 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", } 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_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, } )
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", } 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, } )
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, } )
Enum value maps for CancelExternalWorkflowExecutionFailedCause.
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", } 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, } )
Enum value maps for ResourceExhaustedCause.
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 ( ResetReapplyType_name = map[int32]string{ 0: "RESET_REAPPLY_TYPE_UNSPECIFIED", 1: "RESET_REAPPLY_TYPE_SIGNAL", 2: "RESET_REAPPLY_TYPE_NONE", } ResetReapplyType_value = map[string]int32{ "RESET_REAPPLY_TYPE_UNSPECIFIED": 0, "RESET_REAPPLY_TYPE_SIGNAL": 1, "RESET_REAPPLY_TYPE_NONE": 2, } )
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", } TaskQueueType_value = map[string]int32{ "TASK_QUEUE_TYPE_UNSPECIFIED": 0, "TASK_QUEUE_TYPE_WORKFLOW": 1, "TASK_QUEUE_TYPE_ACTIVITY": 2, } )
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 ( 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 ( 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 ( 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 (
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,
}
)
var (
ContinueAsNewInitiator_shorthandValue = map[string]int32{
"Unspecified": 0,
"Workflow": 1,
"Retry": 2,
"CronSchedule": 3,
}
)
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,
"WorkflowExecutionUpdateAccepted": 41,
"WorkflowExecutionUpdateRejected": 42,
"WorkflowExecutionUpdateCompleted": 43,
"WorkflowPropertiesModifiedExternally": 44,
"ActivityPropertiesModifiedExternally": 45,
"WorkflowPropertiesModified": 46,
}
)
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 (
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 (
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 (
ResetReapplyType_shorthandValue = map[string]int32{
"Unspecified": 0,
"Signal": 1,
"None": 2,
}
)
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,
}
)
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,
}
)
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 (
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 (
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,
}
)
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 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 )
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 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 accepted (i.e. validated) EVENT_TYPE_WORKFLOW_EXECUTION_UPDATE_ACCEPTED EventType = 41 // An update was rejected (i.e. failed validation) 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 )
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 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 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 ResetReapplyType ¶ added in v1.5.0
type ResetReapplyType int32
Reset reapply (replay) options * RESET_REAPPLY_TYPE_SIGNAL (default) - Signals are reapplied when workflow is reset * RESET_REAPPLY_TYPE_NONE - nothing is reapplied
const ( RESET_REAPPLY_TYPE_UNSPECIFIED ResetReapplyType = 0 RESET_REAPPLY_TYPE_SIGNAL ResetReapplyType = 1 RESET_REAPPLY_TYPE_NONE ResetReapplyType = 2 )
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 )
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 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 )
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.
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 UpdateWorkflowExecutionLifecycleStage ¶ added in v1.16.0
type UpdateWorkflowExecutionLifecycleStage int32
UpdateWorkflowExecutionLifecycleStage is specified by clients invoking workflow execution updates and used to indicate to the server how long the client wishes to wait for a return value from the RPC. If any value other than UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_COMPLETED is sent by the client then the RPC 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.
const ( // An unspecified vale for this enum. UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_UNSPECIFIED UpdateWorkflowExecutionLifecycleStage = 0 // The gRPC 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 gRPC call will not return until the update has passed validation on // a worker. UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_ACCEPTED UpdateWorkflowExecutionLifecycleStage = 2 // The gRPC 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 WorkflowIdReusePolicy ¶
type WorkflowIdReusePolicy int32
Defines how new runs of a workflow with a particular ID may or may not be allowed. Note that it is *never* valid to have two actively running instances of the same workflow id.
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 // If a workflow is running using the same workflow ID, terminate it and start a new one. // 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 )
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