enums

package
v1.26.2 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2024 License: MIT Imports: 6 Imported by: 4

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

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",
	}
	HealthState_value = map[string]int32{
		"HEALTH_STATE_UNSPECIFIED": 0,
		"HEALTH_STATE_SERVING":     1,
		"HEALTH_STATE_NOT_SERVING": 2,
	}
)

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 (
	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.

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 (
	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",
	}
	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.

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 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_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,
	}
)
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 (
	SchedulerState_shorthandValue = map[string]int32{
		"Unspecified": 0,
		"Waiting":     1,
		"Executing":   2,
	}
)
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,
	}
)
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 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 PausedWorkflowEntityType added in v1.26.2 

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 added in v1.26.2 

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 added in v1.26.2 

func (PausedWorkflowEntityType) Descriptor() protoreflect.EnumDescriptor

func (PausedWorkflowEntityType) Enum added in v1.26.2 

func (x PausedWorkflowEntityType) Enum() *PausedWorkflowEntityType

func (PausedWorkflowEntityType) EnumDescriptor deprecated added in v1.26.2 

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

Deprecated: Use PausedWorkflowEntityType.Descriptor instead.

func (PausedWorkflowEntityType) Number added in v1.26.2 

func (x PausedWorkflowEntityType) Number() protoreflect.EnumNumber

func (PausedWorkflowEntityType) String added in v1.26.2 

func (x PausedWorkflowEntityType) String() string

func (PausedWorkflowEntityType) Type added in v1.26.2 

func (PausedWorkflowEntityType) 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 

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 added in v1.23.0 

func (TaskType) Descriptor() protoreflect.EnumDescriptor

func (TaskType) Enum added in v1.23.0 

func (x TaskType) Enum() *TaskType

func (TaskType) EnumDescriptor 

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

func (TaskType) Number added in v1.23.0 

func (x TaskType) Number() protoreflect.EnumNumber

func (TaskType) String 

func (x TaskType) String() string

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

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.