Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ChecksumFlavor_name = map[int32]string{
0: "Unspecified",
1: "IeeeCrc32OverProto3Binary",
}
View Source
var ChecksumFlavor_value = map[string]int32{
"Unspecified": 0,
"IeeeCrc32OverProto3Binary": 1,
}
View Source
var DeadLetterQueueType_name = map[int32]string{
0: "Unspecified",
1: "Replication",
2: "Namespace",
}
View Source
var DeadLetterQueueType_value = map[string]int32{
"Unspecified": 0,
"Replication": 1,
"Namespace": 2,
}
View Source
var FieldType_name = map[int32]string{
0: "Unspecified",
1: "String",
2: "Int",
3: "Bool",
4: "Binary",
}
View Source
var FieldType_value = map[string]int32{
"Unspecified": 0,
"String": 1,
"Int": 2,
"Bool": 3,
"Binary": 4,
}
View Source
var MessageType_name = map[int32]string{
0: "Unspecified",
1: "Index",
2: "Delete",
}
View Source
var MessageType_value = map[string]int32{
"Unspecified": 0,
"Index": 1,
"Delete": 2,
}
View Source
var NamespaceOperation_name = map[int32]string{
0: "Unspecified",
1: "Create",
2: "Update",
}
View Source
var NamespaceOperation_value = map[string]int32{
"Unspecified": 0,
"Create": 1,
"Update": 2,
}
View Source
var ReplicationTaskType_name = map[int32]string{
0: "Unspecified",
1: "NamespaceTask",
2: "HistoryTask",
3: "SyncShardStatusTask",
4: "SyncActivityTask",
5: "HistoryMetadataTask",
6: "HistoryV2Task",
}
View Source
var ReplicationTaskType_value = map[string]int32{
"Unspecified": 0,
"NamespaceTask": 1,
"HistoryTask": 2,
"SyncShardStatusTask": 3,
"SyncActivityTask": 4,
"HistoryMetadataTask": 5,
"HistoryV2Task": 6,
}
View Source
var TaskCategory_name = map[int32]string{
0: "Unspecified",
1: "Transfer",
2: "Timer",
3: "Replication",
4: "Visibility",
}
View Source
var TaskCategory_value = map[string]int32{
"Unspecified": 0,
"Transfer": 1,
"Timer": 2,
"Replication": 3,
"Visibility": 4,
}
View Source
var TaskSource_name = map[int32]string{
0: "Unspecified",
1: "History",
2: "DbBacklog",
}
View Source
var TaskSource_value = map[string]int32{
"Unspecified": 0,
"History": 1,
"DbBacklog": 2,
}
View Source
var TaskType_name = map[int32]string{
0: "Unspecified",
1: "ReplicationHistory",
2: "ReplicationSyncActivity",
3: "TransferWorkflowTask",
4: "TransferActivityTask",
5: "TransferCloseExecution",
6: "TransferCancelExecution",
7: "TransferStartChildExecution",
8: "TransferSignalExecution",
9: "TransferRecordWorkflowStarted",
10: "TransferResetWorkflow",
11: "TransferUpsertWorkflowSearchAttributes",
12: "WorkflowTaskTimeout",
13: "ActivityTimeout",
14: "UserTimer",
15: "WorkflowRunTimeout",
16: "DeleteHistoryEvent",
17: "ActivityRetryTimer",
18: "WorkflowBackoffTimer",
19: "VisibilityStartExecution",
20: "VisibilityUpsertExecution",
21: "VisibilityCloseExecution",
22: "VisibilityDeleteExecution",
}
View Source
var TaskType_value = map[string]int32{
"Unspecified": 0,
"ReplicationHistory": 1,
"ReplicationSyncActivity": 2,
"TransferWorkflowTask": 3,
"TransferActivityTask": 4,
"TransferCloseExecution": 5,
"TransferCancelExecution": 6,
"TransferStartChildExecution": 7,
"TransferSignalExecution": 8,
"TransferRecordWorkflowStarted": 9,
"TransferResetWorkflow": 10,
"TransferUpsertWorkflowSearchAttributes": 11,
"WorkflowTaskTimeout": 12,
"ActivityTimeout": 13,
"UserTimer": 14,
"WorkflowRunTimeout": 15,
"DeleteHistoryEvent": 16,
"ActivityRetryTimer": 17,
"WorkflowBackoffTimer": 18,
"VisibilityStartExecution": 19,
"VisibilityUpsertExecution": 20,
"VisibilityCloseExecution": 21,
"VisibilityDeleteExecution": 22,
}
View Source
var WorkflowBackoffType_name = map[int32]string{
0: "Unspecified",
1: "Retry",
2: "Cron",
}
View Source
var WorkflowBackoffType_value = map[string]int32{
"Unspecified": 0,
"Retry": 1,
"Cron": 2,
}
View Source
var WorkflowExecutionState_name = map[int32]string{
0: "Unspecified",
1: "Created",
2: "Running",
3: "Completed",
4: "Zombie",
5: "Void",
6: "Corrupted",
}
View Source
var WorkflowExecutionState_value = map[string]int32{
"Unspecified": 0,
"Created": 1,
"Running": 2,
"Completed": 3,
"Zombie": 4,
"Void": 5,
"Corrupted": 6,
}
Functions ¶
This section is empty.
Types ¶
type ChecksumFlavor ¶
type ChecksumFlavor int32
const ( CHECKSUM_FLAVOR_UNSPECIFIED ChecksumFlavor = 0 CHECKSUM_FLAVOR_IEEE_CRC32_OVER_PROTO3_BINARY ChecksumFlavor = 1 )
func (ChecksumFlavor) EnumDescriptor ¶
func (ChecksumFlavor) EnumDescriptor() ([]byte, []int)
func (ChecksumFlavor) String ¶
func (x ChecksumFlavor) String() string
type DeadLetterQueueType ¶
type DeadLetterQueueType int32
const ( DEAD_LETTER_QUEUE_TYPE_UNSPECIFIED DeadLetterQueueType = 0 DEAD_LETTER_QUEUE_TYPE_REPLICATION DeadLetterQueueType = 1 DEAD_LETTER_QUEUE_TYPE_NAMESPACE DeadLetterQueueType = 2 )
func (DeadLetterQueueType) EnumDescriptor ¶
func (DeadLetterQueueType) EnumDescriptor() ([]byte, []int)
func (DeadLetterQueueType) String ¶
func (x DeadLetterQueueType) String() string
type FieldType ¶
type FieldType int32
Deprecated. Remove with kafka removal.
func (FieldType) EnumDescriptor ¶
type MessageType ¶
type MessageType int32
Deprecated. Remove with kafka removal.
const ( MESSAGE_TYPE_UNSPECIFIED MessageType = 0 MESSAGE_TYPE_INDEX MessageType = 1 MESSAGE_TYPE_DELETE MessageType = 2 )
func (MessageType) EnumDescriptor ¶
func (MessageType) EnumDescriptor() ([]byte, []int)
func (MessageType) String ¶
func (x MessageType) String() string
type NamespaceOperation ¶
type NamespaceOperation int32
const ( NAMESPACE_OPERATION_UNSPECIFIED NamespaceOperation = 0 NAMESPACE_OPERATION_CREATE NamespaceOperation = 1 NAMESPACE_OPERATION_UPDATE NamespaceOperation = 2 )
func (NamespaceOperation) EnumDescriptor ¶
func (NamespaceOperation) EnumDescriptor() ([]byte, []int)
func (NamespaceOperation) String ¶
func (x NamespaceOperation) String() string
type ReplicationTaskType ¶
type ReplicationTaskType int32
const ( REPLICATION_TASK_TYPE_UNSPECIFIED ReplicationTaskType = 0 REPLICATION_TASK_TYPE_NAMESPACE_TASK ReplicationTaskType = 1 REPLICATION_TASK_TYPE_HISTORY_TASK ReplicationTaskType = 2 REPLICATION_TASK_TYPE_SYNC_SHARD_STATUS_TASK ReplicationTaskType = 3 REPLICATION_TASK_TYPE_SYNC_ACTIVITY_TASK ReplicationTaskType = 4 REPLICATION_TASK_TYPE_HISTORY_METADATA_TASK ReplicationTaskType = 5 REPLICATION_TASK_TYPE_HISTORY_V2_TASK ReplicationTaskType = 6 )
func (ReplicationTaskType) EnumDescriptor ¶
func (ReplicationTaskType) EnumDescriptor() ([]byte, []int)
func (ReplicationTaskType) String ¶
func (x ReplicationTaskType) String() string
type TaskCategory ¶
type TaskCategory int32
const ( TASK_CATEGORY_UNSPECIFIED TaskCategory = 0 // Transfer is the task type for transfer task. TASK_CATEGORY_TRANSFER TaskCategory = 1 // Timer is the task type for timer task. TASK_CATEGORY_TIMER TaskCategory = 2 // Replication is the task type for replication task. TASK_CATEGORY_REPLICATION TaskCategory = 3 // Visibility is the task type for visibility task. TASK_CATEGORY_VISIBILITY TaskCategory = 4 )
func (TaskCategory) EnumDescriptor ¶
func (TaskCategory) EnumDescriptor() ([]byte, []int)
func (TaskCategory) String ¶
func (x TaskCategory) String() string
type TaskSource ¶
type TaskSource int32
TaskSource is the source from which a task was produced.
const ( TASK_SOURCE_UNSPECIFIED TaskSource = 0 // Task produced by history service. TASK_SOURCE_HISTORY TaskSource = 1 // Task produced from matching db backlog. TASK_SOURCE_DB_BACKLOG TaskSource = 2 )
func (TaskSource) EnumDescriptor ¶
func (TaskSource) EnumDescriptor() ([]byte, []int)
func (TaskSource) String ¶
func (x TaskSource) String() string
type TaskType ¶
type TaskType int32
const ( TASK_TYPE_UNSPECIFIED TaskType = 0 TASK_TYPE_REPLICATION_HISTORY TaskType = 1 TASK_TYPE_REPLICATION_SYNC_ACTIVITY TaskType = 2 TASK_TYPE_TRANSFER_WORKFLOW_TASK TaskType = 3 TASK_TYPE_TRANSFER_ACTIVITY_TASK TaskType = 4 TASK_TYPE_TRANSFER_CLOSE_EXECUTION TaskType = 5 TASK_TYPE_TRANSFER_CANCEL_EXECUTION TaskType = 6 TASK_TYPE_TRANSFER_START_CHILD_EXECUTION TaskType = 7 TASK_TYPE_TRANSFER_SIGNAL_EXECUTION TaskType = 8 TASK_TYPE_TRANSFER_RECORD_WORKFLOW_STARTED TaskType = 9 // Deprecated: Do not use. TASK_TYPE_TRANSFER_RESET_WORKFLOW TaskType = 10 TASK_TYPE_TRANSFER_UPSERT_WORKFLOW_SEARCH_ATTRIBUTES TaskType = 11 // Deprecated: Do not use. TASK_TYPE_WORKFLOW_TASK_TIMEOUT TaskType = 12 TASK_TYPE_ACTIVITY_TIMEOUT TaskType = 13 TASK_TYPE_USER_TIMER TaskType = 14 TASK_TYPE_WORKFLOW_RUN_TIMEOUT TaskType = 15 TASK_TYPE_DELETE_HISTORY_EVENT TaskType = 16 TASK_TYPE_ACTIVITY_RETRY_TIMER TaskType = 17 TASK_TYPE_WORKFLOW_BACKOFF_TIMER TaskType = 18 TASK_TYPE_VISIBILITY_START_EXECUTION TaskType = 19 TASK_TYPE_VISIBILITY_UPSERT_EXECUTION TaskType = 20 TASK_TYPE_VISIBILITY_CLOSE_EXECUTION TaskType = 21 TASK_TYPE_VISIBILITY_DELETE_EXECUTION TaskType = 22 )
func (TaskType) EnumDescriptor ¶
type WorkflowBackoffType ¶
type WorkflowBackoffType int32
const ( WORKFLOW_BACKOFF_TYPE_UNSPECIFIED WorkflowBackoffType = 0 WORKFLOW_BACKOFF_TYPE_RETRY WorkflowBackoffType = 1 WORKFLOW_BACKOFF_TYPE_CRON WorkflowBackoffType = 2 )
func (WorkflowBackoffType) EnumDescriptor ¶
func (WorkflowBackoffType) EnumDescriptor() ([]byte, []int)
func (WorkflowBackoffType) String ¶
func (x WorkflowBackoffType) String() string
type WorkflowExecutionState ¶
type WorkflowExecutionState int32
const ( WORKFLOW_EXECUTION_STATE_UNSPECIFIED WorkflowExecutionState = 0 WORKFLOW_EXECUTION_STATE_CREATED WorkflowExecutionState = 1 WORKFLOW_EXECUTION_STATE_RUNNING WorkflowExecutionState = 2 WORKFLOW_EXECUTION_STATE_COMPLETED WorkflowExecutionState = 3 WORKFLOW_EXECUTION_STATE_ZOMBIE WorkflowExecutionState = 4 WORKFLOW_EXECUTION_STATE_VOID WorkflowExecutionState = 5 WORKFLOW_EXECUTION_STATE_CORRUPTED WorkflowExecutionState = 6 )
func (WorkflowExecutionState) EnumDescriptor ¶
func (WorkflowExecutionState) EnumDescriptor() ([]byte, []int)
func (WorkflowExecutionState) String ¶
func (x WorkflowExecutionState) String() string
Click to show internal directories.
Click to hide internal directories.