enums

package
v1.9.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 23, 2026 License: MIT Imports: 7 Imported by: 0

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.

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
var (
	HealthState_name = map[int32]string{
		0: "HEALTH_STATE_UNSPECIFIED",
		1: "HEALTH_STATE_SERVING",
		2: "HEALTH_STATE_NOT_SERVING",
		3: "HEALTH_STATE_DECLINED_SERVING",
		4: "HEALTH_STATE_INTERNAL_ERROR",
	}
	HealthState_value = map[string]int32{
		"HEALTH_STATE_UNSPECIFIED":      0,
		"HEALTH_STATE_SERVING":          1,
		"HEALTH_STATE_NOT_SERVING":      2,
		"HEALTH_STATE_DECLINED_SERVING": 3,
		"HEALTH_STATE_INTERNAL_ERROR":   4,
	}
)

Enum value maps for HealthState.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
var (
	FairnessState_name = map[int32]string{
		0: "FAIRNESS_STATE_UNSPECIFIED",
		1: "FAIRNESS_STATE_V0",
		2: "FAIRNESS_STATE_V1",
		3: "FAIRNESS_STATE_V2",
	}
	FairnessState_value = map[string]int32{
		"FAIRNESS_STATE_UNSPECIFIED": 0,
		"FAIRNESS_STATE_V0":          1,
		"FAIRNESS_STATE_V1":          2,
		"FAIRNESS_STATE_V2":          3,
	}
)

Enum value maps for FairnessState.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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,
	}
)
View Source 
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.

View Source 
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.

View Source 
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",
		32: "TASK_TYPE_CHASM_PURE",
		33: "TASK_TYPE_CHASM",
	}
	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,
		"TASK_TYPE_CHASM_PURE":                            32,
		"TASK_TYPE_CHASM":                                 33,
	}
)

Enum value maps for TaskType.

View Source 
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,
	}
)
View Source 
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.

View Source 
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.

View Source 
var (
	PausedWorkflowEntityType_name = map[int32]string{
		0: "PAUSED_WORKFLOW_ENTITY_TYPE_UNSPECIFIED",
		1: "PAUSED_WORKFLOW_ENTITY_TYPE_ACTIVITY",
		2: "PAUSED_WORKFLOW_ENTITY_TYPE_WORKFLOW",
	}
	PausedWorkflowEntityType_value = map[string]int32{
		"PAUSED_WORKFLOW_ENTITY_TYPE_UNSPECIFIED": 0,
		"PAUSED_WORKFLOW_ENTITY_TYPE_ACTIVITY":    1,
		"PAUSED_WORKFLOW_ENTITY_TYPE_WORKFLOW":    2,
	}
)

Enum value maps for PausedWorkflowEntityType.

View Source 
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.

