enums

Documentation

Index

• Variables
• type ArchivalState
  • func (ArchivalState) EnumDescriptor() ([]byte, []int)
  • func (x ArchivalState) String() string
• type BatchOperationState
  • func (BatchOperationState) EnumDescriptor() ([]byte, []int)
  • func (x BatchOperationState) String() string
• type BatchOperationType
  • func (BatchOperationType) EnumDescriptor() ([]byte, []int)
  • func (x BatchOperationType) String() string
• type CancelExternalWorkflowExecutionFailedCause
  • func (CancelExternalWorkflowExecutionFailedCause) EnumDescriptor() ([]byte, []int)
  • func (x CancelExternalWorkflowExecutionFailedCause) String() string
• type CommandType
  • func (CommandType) EnumDescriptor() ([]byte, []int)
  • func (x CommandType) String() string
• type ContinueAsNewInitiator
  • func (ContinueAsNewInitiator) EnumDescriptor() ([]byte, []int)
  • func (x ContinueAsNewInitiator) String() string
• type EncodingType
  • func (EncodingType) EnumDescriptor() ([]byte, []int)
  • func (x EncodingType) String() string
• type EventType
  • func (EventType) EnumDescriptor() ([]byte, []int)
  • func (x EventType) String() string
• type HistoryEventFilterType
  • func (HistoryEventFilterType) EnumDescriptor() ([]byte, []int)
  • func (x HistoryEventFilterType) String() string
• type IndexedValueType
  • func (IndexedValueType) EnumDescriptor() ([]byte, []int)
  • func (x IndexedValueType) String() string
• type NamespaceState
  • func (NamespaceState) EnumDescriptor() ([]byte, []int)
  • func (x NamespaceState) String() string
• type ParentClosePolicy
  • func (ParentClosePolicy) EnumDescriptor() ([]byte, []int)
  • func (x ParentClosePolicy) String() string
• type PendingActivityState
  • func (PendingActivityState) EnumDescriptor() ([]byte, []int)
  • func (x PendingActivityState) String() string
• type PendingWorkflowTaskState
  • func (PendingWorkflowTaskState) EnumDescriptor() ([]byte, []int)
  • func (x PendingWorkflowTaskState) String() string
• type QueryRejectCondition
  • func (QueryRejectCondition) EnumDescriptor() ([]byte, []int)
  • func (x QueryRejectCondition) String() string
• type QueryResultType
  • func (QueryResultType) EnumDescriptor() ([]byte, []int)
  • func (x QueryResultType) String() string
• type ReplicationState
  • func (ReplicationState) EnumDescriptor() ([]byte, []int)
  • func (x ReplicationState) String() string
• type ResetReapplyType
  • func (ResetReapplyType) EnumDescriptor() ([]byte, []int)
  • func (x ResetReapplyType) String() string
• type ResourceExhaustedCause
  • func (ResourceExhaustedCause) EnumDescriptor() ([]byte, []int)
  • func (x ResourceExhaustedCause) String() string
• type RetryState
  • func (RetryState) EnumDescriptor() ([]byte, []int)
  • func (x RetryState) String() string
• type ScheduleOverlapPolicy
  • func (ScheduleOverlapPolicy) EnumDescriptor() ([]byte, []int)
  • func (x ScheduleOverlapPolicy) String() string
• type Severity
  • func (Severity) EnumDescriptor() ([]byte, []int)
  • func (x Severity) String() string
• type SignalExternalWorkflowExecutionFailedCause
  • func (SignalExternalWorkflowExecutionFailedCause) EnumDescriptor() ([]byte, []int)
  • func (x SignalExternalWorkflowExecutionFailedCause) String() string
• type StartChildWorkflowExecutionFailedCause
  • func (StartChildWorkflowExecutionFailedCause) EnumDescriptor() ([]byte, []int)
  • func (x StartChildWorkflowExecutionFailedCause) String() string
• type TaskQueueKind
  • func (TaskQueueKind) EnumDescriptor() ([]byte, []int)
  • func (x TaskQueueKind) String() string
• type TaskQueueType
  • func (TaskQueueType) EnumDescriptor() ([]byte, []int)
  • func (x TaskQueueType) String() string
• type TimeoutType
  • func (TimeoutType) EnumDescriptor() ([]byte, []int)
  • func (x TimeoutType) String() string
• type UpdateWorkflowExecutionLifecycleStage
  • func (UpdateWorkflowExecutionLifecycleStage) EnumDescriptor() ([]byte, []int)
  • func (x UpdateWorkflowExecutionLifecycleStage) String() string
• type WorkflowExecutionStatus
  • func (WorkflowExecutionStatus) EnumDescriptor() ([]byte, []int)
  • func (x WorkflowExecutionStatus) String() string
