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 ClusterMemberRole_name = map[int32]string{
0: "Unspecified",
1: "Frontend",
2: "History",
3: "Matching",
4: "Worker",
}
View Source
var ClusterMemberRole_value = map[string]int32{
"Unspecified": 0,
"Frontend": 1,
"History": 2,
"Matching": 3,
"Worker": 4,
}
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 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 PredicateType_name = map[int32]string{
0: "Unspecified",
1: "Universal",
2: "Empty",
3: "And",
4: "Or",
5: "Not",
6: "NamespaceId",
7: "TaskType",
}
View Source
var PredicateType_value = map[string]int32{
"Unspecified": 0,
"Universal": 1,
"Empty": 2,
"And": 3,
"Or": 4,
"Not": 5,
"NamespaceId": 6,
"TaskType": 7,
}
View Source
var ReplicationTaskType_name = map[int32]string{
0: "Unspecified",
1: "NamespaceTask",
2: "HistoryTask",
3: "SyncShardStatusTask",
4: "SyncActivityTask",
5: "HistoryMetadataTask",
6: "HistoryV2Task",
7: "SyncWorkflowStateTask",
}
View Source
var ReplicationTaskType_value = map[string]int32{
"Unspecified": 0,
"NamespaceTask": 1,
"HistoryTask": 2,
"SyncShardStatusTask": 3,
"SyncActivityTask": 4,
"HistoryMetadataTask": 5,
"HistoryV2Task": 6,
"SyncWorkflowStateTask": 7,
}
View Source
var TaskCategory_name = map[int32]string{
0: "Unspecified",
1: "Transfer",
2: "Timer",
3: "Replication",
4: "Visibility",
5: "Archival",
}
View Source
var TaskCategory_value = map[string]int32{
"Unspecified": 0,
"Transfer": 1,
"Timer": 2,
"Replication": 3,
"Visibility": 4,
"Archival": 5,
}
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",
10: "TransferResetWorkflow",
12: "WorkflowTaskTimeout",
13: "ActivityTimeout",
14: "UserTimer",
15: "WorkflowRunTimeout",
16: "DeleteHistoryEvent",
17: "ActivityRetryTimer",
18: "WorkflowBackoffTimer",
19: "VisibilityStartExecution",
20: "VisibilityUpsertExecution",
21: "VisibilityCloseExecution",
22: "VisibilityDeleteExecution",
24: "TransferDeleteExecution",
25: "ReplicationSyncWorkflowState",
26: "ArchivalArchiveExecution",
}
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,
"TransferResetWorkflow": 10,
"WorkflowTaskTimeout": 12,
"ActivityTimeout": 13,
"UserTimer": 14,
"WorkflowRunTimeout": 15,
"DeleteHistoryEvent": 16,
"ActivityRetryTimer": 17,
"WorkflowBackoffTimer": 18,
"VisibilityStartExecution": 19,
"VisibilityUpsertExecution": 20,
"VisibilityCloseExecution": 21,
"VisibilityDeleteExecution": 22,
"TransferDeleteExecution": 24,
"ReplicationSyncWorkflowState": 25,
"ArchivalArchiveExecution": 26,
}
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,
}
View Source
var WorkflowTaskType_name = map[int32]string{
0: "Unspecified",
1: "Normal",
2: "Transient",
3: "Speculative",
}
View Source
var WorkflowTaskType_value = map[string]int32{
"Unspecified": 0,
"Normal": 1,
"Transient": 2,
"Speculative": 3,
}
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 ClusterMemberRole ¶ added in v1.14.0
type ClusterMemberRole int32
const ( CLUSTER_MEMBER_ROLE_UNSPECIFIED ClusterMemberRole = 0 CLUSTER_MEMBER_ROLE_FRONTEND ClusterMemberRole = 1 CLUSTER_MEMBER_ROLE_HISTORY ClusterMemberRole = 2 CLUSTER_MEMBER_ROLE_MATCHING ClusterMemberRole = 3 CLUSTER_MEMBER_ROLE_WORKER ClusterMemberRole = 4 )
func (ClusterMemberRole) EnumDescriptor ¶ added in v1.14.0
func (ClusterMemberRole) EnumDescriptor() ([]byte, []int)
func (ClusterMemberRole) String ¶ added in v1.14.0
func (x ClusterMemberRole) 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 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 PredicateType ¶ added in v1.17.3
type PredicateType int32
const ( PREDICATE_TYPE_UNSPECIFIED PredicateType = 0 PREDICATE_TYPE_UNIVERSAL PredicateType = 1 PREDICATE_TYPE_EMPTY PredicateType = 2 PREDICATE_TYPE_AND PredicateType = 3 PREDICATE_TYPE_OR PredicateType = 4 PREDICATE_TYPE_NOT PredicateType = 5 PREDICATE_TYPE_NAMESPACE_ID PredicateType = 6 PREDICATE_TYPE_TASK_TYPE PredicateType = 7 )
func (PredicateType) EnumDescriptor ¶ added in v1.17.3
func (PredicateType) EnumDescriptor() ([]byte, []int)
func (PredicateType) String ¶ added in v1.17.3
func (x PredicateType) 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 REPLICATION_TASK_TYPE_SYNC_WORKFLOW_STATE_TASK ReplicationTaskType = 7 )
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 // Archival is the task type for workflow archival tasks. TASK_CATEGORY_ARCHIVAL TaskCategory = 5 )
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_RESET_WORKFLOW TaskType = 10 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 TASK_TYPE_TRANSFER_DELETE_EXECUTION TaskType = 24 TASK_TYPE_REPLICATION_SYNC_WORKFLOW_STATE TaskType = 25 TASK_TYPE_ARCHIVAL_ARCHIVE_EXECUTION TaskType = 26 )
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
type WorkflowTaskType ¶ added in v1.20.0
type WorkflowTaskType int32
const ( WORKFLOW_TASK_TYPE_UNSPECIFIED WorkflowTaskType = 0 WORKFLOW_TASK_TYPE_NORMAL WorkflowTaskType = 1 // TODO (alex): TRANSIENT is not current used. Needs to be set when Attempt>1. WORKFLOW_TASK_TYPE_TRANSIENT WorkflowTaskType = 2 WORKFLOW_TASK_TYPE_SPECULATIVE WorkflowTaskType = 3 )
func (WorkflowTaskType) EnumDescriptor ¶ added in v1.20.0
func (WorkflowTaskType) EnumDescriptor() ([]byte, []int)
func (WorkflowTaskType) String ¶ added in v1.20.0
func (x WorkflowTaskType) String() string
Click to show internal directories.
Click to hide internal directories.