Documentation ¶
Index ¶
- Variables
- type ArchivalState
- type CancelExternalWorkflowExecutionFailedCause
- type CommandType
- type ContinueAsNewInitiator
- type EncodingType
- type EventType
- type HistoryEventFilterType
- type IndexedValueType
- type NamespaceState
- type ParentClosePolicy
- type PendingActivityState
- type PendingWorkflowTaskState
- type QueryRejectCondition
- type QueryResultType
- type ReplicationState
- type ResetReapplyType
- type ResourceExhaustedCause
- type RetryState
- type Severity
- type SignalExternalWorkflowExecutionFailedCause
- type StartChildWorkflowExecutionFailedCause
- type TaskQueueKind
- type TaskQueueType
- type TimeoutType
- type WorkflowExecutionStatus
- type WorkflowIdReusePolicy
- type WorkflowTaskFailedCause
Constants ¶
This section is empty.
Variables ¶
var ArchivalState_name = map[int32]string{
0: "Unspecified",
1: "Disabled",
2: "Enabled",
}
var ArchivalState_value = map[string]int32{
"Unspecified": 0,
"Disabled": 1,
"Enabled": 2,
}
var CancelExternalWorkflowExecutionFailedCause_name = map[int32]string{
0: "Unspecified",
1: "ExternalWorkflowExecutionNotFound",
}
var CancelExternalWorkflowExecutionFailedCause_value = map[string]int32{
"Unspecified": 0,
"ExternalWorkflowExecutionNotFound": 1,
}
var CommandType_name = map[int32]string{
0: "Unspecified",
1: "ScheduleActivityTask",
2: "RequestCancelActivityTask",
3: "StartTimer",
4: "CompleteWorkflowExecution",
5: "FailWorkflowExecution",
6: "CancelTimer",
7: "CancelWorkflowExecution",
8: "RequestCancelExternalWorkflowExecution",
9: "RecordMarker",
10: "ContinueAsNewWorkflowExecution",
11: "StartChildWorkflowExecution",
12: "SignalExternalWorkflowExecution",
13: "UpsertWorkflowSearchAttributes",
}
var CommandType_value = 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,
}
var ContinueAsNewInitiator_name = map[int32]string{
0: "Unspecified",
1: "Workflow",
2: "Retry",
3: "CronSchedule",
}
var ContinueAsNewInitiator_value = map[string]int32{
"Unspecified": 0,
"Workflow": 1,
"Retry": 2,
"CronSchedule": 3,
}
var EncodingType_name = map[int32]string{
0: "Unspecified",
1: "Proto3",
2: "Json",
}
var EncodingType_value = map[string]int32{
"Unspecified": 0,
"Proto3": 1,
"Json": 2,
}
var EventType_name = map[int32]string{
0: "Unspecified",
1: "WorkflowExecutionStarted",
2: "WorkflowExecutionCompleted",
3: "WorkflowExecutionFailed",
4: "WorkflowExecutionTimedOut",
5: "WorkflowTaskScheduled",
6: "WorkflowTaskStarted",
7: "WorkflowTaskCompleted",
8: "WorkflowTaskTimedOut",
9: "WorkflowTaskFailed",
10: "ActivityTaskScheduled",
11: "ActivityTaskStarted",
12: "ActivityTaskCompleted",
13: "ActivityTaskFailed",
14: "ActivityTaskTimedOut",
15: "ActivityTaskCancelRequested",
16: "ActivityTaskCanceled",
17: "TimerStarted",
18: "TimerFired",
19: "TimerCanceled",
20: "WorkflowExecutionCancelRequested",
21: "WorkflowExecutionCanceled",
22: "RequestCancelExternalWorkflowExecutionInitiated",
23: "RequestCancelExternalWorkflowExecutionFailed",
24: "ExternalWorkflowExecutionCancelRequested",
25: "MarkerRecorded",
26: "WorkflowExecutionSignaled",
27: "WorkflowExecutionTerminated",
28: "WorkflowExecutionContinuedAsNew",
29: "StartChildWorkflowExecutionInitiated",
30: "StartChildWorkflowExecutionFailed",
31: "ChildWorkflowExecutionStarted",
32: "ChildWorkflowExecutionCompleted",
33: "ChildWorkflowExecutionFailed",
34: "ChildWorkflowExecutionCanceled",
35: "ChildWorkflowExecutionTimedOut",
36: "ChildWorkflowExecutionTerminated",
37: "SignalExternalWorkflowExecutionInitiated",
38: "SignalExternalWorkflowExecutionFailed",
39: "ExternalWorkflowExecutionSignaled",
40: "UpsertWorkflowSearchAttributes",
}
var EventType_value = 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,
}
var HistoryEventFilterType_name = map[int32]string{
0: "Unspecified",
1: "AllEvent",
2: "CloseEvent",
}
var HistoryEventFilterType_value = map[string]int32{
"Unspecified": 0,
"AllEvent": 1,
"CloseEvent": 2,
}
var IndexedValueType_name = map[int32]string{
0: "Unspecified",
1: "Text",
2: "Keyword",
3: "Int",
4: "Double",
5: "Bool",
6: "Datetime",
}
var IndexedValueType_value = map[string]int32{
"Unspecified": 0,
"Text": 1,
"Keyword": 2,
"Int": 3,
"Double": 4,
"Bool": 5,
"Datetime": 6,
}
var NamespaceState_name = map[int32]string{
0: "Unspecified",
1: "Registered",
2: "Deprecated",
3: "Deleted",
}
var NamespaceState_value = map[string]int32{
"Unspecified": 0,
"Registered": 1,
"Deprecated": 2,
"Deleted": 3,
}
var ParentClosePolicy_name = map[int32]string{
0: "Unspecified",
1: "Terminate",
2: "Abandon",
3: "RequestCancel",
}
var ParentClosePolicy_value = map[string]int32{
"Unspecified": 0,
"Terminate": 1,
"Abandon": 2,
"RequestCancel": 3,
}
var PendingActivityState_name = map[int32]string{
0: "Unspecified",
1: "Scheduled",
2: "Started",
3: "CancelRequested",
}
var PendingActivityState_value = map[string]int32{
"Unspecified": 0,
"Scheduled": 1,
"Started": 2,
"CancelRequested": 3,
}
var PendingWorkflowTaskState_name = map[int32]string{
0: "Unspecified",
1: "Scheduled",
2: "Started",
}
var PendingWorkflowTaskState_value = map[string]int32{
"Unspecified": 0,
"Scheduled": 1,
"Started": 2,
}
var QueryRejectCondition_name = map[int32]string{
0: "Unspecified",
1: "None",
2: "NotOpen",
3: "NotCompletedCleanly",
}
var QueryRejectCondition_value = map[string]int32{
"Unspecified": 0,
"None": 1,
"NotOpen": 2,
"NotCompletedCleanly": 3,
}
var QueryResultType_name = map[int32]string{
0: "Unspecified",
1: "Answered",
2: "Failed",
}
var QueryResultType_value = map[string]int32{
"Unspecified": 0,
"Answered": 1,
"Failed": 2,
}
var ReplicationState_name = map[int32]string{
0: "Unspecified",
1: "Normal",
2: "Handover",
}
var ReplicationState_value = map[string]int32{
"Unspecified": 0,
"Normal": 1,
"Handover": 2,
}
var ResetReapplyType_name = map[int32]string{
0: "Unspecified",
1: "Signal",
2: "None",
}
var ResetReapplyType_value = map[string]int32{
"Unspecified": 0,
"Signal": 1,
"None": 2,
}
var ResourceExhaustedCause_name = map[int32]string{
0: "Unspecified",
1: "RpsLimit",
2: "ConcurrentLimit",
3: "SystemOverloaded",
}
var ResourceExhaustedCause_value = map[string]int32{
"Unspecified": 0,
"RpsLimit": 1,
"ConcurrentLimit": 2,
"SystemOverloaded": 3,
}
var RetryState_name = map[int32]string{
0: "Unspecified",
1: "InProgress",
2: "NonRetryableFailure",
3: "Timeout",
4: "MaximumAttemptsReached",
5: "RetryPolicyNotSet",
6: "InternalServerError",
7: "CancelRequested",
}
var RetryState_value = map[string]int32{
"Unspecified": 0,
"InProgress": 1,
"NonRetryableFailure": 2,
"Timeout": 3,
"MaximumAttemptsReached": 4,
"RetryPolicyNotSet": 5,
"InternalServerError": 6,
"CancelRequested": 7,
}
var Severity_name = map[int32]string{
0: "Unspecified",
1: "High",
2: "Medium",
3: "Low",
}
var Severity_value = map[string]int32{
"Unspecified": 0,
"High": 1,
"Medium": 2,
"Low": 3,
}
var SignalExternalWorkflowExecutionFailedCause_name = map[int32]string{
0: "Unspecified",
1: "ExternalWorkflowExecutionNotFound",
}
var SignalExternalWorkflowExecutionFailedCause_value = map[string]int32{
"Unspecified": 0,
"ExternalWorkflowExecutionNotFound": 1,
}
var StartChildWorkflowExecutionFailedCause_name = map[int32]string{
0: "Unspecified",
1: "WorkflowAlreadyExists",
}
var StartChildWorkflowExecutionFailedCause_value = map[string]int32{
"Unspecified": 0,
"WorkflowAlreadyExists": 1,
}
var TaskQueueKind_name = map[int32]string{
0: "Unspecified",
1: "Normal",
2: "Sticky",
}
var TaskQueueKind_value = map[string]int32{
"Unspecified": 0,
"Normal": 1,
"Sticky": 2,
}
var TaskQueueType_name = map[int32]string{
0: "Unspecified",
1: "Workflow",
2: "Activity",
}
var TaskQueueType_value = map[string]int32{
"Unspecified": 0,
"Workflow": 1,
"Activity": 2,
}
var TimeoutType_name = map[int32]string{
0: "Unspecified",
1: "StartToClose",
2: "ScheduleToStart",
3: "ScheduleToClose",
4: "Heartbeat",
}
var TimeoutType_value = map[string]int32{
"Unspecified": 0,
"StartToClose": 1,
"ScheduleToStart": 2,
"ScheduleToClose": 3,
"Heartbeat": 4,
}
var WorkflowExecutionStatus_name = map[int32]string{
0: "Unspecified",
1: "Running",
2: "Completed",
3: "Failed",
4: "Canceled",
5: "Terminated",
6: "ContinuedAsNew",
7: "TimedOut",
}
var WorkflowExecutionStatus_value = map[string]int32{
"Unspecified": 0,
"Running": 1,
"Completed": 2,
"Failed": 3,
"Canceled": 4,
"Terminated": 5,
"ContinuedAsNew": 6,
"TimedOut": 7,
}
var WorkflowIdReusePolicy_name = map[int32]string{
0: "Unspecified",
1: "AllowDuplicate",
2: "AllowDuplicateFailedOnly",
3: "RejectDuplicate",
}
var WorkflowIdReusePolicy_value = map[string]int32{
"Unspecified": 0,
"AllowDuplicate": 1,
"AllowDuplicateFailedOnly": 2,
"RejectDuplicate": 3,
}
var WorkflowTaskFailedCause_name = map[int32]string{
0: "Unspecified",
1: "UnhandledCommand",
2: "BadScheduleActivityAttributes",
3: "BadRequestCancelActivityAttributes",
4: "BadStartTimerAttributes",
5: "BadCancelTimerAttributes",
6: "BadRecordMarkerAttributes",
7: "BadCompleteWorkflowExecutionAttributes",
8: "BadFailWorkflowExecutionAttributes",
9: "BadCancelWorkflowExecutionAttributes",
10: "BadRequestCancelExternalWorkflowExecutionAttributes",
11: "BadContinueAsNewAttributes",
12: "StartTimerDuplicateId",
13: "ResetStickyTaskQueue",
14: "WorkflowWorkerUnhandledFailure",
15: "BadSignalWorkflowExecutionAttributes",
16: "BadStartChildExecutionAttributes",
17: "ForceCloseCommand",
18: "FailoverCloseCommand",
19: "BadSignalInputSize",
20: "ResetWorkflow",
21: "BadBinary",
22: "ScheduleActivityDuplicateId",
23: "BadSearchAttributes",
24: "NonDeterministicError",
}
var WorkflowTaskFailedCause_value = 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,
}
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 (ArchivalState) EnumDescriptor ¶
func (ArchivalState) EnumDescriptor() ([]byte, []int)
func (ArchivalState) String ¶
func (x ArchivalState) String() string
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 )
func (CancelExternalWorkflowExecutionFailedCause) EnumDescriptor ¶
func (CancelExternalWorkflowExecutionFailedCause) EnumDescriptor() ([]byte, []int)
func (CancelExternalWorkflowExecutionFailedCause) String ¶
func (x CancelExternalWorkflowExecutionFailedCause) String() string
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 )
func (CommandType) EnumDescriptor ¶
func (CommandType) EnumDescriptor() ([]byte, []int)
func (CommandType) String ¶
func (x CommandType) String() string
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 (ContinueAsNewInitiator) EnumDescriptor ¶
func (ContinueAsNewInitiator) EnumDescriptor() ([]byte, []int)
func (ContinueAsNewInitiator) String ¶
func (x ContinueAsNewInitiator) String() string
type EncodingType ¶
type EncodingType int32
const ( ENCODING_TYPE_UNSPECIFIED EncodingType = 0 ENCODING_TYPE_PROTO3 EncodingType = 1 ENCODING_TYPE_JSON EncodingType = 2 )
func (EncodingType) EnumDescriptor ¶
func (EncodingType) EnumDescriptor() ([]byte, []int)
func (EncodingType) String ¶
func (x EncodingType) String() string
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 )
func (EventType) EnumDescriptor ¶
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 (HistoryEventFilterType) EnumDescriptor ¶
func (HistoryEventFilterType) EnumDescriptor() ([]byte, []int)
func (HistoryEventFilterType) String ¶
func (x HistoryEventFilterType) String() string
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 )
func (IndexedValueType) EnumDescriptor ¶
func (IndexedValueType) EnumDescriptor() ([]byte, []int)
func (IndexedValueType) String ¶
func (x IndexedValueType) String() string
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 (NamespaceState) EnumDescriptor ¶
func (NamespaceState) EnumDescriptor() ([]byte, []int)
func (NamespaceState) String ¶
func (x NamespaceState) String() string
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 (ParentClosePolicy) EnumDescriptor ¶
func (ParentClosePolicy) EnumDescriptor() ([]byte, []int)
func (ParentClosePolicy) String ¶
func (x ParentClosePolicy) String() string
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 (PendingActivityState) EnumDescriptor ¶
func (PendingActivityState) EnumDescriptor() ([]byte, []int)
func (PendingActivityState) String ¶
func (x PendingActivityState) String() string
type PendingWorkflowTaskState ¶ added in v0.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 (PendingWorkflowTaskState) EnumDescriptor ¶ added in v0.8.0
func (PendingWorkflowTaskState) EnumDescriptor() ([]byte, []int)
func (PendingWorkflowTaskState) String ¶ added in v0.8.0
func (x PendingWorkflowTaskState) String() string
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 (QueryRejectCondition) EnumDescriptor ¶
func (QueryRejectCondition) EnumDescriptor() ([]byte, []int)
func (QueryRejectCondition) String ¶
func (x QueryRejectCondition) String() string
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 (QueryResultType) EnumDescriptor ¶
func (QueryResultType) EnumDescriptor() ([]byte, []int)
func (QueryResultType) String ¶
func (x QueryResultType) String() string
type ReplicationState ¶ added in v0.8.0
type ReplicationState int32
const ( REPLICATION_STATE_UNSPECIFIED ReplicationState = 0 REPLICATION_STATE_NORMAL ReplicationState = 1 REPLICATION_STATE_HANDOVER ReplicationState = 2 )
func (ReplicationState) EnumDescriptor ¶ added in v0.8.0
func (ReplicationState) EnumDescriptor() ([]byte, []int)
func (ReplicationState) String ¶ added in v0.8.0
func (x ReplicationState) String() string
type ResetReapplyType ¶ added in v0.8.0
type ResetReapplyType int32
TODO: What is this?
const ( RESET_REAPPLY_TYPE_UNSPECIFIED ResetReapplyType = 0 RESET_REAPPLY_TYPE_SIGNAL ResetReapplyType = 1 RESET_REAPPLY_TYPE_NONE ResetReapplyType = 2 )
func (ResetReapplyType) EnumDescriptor ¶ added in v0.8.0
func (ResetReapplyType) EnumDescriptor() ([]byte, []int)
func (ResetReapplyType) String ¶ added in v0.8.0
func (x ResetReapplyType) String() string
type ResourceExhaustedCause ¶ added in v0.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 )
func (ResourceExhaustedCause) EnumDescriptor ¶ added in v0.8.0
func (ResourceExhaustedCause) EnumDescriptor() ([]byte, []int)
func (ResourceExhaustedCause) String ¶ added in v0.8.0
func (x ResourceExhaustedCause) String() string
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 (RetryState) EnumDescriptor ¶
func (RetryState) EnumDescriptor() ([]byte, []int)
func (RetryState) String ¶
func (x RetryState) String() string
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 )
func (SignalExternalWorkflowExecutionFailedCause) EnumDescriptor ¶
func (SignalExternalWorkflowExecutionFailedCause) EnumDescriptor() ([]byte, []int)
func (SignalExternalWorkflowExecutionFailedCause) String ¶
func (x SignalExternalWorkflowExecutionFailedCause) String() string
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 )
func (StartChildWorkflowExecutionFailedCause) EnumDescriptor ¶
func (StartChildWorkflowExecutionFailedCause) EnumDescriptor() ([]byte, []int)
func (StartChildWorkflowExecutionFailedCause) String ¶
func (x StartChildWorkflowExecutionFailedCause) String() string
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 (TaskQueueKind) EnumDescriptor ¶
func (TaskQueueKind) EnumDescriptor() ([]byte, []int)
func (TaskQueueKind) String ¶
func (x TaskQueueKind) String() string
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 (TaskQueueType) EnumDescriptor ¶
func (TaskQueueType) EnumDescriptor() ([]byte, []int)
func (TaskQueueType) String ¶
func (x TaskQueueType) String() string
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 (TimeoutType) EnumDescriptor ¶
func (TimeoutType) EnumDescriptor() ([]byte, []int)
func (TimeoutType) String ¶
func (x TimeoutType) String() string
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 (WorkflowExecutionStatus) EnumDescriptor ¶
func (WorkflowExecutionStatus) EnumDescriptor() ([]byte, []int)
func (WorkflowExecutionStatus) String ¶
func (x WorkflowExecutionStatus) String() string
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 )
func (WorkflowIdReusePolicy) EnumDescriptor ¶
func (WorkflowIdReusePolicy) EnumDescriptor() ([]byte, []int)
func (WorkflowIdReusePolicy) String ¶
func (x WorkflowIdReusePolicy) String() string
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 )
func (WorkflowTaskFailedCause) EnumDescriptor ¶
func (WorkflowTaskFailedCause) EnumDescriptor() ([]byte, []int)
func (WorkflowTaskFailedCause) String ¶
func (x WorkflowTaskFailedCause) String() string