• type WorkflowIdReusePolicy
  • func (WorkflowIdReusePolicy) EnumDescriptor() ([]byte, []int)
  • func (x WorkflowIdReusePolicy) String() string
• type WorkflowTaskFailedCause
  • func (WorkflowTaskFailedCause) EnumDescriptor() ([]byte, []int)
  • func (x WorkflowTaskFailedCause) String() string

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 BatchOperationState_name = map[int32]string{
	0: "Unspecified",
	1: "Running",
	2: "Completed",
	3: "Failed",
}

var BatchOperationState_value = map[string]int32{
	"Unspecified": 0,
	"Running":     1,
	"Completed":   2,
	"Failed":      3,
}

var BatchOperationType_name = map[int32]string{
	0: "Unspecified",
	1: "Terminate",
	2: "Cancel",
	3: "Signal",
	4: "Delete",
}

var BatchOperationType_value = map[string]int32{
	"Unspecified": 0,
	"Terminate":   1,
	"Cancel":      2,
	"Signal":      3,
	"Delete":      4,
}

var CancelExternalWorkflowExecutionFailedCause_name = map[int32]string{
	0: "Unspecified",
	1: "ExternalWorkflowExecutionNotFound",
	2: "NamespaceNotFound",
}

var CancelExternalWorkflowExecutionFailedCause_value = map[string]int32{
	"Unspecified":                       0,
	"ExternalWorkflowExecutionNotFound": 1,
	"NamespaceNotFound":                 2,
}

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",
	14: "ProtocolMessage",
	16: "ModifyWorkflowProperties",
}

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,
	"ProtocolMessage":                        14,
	"ModifyWorkflowProperties":               16,
}

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",
	41: "WorkflowExecutionUpdateAccepted",
	42: "WorkflowExecutionUpdateRejected",
	43: "WorkflowExecutionUpdateCompleted",
	44: "WorkflowPropertiesModifiedExternally",
	45: "ActivityPropertiesModifiedExternally",
	46: "WorkflowPropertiesModified",
}

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,
	"WorkflowExecutionUpdateAccepted":                 41,
	"WorkflowExecutionUpdateRejected":                 42,
	"WorkflowExecutionUpdateCompleted":                43,
	"WorkflowPropertiesModifiedExternally":            44,
	"ActivityPropertiesModifiedExternally":            45,
	"WorkflowPropertiesModified":                      46,
}

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",
	7: "KeywordList",
}

var IndexedValueType_value = map[string]int32{
	"Unspecified": 0,
	"Text":        1,
	"Keyword":     2,
	"Int":         3,
	"Double":      4,
	"Bool":        5,
	"Datetime":    6,
	"KeywordList": 7,
}

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",
	4: "PersistenceLimit",
}

var ResourceExhaustedCause_value = map[string]int32{
	"Unspecified":      0,
	"RpsLimit":         1,
	"ConcurrentLimit":  2,
	"SystemOverloaded": 3,
	"PersistenceLimit": 4,
}

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 ScheduleOverlapPolicy_name = map[int32]string{
	0: "Unspecified",
	1: "Skip",
	2: "BufferOne",
	3: "BufferAll",
	4: "CancelOther",
	5: "TerminateOther",
	6: "AllowAll",
}

var ScheduleOverlapPolicy_value = map[string]int32{
	"Unspecified":    0,
	"Skip":           1,
	"BufferOne":      2,
	"BufferAll":      3,
	"CancelOther":    4,
	"TerminateOther": 5,
	"AllowAll":       6,
}

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",
	2: "NamespaceNotFound",
}

var SignalExternalWorkflowExecutionFailedCause_value = map[string]int32{
	"Unspecified":                       0,
	"ExternalWorkflowExecutionNotFound": 1,
	"NamespaceNotFound":                 2,
}

var StartChildWorkflowExecutionFailedCause_name = map[int32]string{
	0: "Unspecified",
	1: "WorkflowAlreadyExists",
	2: "NamespaceNotFound",
}

var StartChildWorkflowExecutionFailedCause_value = map[string]int32{
	"Unspecified":           0,
	"WorkflowAlreadyExists": 1,
	"NamespaceNotFound":     2,
}

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 UpdateWorkflowExecutionLifecycleStage_name = map[int32]string{
	0: "Unspecified",
	1: "Admitted",
	2: "Accepted",
	3: "Completed",
}

var UpdateWorkflowExecutionLifecycleStage_value = map[string]int32{
	"Unspecified": 0,
	"Admitted":    1,
	"Accepted":    2,
	"Completed":   3,
}

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",
	4: "TerminateIfRunning",
}

