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.
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Index ¶
- Variables
- type CallbackState
- func (CallbackState) Descriptor() protoreflect.EnumDescriptor
- func (x CallbackState) Enum() *CallbackState
- func (CallbackState) EnumDescriptor() ([]byte, []int)deprecated
- func (x CallbackState) Number() protoreflect.EnumNumber
- func (x CallbackState) String() string
- func (CallbackState) Type() protoreflect.EnumType
- 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 HealthState
- func (HealthState) Descriptor() protoreflect.EnumDescriptor
- func (x HealthState) Enum() *HealthState
- func (HealthState) EnumDescriptor() ([]byte, []int)deprecated
- func (x HealthState) Number() protoreflect.EnumNumber
- func (x HealthState) String() string
- func (HealthState) 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 NexusOperationState
- func (NexusOperationState) Descriptor() protoreflect.EnumDescriptor
- func (x NexusOperationState) Enum() *NexusOperationState
- func (NexusOperationState) EnumDescriptor() ([]byte, []int)deprecated
- func (x NexusOperationState) Number() protoreflect.EnumNumber
- func (x NexusOperationState) String() string
- func (NexusOperationState) Type() protoreflect.EnumType
- type PredicateType
- func (PredicateType) Descriptor() protoreflect.EnumDescriptor
- func (x PredicateType) Enum() *PredicateType
- func (PredicateType) EnumDescriptor() ([]byte, []int)
- func (x PredicateType) Number() protoreflect.EnumNumber
- func (x PredicateType) String() string
- func (PredicateType) Type() protoreflect.EnumType
- type ReplicationFlowControlCommand
- func (ReplicationFlowControlCommand) Descriptor() protoreflect.EnumDescriptor
- func (x ReplicationFlowControlCommand) Enum() *ReplicationFlowControlCommand
- func (ReplicationFlowControlCommand) EnumDescriptor() ([]byte, []int)deprecated
- func (x ReplicationFlowControlCommand) Number() protoreflect.EnumNumber
- func (x ReplicationFlowControlCommand) String() string
- func (ReplicationFlowControlCommand) 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 SchedulerState
- func (SchedulerState) Descriptor() protoreflect.EnumDescriptor
- func (x SchedulerState) Enum() *SchedulerState
- func (SchedulerState) EnumDescriptor() ([]byte, []int)deprecated
- func (x SchedulerState) Number() protoreflect.EnumNumber
- func (x SchedulerState) String() string
- func (SchedulerState) Type() protoreflect.EnumType
- type TaskPriority
- 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 ( HealthState_name = map[int32]string{ 0: "HEALTH_STATE_UNSPECIFIED", 1: "HEALTH_STATE_SERVING", 2: "HEALTH_STATE_NOT_SERVING", } HealthState_value = map[string]int32{ "HEALTH_STATE_UNSPECIFIED": 0, "HEALTH_STATE_SERVING": 1, "HEALTH_STATE_NOT_SERVING": 2, } )
Enum value maps for HealthState.
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 ( SchedulerState_name = map[int32]string{ 0: "SCHEDULER_STATE_UNSPECIFIED", 1: "SCHEDULER_STATE_WAITING", 2: "SCHEDULER_STATE_EXECUTING", } SchedulerState_value = map[string]int32{ "SCHEDULER_STATE_UNSPECIFIED": 0, "SCHEDULER_STATE_WAITING": 1, "SCHEDULER_STATE_EXECUTING": 2, } )
Enum value maps for SchedulerState.
var ( CallbackState_name = map[int32]string{ 0: "CALLBACK_STATE_UNSPECIFIED", 1: "CALLBACK_STATE_STANDBY", 2: "CALLBACK_STATE_SCHEDULED", 3: "CALLBACK_STATE_BACKING_OFF", 4: "CALLBACK_STATE_FAILED", 5: "CALLBACK_STATE_SUCCEEDED", } CallbackState_value = map[string]int32{ "CALLBACK_STATE_UNSPECIFIED": 0, "CALLBACK_STATE_STANDBY": 1, "CALLBACK_STATE_SCHEDULED": 2, "CALLBACK_STATE_BACKING_OFF": 3, "CALLBACK_STATE_FAILED": 4, "CALLBACK_STATE_SUCCEEDED": 5, } )
Enum value maps for CallbackState.
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 ( NexusOperationState_name = map[int32]string{ 0: "NEXUS_OPERATION_STATE_UNSPECIFIED", 1: "NEXUS_OPERATION_STATE_SCHEDULED", 2: "NEXUS_OPERATION_STATE_BACKING_OFF", 3: "NEXUS_OPERATION_STATE_STARTED", 4: "NEXUS_OPERATION_STATE_SUCCEEDED", 5: "NEXUS_OPERATION_STATE_FAILED", 6: "NEXUS_OPERATION_STATE_CANCELED", 7: "NEXUS_OPERATION_STATE_TIMED_OUT", } NexusOperationState_value = map[string]int32{ "NEXUS_OPERATION_STATE_UNSPECIFIED": 0, "NEXUS_OPERATION_STATE_SCHEDULED": 1, "NEXUS_OPERATION_STATE_BACKING_OFF": 2, "NEXUS_OPERATION_STATE_STARTED": 3, "NEXUS_OPERATION_STATE_SUCCEEDED": 4, "NEXUS_OPERATION_STATE_FAILED": 5, "NEXUS_OPERATION_STATE_CANCELED": 6, "NEXUS_OPERATION_STATE_TIMED_OUT": 7, } )
Enum value maps for NexusOperationState.
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", 9: "PREDICATE_TYPE_OUTBOUND_TASK_GROUP", 10: "PREDICATE_TYPE_OUTBOUND_TASK", } 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, "PREDICATE_TYPE_OUTBOUND_TASK_GROUP": 9, "PREDICATE_TYPE_OUTBOUND_TASK": 10, } )
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", 9: "REPLICATION_TASK_TYPE_SYNC_HSM_TASK", 10: "REPLICATION_TASK_TYPE_BACKFILL_HISTORY_TASK", 11: "REPLICATION_TASK_TYPE_VERIFY_VERSIONED_TRANSITION_TASK", 12: "REPLICATION_TASK_TYPE_SYNC_VERSIONED_TRANSITION_TASK", } 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, "REPLICATION_TASK_TYPE_SYNC_HSM_TASK": 9, "REPLICATION_TASK_TYPE_BACKFILL_HISTORY_TASK": 10, "REPLICATION_TASK_TYPE_VERIFY_VERSIONED_TRANSITION_TASK": 11, "REPLICATION_TASK_TYPE_SYNC_VERSIONED_TRANSITION_TASK": 12, } )
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, } )
var ( ReplicationFlowControlCommand_name = map[int32]string{ 0: "REPLICATION_FLOW_CONTROL_COMMAND_UNSPECIFIED", 1: "REPLICATION_FLOW_CONTROL_COMMAND_RESUME", 2: "REPLICATION_FLOW_CONTROL_COMMAND_PAUSE", } ReplicationFlowControlCommand_value = map[string]int32{ "REPLICATION_FLOW_CONTROL_COMMAND_UNSPECIFIED": 0, "REPLICATION_FLOW_CONTROL_COMMAND_RESUME": 1, "REPLICATION_FLOW_CONTROL_COMMAND_PAUSE": 2, } )
Enum value maps for ReplicationFlowControlCommand.
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", 30: "TASK_TYPE_REPLICATION_SYNC_HSM", 31: "TASK_TYPE_REPLICATION_SYNC_VERSIONED_TRANSITION", } 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, "TASK_TYPE_REPLICATION_SYNC_HSM": 30, "TASK_TYPE_REPLICATION_SYNC_VERSIONED_TRANSITION": 31, } )
Enum value maps for TaskType.
var ( TaskPriority_name = map[int32]string{ 0: "TASK_PRIORITY_UNSPECIFIED", 1: "TASK_PRIORITY_HIGH", 10: "TASK_PRIORITY_LOW", } TaskPriority_value = map[string]int32{ "TASK_PRIORITY_UNSPECIFIED": 0, "TASK_PRIORITY_HIGH": 1, "TASK_PRIORITY_LOW": 10, } )
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 (
CallbackState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Standby": 1,
"Scheduled": 2,
"BackingOff": 3,
"Failed": 4,
"Succeeded": 5,
}
)
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_nexus_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 (
HealthState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Serving": 1,
"NotServing": 2,
}
)
var (
NamespaceOperation_shorthandValue = map[string]int32{
"Unspecified": 0,
"Create": 1,
"Update": 2,
}
)
var (
NexusOperationState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Scheduled": 1,
"BackingOff": 2,
"Started": 3,
"Succeeded": 4,
"Failed": 5,
"Canceled": 6,
"TimedOut": 7,
}
)
var (
PredicateType_shorthandValue = map[string]int32{
"Unspecified": 0,
"Universal": 1,
"Empty": 2,
"And": 3,
"Or": 4,
"Not": 5,
"NamespaceId": 6,
"TaskType": 7,
"Destination": 8,
"OutboundTaskGroup": 9,
"OutboundTask": 10,
}
)
var (
ReplicationFlowControlCommand_shorthandValue = map[string]int32{
"Unspecified": 0,
"Resume": 1,
"Pause": 2,
}
)
var (
ReplicationTaskType_shorthandValue = map[string]int32{
"Unspecified": 0,
"NamespaceTask": 1,
"HistoryTask": 2,
"SyncShardStatusTask": 3,
"SyncActivityTask": 4,
"HistoryMetadataTask": 5,
"HistoryV2Task": 6,
"SyncWorkflowStateTask": 7,
"TaskQueueUserData": 8,
"SyncHsmTask": 9,
"BackfillHistoryTask": 10,
"VerifyVersionedTransitionTask": 11,
"SyncVersionedTransitionTask": 12,
}
)
var (
SchedulerState_shorthandValue = map[string]int32{
"Unspecified": 0,
"Waiting": 1,
"Executing": 2,
}
)
var (
TaskPriority_shorthandValue = map[string]int32{
"Unspecified": 0,
"High": 1,
"Low": 10,
}
)
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,
"ReplicationSyncHsm": 30,
"ReplicationSyncVersionedTransition": 31,
}
)
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 CallbackState ¶ added in v1.25.0
type CallbackState int32
State of a callback.
const ( // Default value, unspecified state. CALLBACK_STATE_UNSPECIFIED CallbackState = 0 // Callback is standing by, waiting to be triggered. CALLBACK_STATE_STANDBY CallbackState = 1 // Callback is in the queue waiting to be executed or is currently executing. CALLBACK_STATE_SCHEDULED CallbackState = 2 // Callback has failed with a retryable error and is backing off before the next attempt. CALLBACK_STATE_BACKING_OFF CallbackState = 3 // Callback has failed. CALLBACK_STATE_FAILED CallbackState = 4 // Callback has succeeded. CALLBACK_STATE_SUCCEEDED CallbackState = 5 )
func CallbackStateFromString ¶ added in v1.25.0
func CallbackStateFromString(s string) (CallbackState, error)
CallbackStateFromString parses a CallbackState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to CallbackState
func (CallbackState) Descriptor ¶ added in v1.25.0
func (CallbackState) Descriptor() protoreflect.EnumDescriptor
func (CallbackState) Enum ¶ added in v1.25.0
func (x CallbackState) Enum() *CallbackState
func (CallbackState) EnumDescriptor
deprecated
added in
v1.25.0
func (CallbackState) EnumDescriptor() ([]byte, []int)
Deprecated: Use CallbackState.Descriptor instead.
func (CallbackState) Number ¶ added in v1.25.0
func (x CallbackState) Number() protoreflect.EnumNumber
func (CallbackState) String ¶ added in v1.25.0
func (x CallbackState) String() string
func (CallbackState) Type ¶ added in v1.25.0
func (CallbackState) Type() protoreflect.EnumType
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 HealthState ¶ added in v1.25.0
type HealthState int32
const ( HEALTH_STATE_UNSPECIFIED HealthState = 0 HEALTH_STATE_SERVING HealthState = 1 HEALTH_STATE_NOT_SERVING HealthState = 2 )
func HealthStateFromString ¶ added in v1.25.0
func HealthStateFromString(s string) (HealthState, error)
HealthStateFromString parses a HealthState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to HealthState
func (HealthState) Descriptor ¶ added in v1.25.0
func (HealthState) Descriptor() protoreflect.EnumDescriptor
func (HealthState) Enum ¶ added in v1.25.0
func (x HealthState) Enum() *HealthState
func (HealthState) EnumDescriptor
deprecated
added in
v1.25.0
func (HealthState) EnumDescriptor() ([]byte, []int)
Deprecated: Use HealthState.Descriptor instead.
func (HealthState) Number ¶ added in v1.25.0
func (x HealthState) Number() protoreflect.EnumNumber
func (HealthState) String ¶ added in v1.25.0
func (x HealthState) String() string
func (HealthState) Type ¶ added in v1.25.0
func (HealthState) 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 NexusOperationState ¶ added in v1.24.0
type NexusOperationState int32
const ( // Default value, unspecified state. NEXUS_OPERATION_STATE_UNSPECIFIED NexusOperationState = 0 // Operation is in the queue waiting to be executed or is currently executing. NEXUS_OPERATION_STATE_SCHEDULED NexusOperationState = 1 // Operation has failed with a retryable error and is backing off before the next attempt. NEXUS_OPERATION_STATE_BACKING_OFF NexusOperationState = 2 // Operation was started and will complete asynchronously. NEXUS_OPERATION_STATE_STARTED NexusOperationState = 3 // Operation succeeded. // This may happen either as a response to a start request or as reported via callback. NEXUS_OPERATION_STATE_SUCCEEDED NexusOperationState = 4 // Operation failed either when a start request encounters a non-retryable error or as reported via callback. NEXUS_OPERATION_STATE_FAILED NexusOperationState = 5 // Operation completed as canceled (may have not ever been delivered). // This may happen either as a response to a start request or as reported via callback. NEXUS_OPERATION_STATE_CANCELED NexusOperationState = 6 // Operation timed out - exceeded the user supplied schedule-to-close timeout. // Any attempts to complete the operation in this state will be ignored. NEXUS_OPERATION_STATE_TIMED_OUT NexusOperationState = 7 )
func NexusOperationStateFromString ¶ added in v1.24.0
func NexusOperationStateFromString(s string) (NexusOperationState, error)
NexusOperationStateFromString parses a NexusOperationState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to NexusOperationState
func (NexusOperationState) Descriptor ¶ added in v1.24.0
func (NexusOperationState) Descriptor() protoreflect.EnumDescriptor
func (NexusOperationState) Enum ¶ added in v1.24.0
func (x NexusOperationState) Enum() *NexusOperationState
func (NexusOperationState) EnumDescriptor
deprecated
added in
v1.24.0
func (NexusOperationState) EnumDescriptor() ([]byte, []int)
Deprecated: Use NexusOperationState.Descriptor instead.
func (NexusOperationState) Number ¶ added in v1.24.0
func (x NexusOperationState) Number() protoreflect.EnumNumber
func (NexusOperationState) String ¶ added in v1.24.0
func (x NexusOperationState) String() string
func (NexusOperationState) Type ¶ added in v1.24.0
func (NexusOperationState) 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 PREDICATE_TYPE_OUTBOUND_TASK_GROUP PredicateType = 9 // Predicate used for grouping outbound tasks. Consists of task_group, namespace_id, and destination. // This replaces a previous implementation which used an AND predicate over 3 separate predicate types. PREDICATE_TYPE_OUTBOUND_TASK PredicateType = 10 )
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 ¶ added in v1.17.3
func (PredicateType) EnumDescriptor() ([]byte, []int)
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 ReplicationFlowControlCommand ¶ added in v1.25.0
type ReplicationFlowControlCommand int32
const ( REPLICATION_FLOW_CONTROL_COMMAND_UNSPECIFIED ReplicationFlowControlCommand = 0 REPLICATION_FLOW_CONTROL_COMMAND_RESUME ReplicationFlowControlCommand = 1 REPLICATION_FLOW_CONTROL_COMMAND_PAUSE ReplicationFlowControlCommand = 2 )
func ReplicationFlowControlCommandFromString ¶ added in v1.25.0
func ReplicationFlowControlCommandFromString(s string) (ReplicationFlowControlCommand, error)
ReplicationFlowControlCommandFromString parses a ReplicationFlowControlCommand value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to ReplicationFlowControlCommand
func (ReplicationFlowControlCommand) Descriptor ¶ added in v1.25.0
func (ReplicationFlowControlCommand) Descriptor() protoreflect.EnumDescriptor
func (ReplicationFlowControlCommand) Enum ¶ added in v1.25.0
func (x ReplicationFlowControlCommand) Enum() *ReplicationFlowControlCommand
func (ReplicationFlowControlCommand) EnumDescriptor
deprecated
added in
v1.25.0
func (ReplicationFlowControlCommand) EnumDescriptor() ([]byte, []int)
Deprecated: Use ReplicationFlowControlCommand.Descriptor instead.
func (ReplicationFlowControlCommand) Number ¶ added in v1.25.0
func (x ReplicationFlowControlCommand) Number() protoreflect.EnumNumber
func (ReplicationFlowControlCommand) String ¶ added in v1.25.0
func (x ReplicationFlowControlCommand) String() string
func (ReplicationFlowControlCommand) Type ¶ added in v1.25.0
func (ReplicationFlowControlCommand) 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 REPLICATION_TASK_TYPE_SYNC_HSM_TASK ReplicationTaskType = 9 REPLICATION_TASK_TYPE_BACKFILL_HISTORY_TASK ReplicationTaskType = 10 REPLICATION_TASK_TYPE_VERIFY_VERSIONED_TRANSITION_TASK ReplicationTaskType = 11 REPLICATION_TASK_TYPE_SYNC_VERSIONED_TRANSITION_TASK ReplicationTaskType = 12 )
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 SchedulerState ¶ added in v1.25.0
type SchedulerState int32
State of a scheduler.
const ( // Default value, unspecified state. SCHEDULER_STATE_UNSPECIFIED SchedulerState = 0 // Scheduler is waiting to be activated after the specified amount of time. SCHEDULER_STATE_WAITING SchedulerState = 1 // Scheduler is actively executing logic. SCHEDULER_STATE_EXECUTING SchedulerState = 2 )
func SchedulerStateFromString ¶ added in v1.25.0
func SchedulerStateFromString(s string) (SchedulerState, error)
SchedulerStateFromString parses a SchedulerState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to SchedulerState
func (SchedulerState) Descriptor ¶ added in v1.25.0
func (SchedulerState) Descriptor() protoreflect.EnumDescriptor
func (SchedulerState) Enum ¶ added in v1.25.0
func (x SchedulerState) Enum() *SchedulerState
func (SchedulerState) EnumDescriptor
deprecated
added in
v1.25.0
func (SchedulerState) EnumDescriptor() ([]byte, []int)
Deprecated: Use SchedulerState.Descriptor instead.
func (SchedulerState) Number ¶ added in v1.25.0
func (x SchedulerState) Number() protoreflect.EnumNumber
func (SchedulerState) String ¶ added in v1.25.0
func (x SchedulerState) String() string
func (SchedulerState) Type ¶ added in v1.25.0
func (SchedulerState) Type() protoreflect.EnumType
type TaskPriority ¶ added in v1.24.0
type TaskPriority int32
const ( TASK_PRIORITY_UNSPECIFIED TaskPriority = 0 TASK_PRIORITY_HIGH TaskPriority = 1 TASK_PRIORITY_LOW TaskPriority = 10 )
func TaskPriorityFromString ¶ added in v1.24.0
func TaskPriorityFromString(s string) (TaskPriority, error)
TaskPriorityFromString parses a TaskPriority value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to TaskPriority
func (TaskPriority) Descriptor ¶ added in v1.24.0
func (TaskPriority) Descriptor() protoreflect.EnumDescriptor
func (TaskPriority) Enum ¶ added in v1.24.0
func (x TaskPriority) Enum() *TaskPriority
func (TaskPriority) EnumDescriptor ¶ added in v1.24.0
func (TaskPriority) EnumDescriptor() ([]byte, []int)
func (TaskPriority) Number ¶ added in v1.24.0
func (x TaskPriority) Number() protoreflect.EnumNumber
func (TaskPriority) String ¶ added in v1.24.0
func (x TaskPriority) String() string
func (TaskPriority) Type ¶ added in v1.24.0
func (TaskPriority) 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 TASK_TYPE_REPLICATION_SYNC_HSM TaskType = 30 TASK_TYPE_REPLICATION_SYNC_VERSIONED_TRANSITION TaskType = 31 )
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
- nexus.go-helpers.pb.go
- nexus.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