Documentation ¶
Overview ¶
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Index ¶
- Variables
- type ChecksumFlavor
- func (ChecksumFlavor) Descriptor() protoreflect.EnumDescriptor
- func (x ChecksumFlavor) Enum() *ChecksumFlavor
- func (ChecksumFlavor) EnumDescriptor() ([]byte, []int)deprecated
- func (x ChecksumFlavor) Number() protoreflect.EnumNumber
- func (x ChecksumFlavor) String() string
- func (ChecksumFlavor) Type() protoreflect.EnumType
- type ClusterMemberRole
- func (ClusterMemberRole) Descriptor() protoreflect.EnumDescriptor
- func (x ClusterMemberRole) Enum() *ClusterMemberRole
- func (ClusterMemberRole) EnumDescriptor() ([]byte, []int)deprecated
- func (x ClusterMemberRole) Number() protoreflect.EnumNumber
- func (x ClusterMemberRole) String() string
- func (ClusterMemberRole) Type() protoreflect.EnumType
- type DLQOperationState
- func (DLQOperationState) Descriptor() protoreflect.EnumDescriptor
- func (x DLQOperationState) Enum() *DLQOperationState
- func (DLQOperationState) EnumDescriptor() ([]byte, []int)deprecated
- func (x DLQOperationState) Number() protoreflect.EnumNumber
- func (x DLQOperationState) String() string
- func (DLQOperationState) Type() protoreflect.EnumType
- type DLQOperationType
- func (DLQOperationType) Descriptor() protoreflect.EnumDescriptor
- func (x DLQOperationType) Enum() *DLQOperationType
- func (DLQOperationType) EnumDescriptor() ([]byte, []int)deprecated
- func (x DLQOperationType) Number() protoreflect.EnumNumber
- func (x DLQOperationType) String() string
- func (DLQOperationType) Type() protoreflect.EnumType
- type DeadLetterQueueType
- func (DeadLetterQueueType) Descriptor() protoreflect.EnumDescriptor
- func (x DeadLetterQueueType) Enum() *DeadLetterQueueType
- func (DeadLetterQueueType) EnumDescriptor() ([]byte, []int)deprecated
- func (x DeadLetterQueueType) Number() protoreflect.EnumNumber
- func (x DeadLetterQueueType) String() string
- func (DeadLetterQueueType) Type() protoreflect.EnumType
- type NamespaceOperation
- func (NamespaceOperation) Descriptor() protoreflect.EnumDescriptor
- func (x NamespaceOperation) Enum() *NamespaceOperation
- func (NamespaceOperation) EnumDescriptor() ([]byte, []int)deprecated
- func (x NamespaceOperation) Number() protoreflect.EnumNumber
- func (x NamespaceOperation) String() string
- func (NamespaceOperation) Type() protoreflect.EnumType
- type PredicateType
- func (PredicateType) Descriptor() protoreflect.EnumDescriptor
- func (x PredicateType) Enum() *PredicateType
- func (PredicateType) EnumDescriptor() ([]byte, []int)deprecated
- func (x PredicateType) Number() protoreflect.EnumNumber
- func (x PredicateType) String() string
- func (PredicateType) Type() protoreflect.EnumType
- type ReplicationTaskType
- func (ReplicationTaskType) Descriptor() protoreflect.EnumDescriptor
- func (x ReplicationTaskType) Enum() *ReplicationTaskType
- func (ReplicationTaskType) EnumDescriptor() ([]byte, []int)
- func (x ReplicationTaskType) Number() protoreflect.EnumNumber
- func (x ReplicationTaskType) String() string
- func (ReplicationTaskType) Type() protoreflect.EnumType
- type TaskSource
- type TaskType
- type WorkflowBackoffType
- func (WorkflowBackoffType) Descriptor() protoreflect.EnumDescriptor
- func (x WorkflowBackoffType) Enum() *WorkflowBackoffType
- func (WorkflowBackoffType) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkflowBackoffType) Number() protoreflect.EnumNumber
- func (x WorkflowBackoffType) String() string
- func (WorkflowBackoffType) Type() protoreflect.EnumType
- type WorkflowExecutionState
- func (WorkflowExecutionState) Descriptor() protoreflect.EnumDescriptor
- func (x WorkflowExecutionState) Enum() *WorkflowExecutionState
- func (WorkflowExecutionState) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkflowExecutionState) Number() protoreflect.EnumNumber
- func (x WorkflowExecutionState) String() string
- func (WorkflowExecutionState) Type() protoreflect.EnumType
- type WorkflowTaskType
- func (WorkflowTaskType) Descriptor() protoreflect.EnumDescriptor
- func (x WorkflowTaskType) Enum() *WorkflowTaskType
- func (WorkflowTaskType) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkflowTaskType) Number() protoreflect.EnumNumber
- func (x WorkflowTaskType) String() string
- func (WorkflowTaskType) Type() protoreflect.EnumType
Constants ¶
This section is empty.
Variables ¶
var ( ClusterMemberRole_name = map[int32]string{ 0: "CLUSTER_MEMBER_ROLE_UNSPECIFIED", 1: "CLUSTER_MEMBER_ROLE_FRONTEND", 2: "CLUSTER_MEMBER_ROLE_HISTORY", 3: "CLUSTER_MEMBER_ROLE_MATCHING", 4: "CLUSTER_MEMBER_ROLE_WORKER", } ClusterMemberRole_value = map[string]int32{ "CLUSTER_MEMBER_ROLE_UNSPECIFIED": 0, "CLUSTER_MEMBER_ROLE_FRONTEND": 1, "CLUSTER_MEMBER_ROLE_HISTORY": 2, "CLUSTER_MEMBER_ROLE_MATCHING": 3, "CLUSTER_MEMBER_ROLE_WORKER": 4, } )
Enum value maps for ClusterMemberRole.
var ( DeadLetterQueueType_name = map[int32]string{ 0: "DEAD_LETTER_QUEUE_TYPE_UNSPECIFIED", 1: "DEAD_LETTER_QUEUE_TYPE_REPLICATION", 2: "DEAD_LETTER_QUEUE_TYPE_NAMESPACE", } DeadLetterQueueType_value = map[string]int32{ "DEAD_LETTER_QUEUE_TYPE_UNSPECIFIED": 0, "DEAD_LETTER_QUEUE_TYPE_REPLICATION": 1, "DEAD_LETTER_QUEUE_TYPE_NAMESPACE": 2, } )
Enum value maps for DeadLetterQueueType.
var ( ChecksumFlavor_name = map[int32]string{ 0: "CHECKSUM_FLAVOR_UNSPECIFIED", 1: "CHECKSUM_FLAVOR_IEEE_CRC32_OVER_PROTO3_BINARY", } ChecksumFlavor_value = map[string]int32{ "CHECKSUM_FLAVOR_UNSPECIFIED": 0, "CHECKSUM_FLAVOR_IEEE_CRC32_OVER_PROTO3_BINARY": 1, } )
Enum value maps for ChecksumFlavor.
var ( DLQOperationType_name = map[int32]string{ 0: "DLQ_OPERATION_TYPE_UNSPECIFIED", 1: "DLQ_OPERATION_TYPE_MERGE", 2: "DLQ_OPERATION_TYPE_PURGE", } DLQOperationType_value = map[string]int32{ "DLQ_OPERATION_TYPE_UNSPECIFIED": 0, "DLQ_OPERATION_TYPE_MERGE": 1, "DLQ_OPERATION_TYPE_PURGE": 2, } )
Enum value maps for DLQOperationType.
var ( DLQOperationState_name = map[int32]string{ 0: "DLQ_OPERATION_STATE_UNSPECIFIED", 1: "DLQ_OPERATION_STATE_RUNNING", 2: "DLQ_OPERATION_STATE_COMPLETED", 3: "DLQ_OPERATION_STATE_FAILED", } DLQOperationState_value = map[string]int32{ "DLQ_OPERATION_STATE_UNSPECIFIED": 0, "DLQ_OPERATION_STATE_RUNNING": 1, "DLQ_OPERATION_STATE_COMPLETED": 2, "DLQ_OPERATION_STATE_FAILED": 3, } )
Enum value maps for DLQOperationState.
var ( PredicateType_name = map[int32]string{ 0: "PREDICATE_TYPE_UNSPECIFIED", 1: "PREDICATE_TYPE_UNIVERSAL", 2: "PREDICATE_TYPE_EMPTY", 3: "PREDICATE_TYPE_AND", 4: "PREDICATE_TYPE_OR", 5: "PREDICATE_TYPE_NOT", 6: "PREDICATE_TYPE_NAMESPACE_ID", 7: "PREDICATE_TYPE_TASK_TYPE", 8: "PREDICATE_TYPE_DESTINATION", } PredicateType_value = map[string]int32{ "PREDICATE_TYPE_UNSPECIFIED": 0, "PREDICATE_TYPE_UNIVERSAL": 1, "PREDICATE_TYPE_EMPTY": 2, "PREDICATE_TYPE_AND": 3, "PREDICATE_TYPE_OR": 4, "PREDICATE_TYPE_NOT": 5, "PREDICATE_TYPE_NAMESPACE_ID": 6, "PREDICATE_TYPE_TASK_TYPE": 7, "PREDICATE_TYPE_DESTINATION": 8, } )
Enum value maps for PredicateType.
var ( ReplicationTaskType_name = map[int32]string{ 0: "REPLICATION_TASK_TYPE_UNSPECIFIED", 1: "REPLICATION_TASK_TYPE_NAMESPACE_TASK", 2: "REPLICATION_TASK_TYPE_HISTORY_TASK", 3: "REPLICATION_TASK_TYPE_SYNC_SHARD_STATUS_TASK", 4: "REPLICATION_TASK_TYPE_SYNC_ACTIVITY_TASK", 5: "REPLICATION_TASK_TYPE_HISTORY_METADATA_TASK", 6: "REPLICATION_TASK_TYPE_HISTORY_V2_TASK", 7: "REPLICATION_TASK_TYPE_SYNC_WORKFLOW_STATE_TASK", 8: "REPLICATION_TASK_TYPE_TASK_QUEUE_USER_DATA", } ReplicationTaskType_value = map[string]int32{ "REPLICATION_TASK_TYPE_UNSPECIFIED": 0, "REPLICATION_TASK_TYPE_NAMESPACE_TASK": 1, "REPLICATION_TASK_TYPE_HISTORY_TASK": 2, "REPLICATION_TASK_TYPE_SYNC_SHARD_STATUS_TASK": 3, "REPLICATION_TASK_TYPE_SYNC_ACTIVITY_TASK": 4, "REPLICATION_TASK_TYPE_HISTORY_METADATA_TASK": 5, "REPLICATION_TASK_TYPE_HISTORY_V2_TASK": 6, "REPLICATION_TASK_TYPE_SYNC_WORKFLOW_STATE_TASK": 7, "REPLICATION_TASK_TYPE_TASK_QUEUE_USER_DATA": 8, } )
Enum value maps for ReplicationTaskType.
var ( NamespaceOperation_name = map[int32]string{ 0: "NAMESPACE_OPERATION_UNSPECIFIED", 1: "NAMESPACE_OPERATION_CREATE", 2: "NAMESPACE_OPERATION_UPDATE", } NamespaceOperation_value = map[string]int32{ "NAMESPACE_OPERATION_UNSPECIFIED": 0, "NAMESPACE_OPERATION_CREATE": 1, "NAMESPACE_OPERATION_UPDATE": 2, } )
Enum value maps for NamespaceOperation.
var ( TaskSource_name = map[int32]string{ 0: "TASK_SOURCE_UNSPECIFIED", 1: "TASK_SOURCE_HISTORY", 2: "TASK_SOURCE_DB_BACKLOG", } TaskSource_value = map[string]int32{ "TASK_SOURCE_UNSPECIFIED": 0, "TASK_SOURCE_HISTORY": 1, "TASK_SOURCE_DB_BACKLOG": 2, } )
Enum value maps for TaskSource.
var ( TaskType_name = map[int32]string{ 0: "TASK_TYPE_UNSPECIFIED", 1: "TASK_TYPE_REPLICATION_HISTORY", 2: "TASK_TYPE_REPLICATION_SYNC_ACTIVITY", 3: "TASK_TYPE_TRANSFER_WORKFLOW_TASK", 4: "TASK_TYPE_TRANSFER_ACTIVITY_TASK", 5: "TASK_TYPE_TRANSFER_CLOSE_EXECUTION", 6: "TASK_TYPE_TRANSFER_CANCEL_EXECUTION", 7: "TASK_TYPE_TRANSFER_START_CHILD_EXECUTION", 8: "TASK_TYPE_TRANSFER_SIGNAL_EXECUTION", 10: "TASK_TYPE_TRANSFER_RESET_WORKFLOW", 12: "TASK_TYPE_WORKFLOW_TASK_TIMEOUT", 13: "TASK_TYPE_ACTIVITY_TIMEOUT", 14: "TASK_TYPE_USER_TIMER", 15: "TASK_TYPE_WORKFLOW_RUN_TIMEOUT", 16: "TASK_TYPE_DELETE_HISTORY_EVENT", 17: "TASK_TYPE_ACTIVITY_RETRY_TIMER", 18: "TASK_TYPE_WORKFLOW_BACKOFF_TIMER", 19: "TASK_TYPE_VISIBILITY_START_EXECUTION", 20: "TASK_TYPE_VISIBILITY_UPSERT_EXECUTION", 21: "TASK_TYPE_VISIBILITY_CLOSE_EXECUTION", 22: "TASK_TYPE_VISIBILITY_DELETE_EXECUTION", 24: "TASK_TYPE_TRANSFER_DELETE_EXECUTION", 25: "TASK_TYPE_REPLICATION_SYNC_WORKFLOW_STATE", 26: "TASK_TYPE_ARCHIVAL_ARCHIVE_EXECUTION", 27: "TASK_TYPE_STATE_MACHINE_OUTBOUND", 28: "TASK_TYPE_STATE_MACHINE_TIMER", 29: "TASK_TYPE_WORKFLOW_EXECUTION_TIMEOUT", } TaskType_value = map[string]int32{ "TASK_TYPE_UNSPECIFIED": 0, "TASK_TYPE_REPLICATION_HISTORY": 1, "TASK_TYPE_REPLICATION_SYNC_ACTIVITY": 2, "TASK_TYPE_TRANSFER_WORKFLOW_TASK": 3, "TASK_TYPE_TRANSFER_ACTIVITY_TASK": 4, "TASK_TYPE_TRANSFER_CLOSE_EXECUTION": 5, "TASK_TYPE_TRANSFER_CANCEL_EXECUTION": 6, "TASK_TYPE_TRANSFER_START_CHILD_EXECUTION": 7, "TASK_TYPE_TRANSFER_SIGNAL_EXECUTION": 8, "TASK_TYPE_TRANSFER_RESET_WORKFLOW": 10, "TASK_TYPE_WORKFLOW_TASK_TIMEOUT": 12, "TASK_TYPE_ACTIVITY_TIMEOUT": 13, "TASK_TYPE_USER_TIMER": 14, "TASK_TYPE_WORKFLOW_RUN_TIMEOUT": 15, "TASK_TYPE_DELETE_HISTORY_EVENT": 16, "TASK_TYPE_ACTIVITY_RETRY_TIMER": 17, "TASK_TYPE_WORKFLOW_BACKOFF_TIMER": 18, "TASK_TYPE_VISIBILITY_START_EXECUTION": 19, "TASK_TYPE_VISIBILITY_UPSERT_EXECUTION": 20, "TASK_TYPE_VISIBILITY_CLOSE_EXECUTION": 21, "TASK_TYPE_VISIBILITY_DELETE_EXECUTION": 22, "TASK_TYPE_TRANSFER_DELETE_EXECUTION": 24, "TASK_TYPE_REPLICATION_SYNC_WORKFLOW_STATE": 25, "TASK_TYPE_ARCHIVAL_ARCHIVE_EXECUTION": 26, "TASK_TYPE_STATE_MACHINE_OUTBOUND": 27, "TASK_TYPE_STATE_MACHINE_TIMER": 28, "TASK_TYPE_WORKFLOW_EXECUTION_TIMEOUT": 29, } )
Enum value maps for TaskType.
var ( WorkflowExecutionState_name = map[int32]string{ 0: "WORKFLOW_EXECUTION_STATE_UNSPECIFIED", 1: "WORKFLOW_EXECUTION_STATE_CREATED", 2: "WORKFLOW_EXECUTION_STATE_RUNNING", 3: "WORKFLOW_EXECUTION_STATE_COMPLETED", 4: "WORKFLOW_EXECUTION_STATE_ZOMBIE", 5: "WORKFLOW_EXECUTION_STATE_VOID", 6: "WORKFLOW_EXECUTION_STATE_CORRUPTED", } WorkflowExecutionState_value = map[string]int32{ "WORKFLOW_EXECUTION_STATE_UNSPECIFIED": 0, "WORKFLOW_EXECUTION_STATE_CREATED": 1, "WORKFLOW_EXECUTION_STATE_RUNNING": 2, "WORKFLOW_EXECUTION_STATE_COMPLETED": 3, "WORKFLOW_EXECUTION_STATE_ZOMBIE": 4, "WORKFLOW_EXECUTION_STATE_VOID": 5, "WORKFLOW_EXECUTION_STATE_CORRUPTED": 6, } )
Enum value maps for WorkflowExecutionState.
var ( WorkflowBackoffType_name = map[int32]string{ 0: "WORKFLOW_BACKOFF_TYPE_UNSPECIFIED", 1: "WORKFLOW_BACKOFF_TYPE_RETRY", 2: "WORKFLOW_BACKOFF_TYPE_CRON", 3: "WORKFLOW_BACKOFF_TYPE_DELAY_START", } WorkflowBackoffType_value = map[string]int32{ "WORKFLOW_BACKOFF_TYPE_UNSPECIFIED": 0, "WORKFLOW_BACKOFF_TYPE_RETRY": 1, "WORKFLOW_BACKOFF_TYPE_CRON": 2, "WORKFLOW_BACKOFF_TYPE_DELAY_START": 3, } )
Enum value maps for WorkflowBackoffType.
var ( WorkflowTaskType_name = map[int32]string{ 0: "WORKFLOW_TASK_TYPE_UNSPECIFIED", 1: "WORKFLOW_TASK_TYPE_NORMAL", 2: "WORKFLOW_TASK_TYPE_TRANSIENT", 3: "WORKFLOW_TASK_TYPE_SPECULATIVE", } WorkflowTaskType_value = map[string]int32{ "WORKFLOW_TASK_TYPE_UNSPECIFIED": 0, "WORKFLOW_TASK_TYPE_NORMAL": 1, "WORKFLOW_TASK_TYPE_TRANSIENT": 2, "WORKFLOW_TASK_TYPE_SPECULATIVE": 3, } )
Enum value maps for WorkflowTaskType.
var (
ChecksumFlavor_shorthandValue = map[string]int32{
"Unspecified": 0,
"IeeeCrc32OverProto3Binary": 1,
}
)
var (
ClusterMemberRole_shorthandValue = map[string]int32{
"Unspecified": 0,
"Frontend": 1,
"History": 2,
"Matching": 3,
"Worker": 4,
}
)
var (
DLQOperationState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Running": 1,
"Completed": 2,
"Failed": 3,
}
)
var (
DLQOperationType_shorthandValue = map[string]int32{
"Unspecified": 0,
"Merge": 1,
"Purge": 2,
}
)
var (
DeadLetterQueueType_shorthandValue = map[string]int32{
"Unspecified": 0,
"Replication": 1,
"Namespace": 2,
}
)
var File_temporal_server_api_enums_v1_cluster_proto protoreflect.FileDescriptor
var File_temporal_server_api_enums_v1_common_proto protoreflect.FileDescriptor
var File_temporal_server_api_enums_v1_dlq_proto protoreflect.FileDescriptor
var File_temporal_server_api_enums_v1_predicate_proto protoreflect.FileDescriptor
var File_temporal_server_api_enums_v1_replication_proto protoreflect.FileDescriptor
var File_temporal_server_api_enums_v1_task_proto protoreflect.FileDescriptor
var File_temporal_server_api_enums_v1_workflow_proto protoreflect.FileDescriptor
var File_temporal_server_api_enums_v1_workflow_task_type_proto protoreflect.FileDescriptor
var (
NamespaceOperation_shorthandValue = map[string]int32{
"Unspecified": 0,
"Create": 1,
"Update": 2,
}
)
var (
PredicateType_shorthandValue = map[string]int32{
"Unspecified": 0,
"Universal": 1,
"Empty": 2,
"And": 3,
"Or": 4,
"Not": 5,
"NamespaceId": 6,
"TaskType": 7,
"Destination": 8,
}
)
var (
ReplicationTaskType_shorthandValue = map[string]int32{
"Unspecified": 0,
"NamespaceTask": 1,
"HistoryTask": 2,
"SyncShardStatusTask": 3,
"SyncActivityTask": 4,
"HistoryMetadataTask": 5,
"HistoryV2Task": 6,
"SyncWorkflowStateTask": 7,
"TaskQueueUserData": 8,
}
)
var (
TaskSource_shorthandValue = map[string]int32{
"Unspecified": 0,
"History": 1,
"DbBacklog": 2,
}
)
var (
TaskType_shorthandValue = 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,
"StateMachineOutbound": 27,
"StateMachineTimer": 28,
"WorkflowExecutionTimeout": 29,
}
)
var (
WorkflowBackoffType_shorthandValue = map[string]int32{
"Unspecified": 0,
"Retry": 1,
"Cron": 2,
"DelayStart": 3,
}
)
var (
WorkflowExecutionState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Created": 1,
"Running": 2,
"Completed": 3,
"Zombie": 4,
"Void": 5,
"Corrupted": 6,
}
)
var (
WorkflowTaskType_shorthandValue = 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 ChecksumFlavorFromString ¶ added in v1.23.0
func ChecksumFlavorFromString(s string) (ChecksumFlavor, error)
ChecksumFlavorFromString parses a ChecksumFlavor value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to ChecksumFlavor
func (ChecksumFlavor) Descriptor ¶ added in v1.23.0
func (ChecksumFlavor) Descriptor() protoreflect.EnumDescriptor
func (ChecksumFlavor) Enum ¶ added in v1.23.0
func (x ChecksumFlavor) Enum() *ChecksumFlavor
func (ChecksumFlavor) EnumDescriptor
deprecated
func (ChecksumFlavor) EnumDescriptor() ([]byte, []int)
Deprecated: Use ChecksumFlavor.Descriptor instead.
func (ChecksumFlavor) Number ¶ added in v1.23.0
func (x ChecksumFlavor) Number() protoreflect.EnumNumber
func (ChecksumFlavor) String ¶
func (x ChecksumFlavor) String() string
func (ChecksumFlavor) Type ¶ added in v1.23.0
func (ChecksumFlavor) Type() protoreflect.EnumType
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 ClusterMemberRoleFromString ¶ added in v1.23.0
func ClusterMemberRoleFromString(s string) (ClusterMemberRole, error)
ClusterMemberRoleFromString parses a ClusterMemberRole value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to ClusterMemberRole
func (ClusterMemberRole) Descriptor ¶ added in v1.23.0
func (ClusterMemberRole) Descriptor() protoreflect.EnumDescriptor
func (ClusterMemberRole) Enum ¶ added in v1.23.0
func (x ClusterMemberRole) Enum() *ClusterMemberRole
func (ClusterMemberRole) EnumDescriptor
deprecated
added in
v1.14.0
func (ClusterMemberRole) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClusterMemberRole.Descriptor instead.
func (ClusterMemberRole) Number ¶ added in v1.23.0
func (x ClusterMemberRole) Number() protoreflect.EnumNumber
func (ClusterMemberRole) String ¶ added in v1.14.0
func (x ClusterMemberRole) String() string
func (ClusterMemberRole) Type ¶ added in v1.23.0
func (ClusterMemberRole) Type() protoreflect.EnumType
type DLQOperationState ¶ added in v1.23.0
type DLQOperationState int32
const ( DLQ_OPERATION_STATE_UNSPECIFIED DLQOperationState = 0 DLQ_OPERATION_STATE_RUNNING DLQOperationState = 1 DLQ_OPERATION_STATE_COMPLETED DLQOperationState = 2 DLQ_OPERATION_STATE_FAILED DLQOperationState = 3 )
func DLQOperationStateFromString ¶ added in v1.23.0
func DLQOperationStateFromString(s string) (DLQOperationState, error)
DLQOperationStateFromString parses a DLQOperationState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to DLQOperationState
func (DLQOperationState) Descriptor ¶ added in v1.23.0
func (DLQOperationState) Descriptor() protoreflect.EnumDescriptor
func (DLQOperationState) Enum ¶ added in v1.23.0
func (x DLQOperationState) Enum() *DLQOperationState
func (DLQOperationState) EnumDescriptor
deprecated
added in
v1.23.0
func (DLQOperationState) EnumDescriptor() ([]byte, []int)
Deprecated: Use DLQOperationState.Descriptor instead.
func (DLQOperationState) Number ¶ added in v1.23.0
func (x DLQOperationState) Number() protoreflect.EnumNumber
func (DLQOperationState) String ¶ added in v1.23.0
func (x DLQOperationState) String() string
func (DLQOperationState) Type ¶ added in v1.23.0
func (DLQOperationState) Type() protoreflect.EnumType
type DLQOperationType ¶ added in v1.23.0
type DLQOperationType int32
const ( DLQ_OPERATION_TYPE_UNSPECIFIED DLQOperationType = 0 DLQ_OPERATION_TYPE_MERGE DLQOperationType = 1 DLQ_OPERATION_TYPE_PURGE DLQOperationType = 2 )
func DLQOperationTypeFromString ¶ added in v1.23.0
func DLQOperationTypeFromString(s string) (DLQOperationType, error)
DLQOperationTypeFromString parses a DLQOperationType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to DLQOperationType
func (DLQOperationType) Descriptor ¶ added in v1.23.0
func (DLQOperationType) Descriptor() protoreflect.EnumDescriptor
func (DLQOperationType) Enum ¶ added in v1.23.0
func (x DLQOperationType) Enum() *DLQOperationType
func (DLQOperationType) EnumDescriptor
deprecated
added in
v1.23.0
func (DLQOperationType) EnumDescriptor() ([]byte, []int)
Deprecated: Use DLQOperationType.Descriptor instead.
func (DLQOperationType) Number ¶ added in v1.23.0
func (x DLQOperationType) Number() protoreflect.EnumNumber
func (DLQOperationType) String ¶ added in v1.23.0
func (x DLQOperationType) String() string
func (DLQOperationType) Type ¶ added in v1.23.0
func (DLQOperationType) Type() protoreflect.EnumType
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 DeadLetterQueueTypeFromString ¶ added in v1.23.0
func DeadLetterQueueTypeFromString(s string) (DeadLetterQueueType, error)
DeadLetterQueueTypeFromString parses a DeadLetterQueueType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to DeadLetterQueueType
func (DeadLetterQueueType) Descriptor ¶ added in v1.23.0
func (DeadLetterQueueType) Descriptor() protoreflect.EnumDescriptor
func (DeadLetterQueueType) Enum ¶ added in v1.23.0
func (x DeadLetterQueueType) Enum() *DeadLetterQueueType
func (DeadLetterQueueType) EnumDescriptor
deprecated
func (DeadLetterQueueType) EnumDescriptor() ([]byte, []int)
Deprecated: Use DeadLetterQueueType.Descriptor instead.
func (DeadLetterQueueType) Number ¶ added in v1.23.0
func (x DeadLetterQueueType) Number() protoreflect.EnumNumber
func (DeadLetterQueueType) String ¶
func (x DeadLetterQueueType) String() string
func (DeadLetterQueueType) Type ¶ added in v1.23.0
func (DeadLetterQueueType) Type() protoreflect.EnumType
type NamespaceOperation ¶
type NamespaceOperation int32
const ( NAMESPACE_OPERATION_UNSPECIFIED NamespaceOperation = 0 NAMESPACE_OPERATION_CREATE NamespaceOperation = 1 NAMESPACE_OPERATION_UPDATE NamespaceOperation = 2 )
func NamespaceOperationFromString ¶ added in v1.23.0
func NamespaceOperationFromString(s string) (NamespaceOperation, error)
NamespaceOperationFromString parses a NamespaceOperation value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to NamespaceOperation
func (NamespaceOperation) Descriptor ¶ added in v1.23.0
func (NamespaceOperation) Descriptor() protoreflect.EnumDescriptor
func (NamespaceOperation) Enum ¶ added in v1.23.0
func (x NamespaceOperation) Enum() *NamespaceOperation
func (NamespaceOperation) EnumDescriptor
deprecated
func (NamespaceOperation) EnumDescriptor() ([]byte, []int)
Deprecated: Use NamespaceOperation.Descriptor instead.
func (NamespaceOperation) Number ¶ added in v1.23.0
func (x NamespaceOperation) Number() protoreflect.EnumNumber
func (NamespaceOperation) String ¶
func (x NamespaceOperation) String() string
func (NamespaceOperation) Type ¶ added in v1.23.0
func (NamespaceOperation) Type() protoreflect.EnumType
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 PREDICATE_TYPE_DESTINATION PredicateType = 8 )
func PredicateTypeFromString ¶ added in v1.23.0
func PredicateTypeFromString(s string) (PredicateType, error)
PredicateTypeFromString parses a PredicateType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to PredicateType
func (PredicateType) Descriptor ¶ added in v1.23.0
func (PredicateType) Descriptor() protoreflect.EnumDescriptor
func (PredicateType) Enum ¶ added in v1.23.0
func (x PredicateType) Enum() *PredicateType
func (PredicateType) EnumDescriptor
deprecated
added in
v1.17.3
func (PredicateType) EnumDescriptor() ([]byte, []int)
Deprecated: Use PredicateType.Descriptor instead.
func (PredicateType) Number ¶ added in v1.23.0
func (x PredicateType) Number() protoreflect.EnumNumber
func (PredicateType) String ¶ added in v1.17.3
func (x PredicateType) String() string
func (PredicateType) Type ¶ added in v1.23.0
func (PredicateType) Type() protoreflect.EnumType
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 REPLICATION_TASK_TYPE_TASK_QUEUE_USER_DATA ReplicationTaskType = 8 )
func ReplicationTaskTypeFromString ¶ added in v1.23.0
func ReplicationTaskTypeFromString(s string) (ReplicationTaskType, error)
ReplicationTaskTypeFromString parses a ReplicationTaskType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to ReplicationTaskType
func (ReplicationTaskType) Descriptor ¶ added in v1.23.0
func (ReplicationTaskType) Descriptor() protoreflect.EnumDescriptor
func (ReplicationTaskType) Enum ¶ added in v1.23.0
func (x ReplicationTaskType) Enum() *ReplicationTaskType
func (ReplicationTaskType) EnumDescriptor ¶
func (ReplicationTaskType) EnumDescriptor() ([]byte, []int)
func (ReplicationTaskType) Number ¶ added in v1.23.0
func (x ReplicationTaskType) Number() protoreflect.EnumNumber
func (ReplicationTaskType) String ¶
func (x ReplicationTaskType) String() string
func (ReplicationTaskType) Type ¶ added in v1.23.0
func (ReplicationTaskType) Type() protoreflect.EnumType
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 TaskSourceFromString ¶ added in v1.23.0
func TaskSourceFromString(s string) (TaskSource, error)
TaskSourceFromString parses a TaskSource value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to TaskSource
func (TaskSource) Descriptor ¶ added in v1.23.0
func (TaskSource) Descriptor() protoreflect.EnumDescriptor
func (TaskSource) Enum ¶ added in v1.23.0
func (x TaskSource) Enum() *TaskSource
func (TaskSource) EnumDescriptor
deprecated
func (TaskSource) EnumDescriptor() ([]byte, []int)
Deprecated: Use TaskSource.Descriptor instead.
func (TaskSource) Number ¶ added in v1.23.0
func (x TaskSource) Number() protoreflect.EnumNumber
func (TaskSource) String ¶
func (x TaskSource) String() string
func (TaskSource) Type ¶ added in v1.23.0
func (TaskSource) Type() protoreflect.EnumType
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 // An immediate outbound task generated by a state machine. // Outbound tasks specify a destination that is used to group tasks into a per namespace-and-destination // scheduler. TASK_TYPE_STATE_MACHINE_OUTBOUND TaskType = 27 // A timer task generated by a state machine. TASK_TYPE_STATE_MACHINE_TIMER TaskType = 28 // Timeout task for the entire workflow execution chain. TASK_TYPE_WORKFLOW_EXECUTION_TIMEOUT TaskType = 29 )
func TaskTypeFromString ¶ added in v1.23.0
TaskTypeFromString parses a TaskType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to TaskType
func (TaskType) Descriptor ¶ added in v1.23.0
func (TaskType) Descriptor() protoreflect.EnumDescriptor
func (TaskType) EnumDescriptor ¶
func (TaskType) Number ¶ added in v1.23.0
func (x TaskType) Number() protoreflect.EnumNumber
func (TaskType) Type ¶ added in v1.23.0
func (TaskType) Type() protoreflect.EnumType
type WorkflowBackoffType ¶
type WorkflowBackoffType int32
const ( WORKFLOW_BACKOFF_TYPE_UNSPECIFIED WorkflowBackoffType = 0 WORKFLOW_BACKOFF_TYPE_RETRY WorkflowBackoffType = 1 WORKFLOW_BACKOFF_TYPE_CRON WorkflowBackoffType = 2 WORKFLOW_BACKOFF_TYPE_DELAY_START WorkflowBackoffType = 3 )
func WorkflowBackoffTypeFromString ¶ added in v1.23.0
func WorkflowBackoffTypeFromString(s string) (WorkflowBackoffType, error)
WorkflowBackoffTypeFromString parses a WorkflowBackoffType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to WorkflowBackoffType
func (WorkflowBackoffType) Descriptor ¶ added in v1.23.0
func (WorkflowBackoffType) Descriptor() protoreflect.EnumDescriptor
func (WorkflowBackoffType) Enum ¶ added in v1.23.0
func (x WorkflowBackoffType) Enum() *WorkflowBackoffType
func (WorkflowBackoffType) EnumDescriptor
deprecated
func (WorkflowBackoffType) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkflowBackoffType.Descriptor instead.
func (WorkflowBackoffType) Number ¶ added in v1.23.0
func (x WorkflowBackoffType) Number() protoreflect.EnumNumber
func (WorkflowBackoffType) String ¶
func (x WorkflowBackoffType) String() string
func (WorkflowBackoffType) Type ¶ added in v1.23.0
func (WorkflowBackoffType) Type() protoreflect.EnumType
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 WorkflowExecutionStateFromString ¶ added in v1.23.0
func WorkflowExecutionStateFromString(s string) (WorkflowExecutionState, error)
WorkflowExecutionStateFromString parses a WorkflowExecutionState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to WorkflowExecutionState
func (WorkflowExecutionState) Descriptor ¶ added in v1.23.0
func (WorkflowExecutionState) Descriptor() protoreflect.EnumDescriptor
func (WorkflowExecutionState) Enum ¶ added in v1.23.0
func (x WorkflowExecutionState) Enum() *WorkflowExecutionState
func (WorkflowExecutionState) EnumDescriptor
deprecated
func (WorkflowExecutionState) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionState.Descriptor instead.
func (WorkflowExecutionState) Number ¶ added in v1.23.0
func (x WorkflowExecutionState) Number() protoreflect.EnumNumber
func (WorkflowExecutionState) String ¶
func (x WorkflowExecutionState) String() string
func (WorkflowExecutionState) Type ¶ added in v1.23.0
func (WorkflowExecutionState) Type() protoreflect.EnumType
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 WorkflowTaskTypeFromString ¶ added in v1.23.0
func WorkflowTaskTypeFromString(s string) (WorkflowTaskType, error)
WorkflowTaskTypeFromString parses a WorkflowTaskType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to WorkflowTaskType
func (WorkflowTaskType) Descriptor ¶ added in v1.23.0
func (WorkflowTaskType) Descriptor() protoreflect.EnumDescriptor
func (WorkflowTaskType) Enum ¶ added in v1.23.0
func (x WorkflowTaskType) Enum() *WorkflowTaskType
func (WorkflowTaskType) EnumDescriptor
deprecated
added in
v1.20.0
func (WorkflowTaskType) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkflowTaskType.Descriptor instead.
func (WorkflowTaskType) Number ¶ added in v1.23.0
func (x WorkflowTaskType) Number() protoreflect.EnumNumber
func (WorkflowTaskType) String ¶ added in v1.20.0
func (x WorkflowTaskType) String() string
func (WorkflowTaskType) Type ¶ added in v1.23.0
func (WorkflowTaskType) Type() protoreflect.EnumType
Source Files ¶
- cluster.go-helpers.pb.go
- cluster.pb.go
- common.go-helpers.pb.go
- common.pb.go
- dlq.go-helpers.pb.go
- dlq.pb.go
- predicate.go-helpers.pb.go
- predicate.pb.go
- replication.go-helpers.pb.go
- replication.pb.go
- task.go-helpers.pb.go
- task.pb.go
- workflow.go-helpers.pb.go
- workflow.pb.go
- workflow_task_type.go-helpers.pb.go
- workflow_task_type.pb.go