var WorkflowIdReusePolicy_value = map[string]int32{
	"Unspecified":              0,
	"AllowDuplicate":           1,
	"AllowDuplicateFailedOnly": 2,
	"RejectDuplicate":          3,
	"TerminateIfRunning":       4,
}

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",
	25: "BadModifyWorkflowPropertiesAttributes",
	26: "PendingChildWorkflowsLimitExceeded",
	27: "PendingActivitiesLimitExceeded",
	28: "PendingSignalsLimitExceeded",
	29: "PendingRequestCancelLimitExceeded",
	30: "BadUpdateWorkflowExecutionMessage",
	31: "UnhandledUpdate",
}

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,
	"BadModifyWorkflowPropertiesAttributes":               25,
	"PendingChildWorkflowsLimitExceeded":                  26,
	"PendingActivitiesLimitExceeded":                      27,
	"PendingSignalsLimitExceeded":                         28,
	"PendingRequestCancelLimitExceeded":                   29,
	"BadUpdateWorkflowExecutionMessage":                   30,
	"UnhandledUpdate":                                     31,
}

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 BatchOperationState

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 (BatchOperationState) EnumDescriptor

func (BatchOperationState) EnumDescriptor() ([]byte, []int)

func (BatchOperationState) String

func (x BatchOperationState) String() string

type BatchOperationType

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
)

func (BatchOperationType) EnumDescriptor

func (BatchOperationType) EnumDescriptor() ([]byte, []int)

func (BatchOperationType) String

func (x BatchOperationType) 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
	CANCEL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_NAMESPACE_NOT_FOUND                   CancelExternalWorkflowExecutionFailedCause = 2
)

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
	COMMAND_TYPE_PROTOCOL_MESSAGE                           CommandType = 14
	COMMAND_TYPE_MODIFY_WORKFLOW_PROPERTIES                 CommandType = 16
)

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
	// 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 (EventType) EnumDescriptor

func (EventType) EnumDescriptor() ([]byte, []int)

func (EventType) String

func (x EventType) String() string

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
	INDEXED_VALUE_TYPE_KEYWORD_LIST IndexedValueType = 7
)

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

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

func (PendingWorkflowTaskState) EnumDescriptor() ([]byte, []int)

func (PendingWorkflowTaskState) String

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

type ReplicationState int32

const (
	REPLICATION_STATE_UNSPECIFIED ReplicationState = 0
	REPLICATION_STATE_NORMAL      ReplicationState = 1
	REPLICATION_STATE_HANDOVER    ReplicationState = 2
)

func (ReplicationState) EnumDescriptor

func (ReplicationState) EnumDescriptor() ([]byte, []int)

func (ReplicationState) String

func (x ReplicationState) String() string

type ResetReapplyType

type ResetReapplyType int32

Reset reapplay(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 (ResetReapplyType) EnumDescriptor

func (ResetReapplyType) EnumDescriptor() ([]byte, []int)

func (ResetReapplyType) String

func (x ResetReapplyType) String() string

type ResourceExhaustedCause

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
)

func (ResourceExhaustedCause) EnumDescriptor

func (ResourceExhaustedCause) EnumDescriptor() ([]byte, []int)

func (ResourceExhaustedCause) String

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 ScheduleOverlapPolicy

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 (ScheduleOverlapPolicy) EnumDescriptor

func (ScheduleOverlapPolicy) EnumDescriptor() ([]byte, []int)

func (ScheduleOverlapPolicy) String

func (x ScheduleOverlapPolicy) String() string

type Severity

type Severity int32

const (
	SEVERITY_UNSPECIFIED Severity = 0
	SEVERITY_HIGH        Severity = 1
	SEVERITY_MEDIUM      Severity = 2
	SEVERITY_LOW         Severity = 3
)

func (Severity) EnumDescriptor

func (Severity) EnumDescriptor() ([]byte, []int)

func (Severity) String

func (x Severity) 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
	SIGNAL_EXTERNAL_WORKFLOW_EXECUTION_FAILED_CAUSE_NAMESPACE_NOT_FOUND                   SignalExternalWorkflowExecutionFailedCause = 2
)

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
	START_CHILD_WORKFLOW_EXECUTION_FAILED_CAUSE_NAMESPACE_NOT_FOUND     StartChildWorkflowExecutionFailedCause = 2
)

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 UpdateWorkflowExecutionLifecycleStage

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 (UpdateWorkflowExecutionLifecycleStage) EnumDescriptor

func (UpdateWorkflowExecutionLifecycleStage) EnumDescriptor() ([]byte, []int)

func (UpdateWorkflowExecutionLifecycleStage) String

func (x UpdateWorkflowExecutionLifecycleStage) 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
	// 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 (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
	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 (WorkflowTaskFailedCause) EnumDescriptor

func (WorkflowTaskFailedCause) EnumDescriptor() ([]byte, []int)

func (WorkflowTaskFailedCause) String

func (x WorkflowTaskFailedCause) String() string