View Source 
var (
	CallbackState_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"Standby":     1,
		"Scheduled":   2,
		"BackingOff":  3,
		"Failed":      4,
		"Succeeded":   5,
	}
)
View Source 
var (
	ChecksumFlavor_shorthandValue = map[string]int32{
		"Unspecified":               0,
		"IeeeCrc32OverProto3Binary": 1,
	}
)
View Source 
var (
	ClusterMemberRole_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"Frontend":    1,
		"History":     2,
		"Matching":    3,
		"Worker":      4,
	}
)
View Source 
var (
	DLQOperationState_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"Running":     1,
		"Completed":   2,
		"Failed":      3,
	}
)
View Source 
var (
	DLQOperationType_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"Merge":       1,
		"Purge":       2,
	}
)
View Source 
var (
	DeadLetterQueueType_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"Replication": 1,
		"Namespace":   2,
	}
)
View Source 
var (
	FairnessState_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"V0":          1,
		"V1":          2,
		"V2":          3,
	}
)
View Source 
var File_temporal_server_api_enums_v1_cluster_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_enums_v1_common_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_enums_v1_dlq_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_enums_v1_fairness_state_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_enums_v1_nexus_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_enums_v1_predicate_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_enums_v1_replication_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_enums_v1_task_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_enums_v1_workflow_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_enums_v1_workflow_task_type_proto protoreflect.FileDescriptor
View Source 
var (
	HealthState_shorthandValue = map[string]int32{
		"Unspecified":     0,
		"Serving":         1,
		"NotServing":      2,
		"DeclinedServing": 3,
		"InternalError":   4,
	}
)
View Source 
var (
	NamespaceOperation_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"Create":      1,
		"Update":      2,
	}
)
View Source 
var (
	NexusOperationState_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"Scheduled":   1,
		"BackingOff":  2,
		"Started":     3,
		"Succeeded":   4,
		"Failed":      5,
		"Canceled":    6,
		"TimedOut":    7,
	}
)
View Source 
var (
	PausedWorkflowEntityType_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"Activity":    1,
		"Workflow":    2,
	}
)
View Source 
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,
	}
)
View Source 
var (
	ReplicationFlowControlCommand_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"Resume":      1,
		"Pause":       2,
	}
)
View Source 
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,
	}
)
View Source 
var (
	TaskPriority_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"High":        1,
		"Low":         10,
	}
)
View Source 
var (
	TaskSource_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"History":     1,
		"DbBacklog":   2,
	}
)
View Source 
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,
		"ChasmPure":                          32,
		"Chasm":                              33,
	}
)
View Source 
var (
	WorkflowBackoffType_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"Retry":       1,
		"Cron":        2,
		"DelayStart":  3,
	}
)
View Source 
var (
	WorkflowExecutionState_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"Created":     1,
		"Running":     2,
		"Completed":   3,
		"Zombie":      4,
		"Void":        5,
		"Corrupted":   6,
	}
)
View Source 
var (
	WorkflowTaskType_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"Normal":      1,
		"Transient":   2,
		"Speculative": 3,
	}
)

Functions

This section is empty.

Types

type CallbackState 

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 

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 

func (CallbackState) Descriptor() protoreflect.EnumDescriptor

func (CallbackState) Enum 

func (x CallbackState) Enum() *CallbackState

func (CallbackState) EnumDescriptor deprecated 

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

Deprecated: Use CallbackState.Descriptor instead.

func (CallbackState) Number 

func (x CallbackState) Number() protoreflect.EnumNumber

func (CallbackState) String 

func (x CallbackState) String() string

func (CallbackState) Type 

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 

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 

func (ChecksumFlavor) Descriptor() protoreflect.EnumDescriptor

func (ChecksumFlavor) Enum 

func (x ChecksumFlavor) Enum() *ChecksumFlavor

func (ChecksumFlavor) EnumDescriptor deprecated 

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

Deprecated: Use ChecksumFlavor.Descriptor instead.

func (ChecksumFlavor) Number 

func (x ChecksumFlavor) Number() protoreflect.EnumNumber

func (ChecksumFlavor) String 

func (x ChecksumFlavor) String() string

func (ChecksumFlavor) Type 

func (ChecksumFlavor) Type() protoreflect.EnumType

type ClusterMemberRole 

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 

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 

func (ClusterMemberRole) Descriptor() protoreflect.EnumDescriptor

func (ClusterMemberRole) Enum 

func (x ClusterMemberRole) Enum() *ClusterMemberRole

func (ClusterMemberRole) EnumDescriptor deprecated 

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

Deprecated: Use ClusterMemberRole.Descriptor instead.

func (ClusterMemberRole) Number 

func (x ClusterMemberRole) Number() protoreflect.EnumNumber

func (ClusterMemberRole) String 

func (x ClusterMemberRole) String() string

func (ClusterMemberRole) Type 

func (ClusterMemberRole) Type() protoreflect.EnumType

type DLQOperationState 

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 

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 

func (DLQOperationState) Descriptor() protoreflect.EnumDescriptor

func (DLQOperationState) Enum 

func (x DLQOperationState) Enum() *DLQOperationState

func (DLQOperationState) EnumDescriptor deprecated 

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

Deprecated: Use DLQOperationState.Descriptor instead.

func (DLQOperationState) Number 

func (x DLQOperationState) Number() protoreflect.EnumNumber

func (DLQOperationState) String 

func (x DLQOperationState) String() string

