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 QueryRejectCondition
- type QueryResultType
- type RetryState
- type SignalExternalWorkflowExecutionFailedCause
- type StartChildWorkflowExecutionFailedCause
- type TaskQueueKind
- type TaskQueueType
- type TimeoutType
- type WorkflowExecutionStatus
- type WorkflowIdReusePolicy
- type WorkflowTaskFailedCause
Constants ¶
This section is empty.
Variables ¶
View Source
var ArchivalState_name = map[int32]string{
0: "Unspecified",
1: "Disabled",
2: "Enabled",
}
View Source
var ArchivalState_value = map[string]int32{
"Unspecified": 0,
"Disabled": 1,
"Enabled": 2,
}
View Source
var CancelExternalWorkflowExecutionFailedCause_name = map[int32]string{
0: "Unspecified",
1: "ExternalWorkflowExecutionNotFound",
}
View Source
var CancelExternalWorkflowExecutionFailedCause_value = map[string]int32{
"Unspecified": 0,
"ExternalWorkflowExecutionNotFound": 1,
}
View Source
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",
}
View Source
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,
}
View Source
var ContinueAsNewInitiator_name = map[int32]string{
0: "Unspecified",
1: "Workflow",
2: "Retry",
3: "CronSchedule",
}
View Source
var ContinueAsNewInitiator_value = map[string]int32{
"Unspecified": 0,
"Workflow": 1,
"Retry": 2,
"CronSchedule": 3,
}
View Source
var EncodingType_name = map[int32]string{
0: "Unspecified",
1: "Proto3",
2: "Json",
}
View Source
var EncodingType_value = map[string]int32{
"Unspecified": 0,
"Proto3": 1,
"Json": 2,
}
View Source
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",
}
View Source
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,
}
View Source
var HistoryEventFilterType_name = map[int32]string{
0: "Unspecified",
1: "AllEvent",
2: "CloseEvent",
}
View Source
var HistoryEventFilterType_value = map[string]int32{
"Unspecified": 0,
"AllEvent": 1,
"CloseEvent": 2,
}
View Source
var IndexedValueType_name = map[int32]string{
0: "Unspecified",
1: "String",
2: "Keyword",
3: "Int",
4: "Double",
5: "Bool",
6: "Datetime",
}
View Source
var IndexedValueType_value = map[string]int32{
"Unspecified": 0,
"String": 1,
"Keyword": 2,
"Int": 3,
"Double": 4,
"Bool": 5,
"Datetime": 6,
}
View Source
var NamespaceState_name = map[int32]string{
0: "Unspecified",
1: "Registered",
2: "Deprecated",
3: "Deleted",
}
View Source
var NamespaceState_value = map[string]int32{
"Unspecified": 0,
"Registered": 1,
"Deprecated": 2,
"Deleted": 3,
}
View Source
var ParentClosePolicy_name = map[int32]string{
0: "Unspecified",
1: "Terminate",
2: "Abandon",
3: "RequestCancel",
}
View Source
var ParentClosePolicy_value = map[string]int32{
"Unspecified": 0,
"Terminate": 1,
"Abandon": 2,
"RequestCancel": 3,
}
View Source
var PendingActivityState_name = map[int32]string{
0: "Unspecified",
1: "Scheduled",
2: "Started",
3: "CancelRequested",
}
View Source
var PendingActivityState_value = map[string]int32{
"Unspecified": 0,
"Scheduled": 1,
"Started": 2,
"CancelRequested": 3,
}
View Source
var QueryRejectCondition_name = map[int32]string{
0: "Unspecified",
1: "None",
2: "NotOpen",
3: "NotCompletedCleanly",
}
View Source
var QueryRejectCondition_value = map[string]int32{
"Unspecified": 0,
"None": 1,
"NotOpen": 2,
"NotCompletedCleanly": 3,
}
View Source
var QueryResultType_name = map[int32]string{
0: "Unspecified",
1: "Answered",
2: "Failed",
}
View Source
var QueryResultType_value = map[string]int32{
"Unspecified": 0,
"Answered": 1,
"Failed": 2,
}
View Source
var RetryState_name = map[int32]string{
0: "Unspecified",
1: "InProgress",
2: "NonRetryableFailure",
3: "Timeout",
4: "MaximumAttemptsReached",
5: "RetryPolicyNotSet",
6: "InternalServerError",
7: "CancelRequested",
}
View Source
var RetryState_value = map[string]int32{
"Unspecified": 0,
"InProgress": 1,
"NonRetryableFailure": 2,
"Timeout": 3,
"MaximumAttemptsReached": 4,
"RetryPolicyNotSet": 5,
"InternalServerError": 6,
"CancelRequested": 7,
}
View Source
var SignalExternalWorkflowExecutionFailedCause_name = map[int32]string{
0: "Unspecified",
1: "ExternalWorkflowExecutionNotFound",
}
View Source
var SignalExternalWorkflowExecutionFailedCause_value = map[string]int32{
"Unspecified": 0,
"ExternalWorkflowExecutionNotFound": 1,
}
View Source
var StartChildWorkflowExecutionFailedCause_name = map[int32]string{
0: "Unspecified",
1: "WorkflowAlreadyExists",
}
View Source
var StartChildWorkflowExecutionFailedCause_value = map[string]int32{
"Unspecified": 0,
"WorkflowAlreadyExists": 1,
}
View Source
var TaskQueueKind_name = map[int32]string{
0: "Unspecified",
1: "Normal",
2: "Sticky",
}
View Source
var TaskQueueKind_value = map[string]int32{
"Unspecified": 0,
"Normal": 1,
"Sticky": 2,
}
View Source
var TaskQueueType_name = map[int32]string{
0: "Unspecified",
1: "Workflow",
2: "Activity",
}
View Source
var TaskQueueType_value = map[string]int32{
"Unspecified": 0,
"Workflow": 1,
"Activity": 2,
}
View Source
var TimeoutType_name = map[int32]string{
0: "Unspecified",
1: "StartToClose",
2: "ScheduleToStart",
3: "ScheduleToClose",
4: "Heartbeat",
}
View Source
var TimeoutType_value = map[string]int32{
"Unspecified": 0,
"StartToClose": 1,
"ScheduleToStart": 2,
"ScheduleToClose": 3,
"Heartbeat": 4,
}
View Source
var WorkflowExecutionStatus_name = map[int32]string{
0: "Unspecified",
1: "Running",
2: "Completed",
3: "Failed",
4: "Canceled",
5: "Terminated",
6: "ContinuedAsNew",
7: "TimedOut",
}
View Source
var WorkflowExecutionStatus_value = map[string]int32{
"Unspecified": 0,
"Running": 1,
"Completed": 2,
"Failed": 3,
"Canceled": 4,
"Terminated": 5,
"ContinuedAsNew": 6,
"TimedOut": 7,
}
View Source
var WorkflowIdReusePolicy_name = map[int32]string{
0: "Unspecified",
1: "AllowDuplicate",
2: "AllowDuplicateFailedOnly",
3: "RejectDuplicate",
}
View Source
var WorkflowIdReusePolicy_value = map[string]int32{
"Unspecified": 0,
"AllowDuplicate": 1,
"AllowDuplicateFailedOnly": 2,
"RejectDuplicate": 3,
}
View Source
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",
}
View Source
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,
}
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 CONTINUE_AS_NEW_INITIATOR_WORKFLOW ContinueAsNewInitiator = 1 CONTINUE_AS_NEW_INITIATOR_RETRY ContinueAsNewInitiator = 2 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 ( EVENT_TYPE_UNSPECIFIED EventType = 0 EVENT_TYPE_WORKFLOW_EXECUTION_STARTED EventType = 1 EVENT_TYPE_WORKFLOW_EXECUTION_COMPLETED EventType = 2 EVENT_TYPE_WORKFLOW_EXECUTION_FAILED EventType = 3 EVENT_TYPE_WORKFLOW_EXECUTION_TIMED_OUT EventType = 4 EVENT_TYPE_WORKFLOW_TASK_SCHEDULED EventType = 5 EVENT_TYPE_WORKFLOW_TASK_STARTED EventType = 6 EVENT_TYPE_WORKFLOW_TASK_COMPLETED EventType = 7 EVENT_TYPE_WORKFLOW_TASK_TIMED_OUT EventType = 8 EVENT_TYPE_WORKFLOW_TASK_FAILED EventType = 9 EVENT_TYPE_ACTIVITY_TASK_SCHEDULED EventType = 10 EVENT_TYPE_ACTIVITY_TASK_STARTED EventType = 11 EVENT_TYPE_ACTIVITY_TASK_COMPLETED EventType = 12 EVENT_TYPE_ACTIVITY_TASK_FAILED EventType = 13 EVENT_TYPE_ACTIVITY_TASK_TIMED_OUT EventType = 14 EVENT_TYPE_ACTIVITY_TASK_CANCEL_REQUESTED EventType = 15 EVENT_TYPE_ACTIVITY_TASK_CANCELED EventType = 16 EVENT_TYPE_TIMER_STARTED EventType = 17 EVENT_TYPE_TIMER_FIRED EventType = 18 EVENT_TYPE_TIMER_CANCELED EventType = 19 EVENT_TYPE_WORKFLOW_EXECUTION_CANCEL_REQUESTED EventType = 20 EVENT_TYPE_WORKFLOW_EXECUTION_CANCELED EventType = 21 EVENT_TYPE_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED EventType = 22 EVENT_TYPE_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED EventType = 23 EVENT_TYPE_EXTERNAL_WORKFLOW_EXECUTION_CANCEL_REQUESTED EventType = 24 EVENT_TYPE_MARKER_RECORDED EventType = 25 EVENT_TYPE_WORKFLOW_EXECUTION_SIGNALED EventType = 26 EVENT_TYPE_WORKFLOW_EXECUTION_TERMINATED EventType = 27 EVENT_TYPE_WORKFLOW_EXECUTION_CONTINUED_AS_NEW EventType = 28 EVENT_TYPE_START_CHILD_WORKFLOW_EXECUTION_INITIATED EventType = 29 EVENT_TYPE_START_CHILD_WORKFLOW_EXECUTION_FAILED EventType = 30 EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_STARTED EventType = 31 EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_COMPLETED EventType = 32 EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_FAILED EventType = 33 EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_CANCELED EventType = 34 EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_TIMED_OUT EventType = 35 EVENT_TYPE_CHILD_WORKFLOW_EXECUTION_TERMINATED EventType = 36 EVENT_TYPE_SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_INITIATED EventType = 37 EVENT_TYPE_SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED EventType = 38 EVENT_TYPE_EXTERNAL_WORKFLOW_EXECUTION_SIGNALED EventType = 39 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_STRING 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
const ( PARENT_CLOSE_POLICY_UNSPECIFIED ParentClosePolicy = 0 // Terminate means terminating the child workflow. PARENT_CLOSE_POLICY_TERMINATE ParentClosePolicy = 1 // Abandon means not doing anything on the child workflow. PARENT_CLOSE_POLICY_ABANDON ParentClosePolicy = 2 // Cancel means requesting cancellation on 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 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 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 TASK_QUEUE_KIND_NORMAL TaskQueueKind = 1 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
const ( WORKFLOW_ID_REUSE_POLICY_UNSPECIFIED WorkflowIdReusePolicy = 0 // Allow start a workflow execution using the same workflow Id, when workflow not running. WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE WorkflowIdReusePolicy = 1 // Allow start a workflow execution using the same workflow Id, when workflow not running, and the last execution close state is in // [terminated, cancelled, timed out, failed]. WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE_FAILED_ONLY WorkflowIdReusePolicy = 2 // Do not allow start a workflow execution using the same workflow Id at all. 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
const ( WORKFLOW_TASK_FAILED_CAUSE_UNSPECIFIED WorkflowTaskFailedCause = 0 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 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 )
func (WorkflowTaskFailedCause) EnumDescriptor ¶
func (WorkflowTaskFailedCause) EnumDescriptor() ([]byte, []int)
func (WorkflowTaskFailedCause) String ¶
func (x WorkflowTaskFailedCause) String() string
Click to show internal directories.
Click to hide internal directories.