func (DLQOperationState) Type 

func (DLQOperationState) Type() protoreflect.EnumType

type DLQOperationType 

type DLQOperationType int32
const (
	DLQ_OPERATION_TYPE_UNSPECIFIED DLQOperationType = 0
	DLQ_OPERATION_TYPE_MERGE       DLQOperationType = 1
	DLQ_OPERATION_TYPE_PURGE       DLQOperationType = 2
)

func DLQOperationTypeFromString 

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 

func (DLQOperationType) Descriptor() protoreflect.EnumDescriptor

func (DLQOperationType) Enum 

func (x DLQOperationType) Enum() *DLQOperationType

func (DLQOperationType) EnumDescriptor deprecated 

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

Deprecated: Use DLQOperationType.Descriptor instead.

func (DLQOperationType) Number 

func (x DLQOperationType) Number() protoreflect.EnumNumber

func (DLQOperationType) String 

func (x DLQOperationType) String() string

func (DLQOperationType) Type 

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 

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 

func (DeadLetterQueueType) Descriptor() protoreflect.EnumDescriptor

func (DeadLetterQueueType) Enum 

func (x DeadLetterQueueType) Enum() *DeadLetterQueueType

func (DeadLetterQueueType) EnumDescriptor deprecated 

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

Deprecated: Use DeadLetterQueueType.Descriptor instead.

func (DeadLetterQueueType) Number 

func (x DeadLetterQueueType) Number() protoreflect.EnumNumber

func (DeadLetterQueueType) String 

func (x DeadLetterQueueType) String() string

func (DeadLetterQueueType) Type 

func (DeadLetterQueueType) Type() protoreflect.EnumType

type FairnessState 

type FairnessState int32
const (
	FAIRNESS_STATE_UNSPECIFIED FairnessState = 0
	FAIRNESS_STATE_V0          FairnessState = 1
	FAIRNESS_STATE_V1          FairnessState = 2
	FAIRNESS_STATE_V2          FairnessState = 3
)

func FairnessStateFromString 

func FairnessStateFromString(s string) (FairnessState, error)

FairnessStateFromString parses a FairnessState value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to FairnessState

func (FairnessState) Descriptor 

func (FairnessState) Descriptor() protoreflect.EnumDescriptor

func (FairnessState) Enum 

func (x FairnessState) Enum() *FairnessState

func (FairnessState) EnumDescriptor deprecated 

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

Deprecated: Use FairnessState.Descriptor instead.

func (FairnessState) Number 

func (x FairnessState) Number() protoreflect.EnumNumber

func (FairnessState) String 

func (x FairnessState) String() string

func (FairnessState) Type 

func (FairnessState) Type() protoreflect.EnumType

type HealthState 

type HealthState int32
const (
	HEALTH_STATE_UNSPECIFIED HealthState = 0
	// The host is in a healthy state.
	HEALTH_STATE_SERVING HealthState = 1
	// The host is unhealthy through external observation.
	HEALTH_STATE_NOT_SERVING HealthState = 2
	// The host has marked itself as not ready to serve traffic.
	HEALTH_STATE_DECLINED_SERVING HealthState = 3
	// An internal error occurred while checking health (e.g. resolver failure).
	HEALTH_STATE_INTERNAL_ERROR HealthState = 4
)

func HealthStateFromString 

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 

func (HealthState) Descriptor() protoreflect.EnumDescriptor

func (HealthState) Enum 

func (x HealthState) Enum() *HealthState

func (HealthState) EnumDescriptor deprecated 

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

Deprecated: Use HealthState.Descriptor instead.

func (HealthState) Number 

func (x HealthState) Number() protoreflect.EnumNumber

func (HealthState) String 

func (x HealthState) String() string

func (HealthState) Type 

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 

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 

func (NamespaceOperation) Descriptor() protoreflect.EnumDescriptor

func (NamespaceOperation) Enum 

func (x NamespaceOperation) Enum() *NamespaceOperation

func (NamespaceOperation) EnumDescriptor deprecated 

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

Deprecated: Use NamespaceOperation.Descriptor instead.

func (NamespaceOperation) Number 

func (x NamespaceOperation) Number() protoreflect.EnumNumber

func (NamespaceOperation) String 

func (x NamespaceOperation) String() string

func (NamespaceOperation) Type 

func (NamespaceOperation) Type() protoreflect.EnumType

type NexusOperationState 

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 

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 

func (NexusOperationState) Descriptor() protoreflect.EnumDescriptor

func (NexusOperationState) Enum 

func (x NexusOperationState) Enum() *NexusOperationState

func (NexusOperationState) EnumDescriptor deprecated 

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

Deprecated: Use NexusOperationState.Descriptor instead.

func (NexusOperationState) Number 

func (x NexusOperationState) Number() protoreflect.EnumNumber

func (NexusOperationState) String 

func (x NexusOperationState) String() string

func (NexusOperationState) Type 

func (NexusOperationState) Type() protoreflect.EnumType

type PausedWorkflowEntityType 

type PausedWorkflowEntityType int32
const (
	PAUSED_WORKFLOW_ENTITY_TYPE_UNSPECIFIED PausedWorkflowEntityType = 0
	PAUSED_WORKFLOW_ENTITY_TYPE_ACTIVITY    PausedWorkflowEntityType = 1
	PAUSED_WORKFLOW_ENTITY_TYPE_WORKFLOW    PausedWorkflowEntityType = 2
)

func PausedWorkflowEntityTypeFromString 

func PausedWorkflowEntityTypeFromString(s string) (PausedWorkflowEntityType, error)

PausedWorkflowEntityTypeFromString parses a PausedWorkflowEntityType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to PausedWorkflowEntityType

func (PausedWorkflowEntityType) Descriptor 

func (PausedWorkflowEntityType) Descriptor() protoreflect.EnumDescriptor

func (PausedWorkflowEntityType) Enum 

func (x PausedWorkflowEntityType) Enum() *PausedWorkflowEntityType

func (PausedWorkflowEntityType) EnumDescriptor deprecated 

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

Deprecated: Use PausedWorkflowEntityType.Descriptor instead.

func (PausedWorkflowEntityType) Number 

func (x PausedWorkflowEntityType) Number() protoreflect.EnumNumber

func (PausedWorkflowEntityType) String 

func (x PausedWorkflowEntityType) String() string

func (PausedWorkflowEntityType) Type 

func (PausedWorkflowEntityType) Type() protoreflect.EnumType

type PredicateType 

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 

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 

func (PredicateType) Descriptor() protoreflect.EnumDescriptor

func (PredicateType) Enum 

func (x PredicateType) Enum() *PredicateType

func (PredicateType) EnumDescriptor 

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

func (PredicateType) Number 

func (x PredicateType) Number() protoreflect.EnumNumber

func (PredicateType) String 

func (x PredicateType) String() string

func (PredicateType) Type 

func (PredicateType) Type() protoreflect.EnumType

type ReplicationFlowControlCommand 

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 

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 

func (ReplicationFlowControlCommand) Descriptor() protoreflect.EnumDescriptor

func (ReplicationFlowControlCommand) Enum 

func (x ReplicationFlowControlCommand) Enum() *ReplicationFlowControlCommand

func (ReplicationFlowControlCommand) EnumDescriptor deprecated 

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

Deprecated: Use ReplicationFlowControlCommand.Descriptor instead.

func (ReplicationFlowControlCommand) Number 

func (x ReplicationFlowControlCommand) Number() protoreflect.EnumNumber

func (ReplicationFlowControlCommand) String 

func (x ReplicationFlowControlCommand) String() string

func (ReplicationFlowControlCommand) Type 

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 

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 

func (ReplicationTaskType) Descriptor() protoreflect.EnumDescriptor

func (ReplicationTaskType) Enum 

func (x ReplicationTaskType) Enum() *ReplicationTaskType

func (ReplicationTaskType) EnumDescriptor 

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

func (ReplicationTaskType) Number 

func (x ReplicationTaskType) Number() protoreflect.EnumNumber

func (ReplicationTaskType) String 

func (x ReplicationTaskType) String() string

func (ReplicationTaskType) Type 

func (ReplicationTaskType) Type() protoreflect.EnumType

type TaskPriority 

type TaskPriority int32
const (
	TASK_PRIORITY_UNSPECIFIED TaskPriority = 0
	TASK_PRIORITY_HIGH        TaskPriority = 1

	TASK_PRIORITY_LOW TaskPriority = 10
)

func TaskPriorityFromString 

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 

func (TaskPriority) Descriptor() protoreflect.EnumDescriptor

func (TaskPriority) Enum 

func (x TaskPriority) Enum() *TaskPriority

func (TaskPriority) EnumDescriptor 

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

func (TaskPriority) Number 

func (x TaskPriority) Number() protoreflect.EnumNumber

func (TaskPriority) String 

func (x TaskPriority) String() string

func (TaskPriority) Type 

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 

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 

func (TaskSource) Descriptor() protoreflect.EnumDescriptor

func (TaskSource) Enum 

func (x TaskSource) Enum() *TaskSource

func (TaskSource) EnumDescriptor deprecated 

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

Deprecated: Use TaskSource.Descriptor instead.

func (TaskSource) Number 

func (x TaskSource) Number() protoreflect.EnumNumber

func (TaskSource) String 

func (x TaskSource) String() string

func (TaskSource) Type 

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
	// A task that applies a batch of state changes to a CHASM entity.
	TASK_TYPE_CHASM_PURE TaskType = 32
	// A task with side effects generated by a CHASM component.
	TASK_TYPE_CHASM TaskType = 33
)

func TaskTypeFromString 

func TaskTypeFromString(s string) (TaskType, error)

TaskTypeFromString parses a TaskType value from either the protojson canonical SCREAMING_CASE enum or the traditional temporal PascalCase enum to TaskType

func (TaskType) Descriptor 

func (TaskType) Descriptor() protoreflect.EnumDescriptor

func (TaskType) Enum 

func (x TaskType) Enum() *TaskType

func (TaskType) EnumDescriptor 

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

func (TaskType) Number 

func (x TaskType) Number() protoreflect.EnumNumber

func (TaskType) String 

func (x TaskType) String() string

func (TaskType) Type 

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 

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 

func (WorkflowBackoffType) Descriptor() protoreflect.EnumDescriptor

func (WorkflowBackoffType) Enum 

func (x WorkflowBackoffType) Enum() *WorkflowBackoffType

func (WorkflowBackoffType) EnumDescriptor deprecated 

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

Deprecated: Use WorkflowBackoffType.Descriptor instead.

func (WorkflowBackoffType) Number 

func (x WorkflowBackoffType) Number() protoreflect.EnumNumber

func (WorkflowBackoffType) String 

func (x WorkflowBackoffType) String() string

func (WorkflowBackoffType) Type 

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 

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 

func (WorkflowExecutionState) Descriptor() protoreflect.EnumDescriptor

func (WorkflowExecutionState) Enum 

func (x WorkflowExecutionState) Enum() *WorkflowExecutionState

func (WorkflowExecutionState) EnumDescriptor deprecated 

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

Deprecated: Use WorkflowExecutionState.Descriptor instead.

func (WorkflowExecutionState) Number 

func (x WorkflowExecutionState) Number() protoreflect.EnumNumber

func (WorkflowExecutionState) String 

func (x WorkflowExecutionState) String() string

func (WorkflowExecutionState) Type 

func (WorkflowExecutionState) Type() protoreflect.EnumType

type WorkflowTaskType 

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 

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 

func (WorkflowTaskType) Descriptor() protoreflect.EnumDescriptor

func (WorkflowTaskType) Enum 

func (x WorkflowTaskType) Enum() *WorkflowTaskType

func (WorkflowTaskType) EnumDescriptor deprecated 

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

Deprecated: Use WorkflowTaskType.Descriptor instead.

func (WorkflowTaskType) Number 

func (x WorkflowTaskType) Number() protoreflect.EnumNumber

func (WorkflowTaskType) String 

func (x WorkflowTaskType) String() string

func (WorkflowTaskType) Type 

func (WorkflowTaskType) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.