Files
tasks/common/metrics/metric_defs.go
Tim Deeb-SwihartandGitHub c3f2b821ea Backport code to drop internal errors encountered during task processing (#5385)
## What changed?

Internal errors encountered during task processing will be dropped when
this new config is enabled.

## Why?

These errors represent unprocessable tasks, so should not block our task
queues.

## How did you test it?


## Potential risks

We're not 100% certain that we only return internal errors when a task
is unprocessable, so this will be enabled by dynamicconfig for now.

## Is hotfix candidate?
2024-02-01 15:00:00 -08:00

1664 lines
126 KiB
Go

// The MIT License
//
// Copyright (c) 2020 Temporal Technologies Inc. All rights reserved.
//
// Copyright (c) 2020 Uber Technologies, Inc.
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in
// all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.
package metrics
// Common tags for all services
const (
OperationTagName = "operation"
ServiceRoleTagName = "service_role"
CacheTypeTagName = "cache_type"
FailureTagName = "failure"
TaskCategoryTagName = "task_category"
TaskTypeTagName = "task_type"
TaskPriorityTagName = "task_priority"
QueueReaderIDTagName = "queue_reader_id"
QueueActionTagName = "queue_action"
QueueTypeTagName = "queue_type"
visibilityTypeTagName = "visibility_type"
ErrorTypeTagName = "error_type"
httpStatusTagName = "http_status"
versionedTagName = "versioned"
resourceExhaustedTag = "resource_exhausted_cause"
standardVisibilityTagValue = "standard_visibility"
advancedVisibilityTagValue = "advanced_visibility"
)
// This package should hold all the metrics and tags for temporal
const (
HistoryRoleTagValue = "history"
MatchingRoleTagValue = "matching"
FrontendRoleTagValue = "frontend"
AdminRoleTagValue = "admin"
DCRedirectionRoleTagValue = "dc_redirection"
BlobstoreRoleTagValue = "blobstore"
MutableStateCacheTypeTagValue = "mutablestate"
EventsCacheTypeTagValue = "events"
InvalidHistoryURITagValue = "invalid_history_uri"
InvalidVisibilityURITagValue = "invalid_visibility_uri"
)
// Common service base metrics
const (
RestartCount = "restarts"
NumGoRoutinesGauge = "num_goroutines"
GoMaxProcsGauge = "gomaxprocs"
MemoryAllocatedGauge = "memory_allocated"
MemoryHeapGauge = "memory_heap"
MemoryHeapIdleGauge = "memory_heapidle"
MemoryHeapInuseGauge = "memory_heapinuse"
MemoryStackGauge = "memory_stack"
NumGCCounter = "memory_num_gc"
GcPauseMsTimer = "memory_gc_pause_ms"
)
// Admin Client Operations
const (
// AdminClientAddSearchAttributesScope tracks RPC calls to admin service
AdminClientAddSearchAttributesScope = "AdminClientAddSearchAttributes"
// AdminClientRemoveSearchAttributesScope tracks RPC calls to admin service
AdminClientRemoveSearchAttributesScope = "AdminClientRemoveSearchAttributes"
// AdminClientGetSearchAttributesScope tracks RPC calls to admin service
AdminClientGetSearchAttributesScope = "AdminClientGetSearchAttributes"
// AdminClientCloseShardScope tracks RPC calls to admin service
AdminClientCloseShardScope = "AdminClientCloseShard"
// AdminClientGetShardScope tracks RPC calls to admin service
AdminClientGetShardScope = "AdminClientGetShard"
// AdminClientListHistoryTasksScope tracks RPC calls to admin service
AdminClientListHistoryTasksScope = "AdminClientListHistoryTasks"
// AdminClientRemoveTaskScope tracks RPC calls to admin service
AdminClientRemoveTaskScope = "AdminClientRemoveTask"
// AdminClientDescribeHistoryHostScope tracks RPC calls to admin service
AdminClientDescribeHistoryHostScope = "AdminClientDescribeHistoryHost"
// AdminClientRebuildMutableStateScope tracks RPC calls to admin service
AdminClientRebuildMutableStateScope = "AdminClientRebuildMutableState"
// AdminClientDescribeMutableStateScope tracks RPC calls to admin service
AdminClientDescribeMutableStateScope = "AdminClientDescribeMutableState"
// AdminClientGetWorkflowExecutionRawHistoryV2Scope tracks RPC calls to admin service
AdminClientGetWorkflowExecutionRawHistoryV2Scope = "AdminClientGetWorkflowExecutionRawHistoryV2"
// AdminClientDescribeClusterScope tracks RPC calls to admin service
AdminClientDescribeClusterScope = "AdminClientDescribeCluster"
// AdminClientListClustersScope tracks RPC calls to admin service
AdminClientListClustersScope = "AdminClientListClusters"
// AdminClientListClusterMembersScope tracks RPC calls to admin service
AdminClientListClusterMembersScope = "AdminClientListClusterMembers"
// AdminClientAddOrUpdateRemoteClusterScope tracks RPC calls to admin service
AdminClientAddOrUpdateRemoteClusterScope = "AdminClientAddOrUpdateRemoteCluster"
// AdminClientRemoveRemoteClusterScope tracks RPC calls to admin service
AdminClientRemoveRemoteClusterScope = "AdminClientRemoveRemoteCluster"
// AdminClientGetReplicationMessagesScope tracks RPC calls to admin service
AdminClientGetReplicationMessagesScope = "AdminClientGetReplicationMessages"
// AdminClientGetNamespaceReplicationMessagesScope tracks RPC calls to admin service
AdminClientGetNamespaceReplicationMessagesScope = "AdminClientGetNamespaceReplicationMessages"
// AdminClientGetNamespaceScope tracks RPC calls to admin service
AdminClientGetNamespaceScope = "AdminClientGetNamespace"
// AdminClientGetDLQReplicationMessagesScope tracks RPC calls to admin service
AdminClientGetDLQReplicationMessagesScope = "AdminClientGetDLQReplicationMessages"
// AdminClientReapplyEventsScope tracks RPC calls to admin service
AdminClientReapplyEventsScope = "AdminClientReapplyEvents"
// AdminClientGetDLQMessagesScope tracks RPC calls to admin service
AdminClientGetDLQMessagesScope = "AdminClientGetDLQMessages"
// AdminClientPurgeDLQMessagesScope tracks RPC calls to admin service
AdminClientPurgeDLQMessagesScope = "AdminClientPurgeDLQMessages"
// AdminClientMergeDLQMessagesScope tracks RPC calls to admin service
AdminClientMergeDLQMessagesScope = "AdminClientMergeDLQMessages"
// AdminClientRefreshWorkflowTasksScope tracks RPC calls to admin service
AdminClientRefreshWorkflowTasksScope = "AdminClientRefreshWorkflowTasks"
// AdminClientResendReplicationTasksScope tracks RPC calls to admin service
AdminClientResendReplicationTasksScope = "AdminClientResendReplicationTasks"
// AdminClientGetTaskQueueTasksScope tracks RPC calls to admin service
AdminClientGetTaskQueueTasksScope = "AdminClientGetTaskQueueTasks"
// AdminClientDeleteWorkflowExecutionScope tracks RPC calls to admin service
AdminClientDeleteWorkflowExecutionScope = "AdminClientDeleteWorkflowExecution"
// AdminClientStreamWorkflowReplicationMessagesScope tracks RPC calls to admin service
AdminClientStreamWorkflowReplicationMessagesScope = "AdminClientStreamWorkflowReplicationMessages"
)
// Frontend Client Operations
const (
// FrontendClientDeleteWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientDeleteWorkflowExecutionScope = "FrontendClientDeleteWorkflowExecution"
// FrontendClientDeprecateNamespaceScope tracks RPC calls to frontend service
FrontendClientDeprecateNamespaceScope = "FrontendClientDeprecateNamespace"
// FrontendClientDescribeNamespaceScope tracks RPC calls to frontend service
FrontendClientDescribeNamespaceScope = "FrontendClientDescribeNamespace"
// FrontendClientDescribeTaskQueueScope tracks RPC calls to frontend service
FrontendClientDescribeTaskQueueScope = "FrontendClientDescribeTaskQueue"
// FrontendClientDescribeWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientDescribeWorkflowExecutionScope = "FrontendClientDescribeWorkflowExecution"
// FrontendClientGetWorkflowExecutionHistoryScope tracks RPC calls to frontend service
FrontendClientGetWorkflowExecutionHistoryScope = "FrontendClientGetWorkflowExecutionHistory"
// FrontendClientGetWorkflowExecutionHistoryReverseScope tracks RPC calls to frontend service
FrontendClientGetWorkflowExecutionHistoryReverseScope = "FrontendClientGetWorkflowExecutionHistoryReverse"
// FrontendClientGetWorkflowExecutionRawHistoryScope tracks RPC calls to frontend service
FrontendClientGetWorkflowExecutionRawHistoryScope = "FrontendClientGetWorkflowExecutionRawHistory"
// FrontendClientPollForWorkflowExecutionRawHistoryScope tracks RPC calls to frontend service
FrontendClientPollForWorkflowExecutionRawHistoryScope = "FrontendClientPollForWorkflowExecutionRawHistory"
// FrontendClientListArchivedWorkflowExecutionsScope tracks RPC calls to frontend service
FrontendClientListArchivedWorkflowExecutionsScope = "FrontendClientListArchivedWorkflowExecutions"
// FrontendClientListClosedWorkflowExecutionsScope tracks RPC calls to frontend service
FrontendClientListClosedWorkflowExecutionsScope = "FrontendClientListClosedWorkflowExecutions"
// FrontendClientListNamespacesScope tracks RPC calls to frontend service
FrontendClientListNamespacesScope = "FrontendClientListNamespaces"
// FrontendClientListOpenWorkflowExecutionsScope tracks RPC calls to frontend service
FrontendClientListOpenWorkflowExecutionsScope = "FrontendClientListOpenWorkflowExecutions"
// FrontendClientPollActivityTaskQueueScope tracks RPC calls to frontend service
FrontendClientPollActivityTaskQueueScope = "FrontendClientPollActivityTaskQueue"
// FrontendClientPollWorkflowExecutionUpdateScope tracks RPC calls to frontend service
FrontendClientPollWorkflowExecutionUpdateScope = "FrontendClientPollWorkflowExecutionUpdate"
// FrontendClientPollWorkflowTaskQueueScope tracks RPC calls to frontend service
FrontendClientPollWorkflowTaskQueueScope = "FrontendClientPollWorkflowTaskQueue"
// FrontendClientQueryWorkflowScope tracks RPC calls to frontend service
FrontendClientQueryWorkflowScope = "FrontendClientQueryWorkflow"
// FrontendClientRecordActivityTaskHeartbeatScope tracks RPC calls to frontend service
FrontendClientRecordActivityTaskHeartbeatScope = "FrontendClientRecordActivityTaskHeartbeat"
// FrontendClientRecordActivityTaskHeartbeatByIdScope tracks RPC calls to frontend service
FrontendClientRecordActivityTaskHeartbeatByIdScope = "FrontendClientRecordActivityTaskHeartbeatById"
// FrontendClientRegisterNamespaceScope tracks RPC calls to frontend service
FrontendClientRegisterNamespaceScope = "FrontendClientRegisterNamespace"
// FrontendClientRequestCancelWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientRequestCancelWorkflowExecutionScope = "FrontendClientRequestCancelWorkflowExecution"
// FrontendClientResetStickyTaskQueueScope tracks RPC calls to frontend service
FrontendClientResetStickyTaskQueueScope = "FrontendClientResetStickyTaskQueue"
// FrontendClientResetWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientResetWorkflowExecutionScope = "FrontendClientResetWorkflowExecution"
// FrontendClientRespondActivityTaskCanceledScope tracks RPC calls to frontend service
FrontendClientRespondActivityTaskCanceledScope = "FrontendClientRespondActivityTaskCanceled"
// FrontendClientRespondActivityTaskCanceledByIdScope tracks RPC calls to frontend service
FrontendClientRespondActivityTaskCanceledByIdScope = "FrontendClientRespondActivityTaskCanceledById"
// FrontendClientRespondActivityTaskCompletedScope tracks RPC calls to frontend service
FrontendClientRespondActivityTaskCompletedScope = "FrontendClientRespondActivityTaskCompleted"
// FrontendClientRespondActivityTaskCompletedByIdScope tracks RPC calls to frontend service
FrontendClientRespondActivityTaskCompletedByIdScope = "FrontendClientRespondActivityTaskCompletedById"
// FrontendClientRespondActivityTaskFailedScope tracks RPC calls to frontend service
FrontendClientRespondActivityTaskFailedScope = "FrontendClientRespondActivityTaskFailed"
// FrontendClientRespondActivityTaskFailedByIdScope tracks RPC calls to frontend service
FrontendClientRespondActivityTaskFailedByIdScope = "FrontendClientRespondActivityTaskFailedById"
// FrontendClientRespondWorkflowTaskCompletedScope tracks RPC calls to frontend service
FrontendClientRespondWorkflowTaskCompletedScope = "FrontendClientRespondWorkflowTaskCompleted"
// FrontendClientRespondWorkflowTaskFailedScope tracks RPC calls to frontend service
FrontendClientRespondWorkflowTaskFailedScope = "FrontendClientRespondWorkflowTaskFailed"
// FrontendClientRespondQueryTaskCompletedScope tracks RPC calls to frontend service
FrontendClientRespondQueryTaskCompletedScope = "FrontendClientRespondQueryTaskCompleted"
// FrontendClientSignalWithStartWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientSignalWithStartWorkflowExecutionScope = "FrontendClientSignalWithStartWorkflowExecution"
// FrontendClientSignalWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientSignalWorkflowExecutionScope = "FrontendClientSignalWorkflowExecution"
// FrontendClientStartWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientStartWorkflowExecutionScope = "FrontendClientStartWorkflowExecution"
// FrontendClientTerminateWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientTerminateWorkflowExecutionScope = "FrontendClientTerminateWorkflowExecution"
// FrontendClientUpdateNamespaceScope tracks RPC calls to frontend service
FrontendClientUpdateNamespaceScope = "FrontendClientUpdateNamespace"
// FrontendClientListWorkflowExecutionsScope tracks RPC calls to frontend service
FrontendClientListWorkflowExecutionsScope = "FrontendClientListWorkflowExecutions"
// FrontendClientScanWorkflowExecutionsScope tracks RPC calls to frontend service
FrontendClientScanWorkflowExecutionsScope = "FrontendClientScanWorkflowExecutions"
// FrontendClientCountWorkflowExecutionsScope tracks RPC calls to frontend service
FrontendClientCountWorkflowExecutionsScope = "FrontendClientCountWorkflowExecutions"
// FrontendClientGetSearchAttributesScope tracks RPC calls to frontend service
FrontendClientGetSearchAttributesScope = "FrontendClientGetSearchAttributes"
// FrontendClientGetClusterInfoScope tracks RPC calls to frontend
FrontendClientGetClusterInfoScope = "FrontendClientGetClusterInfo"
// FrontendClientGetSystemInfoScope tracks RPC calls to frontend
FrontendClientGetSystemInfoScope = "FrontendClientGetSystemInfo"
// FrontendClientListTaskQueuePartitionsScope tracks RPC calls to frontend service
FrontendClientListTaskQueuePartitionsScope = "FrontendClientListTaskQueuePartitions"
// FrontendClientCreateScheduleScope tracks RPC calls to frontend service
FrontendClientCreateScheduleScope = "FrontendClientCreateSchedule"
// FrontendClientDescribeScheduleScope tracks RPC calls to frontend service
FrontendClientDescribeScheduleScope = "FrontendClientDescribeSchedule"
// FrontendClientUpdateScheduleScope tracks RPC calls to frontend service
FrontendClientUpdateScheduleScope = "FrontendClientUpdateSchedule"
// FrontendClientPatchScheduleScope tracks RPC calls to frontend service
FrontendClientPatchScheduleScope = "FrontendClientPatchSchedule"
// FrontendClientListScheduleMatchingTimesScope tracks RPC calls to frontend service
FrontendClientListScheduleMatchingTimesScope = "FrontendClientListScheduleMatchingTimes"
// FrontendClientDeleteScheduleScope tracks RPC calls to frontend service
FrontendClientDeleteScheduleScope = "FrontendClientDeleteSchedule"
// FrontendClientListSchedulesScope tracks RPC calls to frontend service
FrontendClientListSchedulesScope = "FrontendClientListSchedules"
// FrontendClientUpdateWorkerBuildIdCompatibilityScope tracks RPC calls to frontend service
FrontendClientUpdateWorkerBuildIdCompatibilityScope = "FrontendClientUpdateWorkerBuildIdCompatibility"
// FrontendClientUpdateWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientUpdateWorkflowExecutionScope = "FrontendClientUpdateWorkflowExecution"
// FrontendClientGetWorkerBuildIdCompatibilityScope tracks RPC calls to frontend service
FrontendClientGetWorkerBuildIdCompatibilityScope = "FrontendClientGetWorkerBuildIdCompatibility"
// FrontendClientGetWorkerTaskReachabilityScope tracks RPC calls to frontend service
FrontendClientGetWorkerTaskReachabilityScope = "FrontendClientGetWorkerTaskReachability"
// FrontendClientDescribeBatchOperationScope tracks RPC calls to frontend service
FrontendClientDescribeBatchOperationScope = "FrontendClientDescribeBatchOperation"
// FrontendClientListBatchOperationsScope tracks RPC calls to frontend service
FrontendClientListBatchOperationsScope = "FrontendClientListBatchOperations"
// FrontendClientStartBatchOperationScope tracks RPC calls to frontend service
FrontendClientStartBatchOperationScope = "FrontendClientStartBatchOperation"
// FrontendClientStopBatchOperationScope tracks RPC calls to frontend service
FrontendClientStopBatchOperationScope = "FrontendClientStopBatchOperation"
)
// History Client Operations
const (
// HistoryClientStartWorkflowExecutionScope tracks RPC calls to history service
HistoryClientStartWorkflowExecutionScope = "HistoryClientStartWorkflowExecution"
// HistoryClientRecordActivityTaskHeartbeatScope tracks RPC calls to history service
HistoryClientRecordActivityTaskHeartbeatScope = "HistoryClientRecordActivityTaskHeartbeat"
// HistoryClientRespondWorkflowTaskCompletedScope tracks RPC calls to history service
HistoryClientRespondWorkflowTaskCompletedScope = "HistoryClientRespondWorkflowTaskCompleted"
// HistoryClientRespondWorkflowTaskFailedScope tracks RPC calls to history service
HistoryClientRespondWorkflowTaskFailedScope = "HistoryClientRespondWorkflowTaskFailed"
// HistoryClientRespondActivityTaskCompletedScope tracks RPC calls to history service
HistoryClientRespondActivityTaskCompletedScope = "HistoryClientRespondActivityTaskCompleted"
// HistoryClientRespondActivityTaskFailedScope tracks RPC calls to history service
HistoryClientRespondActivityTaskFailedScope = "HistoryClientRespondActivityTaskFailed"
// HistoryClientRespondActivityTaskCanceledScope tracks RPC calls to history service
HistoryClientRespondActivityTaskCanceledScope = "HistoryClientRespondActivityTaskCanceled"
// HistoryClientGetMutableStateScope tracks RPC calls to history service
HistoryClientGetMutableStateScope = "HistoryClientGetMutableState"
// HistoryClientPollMutableStateScope tracks RPC calls to history service
HistoryClientPollMutableStateScope = "HistoryClientPollMutableState"
// HistoryClientResetStickyTaskQueueScope tracks RPC calls to history service
HistoryClientResetStickyTaskQueueScope = "HistoryClientResetStickyTaskQueue"
// HistoryClientDescribeWorkflowExecutionScope tracks RPC calls to history service
HistoryClientDescribeWorkflowExecutionScope = "HistoryClientDescribeWorkflowExecution"
// HistoryClientRecordWorkflowTaskStartedScope tracks RPC calls to history service
HistoryClientRecordWorkflowTaskStartedScope = "HistoryClientRecordWorkflowTaskStarted"
// HistoryClientRecordActivityTaskStartedScope tracks RPC calls to history service
HistoryClientRecordActivityTaskStartedScope = "HistoryClientRecordActivityTaskStarted"
// HistoryClientRequestCancelWorkflowExecutionScope tracks RPC calls to history service
HistoryClientRequestCancelWorkflowExecutionScope = "HistoryClientRequestCancelWorkflowExecution"
// HistoryClientSignalWorkflowExecutionScope tracks RPC calls to history service
HistoryClientSignalWorkflowExecutionScope = "HistoryClientSignalWorkflowExecution"
// HistoryClientSignalWithStartWorkflowExecutionScope tracks RPC calls to history service
HistoryClientSignalWithStartWorkflowExecutionScope = "HistoryClientSignalWithStartWorkflowExecution"
// HistoryClientRemoveSignalMutableStateScope tracks RPC calls to history service
HistoryClientRemoveSignalMutableStateScope = "HistoryClientRemoveSignalMutableState"
// HistoryClientTerminateWorkflowExecutionScope tracks RPC calls to history service
HistoryClientTerminateWorkflowExecutionScope = "HistoryClientTerminateWorkflowExecution"
// HistoryClientUpdateWorkflowExecutionScope tracks RPC calls to history service
HistoryClientUpdateWorkflowExecutionScope = "HistoryClientUpdateWorkflowExecution"
// HistoryClientPollWorkflowExecutionUpdateScope tracks RPC calls to history service
HistoryClientPollWorkflowExecutionUpdateScope = "HistoryClientPollPollWorkflowExecutionUpdate"
// HistoryClientDeleteWorkflowExecutionScope tracks RPC calls to history service
HistoryClientDeleteWorkflowExecutionScope = "HistoryClientDeleteWorkflowExecution"
// HistoryClientResetWorkflowExecutionScope tracks RPC calls to history service
HistoryClientResetWorkflowExecutionScope = "HistoryClientResetWorkflowExecution"
// HistoryClientScheduleWorkflowTaskScope tracks RPC calls to history service
HistoryClientScheduleWorkflowTaskScope = "HistoryClientScheduleWorkflowTask"
// HistoryClientVerifyFirstWorkflowTaskScheduled tracks RPC calls to history service
HistoryClientVerifyFirstWorkflowTaskScheduled
// HistoryClientRecordChildExecutionCompletedScope tracks RPC calls to history service
HistoryClientRecordChildExecutionCompletedScope = "HistoryClientRecordChildExecutionCompleted"
// HistoryClientVerifyChildExecutionCompletionRecordedScope tracks RPC calls to history service
HistoryClientVerifyChildExecutionCompletionRecordedScope = "HistoryClientVerifyChildExecutionCompletionRecorded"
// HistoryClientReplicateEventsV2Scope tracks RPC calls to history service
HistoryClientReplicateEventsV2Scope = "HistoryClientReplicateEventsV2"
// HistoryClientReplicateWorkflowStateScope tracks RPC calls to history service
HistoryClientReplicateWorkflowStateScope = "HistoryClientReplicateWorkflowState"
// HistoryClientSyncShardStatusScope tracks RPC calls to history service
HistoryClientSyncShardStatusScope = "HistoryClientSyncShardStatus"
// HistoryClientSyncActivityScope tracks RPC calls to history service
HistoryClientSyncActivityScope = "HistoryClientSyncActivity"
// HistoryClientGetReplicationTasksScope tracks RPC calls to history service
HistoryClientGetReplicationTasksScope = "HistoryClientGetReplicationTasks"
// HistoryClientGetDLQReplicationTasksScope tracks RPC calls to history service
HistoryClientGetDLQReplicationTasksScope = "HistoryClientGetDLQReplicationTasks"
// HistoryClientQueryWorkflowScope tracks RPC calls to history service
HistoryClientQueryWorkflowScope = "HistoryClientQueryWorkflow"
// HistoryClientReapplyEventsScope tracks RPC calls to history service
HistoryClientReapplyEventsScope = "HistoryClientReapplyEvents"
// HistoryClientGetDLQMessagesScope tracks RPC calls to history service
HistoryClientGetDLQMessagesScope = "HistoryClientGetDLQMessages"
// HistoryClientPurgeDLQMessagesScope tracks RPC calls to history service
HistoryClientPurgeDLQMessagesScope = "HistoryClientPurgeDLQMessages"
// HistoryClientMergeDLQMessagesScope tracks RPC calls to history service
HistoryClientMergeDLQMessagesScope = "HistoryClientMergeDLQMessages"
// HistoryClientRefreshWorkflowTasksScope tracks RPC calls to history service
HistoryClientRefreshWorkflowTasksScope = "HistoryClientRefreshWorkflowTasks"
// HistoryClientGenerateLastHistoryReplicationTasksScope tracks RPC calls to history service
HistoryClientGenerateLastHistoryReplicationTasksScope = "HistoryClientGenerateLastHistoryReplicationTasks"
// HistoryClientGetReplicationStatusScope tracks RPC calls to history service
HistoryClientGetReplicationStatusScope = "HistoryClientGetReplicationStatus"
// HistoryClientDeleteWorkflowVisibilityRecordScope tracks RPC calls to history service
HistoryClientDeleteWorkflowVisibilityRecordScope = "HistoryClientDeleteWorkflowVisibilityRecord"
// HistoryClientCloseShardScope tracks RPC calls to history service
HistoryClientCloseShardScope = "HistoryClientCloseShard"
// HistoryClientDescribeMutableStateScope tracks RPC calls to history service
HistoryClientDescribeMutableStateScope = "HistoryClientDescribeMutableState"
// HistoryClientGetDLQReplicationMessagesScope tracks RPC calls to history service
HistoryClientGetDLQReplicationMessagesScope = "HistoryClientGetDLQReplicationMessages"
// HistoryClientGetShardScope tracks RPC calls to history service
HistoryClientGetShardScope = "HistoryClientGetShard"
// HistoryClientIsActivityTaskValidScope tracks RPC calls to history service
HistoryClientIsActivityTaskValidScope = "HistoryClientIsActivityTaskValid"
// HistoryClientIsWorkflowTaskValidScope tracks RPC calls to history service
HistoryClientIsWorkflowTaskValidScope = "HistoryClientIsWorkflowTaskValid"
// HistoryClientRebuildMutableStateScope tracks RPC calls to history service
HistoryClientRebuildMutableStateScope = "HistoryClientRebuildMutableState"
// HistoryClientRemoveTaskScope tracks RPC calls to history service
HistoryClientRemoveTaskScope = "HistoryClientRemoveTask"
// HistoryClientVerifyFirstWorkflowTaskScheduledScope tracks RPC calls to history service
HistoryClientVerifyFirstWorkflowTaskScheduledScope = "HistoryClientVerifyFirstWorkflowTaskScheduled"
// HistoryClientDescribeHistoryHostScope tracks RPC calls to history service
HistoryClientDescribeHistoryHostScope = "HistoryClientDescribeHistoryHost"
// HistoryClientGetReplicationMessagesScope tracks RPC calls to history service
HistoryClientGetReplicationMessagesScope = "HistoryClientGetReplicationMessages"
// HistoryClientStreamWorkflowReplicationMessagesScope tracks RPC calls to history service
HistoryClientStreamWorkflowReplicationMessagesScope = "HistoryClientStreamWorkflowReplicationMessages"
)
// Matching Client Operations
const (
// MatchingClientPollWorkflowTaskQueueScope tracks RPC calls to matching service
MatchingClientPollWorkflowTaskQueueScope = "MatchingClientPollWorkflowTaskQueue"
// MatchingClientPollActivityTaskQueueScope tracks RPC calls to matching service
MatchingClientPollActivityTaskQueueScope = "MatchingClientPollActivityTaskQueue"
// MatchingClientAddActivityTaskScope tracks RPC calls to matching service
MatchingClientAddActivityTaskScope = "MatchingClientAddActivityTask"
// MatchingClientAddWorkflowTaskScope tracks RPC calls to matching service
MatchingClientAddWorkflowTaskScope = "MatchingClientAddWorkflowTask"
// MatchingClientQueryWorkflowScope tracks RPC calls to matching service
MatchingClientQueryWorkflowScope = "MatchingClientQueryWorkflow"
// MatchingClientRespondQueryTaskCompletedScope tracks RPC calls to matching service
MatchingClientRespondQueryTaskCompletedScope = "MatchingClientRespondQueryTaskCompleted"
// MatchingClientCancelOutstandingPollScope tracks RPC calls to matching service
MatchingClientCancelOutstandingPollScope = "MatchingClientCancelOutstandingPoll"
// MatchingClientDescribeTaskQueueScope tracks RPC calls to matching service
MatchingClientDescribeTaskQueueScope = "MatchingClientDescribeTaskQueue"
// MatchingClientGetBuildIdTaskQueueMappingScope tracks RPC calls to matching service
MatchingClientGetBuildIdTaskQueueMappingScope = "MatchingClientGetBuildIdTaskQueueMapping"
// MatchingClientListTaskQueuePartitionsScope tracks RPC calls to matching service
MatchingClientListTaskQueuePartitionsScope = "MatchingClientListTaskQueuePartitions"
// MatchingClientUpdateWorkerBuildIdCompatibilityScope tracks RPC calls to matching service
MatchingClientUpdateWorkerBuildIdCompatibilityScope = "MatchingClientUpdateWorkerBuildIdCompatibility"
// MatchingClientGetWorkerBuildIdCompatibilityScope tracks RPC calls to matching service
MatchingClientGetWorkerBuildIdCompatibilityScope = "MatchingClientGetWorkerBuildIdCompatibility"
// MatchingClientGetTaskQueueUserDataScope tracks RPC calls to matching service
MatchingClientGetTaskQueueUserDataScope = "MatchingClientGetTaskQueueUserData"
// MatchingClientApplyTaskQueueUserDataReplicationEventScope tracks RPC calls to matching service
MatchingClientApplyTaskQueueUserDataReplicationEventScope = "MatchingClientApplyTaskQueueUserDataReplicationEvent"
// MatchingClientForceUnloadTaskQueueScope tracks RPC calls to matching service
MatchingClientForceUnloadTaskQueueScope = "MatchingClientForceUnloadTaskQueue"
// MatchingClientUpdateTaskQueueUserDataScope tracks RPC calls to matching service
MatchingClientUpdateTaskQueueUserDataScope = "MatchingClientUpdateTaskQueueUserData"
// MatchingClientReplicateTaskQueueUserDataScope tracks RPC calls to matching service
MatchingClientReplicateTaskQueueUserDataScope = "MatchingClientReplicateTaskQueueUserData"
)
// Worker
const (
// TaskQueueScavengerScope is scope used by all metrics emitted by worker.taskqueue.Scavenger module
TaskQueueScavengerScope = "TaskQueueScavenger"
// ExecutionsScavengerScope is scope used by all metrics emitted by worker.executions.Scavenger module
ExecutionsScavengerScope = "ExecutionsScavenger"
)
const (
// PersistenceAppendHistoryNodesScope tracks AppendHistoryNodes calls made by service to persistence layer
PersistenceAppendHistoryNodesScope = "AppendHistoryNodes"
// PersistenceAppendRawHistoryNodesScope tracks AppendRawHistoryNodes calls made by service to persistence layer
PersistenceAppendRawHistoryNodesScope = "AppendRawHistoryNodes"
// PersistenceDeleteHistoryNodesScope tracks DeleteHistoryNodes calls made by service to persistence layer
PersistenceDeleteHistoryNodesScope = "DeleteHistoryNodes"
// PersistenceReadHistoryBranchScope tracks ReadHistoryBranch calls made by service to persistence layer
PersistenceReadHistoryBranchScope = "ReadHistoryBranch"
// PersistenceReadHistoryBranchReverseScope tracks ReadHistoryBranchReverse calls made by service to persistence layer
PersistenceReadHistoryBranchReverseScope = "ReadHistoryBranchReverse"
// PersistenceReadRawHistoryBranchScope tracks ReadRawHistoryBranch calls made by service to persistence layer
PersistenceReadRawHistoryBranchScope = "ReadRawHistoryBranch"
// PersistenceForkHistoryBranchScope tracks ForkHistoryBranch calls made by service to persistence layer
PersistenceForkHistoryBranchScope = "ForkHistoryBranch"
// PersistenceDeleteHistoryBranchScope tracks DeleteHistoryBranch calls made by service to persistence layer
PersistenceDeleteHistoryBranchScope = "DeleteHistoryBranch"
// PersistenceTrimHistoryBranchScope tracks TrimHistoryBranch calls made by service to persistence layer
PersistenceTrimHistoryBranchScope = "TrimHistoryBranch"
// PersistenceCompleteForkBranchScope tracks CompleteForkBranch calls made by service to persistence layer
PersistenceCompleteForkBranchScope = "CompleteForkBranch"
// PersistenceGetHistoryTreeScope tracks GetHistoryTree calls made by service to persistence layer
PersistenceGetHistoryTreeScope = "GetHistoryTree"
// PersistenceGetAllHistoryTreeBranchesScope tracks GetHistoryTree calls made by service to persistence layer
PersistenceGetAllHistoryTreeBranchesScope = "GetAllHistoryTreeBranches"
// PersistenceNamespaceReplicationQueueScope is the metrics scope for namespace replication queue
PersistenceNamespaceReplicationQueueScope = "NamespaceReplicationQueue"
// PersistenceEnqueueMessageScope tracks Enqueue calls made by service to persistence layer
PersistenceEnqueueMessageScope = "EnqueueMessage"
// PersistenceEnqueueMessageToDLQScope tracks Enqueue DLQ calls made by service to persistence layer
PersistenceEnqueueMessageToDLQScope = "EnqueueMessageToDLQ"
// PersistenceReadQueueMessagesScope tracks ReadMessages calls made by service to persistence layer
PersistenceReadQueueMessagesScope = "ReadQueueMessages"
// PersistenceReadMessagesFromDLQScope tracks ReadMessagesFromDLQ calls made by service to persistence layer
PersistenceReadMessagesFromDLQScope = "ReadMessagesFromDLQ"
// PersistenceDeleteMessagesBeforeScope tracks DeleteMessagesBefore calls made by service to persistence layer
PersistenceDeleteMessagesBeforeScope = "DeleteMessagesBefore"
// PersistenceDeleteMessageFromDLQScope tracks DeleteMessageFromDLQ calls made by service to persistence layer
PersistenceDeleteMessageFromDLQScope = "DeleteMessageFromDLQ"
// PersistenceRangeDeleteMessagesFromDLQScope tracks RangeDeleteMessagesFromDLQ calls made by service to persistence layer
PersistenceRangeDeleteMessagesFromDLQScope = "RangeDeleteMessagesFromDLQ"
// PersistenceUpdateAckLevelScope tracks UpdateAckLevel calls made by service to persistence layer
PersistenceUpdateAckLevelScope = "UpdateAckLevel"
// PersistenceGetAckLevelScope tracks GetAckLevel calls made by service to persistence layer
PersistenceGetAckLevelScope = "GetAckLevel"
// PersistenceUpdateDLQAckLevelScope tracks UpdateDLQAckLevel calls made by service to persistence layer
PersistenceUpdateDLQAckLevelScope = "UpdateDLQAckLevel"
// PersistenceGetDLQAckLevelScope tracks GetDLQAckLevel calls made by service to persistence layer
PersistenceGetDLQAckLevelScope = "GetDLQAckLevel"
// PersistenceListClusterMetadataScope tracks ListClusterMetadata calls made by service to persistence layer
PersistenceListClusterMetadataScope = "ListClusterMetadata"
// PersistenceGetClusterMetadataScope tracks GetClusterMetadata calls made by service to persistence layer
PersistenceGetClusterMetadataScope = "GetClusterMetadata"
// PersistenceGetCurrentClusterMetadataScope tracks GetCurrentClusterMetadata calls made by service to persistence layer
PersistenceGetCurrentClusterMetadataScope = "GetCurrentClusterMetadata"
// PersistenceSaveClusterMetadataScope tracks SaveClusterMetadata calls made by service to persistence layer
PersistenceSaveClusterMetadataScope = "SaveClusterMetadata"
// PersistenceDeleteClusterMetadataScope tracks DeleteClusterMetadata calls made by service to persistence layer
PersistenceDeleteClusterMetadataScope = "DeleteClusterMetadata"
// PersistenceUpsertClusterMembershipScope tracks UpsertClusterMembership calls made by service to persistence layer
PersistenceUpsertClusterMembershipScope = "UpsertClusterMembership"
// PersistencePruneClusterMembershipScope tracks PruneClusterMembership calls made by service to persistence layer
PersistencePruneClusterMembershipScope = "PruneClusterMembership"
// PersistenceGetClusterMembersScope tracks GetClusterMembers calls made by service to persistence layer
PersistenceGetClusterMembersScope = "GetClusterMembers"
// PersistenceGetOrCreateShardScope tracks GetOrCreateShard calls made by service to persistence layer
PersistenceGetOrCreateShardScope = "GetOrCreateShard"
// PersistenceUpdateShardScope tracks UpdateShard calls made by service to persistence layer
PersistenceUpdateShardScope = "UpdateShard"
// PersistenceAssertShardOwnershipScope tracks UpdateShard calls made by service to persistence layer
PersistenceAssertShardOwnershipScope = "AssertShardOwnership"
// PersistenceCreateWorkflowExecutionScope tracks CreateWorkflowExecution calls made by service to persistence layer
PersistenceCreateWorkflowExecutionScope = "CreateWorkflowExecution"
// PersistenceGetWorkflowExecutionScope tracks GetWorkflowExecution calls made by service to persistence layer
PersistenceGetWorkflowExecutionScope = "GetWorkflowExecution"
// PersistenceSetWorkflowExecutionScope tracks SetWorkflowExecution calls made by service to persistence layer
PersistenceSetWorkflowExecutionScope = "SetWorkflowExecution"
// PersistenceUpdateWorkflowExecutionScope tracks UpdateWorkflowExecution calls made by service to persistence layer
PersistenceUpdateWorkflowExecutionScope = "UpdateWorkflowExecution"
// PersistenceConflictResolveWorkflowExecutionScope tracks ConflictResolveWorkflowExecution calls made by service to persistence layer
PersistenceConflictResolveWorkflowExecutionScope = "ConflictResolveWorkflowExecution"
// PersistenceResetWorkflowExecutionScope tracks ResetWorkflowExecution calls made by service to persistence layer
PersistenceResetWorkflowExecutionScope = "ResetWorkflowExecution"
// PersistenceDeleteWorkflowExecutionScope tracks DeleteWorkflowExecution calls made by service to persistence layer
PersistenceDeleteWorkflowExecutionScope = "DeleteWorkflowExecution"
// PersistenceDeleteCurrentWorkflowExecutionScope tracks DeleteCurrentWorkflowExecution calls made by service to persistence layer
PersistenceDeleteCurrentWorkflowExecutionScope = "DeleteCurrentWorkflowExecution"
// PersistenceGetCurrentExecutionScope tracks GetCurrentExecution calls made by service to persistence layer
PersistenceGetCurrentExecutionScope = "GetCurrentExecution"
// PersistenceListConcreteExecutionsScope tracks ListConcreteExecutions calls made by service to persistence layer
PersistenceListConcreteExecutionsScope = "ListConcreteExecutions"
// PersistenceAddTasksScope tracks AddTasks calls made by service to persistence layer
PersistenceAddTasksScope = "AddTasks"
// PersistenceGetTransferTasksScope tracks GetTransferTasks calls made by service to persistence layer
PersistenceGetTransferTasksScope = "GetTransferTasks"
// PersistenceCompleteTransferTaskScope tracks CompleteTransferTasks calls made by service to persistence layer
PersistenceCompleteTransferTaskScope = "CompleteTransferTask"
// PersistenceRangeCompleteTransferTasksScope tracks CompleteTransferTasks calls made by service to persistence layer
PersistenceRangeCompleteTransferTasksScope = "RangeCompleteTransferTasks"
// PersistenceGetVisibilityTasksScope tracks GetVisibilityTasks calls made by service to persistence layer
PersistenceGetVisibilityTasksScope = "GetVisibilityTasks"
// PersistenceCompleteVisibilityTaskScope tracks CompleteVisibilityTasks calls made by service to persistence layer
PersistenceCompleteVisibilityTaskScope = "CompleteVisibilityTask"
// PersistenceRangeCompleteVisibilityTasksScope tracks CompleteVisibilityTasks calls made by service to persistence layer
PersistenceRangeCompleteVisibilityTasksScope = "RangeCompleteVisibilityTasks"
// PersistenceGetReplicationTaskScope tracks GetReplicationTask calls made by service to persistence layer
PersistenceGetArchivalTasksScope = "GetArchivalTasks"
// PersistenceCompleteArchivalTaskScope tracks CompleteArchivalTasks calls made by service to persistence layer
PersistenceCompleteArchivalTaskScope = "CompleteArchivalTask"
// PersistenceRangeCompleteArchivalTasksScope tracks CompleteArchivalTasks calls made by service to persistence layer
PersistenceRangeCompleteArchivalTasksScope = "RangeCompleteArchivalTasks"
// PersistenceGetReplicationTasksScope tracks GetReplicationTasks calls made by service to persistence layer
PersistenceGetReplicationTasksScope = "GetReplicationTasks"
// PersistenceCompleteReplicationTaskScope tracks CompleteReplicationTasks calls made by service to persistence layer
PersistenceCompleteReplicationTaskScope = "CompleteReplicationTask"
// PersistenceRangeCompleteReplicationTasksScope tracks RangeCompleteReplicationTasks calls made by service to persistence layer
PersistenceRangeCompleteReplicationTasksScope = "RangeCompleteReplicationTasks"
// PersistencePutReplicationTaskToDLQScope tracks PersistencePutReplicationTaskToDLQScope calls made by service to persistence layer
PersistencePutReplicationTaskToDLQScope = "PutReplicationTaskToDLQ"
// PersistenceGetReplicationTasksFromDLQScope tracks PersistenceGetReplicationTasksFromDLQScope calls made by service to persistence layer
PersistenceGetReplicationTasksFromDLQScope = "GetReplicationTasksFromDLQ"
// PersistenceDeleteReplicationTaskFromDLQScope tracks PersistenceDeleteReplicationTaskFromDLQScope calls made by service to persistence layer
PersistenceDeleteReplicationTaskFromDLQScope = "DeleteReplicationTaskFromDLQ"
// PersistenceRangeDeleteReplicationTaskFromDLQScope tracks PersistenceRangeDeleteReplicationTaskFromDLQScope calls made by service to persistence layer
PersistenceRangeDeleteReplicationTaskFromDLQScope = "RangeDeleteReplicationTaskFromDLQ"
// PersistenceGetTimerTasksScope tracks GetTimerTasks calls made by service to persistence layer
PersistenceGetTimerTasksScope = "GetTimerTasks"
// PersistenceCompleteTimerTaskScope tracks CompleteTimerTasks calls made by service to persistence layer
PersistenceCompleteTimerTaskScope = "CompleteTimerTask"
// PersistenceRangeCompleteTimerTasksScope tracks CompleteTimerTasks calls made by service to persistence layer
PersistenceRangeCompleteTimerTasksScope = "RangeCompleteTimerTasks"
// PersistenceCreateTasksScope tracks CreateTasks calls made by service to persistence layer
PersistenceCreateTasksScope = "CreateTasks"
// PersistenceGetTasksScope tracks GetTasks calls made by service to persistence layer
PersistenceGetTasksScope = "GetTasks"
// PersistenceCompleteTaskScope tracks CompleteTask calls made by service to persistence layer
PersistenceCompleteTaskScope = "CompleteTask"
// PersistenceCompleteTasksLessThanScope is the metric scope for persistence.TaskManager.PersistenceCompleteTasksLessThan API
PersistenceCompleteTasksLessThanScope = "CompleteTasksLessThan"
// PersistenceCreateTaskQueueScope tracks PersistenceCreateTaskQueueScope calls made by service to persistence layer
PersistenceCreateTaskQueueScope = "CreateTaskQueue"
// PersistenceUpdateTaskQueueScope tracks PersistenceUpdateTaskQueueScope calls made by service to persistence layer
PersistenceUpdateTaskQueueScope = "UpdateTaskQueue"
// PersistenceGetTaskQueueScope tracks PersistenceGetTaskQueueScope calls made by service to persistence layer
PersistenceGetTaskQueueScope = "GetTaskQueue"
// PersistenceListTaskQueueScope is the metric scope for persistence.TaskManager.ListTaskQueue API
PersistenceListTaskQueueScope = "ListTaskQueue"
// PersistenceDeleteTaskQueueScope is the metric scope for persistence.TaskManager.DeleteTaskQueue API
PersistenceDeleteTaskQueueScope = "DeleteTaskQueue"
// PersistenceGetTaskQueueUserDataScope is the metric scope for persistence.TaskManager.GetTaskQueueUserData API
PersistenceGetTaskQueueUserDataScope = "GetTaskQueueUserData"
// PersistenceUpdateTaskQueueUserDataScope is the metric scope for persistence.TaskManager.UpdateTaskQueueUserData API
PersistenceUpdateTaskQueueUserDataScope = "UpdateTaskQueueUserData"
// PersistenceListTaskQueueUserDataEntriesScope is the metric scope for persistence.TaskManager.ListTaskQueueUserDataEntries API
PersistenceListTaskQueueUserDataEntriesScope = "ListTaskQueueUserDataEntries"
// PersistenceGetTaskQueuesByBuildIdScope is the metric scope for persistence.TaskManager.GetTaskQueuesByBuildId API
PersistenceGetTaskQueuesByBuildIdScope = "GetTaskQueuesByBuildId"
// PersistenceCountTaskQueuesByBuildIdScope is the metric scope for persistence.TaskManager.CountTaskQueuesByBuildId API
PersistenceCountTaskQueuesByBuildIdScope = "CountTaskQueuesByBuildId"
// PersistenceAppendHistoryEventsScope tracks AppendHistoryEvents calls made by service to persistence layer
PersistenceAppendHistoryEventsScope = "AppendHistoryEvents"
// PersistenceGetWorkflowExecutionHistoryScope tracks GetWorkflowExecutionHistory calls made by service to persistence layer
PersistenceGetWorkflowExecutionHistoryScope = "GetWorkflowExecutionHistory"
// PersistenceDeleteWorkflowExecutionHistoryScope tracks DeleteWorkflowExecutionHistory calls made by service to persistence layer
PersistenceDeleteWorkflowExecutionHistoryScope = "DeleteWorkflowExecutionHistory"
// PersistenceInitializeSystemNamespaceScope tracks InitializeSystemNamespaceScope calls made by service to persistence layer
PersistenceInitializeSystemNamespaceScope = "InitializeSystemNamespace"
// PersistenceCreateNamespaceScope tracks CreateNamespace calls made by service to persistence layer
PersistenceCreateNamespaceScope = "CreateNamespace"
// PersistenceGetNamespaceScope tracks GetNamespace calls made by service to persistence layer
PersistenceGetNamespaceScope = "GetNamespace"
// PersistenceUpdateNamespaceScope tracks UpdateNamespace calls made by service to persistence layer
PersistenceUpdateNamespaceScope = "UpdateNamespace"
// PersistenceDeleteNamespaceScope tracks DeleteNamespace calls made by service to persistence layer
PersistenceDeleteNamespaceScope = "DeleteNamespace"
// PersistenceRenameNamespaceScope tracks RenameNamespace calls made by service to persistence layer
PersistenceRenameNamespaceScope = "RenameNamespace"
// PersistenceDeleteNamespaceByNameScope tracks DeleteNamespaceByName calls made by service to persistence layer
PersistenceDeleteNamespaceByNameScope = "DeleteNamespaceByName"
// PersistenceListNamespacesScope tracks ListNamespaces calls made by service to persistence layer
PersistenceListNamespacesScope = "ListNamespaces"
// PersistenceGetMetadataScope tracks DeleteNamespaceByName calls made by service to persistence layer
PersistenceGetMetadataScope = "GetMetadata"
// VisibilityPersistenceRecordWorkflowExecutionStartedScope tracks RecordWorkflowExecutionStarted calls made by service to visibility persistence layer
VisibilityPersistenceRecordWorkflowExecutionStartedScope = "RecordWorkflowExecutionStarted"
// VisibilityPersistenceRecordWorkflowExecutionClosedScope tracks RecordWorkflowExecutionClosed calls made by service to visibility persistence layer
VisibilityPersistenceRecordWorkflowExecutionClosedScope = "RecordWorkflowExecutionClosed"
// VisibilityPersistenceUpsertWorkflowExecutionScope tracks UpsertWorkflowExecution calls made by service to persistence visibility layer
VisibilityPersistenceUpsertWorkflowExecutionScope = "UpsertWorkflowExecution"
// VisibilityPersistenceListOpenWorkflowExecutionsScope tracks ListOpenWorkflowExecutions calls made by service to visibility persistence layer
VisibilityPersistenceListOpenWorkflowExecutionsScope = "ListOpenWorkflowExecutions"
// VisibilityPersistenceListClosedWorkflowExecutionsScope tracks ListClosedWorkflowExecutions calls made by service to visibility persistence layer
VisibilityPersistenceListClosedWorkflowExecutionsScope = "ListClosedWorkflowExecutions"
// VisibilityPersistenceListOpenWorkflowExecutionsByTypeScope tracks ListOpenWorkflowExecutionsByType calls made by service to visibility persistence layer
VisibilityPersistenceListOpenWorkflowExecutionsByTypeScope = "ListOpenWorkflowExecutionsByType"
// VisibilityPersistenceListClosedWorkflowExecutionsByTypeScope tracks ListClosedWorkflowExecutionsByType calls made by service to visibility persistence layer
VisibilityPersistenceListClosedWorkflowExecutionsByTypeScope = "ListClosedWorkflowExecutionsByType"
// VisibilityPersistenceListOpenWorkflowExecutionsByWorkflowIDScope tracks ListOpenWorkflowExecutionsByWorkflowID calls made by service to visibility persistence layer
VisibilityPersistenceListOpenWorkflowExecutionsByWorkflowIDScope = "ListOpenWorkflowExecutionsByWorkflowID"
// VisibilityPersistenceListClosedWorkflowExecutionsByWorkflowIDScope tracks ListClosedWorkflowExecutionsByWorkflowID calls made by service to visibility persistence layer
VisibilityPersistenceListClosedWorkflowExecutionsByWorkflowIDScope = "ListClosedWorkflowExecutionsByWorkflowID"
// VisibilityPersistenceListClosedWorkflowExecutionsByStatusScope tracks ListClosedWorkflowExecutionsByStatus calls made by service to visibility persistence layer
VisibilityPersistenceListClosedWorkflowExecutionsByStatusScope = "ListClosedWorkflowExecutionsByStatus"
// VisibilityPersistenceDeleteWorkflowExecutionScope tracks DeleteWorkflowExecutions calls made by service to visibility persistence layer
VisibilityPersistenceDeleteWorkflowExecutionScope = "DeleteWorkflowExecution"
// VisibilityPersistenceListWorkflowExecutionsScope tracks ListWorkflowExecutions calls made by service to visibility persistence layer
VisibilityPersistenceListWorkflowExecutionsScope = "ListWorkflowExecutions"
// VisibilityPersistenceScanWorkflowExecutionsScope tracks ScanWorkflowExecutions calls made by service to visibility persistence layer
VisibilityPersistenceScanWorkflowExecutionsScope = "ScanWorkflowExecutions"
// VisibilityPersistenceCountWorkflowExecutionsScope tracks CountWorkflowExecutions calls made by service to visibility persistence layer
VisibilityPersistenceCountWorkflowExecutionsScope = "CountWorkflowExecutions"
// VisibilityPersistenceGetWorkflowExecutionScope tracks GetWorkflowExecution calls made by service to visibility persistence layer
VisibilityPersistenceGetWorkflowExecutionScope = "GetWorkflowExecution"
)
// Common
const (
ServerTlsScope = "ServerTls"
// AuthorizationScope is the scope used by all metric emitted by authorization code
AuthorizationScope = "Authorization"
// NamespaceCacheScope tracks namespace cache callbacks
NamespaceCacheScope = "NamespaceCache"
)
// Frontend Scope
const (
// AdminGetWorkflowExecutionRawHistoryV2Scope is the metric scope for admin.GetWorkflowExecutionRawHistoryScope
AdminGetWorkflowExecutionRawHistoryV2Scope = "AdminGetWorkflowExecutionRawHistoryV2"
// OperatorAddSearchAttributesScope is the metric scope for operator.AddSearchAttributes
OperatorAddSearchAttributesScope = "OperatorAddSearchAttributes"
// OperatorDeleteNamespaceScope is the metric scope for operator.OperatorDeleteNamespace
OperatorDeleteNamespaceScope = "OperatorDeleteNamespace"
// FrontendPollWorkflowTaskQueueScope is the metric scope for frontend.PollWorkflowTaskQueue
FrontendPollWorkflowTaskQueueScope = "PollWorkflowTaskQueue"
// FrontendRespondWorkflowTaskFailedScope is the metric scope for frontend.RespondWorkflowTaskFailed
FrontendRespondWorkflowTaskFailedScope = "RespondWorkflowTaskFailed"
// FrontendRespondQueryTaskCompletedScope is the metric scope for frontend.RespondQueryTaskCompleted
FrontendRespondQueryTaskCompletedScope = "RespondQueryTaskCompleted"
// FrontendRespondActivityTaskCompletedScope is the metric scope for frontend.RespondActivityTaskCompleted
FrontendRespondActivityTaskCompletedScope = "RespondActivityTaskCompleted"
// FrontendRespondActivityTaskFailedScope is the metric scope for frontend.RespondActivityTaskFailed
FrontendRespondActivityTaskFailedScope = "RespondActivityTaskFailed"
// FrontendRespondActivityTaskCanceledScope is the metric scope for frontend.RespondActivityTaskCanceled
FrontendRespondActivityTaskCanceledScope = "RespondActivityTaskCanceled"
// FrontendRespondActivityTaskCompletedByIdScope is the metric scope for frontend.RespondActivityTaskCompletedById
FrontendRespondActivityTaskCompletedByIdScope = "RespondActivityTaskCompletedById"
// FrontendRespondActivityTaskFailedByIdScope is the metric scope for frontend.RespondActivityTaskFailedById
FrontendRespondActivityTaskFailedByIdScope = "RespondActivityTaskFailedById"
// FrontendRespondActivityTaskCanceledByIdScope is the metric scope for frontend.RespondActivityTaskCanceledById
FrontendRespondActivityTaskCanceledByIdScope = "RespondActivityTaskCanceledById"
// FrontendGetWorkflowExecutionHistoryScope is the metric scope for non-long-poll frontend.GetWorkflowExecutionHistory
FrontendGetWorkflowExecutionHistoryScope = "GetWorkflowExecutionHistory"
// FrontendGetWorkflowExecutionHistoryReverseScope is the metric for frontend.GetWorkflowExecutionHistoryReverse
FrontendGetWorkflowExecutionHistoryReverseScope = "GetWorkflowExecutionHistoryReverse"
// FrontendPollWorkflowExecutionHistoryScope is the metric scope for long poll case of frontend.GetWorkflowExecutionHistory
FrontendPollWorkflowExecutionHistoryScope = "PollWorkflowExecutionHistory"
// FrontendGetWorkflowExecutionRawHistoryScope is the metric scope for frontend.GetWorkflowExecutionRawHistory
FrontendGetWorkflowExecutionRawHistoryScope = "GetWorkflowExecutionRawHistory"
// FrontendPollForWorkflowExecutionRawHistoryScope is the metric scope for frontend.GetWorkflowExecutionRawHistory
FrontendPollForWorkflowExecutionRawHistoryScope = "PollForWorkflowExecutionRawHistory"
// FrontendTerminateWorkflowExecutionScope is the metric scope for frontend.TerminateWorkflowExecution
FrontendTerminateWorkflowExecutionScope = "TerminateWorkflowExecution"
// FrontendDeleteWorkflowExecutionScope is the metric scope for frontend.DeleteWorkflowExecution
FrontendDeleteWorkflowExecutionScope = "DeleteWorkflowExecution"
// FrontendRequestCancelWorkflowExecutionScope is the metric scope for frontend.RequestCancelWorkflowExecution
FrontendRequestCancelWorkflowExecutionScope = "RequestCancelWorkflowExecution"
// FrontendListArchivedWorkflowExecutionsScope is the metric scope for frontend.ListArchivedWorkflowExecutions
FrontendListArchivedWorkflowExecutionsScope = "ListArchivedWorkflowExecutions"
// FrontendListOpenWorkflowExecutionsScope is the metric scope for frontend.ListOpenWorkflowExecutions
FrontendListOpenWorkflowExecutionsScope = "ListOpenWorkflowExecutions"
// FrontendListClosedWorkflowExecutionsScope is the metric scope for frontend.ListClosedWorkflowExecutions
FrontendListClosedWorkflowExecutionsScope = "ListClosedWorkflowExecutions"
// FrontendListWorkflowExecutionsScope is the metric scope for frontend.ListWorkflowExecutions
FrontendListWorkflowExecutionsScope = "ListWorkflowExecutions"
// FrontendScanWorkflowExecutionsScope is the metric scope for frontend.ListWorkflowExecutions
FrontendScanWorkflowExecutionsScope = "ScanWorkflowExecutions"
// FrontendCountWorkflowExecutionsScope is the metric scope for frontend.CountWorkflowExecutions
FrontendCountWorkflowExecutionsScope = "CountWorkflowExecutions"
// FrontendRegisterNamespaceScope is the metric scope for frontend.RegisterNamespace
FrontendRegisterNamespaceScope = "RegisterNamespace"
// FrontendDescribeNamespaceScope is the metric scope for frontend.DescribeNamespace
FrontendDescribeNamespaceScope = "DescribeNamespace"
// FrontendUpdateNamespaceScope is the metric scope for frontend.DescribeNamespace
FrontendUpdateNamespaceScope = "UpdateNamespace"
// FrontendDeprecateNamespaceScope is the metric scope for frontend.DeprecateNamespace
FrontendDeprecateNamespaceScope = "DeprecateNamespace"
// FrontendDescribeWorkflowExecutionScope is the metric scope for frontend.DescribeWorkflowExecution
FrontendDescribeWorkflowExecutionScope = "DescribeWorkflowExecution"
// FrontendDescribeTaskQueueScope is the metric scope for frontend.DescribeTaskQueue
FrontendDescribeTaskQueueScope = "DescribeTaskQueue"
// FrontendListTaskQueuePartitionsScope is the metric scope for frontend.ResetStickyTaskQueue
FrontendListTaskQueuePartitionsScope = "ListTaskQueuePartitions"
// FrontendResetStickyTaskQueueScope is the metric scope for frontend.ResetStickyTaskQueue
FrontendResetStickyTaskQueueScope = "ResetStickyTaskQueue"
// FrontendListNamespacesScope is the metric scope for frontend.ListNamespace
FrontendListNamespacesScope = "ListNamespaces"
// FrontendGetSearchAttributesScope is the metric scope for frontend.GetSearchAttributes
FrontendGetSearchAttributesScope = "GetSearchAttributes"
// FrontendGetClusterInfoScope is the metric scope for frontend.GetClusterInfo
FrontendGetClusterInfoScope = "GetClusterInfo"
// FrontendGetSystemInfoScope is the metric scope for frontend.GetSystemInfo
FrontendGetSystemInfoScope = "GetSystemInfo"
// FrontendCreateScheduleScope is the metric scope for frontend.CreateScheduleScope = "CreateScheduleScope is the metric scope for frontend.CreateSchedule"
FrontendCreateScheduleScope = "CreateSchedule"
// FrontendDescribeScheduleScope is the metric scope for frontend.DescribeScheduleScope = "DescribeScheduleScope is the metric scope for frontend.DescribeSchedule"
FrontendDescribeScheduleScope = "DescribeSchedule"
// FrontendUpdateScheduleScope is the metric scope for frontend.UpdateScheduleScope = "UpdateScheduleScope is the metric scope for frontend.UpdateSchedule"
FrontendUpdateScheduleScope = "UpdateSchedule"
// FrontendPatchScheduleScope is the metric scope for frontend.PatchScheduleScope = "PatchScheduleScope is the metric scope for frontend.PatchSchedule"
FrontendPatchScheduleScope = "PatchSchedule"
// FrontendListScheduleMatchingTimesScope is the metric scope for frontend.ListScheduleMatchingTimesScope = "ListScheduleMatchingTimesScope is the metric scope for frontend.ListScheduleMatchingTimes"
FrontendListScheduleMatchingTimesScope = "ListScheduleMatchingTimes"
// FrontendDeleteScheduleScope is the metric scope for frontend.DeleteScheduleScope = "DeleteScheduleScope is the metric scope for frontend.DeleteSchedule"
FrontendDeleteScheduleScope = "DeleteSchedule"
// FrontendListSchedulesScope is the metric scope for frontend.ListSchedulesScope = "ListSchedulesScope is the metric scope for frontend.ListSchedules"
FrontendListSchedulesScope = "ListSchedules"
// FrontendUpdateWorkerBuildIdCompatibilityScope is the metric scope for frontend.UpdateWorkerBuildIdCompatibilityScope = "UpdateWorkerBuildIdCompatibilityScope is the metric scope for frontend.UpdateWorkerBuildIdCompatibility"
FrontendUpdateWorkerBuildIdCompatibilityScope = "UpdateWorkerBuildIdCompatibility"
// FrontendGetWorkerBuildIdCompatibilityScope is the metric scope for frontend.GetWorkerBuildIdCompatibilityScope = "GetWorkerBuildIdCompatibilityScope is the metric scope for frontend.GetWorkerBuildIdCompatibility"
FrontendGetWorkerBuildIdCompatibilityScope = "GetWorkerBuildIdCompatibility"
// FrontendUpdateWorkflowExecutionScope is the metric scope for frontend.UpdateWorkflowExecution
FrontendUpdateWorkflowExecutionScope = "UpdateWorkflowExecution"
// FrontendDescribeBatchOperationScope is the metric scope for frontend.DescribeBatchOperation
FrontendDescribeBatchOperationScope = "DescribeBatchOperation"
// FrontendListBatchOperationsScope is the metric scope for frontend.ListBatchOperations
FrontendListBatchOperationsScope = "ListBatchOperations"
// FrontendStartBatchOperationScope is the metric scope for frontend.StartBatchOperation
FrontendStartBatchOperationScope = "StartBatchOperation"
// FrontendStopBatchOperationScope is the metric scope for frontend.StopBatchOperation
FrontendStopBatchOperationScope = "StopBatchOperation"
// VersionCheckScope is scope used by version checker
VersionCheckScope = "VersionCheck"
)
// History Scope
const (
// HistoryStartWorkflowExecutionScope tracks StartWorkflowExecution API calls received by service
HistoryStartWorkflowExecutionScope = "StartWorkflowExecution"
// HistoryRecordActivityTaskHeartbeatScope tracks RecordActivityTaskHeartbeat API calls received by service
HistoryRecordActivityTaskHeartbeatScope = "RecordActivityTaskHeartbeat"
// HistoryRespondWorkflowTaskCompletedScope tracks RespondWorkflowTaskCompleted API calls received by service
HistoryRespondWorkflowTaskCompletedScope = "RespondWorkflowTaskCompleted"
// HistoryRespondWorkflowTaskFailedScope tracks RespondWorkflowTaskFailed API calls received by service
HistoryRespondWorkflowTaskFailedScope = "RespondWorkflowTaskFailed"
// HistoryRespondActivityTaskCompletedScope tracks RespondActivityTaskCompleted API calls received by service
HistoryRespondActivityTaskCompletedScope = "RespondActivityTaskCompleted"
// HistoryRespondActivityTaskFailedScope tracks RespondActivityTaskFailed API calls received by service
HistoryRespondActivityTaskFailedScope = "RespondActivityTaskFailed"
// HistoryRespondActivityTaskCanceledScope tracks RespondActivityTaskCanceled API calls received by service
HistoryRespondActivityTaskCanceledScope = "RespondActivityTaskCanceled"
// HistoryGetMutableStateScope tracks GetMutableStateScope API calls received by service
HistoryGetMutableStateScope = "GetMutableState"
// HistoryPollMutableStateScope tracks PollMutableStateScope API calls received by service
HistoryPollMutableStateScope = "PollMutableState"
// HistoryResetStickyTaskQueueScope tracks ResetStickyTaskQueueScope API calls received by service
HistoryResetStickyTaskQueueScope = "ResetStickyTaskQueue"
// HistoryDescribeWorkflowExecutionScope tracks DescribeWorkflowExecution API calls received by service
HistoryDescribeWorkflowExecutionScope = "DescribeWorkflowExecution"
// HistoryRecordWorkflowTaskStartedScope tracks RecordWorkflowTaskStarted API calls received by service
HistoryRecordWorkflowTaskStartedScope = "RecordWorkflowTaskStarted"
// HistoryRecordActivityTaskStartedScope tracks RecordActivityTaskStarted API calls received by service
HistoryRecordActivityTaskStartedScope = "RecordActivityTaskStarted"
// HistorySignalWorkflowExecutionScope tracks SignalWorkflowExecution API calls received by service
HistorySignalWorkflowExecutionScope = "SignalWorkflowExecution"
// HistorySignalWithStartWorkflowExecutionScope tracks SignalWithStartWorkflowExecution API calls received by service
HistorySignalWithStartWorkflowExecutionScope = "SignalWithStartWorkflowExecution"
// HistoryRemoveSignalMutableStateScope tracks RemoveSignalMutableState API calls received by service
HistoryRemoveSignalMutableStateScope = "RemoveSignalMutableState"
// HistoryTerminateWorkflowExecutionScope tracks TerminateWorkflowExecution API calls received by service
HistoryTerminateWorkflowExecutionScope = "TerminateWorkflowExecution"
// HistoryScheduleWorkflowTaskScope tracks ScheduleWorkflowTask API calls received by service
HistoryScheduleWorkflowTaskScope = "ScheduleWorkflowTask"
// HistoryVerifyFirstWorkflowTaskScheduled tracks VerifyFirstWorkflowTaskScheduled API calls received by service
HistoryVerifyFirstWorkflowTaskScheduledScope = "VerifyFirstWorkflowTaskScheduled"
// HistoryRecordChildExecutionCompletedScope tracks RecordChildExecutionCompleted API calls received by service
HistoryRecordChildExecutionCompletedScope = "RecordChildExecutionCompleted"
// HistoryVerifyChildExecutionCompletionRecordedScope tracks VerifyChildExecutionCompletionRecorded API calls received by service
HistoryVerifyChildExecutionCompletionRecordedScope = "VerifyChildExecutionCompletionRecorded"
// HistoryRequestCancelWorkflowExecutionScope tracks RequestCancelWorkflowExecution API calls received by service
HistoryRequestCancelWorkflowExecutionScope = "RequestCancelWorkflowExecution"
// HistorySyncShardStatusScope tracks HistorySyncShardStatus API calls received by service
HistorySyncShardStatusScope = "SyncShardStatus"
// HistorySyncActivityScope tracks HistoryActivity API calls received by service
HistorySyncActivityScope = "SyncActivity"
// HistoryRebuildMutableStateScope tracks RebuildMutable API calls received by service
HistoryRebuildMutableStateScope = "RebuildMutableState"
// HistoryDescribeMutableStateScope tracks DescribeMutableState API calls received by service
HistoryDescribeMutableStateScope = "DescribeMutableState"
// HistoryGetReplicationMessagesScope tracks GetReplicationMessages API calls received by service
HistoryGetReplicationMessagesScope = "GetReplicationMessages"
// HistoryGetDLQReplicationMessagesScope tracks GetReplicationMessages API calls received by service
HistoryGetDLQReplicationMessagesScope = "GetDLQReplicationMessages"
// HistoryReadDLQMessagesScope tracks GetDLQMessages API calls received by service
HistoryReadDLQMessagesScope = "ReadDLQMessages"
// HistoryPurgeDLQMessagesScope tracks PurgeDLQMessages API calls received by service
HistoryPurgeDLQMessagesScope = "PurgeDLQMessages"
// HistoryMergeDLQMessagesScope tracks MergeDLQMessages API calls received by service
HistoryMergeDLQMessagesScope = "MergeDLQMessages"
// HistoryShardControllerScope is the scope used by shard controller
HistoryShardControllerScope = "ShardController"
// HistoryReapplyEventsScope is the scope used by event reapplication
HistoryReapplyEventsScope = "ReapplyEvents"
// HistoryRefreshWorkflowTasksScope is the scope used by refresh workflow tasks API
HistoryRefreshWorkflowTasksScope = "RefreshWorkflowTasks"
// HistoryGenerateLastHistoryReplicationTasksScope is the scope used by generate last replication tasks API
HistoryGenerateLastHistoryReplicationTasksScope = "GenerateLastHistoryReplicationTasks"
// HistoryGetReplicationStatusScope is the scope used by GetReplicationStatus API
HistoryGetReplicationStatusScope = "GetReplicationStatus"
// HistoryHistoryRemoveTaskScope is the scope used by remove task API
HistoryHistoryRemoveTaskScope = "HistoryRemoveTask"
// HistoryCloseShard is the scope used by close shard API
HistoryCloseShardScope = "CloseShard"
// HistoryGetShard is the scope used by get shard API
HistoryGetShardScope = "GetShard"
// HistoryReplicateEventsV2 is the scope used by replicate events API
HistoryReplicateEventsV2Scope = "ReplicateEventsV2"
// HistoryDescribeHistoryHost is the scope used by describe history host API
HistoryDescribeHistoryHostScope = "DescribeHistoryHost"
// HistoryDeleteWorkflowVisibilityRecordScope is the scope used by delete workflow visibility record API
HistoryDeleteWorkflowVisibilityRecordScope = "DeleteWorkflowVisibilityRecord"
// HistoryUpdateWorkflowExecutionScope is the scope used by update workflow execution API
HistoryUpdateWorkflowExecutionScope = "UpdateWorkflowExecution"
// HistoryResetWorkflowExecutionScope tracks ResetWorkflowExecution API calls received by service
HistoryResetWorkflowExecutionScope = "ResetWorkflowExecution"
// HistoryQueryWorkflowScope tracks QueryWorkflow API calls received by service
HistoryQueryWorkflowScope = "QueryWorkflow"
// HistoryProcessDeleteHistoryEventScope tracks ProcessDeleteHistoryEvent processing calls
HistoryProcessDeleteHistoryEventScope = "ProcessDeleteHistoryEvent"
// HistoryDeleteWorkflowExecutionScope tracks DeleteWorkflowExecutions API calls
HistoryDeleteWorkflowExecutionScope = "DeleteWorkflowExecution"
// HistoryCacheGetOrCreateScope is the scope used by history cache
HistoryCacheGetOrCreateScope = "HistoryCacheGetOrCreate"
// HistoryCacheGetOrCreateCurrentScope is the scope used by history cache
HistoryCacheGetOrCreateCurrentScope = "CacheGetOrCreateCurrent"
// TaskPriorityAssignerScope is the scope used by all metric emitted by task priority assigner
TaskPriorityAssignerScope = "TaskPriorityAssigner"
// TransferQueueProcessorScope is the scope used by all metric emitted by transfer queue processor
TransferQueueProcessorScope = "TransferQueueProcessor"
// TransferActiveQueueProcessorScope is the scope used by all metric emitted by transfer queue processor
TransferActiveQueueProcessorScope = "TransferActiveQueueProcessor"
// TransferStandbyQueueProcessorScope is the scope used by all metric emitted by transfer queue processor
TransferStandbyQueueProcessorScope = "TransferStandbyQueueProcessor"
// TransferActiveTaskActivityScope is the scope used for activity task processing by transfer queue processor
TransferActiveTaskActivityScope = "TransferActiveTaskActivity"
// TransferActiveTaskWorkflowTaskScope is the scope used for workflow task processing by transfer queue processor
TransferActiveTaskWorkflowTaskScope = "TransferActiveTaskWorkflowTask"
// TransferActiveTaskCloseExecutionScope is the scope used for close execution task processing by transfer queue processor
TransferActiveTaskCloseExecutionScope = "TransferActiveTaskCloseExecution"
// TransferActiveTaskCancelExecutionScope is the scope used for cancel execution task processing by transfer queue processor
TransferActiveTaskCancelExecutionScope = "TransferActiveTaskCancelExecution"
// TransferActiveTaskSignalExecutionScope is the scope used for signal execution task processing by transfer queue processor
TransferActiveTaskSignalExecutionScope = "TransferActiveTaskSignalExecution"
// TransferActiveTaskStartChildExecutionScope is the scope used for start child execution task processing by transfer queue processor
TransferActiveTaskStartChildExecutionScope = "TransferActiveTaskStartChildExecution"
// TransferActiveTaskResetWorkflowScope is the scope used for record workflow started task processing by transfer queue processor
TransferActiveTaskResetWorkflowScope = "TransferActiveTaskResetWorkflow"
// TransferStandbyTaskResetWorkflowScope is the scope used for record workflow started task processing by transfer queue processor
TransferStandbyTaskResetWorkflowScope = "TransferStandbyTaskResetWorkflow"
// TransferStandbyTaskActivityScope is the scope used for activity task processing by transfer queue processor
TransferStandbyTaskActivityScope = "TransferStandbyTaskActivity"
// TransferStandbyTaskWorkflowTaskScope is the scope used for workflow task processing by transfer queue processor
TransferStandbyTaskWorkflowTaskScope = "TransferStandbyTaskWorkflowTask"
// TransferStandbyTaskCloseExecutionScope is the scope used for close execution task processing by transfer queue processor
TransferStandbyTaskCloseExecutionScope = "TransferStandbyTaskCloseExecution"
// TransferStandbyTaskCancelExecutionScope is the scope used for cancel execution task processing by transfer queue processor
TransferStandbyTaskCancelExecutionScope = "TransferStandbyTaskCancelExecution"
// TransferStandbyTaskSignalExecutionScope is the scope used for signal execution task processing by transfer queue processor
TransferStandbyTaskSignalExecutionScope = "TransferStandbyTaskSignalExecution"
// TransferStandbyTaskStartChildExecutionScope is the scope used for start child execution task processing by transfer queue processor
TransferStandbyTaskStartChildExecutionScope = "TransferStandbyTaskStartChildExecution"
// VisibilityQueueProcessorScope is the scope used by all metric emitted by visibility queue processor
VisibilityQueueProcessorScope = "VisibilityQueueProcessor"
// VisibilityTaskStartExecutionScope is the scope used for start execution processing by visibility queue processor
VisibilityTaskStartExecutionScope = "VisibilityTaskStartExecution"
// VisibilityTaskUpsertExecutionScope is the scope used for upsert execution processing by visibility queue processor
VisibilityTaskUpsertExecutionScope = "VisibilityTaskUpsertExecution"
// VisibilityTaskCloseExecutionScope is the scope used for close execution attributes processing by visibility queue processor
VisibilityTaskCloseExecutionScope = "VisibilityTaskCloseExecution"
// VisibilityTaskDeleteExecutionScope is the scope used for delete by visibility queue processor
VisibilityTaskDeleteExecutionScope = "VisibilityTaskDeleteExecution"
// TimerQueueProcessorScope is the scope used by all metric emitted by timer queue processor
TimerQueueProcessorScope = "TimerQueueProcessor"
// TimerActiveQueueProcessorScope is the scope used by all metric emitted by timer queue processor
TimerActiveQueueProcessorScope = "TimerActiveQueueProcessor"
// TimerStandbyQueueProcessorScope is the scope used by all metric emitted by timer queue processor
TimerStandbyQueueProcessorScope = "TimerStandbyQueueProcessor"
// TimerActiveTaskActivityTimeoutScope is the scope used by metric emitted by timer queue processor for processing activity timeouts
TimerActiveTaskActivityTimeoutScope = "TimerActiveTaskActivityTimeout"
// TimerActiveTaskWorkflowTaskTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow task timeouts
TimerActiveTaskWorkflowTaskTimeoutScope = "TimerActiveTaskWorkflowTaskTimeout"
// TimerActiveTaskUserTimerScope is the scope used by metric emitted by timer queue processor for processing user timers
TimerActiveTaskUserTimerScope = "TimerActiveTaskUserTimer"
// TimerActiveTaskWorkflowTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow timeouts.
TimerActiveTaskWorkflowTimeoutScope = "TimerActiveTaskWorkflowTimeout"
// TimerActiveTaskActivityRetryTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
TimerActiveTaskActivityRetryTimerScope = "TimerActiveTaskActivityRetryTimer"
// TimerActiveTaskWorkflowBackoffTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
TimerActiveTaskWorkflowBackoffTimerScope = "TimerActiveTaskWorkflowBackoffTimer"
// TimerActiveTaskDeleteHistoryEventScope is the scope used by metric emitted by timer queue processor for processing history event cleanup
TimerActiveTaskDeleteHistoryEventScope = "TimerActiveTaskDeleteHistoryEvent"
// TimerStandbyTaskActivityTimeoutScope is the scope used by metric emitted by timer queue processor for processing activity timeouts
TimerStandbyTaskActivityTimeoutScope = "TimerStandbyTaskActivityTimeout"
// TimerStandbyTaskWorkflowTaskTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow task timeouts
TimerStandbyTaskWorkflowTaskTimeoutScope = "TimerStandbyTaskWorkflowTaskTimeout"
// TimerStandbyTaskUserTimerScope is the scope used by metric emitted by timer queue processor for processing user timers
TimerStandbyTaskUserTimerScope = "TimerStandbyTaskUserTimer"
// TimerStandbyTaskWorkflowTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow timeouts.
TimerStandbyTaskWorkflowTimeoutScope = "TimerStandbyTaskWorkflowTimeout"
// TimerStandbyTaskActivityRetryTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
TimerStandbyTaskActivityRetryTimerScope = "TimerStandbyTaskActivityRetryTimer"
// TimerStandbyTaskDeleteHistoryEventScope is the scope used by metric emitted by timer queue processor for processing history event cleanup
TimerStandbyTaskDeleteHistoryEventScope = "TimerStandbyTaskDeleteHistoryEvent"
// TimerStandbyTaskWorkflowBackoffTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
TimerStandbyTaskWorkflowBackoffTimerScope = "TimerStandbyTaskWorkflowBackoffTimer"
// ReplicatorQueueProcessorScope is the scope used by all metric emitted by replicator queue processor
ReplicatorQueueProcessorScope = "ReplicatorQueueProcessor"
// ReplicatorTaskHistoryScope is the scope used for history task processing by replicator queue processor
ReplicatorTaskHistoryScope = "ReplicatorTaskHistory"
// ReplicatorTaskSyncActivityScope is the scope used for sync activity by replicator queue processor
ReplicatorTaskSyncActivityScope = "ReplicatorTaskSyncActivity"
// ReplicateHistoryEventsScope is the scope used by historyReplicator API for applying events
ReplicateHistoryEventsScope = "ReplicateHistoryEvents"
// HistoryRereplicationByTransferTaskScope tracks history replication calls made by transfer task
HistoryRereplicationByTransferTaskScope = "HistoryRereplicationByTransferTask"
// HistoryRereplicationByTimerTaskScope tracks history replication calls made by timer task
HistoryRereplicationByTimerTaskScope = "HistoryRereplicationByTimerTask"
// HistoryRereplicationByHistoryReplicationScope tracks history replication calls made by history replication
HistoryRereplicationByHistoryReplicationScope = "HistoryRereplicationByHistoryReplication"
// HistoryRereplicationByHistoryMetadataReplicationScope tracks history replication calls made by history replication
HistoryRereplicationByHistoryMetadataReplicationScope = "HistoryRereplicationByHistoryMetadataReplication"
// HistoryRereplicationByActivityReplicationScope tracks history replication calls made by activity replication
HistoryRereplicationByActivityReplicationScope = "HistoryRereplicationByActivityReplication"
// ShardInfoScope is the scope used when updating shard info
ShardInfoScope = "ShardInfo"
// WorkflowContextScope is the scope used by WorkflowContext component
WorkflowContextScope = "WorkflowContext"
// ExecutionStatsScope is the scope used for emiting workflow execution related stats
ExecutionStatsScope = "ExecutionStats"
// SessionStatsScope is the scope used for emiting session update related stats
SessionStatsScope = "SessionStats"
// WorkflowCompletionStatsScope tracks workflow completion updates
WorkflowCompletionStatsScope = "CompletionStats"
// ReplicationTaskFetcherScope is scope used by all metrics emitted by ReplicationTaskFetcher
ReplicationTaskFetcherScope = "ReplicationTaskFetcher"
// ReplicationTaskCleanupScope is scope used by all metrics emitted by ReplicationTaskProcessor cleanup
ReplicationTaskCleanupScope = "ReplicationTaskCleanup"
// ReplicationDLQStatsScope is scope used by all metrics emitted related to replication DLQ
ReplicationDLQStatsScope = "ReplicationDLQStats"
// EventsCacheGetEventScope is the scope used by events cache
EventsCacheGetEventScope = "EventsCacheGetEvent"
// EventsCachePutEventScope is the scope used by events cache
EventsCachePutEventScope = "EventsCachePutEvent"
// EventsCacheDeleteEventScope is the scope used by events cache
EventsCacheDeleteEventScope = "EventsCacheDeleteEvent"
// EventsCacheGetFromStoreScope is the scope used by events cache
EventsCacheGetFromStoreScope = "EventsCacheGetFromStore"
// HistoryEventNotificationScope is the scope used by shard history event notification
HistoryEventNotificationScope = "HistoryEventNotification"
// ArchiverClientScope is scope used by all metrics emitted by archiver.Client
ArchiverClientScope = "ArchiverClient"
// DeadlockDetectorScope is a scope for deadlock detector
DeadlockDetectorScope = "DeadlockDetector"
// OperationTimerQueueProcessorScope is a scope for timer queue base processor
OperationTimerQueueProcessorScope = "TimerQueueProcessor"
// OperationTimerActiveQueueProcessorScope is a scope for timer queue active processor
OperationTimerActiveQueueProcessorScope = "TimerActiveQueueProcessor"
// OperationTimerStandbyQueueProcessorScope is a scope for timer queue standby processor
OperationTimerStandbyQueueProcessorScope = "TimerStandbyQueueProcessor"
// OperationTransferQueueProcessorScope is a scope for transfer queue base processor
OperationTransferQueueProcessorScope = "TransferQueueProcessor"
// OperationTransferActiveQueueProcessorScope is a scope for transfer queue active processor
OperationTransferActiveQueueProcessorScope = "TransferActiveQueueProcessor"
// OperationTransferStandbyQueueProcessorScope is a scope for transfer queue standby processor
OperationTransferStandbyQueueProcessorScope = "TransferStandbyQueueProcessor"
// OperationVisibilityQueueProcessorScope is a scope for visibility queue processor
OperationVisibilityQueueProcessorScope = "VisibilityQueueProcessor"
// OperationArchivalQueueProcessorScope is a scope for archival queue processor
OperationArchivalQueueProcessorScope = "ArchivalQueueProcessor"
// OperationMemoryScheduledQueueProcessorScope is a scope for memory scheduled queue processor.
OperationMemoryScheduledQueueProcessorScope = "MemoryScheduledQueueProcessor"
)
// Matching Scope
const (
// MatchingPollWorkflowTaskQueueScope tracks PollWorkflowTaskQueue API calls received by service
MatchingPollWorkflowTaskQueueScope = "PollWorkflowTaskQueue"
// MatchingPollActivityTaskQueueScope tracks PollActivityTaskQueue API calls received by service
MatchingPollActivityTaskQueueScope = "PollActivityTaskQueue"
// MatchingAddActivityTaskScope tracks AddActivityTask API calls received by service
MatchingAddActivityTaskScope = "AddActivityTask"
// MatchingAddWorkflowTaskScope tracks AddWorkflowTask API calls received by service
MatchingAddWorkflowTaskScope = "AddWorkflowTask"
// MatchingTaskQueueMgrScope is the metrics scope for matching.TaskQueueManager component
MatchingTaskQueueMgrScope = "TaskQueueMgr"
// MatchingEngineScope is the metrics scope for matchingEngine component
MatchingEngineScope = "MatchingEngine"
// MatchingQueryWorkflowScope tracks AddWorkflowTask API calls received by service
MatchingQueryWorkflowScope = "QueryWorkflow"
// MatchingRespondQueryTaskCompletedScope tracks AddWorkflowTask API calls received by service
MatchingRespondQueryTaskCompletedScope = "RespondQueryTaskCompleted"
// MatchingCancelOutstandingPollScope tracks CancelOutstandingPoll API calls received by service
MatchingCancelOutstandingPollScope = "CancelOutstandingPoll"
// MatchingDescribeTaskQueueScope tracks DescribeTaskQueue API calls received by service
MatchingDescribeTaskQueueScope = "DescribeTaskQueue"
// MatchingListTaskQueuePartitionsScope tracks ListTaskQueuePartitions API calls received by service
MatchingListTaskQueuePartitionsScope = "ListTaskQueuePartitions"
// MatchingUpdateWorkerBuildIdCompatibilityScope tracks UpdateWorkerBuildIdCompatibility API calls received by service
MatchingUpdateWorkerBuildIdCompatibilityScope = "UpdateWorkerBuildIdCompatibility"
// MatchingGetWorkerBuildIdCompatibilityScope tracks GetWorkerBuildIdCompatibility API calls received by service
MatchingGetWorkerBuildIdCompatibilityScope = "GetWorkerBuildIdCompatibility"
// MatchingGetTaskQueueUserDataScope tracks GetTaskQueueUserData API calls received by service
MatchingGetTaskQueueUserDataScope = "GetTaskQueueUserData"
// MatchingApplyTaskQueueUserDataReplicationEventScope tracks ApplyTaskQueueUserDataReplicationEvent API calls received by service
MatchingApplyTaskQueueUserDataReplicationEventScope = "MatchingApplyTaskQueueUserDataReplicationEvent"
)
// Worker Scope
const (
// HistoryArchiverScope is used by history archivers
HistoryArchiverScope = "HistoryArchiver"
// VisibilityArchiverScope is used by visibility archivers
VisibilityArchiverScope = "VisibilityArchiver"
// HistoryScavengerScope is scope used by all metrics emitted by worker.history.Scavenger module
HistoryScavengerScope = "HistoryScavenger"
// ArchiverDeleteHistoryActivityScope is scope used by all metrics emitted by archiver.DeleteHistoryActivity
ArchiverDeleteHistoryActivityScope = "ArchiverDeleteHistoryActivity"
// ArchiverUploadHistoryActivityScope is scope used by all metrics emitted by archiver.UploadHistoryActivity
ArchiverUploadHistoryActivityScope = "ArchiverUploadHistoryActivity"
// ArchiverArchiveVisibilityActivityScope is scope used by all metrics emitted by archiver.ArchiveVisibilityActivity
ArchiverArchiveVisibilityActivityScope = "ArchiverArchiveVisibilityActivity"
// ArchiverScope is scope used by all metrics emitted by archiver.Archiver
ArchiverScope = "Archiver"
// ArchiverPumpScope is scope used by all metrics emitted by archiver.Pump
ArchiverPumpScope = "ArchiverPump"
// ArchiverArchivalWorkflowScope is scope used by all metrics emitted by archiver.ArchivalWorkflow
ArchiverArchivalWorkflowScope = "ArchiverArchivalWorkflow"
// AddSearchAttributesWorkflowScope is scope used by all metrics emitted by worker.AddSearchAttributesWorkflowScope module
AddSearchAttributesWorkflowScope = "AddSearchAttributesWorkflow"
// BatcherScope is scope used by all metrics emitted by worker.Batcher module
BatcherScope = "Batcher"
// ElasticsearchBulkProcessor is scope used by all metric emitted by Elasticsearch bulk processor
ElasticsearchBulkProcessor = "ElasticsearchBulkProcessor"
// ElasticsearchVisibility is scope used by all Elasticsearch visibility metrics
ElasticsearchVisibility = "ElasticsearchVisibility"
// MigrationWorkflowScope is scope used by metrics emitted by migration related workflows
MigrationWorkflowScope = "MigrationWorkflow"
// ReplicatorScope is the scope used by all metric emitted by replicator
ReplicatorScope = "Replicator"
// NamespaceReplicationTaskScope is the scope used by namespace task replication processing
NamespaceReplicationTaskScope = "NamespaceReplicationTask"
// HistoryReplicationTaskScope is the scope used by history task replication processing
HistoryReplicationTaskScope = "HistoryReplicationTask"
// HistoryMetadataReplicationTaskScope is the scope used by history metadata task replication processing
HistoryMetadataReplicationTaskScope = "HistoryMetadataReplicationTask"
// SyncShardTaskScope is the scope used by sync shrad information processing
SyncShardTaskScope = "SyncShardTask"
// SyncActivityTaskScope is the scope used by sync activity
SyncActivityTaskScope = "SyncActivityTask"
// SyncWorkflowStateTaskScope is the scope used by closed workflow task replication processing
SyncWorkflowStateTaskScope = "SyncWorkflowStateTask"
// SyncWatermarkScope is the scope used by closed workflow task replication processing
SyncWatermarkScope = "SyncWatermark"
// NoopTaskScope is the scope used by noop task
NoopTaskScope = "NoopTask"
// UnknownTaskScope is the scope used by unknown task
UnknownTaskScope = "UnknownTask"
// ParentClosePolicyProcessorScope is scope used by all metrics emitted by worker.ParentClosePolicyProcessor
ParentClosePolicyProcessorScope = "ParentClosePolicyProcessor"
DeleteNamespaceWorkflowScope = "DeleteNamespaceWorkflow"
ReclaimResourcesWorkflowScope = "ReclaimResourcesWorkflow"
DeleteExecutionsWorkflowScope = "DeleteExecutionsWorkflow"
)
// History task type
const (
TaskTypeTransferActiveTaskActivity = "TransferActiveTaskActivity"
TaskTypeTransferActiveTaskWorkflowTask = "TransferActiveTaskWorkflowTask"
TaskTypeTransferActiveTaskCloseExecution = "TransferActiveTaskCloseExecution"
TaskTypeTransferActiveTaskCancelExecution = "TransferActiveTaskCancelExecution"
TaskTypeTransferActiveTaskSignalExecution = "TransferActiveTaskSignalExecution"
TaskTypeTransferActiveTaskStartChildExecution = "TransferActiveTaskStartChildExecution"
TaskTypeTransferActiveTaskResetWorkflow = "TransferActiveTaskResetWorkflow"
TaskTypeTransferActiveTaskDeleteExecution = "TransferActiveTaskDeleteExecution"
TaskTypeTransferStandbyTaskActivity = "TransferStandbyTaskActivity"
TaskTypeTransferStandbyTaskWorkflowTask = "TransferStandbyTaskWorkflowTask"
TaskTypeTransferStandbyTaskCloseExecution = "TransferStandbyTaskCloseExecution"
TaskTypeTransferStandbyTaskCancelExecution = "TransferStandbyTaskCancelExecution"
TaskTypeTransferStandbyTaskSignalExecution = "TransferStandbyTaskSignalExecution"
TaskTypeTransferStandbyTaskStartChildExecution = "TransferStandbyTaskStartChildExecution"
TaskTypeTransferStandbyTaskResetWorkflow = "TransferStandbyTaskResetWorkflow"
TaskTypeTransferStandbyTaskDeleteExecution = "TransferStandbyTaskDeleteExecution"
TaskTypeVisibilityTaskStartExecution = "VisibilityTaskStartExecution"
TaskTypeVisibilityTaskUpsertExecution = "VisibilityTaskUpsertExecution"
TaskTypeVisibilityTaskCloseExecution = "VisibilityTaskCloseExecution"
TaskTypeVisibilityTaskDeleteExecution = "VisibilityTaskDeleteExecution"
TaskTypeArchivalTaskArchiveExecution = "ArchivalTaskArchiveExecution"
TaskTypeTimerActiveTaskActivityTimeout = "TimerActiveTaskActivityTimeout"
TaskTypeTimerActiveTaskWorkflowTaskTimeout = "TimerActiveTaskWorkflowTaskTimeout"
TaskTypeTimerActiveTaskUserTimer = "TimerActiveTaskUserTimer"
TaskTypeTimerActiveTaskWorkflowTimeout = "TimerActiveTaskWorkflowTimeout"
TaskTypeTimerActiveTaskActivityRetryTimer = "TimerActiveTaskActivityRetryTimer"
TaskTypeTimerActiveTaskWorkflowBackoffTimer = "TimerActiveTaskWorkflowBackoffTimer"
TaskTypeTimerActiveTaskDeleteHistoryEvent = "TimerActiveTaskDeleteHistoryEvent"
TaskTypeTimerStandbyTaskActivityTimeout = "TimerStandbyTaskActivityTimeout"
TaskTypeTimerStandbyTaskWorkflowTaskTimeout = "TimerStandbyTaskWorkflowTaskTimeout"
TaskTypeTimerStandbyTaskUserTimer = "TimerStandbyTaskUserTimer"
TaskTypeTimerStandbyTaskWorkflowTimeout = "TimerStandbyTaskWorkflowTimeout"
TaskTypeTimerStandbyTaskActivityRetryTimer = "TimerStandbyTaskActivityRetryTimer"
TaskTypeTimerStandbyTaskWorkflowBackoffTimer = "TimerStandbyTaskWorkflowBackoffTimer"
TaskTypeTimerStandbyTaskDeleteHistoryEvent = "TimerStandbyTaskDeleteHistoryEvent"
TaskTypeMemoryScheduledTaskWorkflowTaskTimeout = "MemoryScheduledTaskWorkflowTaskTimeout"
)
// Schedule action types
const (
ScheduleActionTypeTag = "schedule_action"
ScheduleActionStartWorkflow = "start_workflow"
)
var (
ServiceRequests = NewCounterDef(
"service_requests",
WithDescription("The number of RPC requests received by the service."),
)
ServicePendingRequests = NewGaugeDef("service_pending_requests")
ServiceFailures = NewCounterDef("service_errors")
ServicePanic = NewCounterDef("service_panics")
ServiceErrorWithType = NewCounterDef("service_error_with_type")
ServiceLatency = NewTimerDef("service_latency")
ServiceLatencyNoUserLatency = NewTimerDef("service_latency_nouserlatency")
ServiceLatencyUserLatency = NewTimerDef("service_latency_userlatency")
ServiceErrInvalidArgumentCounter = NewCounterDef("service_errors_invalid_argument")
ServiceErrNamespaceNotActiveCounter = NewCounterDef("service_errors_namespace_not_active")
ServiceErrResourceExhaustedCounter = NewCounterDef("service_errors_resource_exhausted")
ServiceErrNotFoundCounter = NewCounterDef("service_errors_entity_not_found")
ServiceErrExecutionAlreadyStartedCounter = NewCounterDef("service_errors_execution_already_started")
ServiceErrContextTimeoutCounter = NewCounterDef("service_errors_context_timeout")
ServiceErrRetryTaskCounter = NewCounterDef("service_errors_retry_task")
ServiceErrIncompleteHistoryCounter = NewCounterDef("service_errors_incomplete_history")
ServiceErrNonDeterministicCounter = NewCounterDef("service_errors_nondeterministic")
ServiceErrUnauthorizedCounter = NewCounterDef("service_errors_unauthorized")
ServiceErrAuthorizeFailedCounter = NewCounterDef("service_errors_authorize_failed")
ActionCounter = NewCounterDef("action")
TlsCertsExpired = NewGaugeDef("certificates_expired")
TlsCertsExpiring = NewGaugeDef("certificates_expiring")
ServiceAuthorizationLatency = NewTimerDef("service_authorization_latency")
EventBlobSize = NewBytesHistogramDef("event_blob_size")
LockRequests = NewCounterDef("lock_requests")
LockFailures = NewCounterDef("lock_failures")
LockLatency = NewTimerDef("lock_latency")
ClientRequests = NewCounterDef(
"client_requests",
WithDescription("The number of requests sent by the client to an individual service, keyed by `service_role` and `operation`."),
)
ClientFailures = NewCounterDef("client_errors")
ClientLatency = NewTimerDef("client_latency")
ClientRedirectionRequests = NewCounterDef("client_redirection_requests")
ClientRedirectionFailures = NewCounterDef("client_redirection_errors")
ClientRedirectionLatency = NewTimerDef("client_redirection_latency")
StateTransitionCount = NewDimensionlessHistogramDef("state_transition_count")
HistorySize = NewBytesHistogramDef("history_size")
HistoryCount = NewDimensionlessHistogramDef("history_count")
SearchAttributesSize = NewBytesHistogramDef("search_attributes_size")
MemoSize = NewBytesHistogramDef("memo_size")
TooManyPendingChildWorkflows = NewCounterDef(
"wf_too_many_pending_child_workflows",
WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending child workflows to be exceeded. See https://t.mp/limits for more information."),
)
TooManyPendingActivities = NewCounterDef(
"wf_too_many_pending_activities",
WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending activities to be exceeded. See https://t.mp/limits for more information."),
)
TooManyPendingCancelRequests = NewCounterDef(
"wf_too_many_pending_cancel_requests",
WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending cancel requests to be exceeded. See https://t.mp/limits for more information."),
)
TooManyPendingSignalsToExternalWorkflows = NewCounterDef(
"wf_too_many_pending_external_workflow_signals",
WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending signals to external workflows to be exceeded. See https://t.mp/limits for more information."),
)
// Frontend
AddSearchAttributesWorkflowSuccessCount = NewCounterDef("add_search_attributes_workflow_success")
AddSearchAttributesWorkflowFailuresCount = NewCounterDef("add_search_attributes_workflow_failure")
DeleteNamespaceWorkflowSuccessCount = NewCounterDef("delete_namespace_workflow_success")
DeleteNamespaceWorkflowFailuresCount = NewCounterDef("delete_namespace_workflow_failure")
VersionCheckSuccessCount = NewCounterDef("version_check_success")
VersionCheckFailedCount = NewCounterDef("version_check_failed")
VersionCheckRequestFailedCount = NewCounterDef("version_check_request_failed")
VersionCheckLatency = NewTimerDef("version_check_latency")
HTTPServiceRequests = NewCounterDef(
"http_service_requests",
WithDescription("The number of HTTP requests received by the service."),
)
// History
CacheRequests = NewCounterDef("cache_requests")
CacheFailures = NewCounterDef("cache_errors")
CacheLatency = NewTimerDef("cache_latency")
CacheMissCounter = NewCounterDef("cache_miss")
HistoryEventNotificationQueueingLatency = NewTimerDef("history_event_notification_queueing_latency")
HistoryEventNotificationFanoutLatency = NewTimerDef("history_event_notification_fanout_latency")
HistoryEventNotificationInFlightMessageGauge = NewGaugeDef("history_event_notification_inflight_message_gauge")
HistoryEventNotificationFailDeliveryCount = NewCounterDef("history_event_notification_fail_delivery_count")
// ArchivalTaskInvalidURI is emitted by the archival queue task executor when the history or visibility URI for an
// archival task is not a valid URI.
// We may emit this metric several times for a single task if the task is retried.
ArchivalTaskInvalidURI = NewCounterDef("archival_task_invalid_uri")
ArchiverClientSendSignalCount = NewCounterDef("archiver_client_sent_signal")
ArchiverClientSendSignalFailureCount = NewCounterDef("archiver_client_send_signal_error")
ArchiverClientHistoryRequestCount = NewCounterDef("archiver_client_history_request")
ArchiverClientHistoryInlineArchiveAttemptCount = NewCounterDef("archiver_client_history_inline_archive_attempt")
ArchiverClientHistoryInlineArchiveFailureCount = NewCounterDef("archiver_client_history_inline_archive_failure")
ArchiverClientVisibilityRequestCount = NewCounterDef("archiver_client_visibility_request")
ArchiverClientVisibilityInlineArchiveAttemptCount = NewCounterDef("archiver_client_visibility_inline_archive_attempt")
ArchiverClientVisibilityInlineArchiveFailureCount = NewCounterDef("archiver_client_visibility_inline_archive_failure")
ArchiverArchiveLatency = NewTimerDef("archiver_archive_latency")
ArchiverArchiveTargetLatency = NewTimerDef("archiver_archive_target_latency")
ShardContextClosedCounter = NewCounterDef("shard_closed_count")
ShardContextCreatedCounter = NewCounterDef("sharditem_created_count")
ShardContextRemovedCounter = NewCounterDef("sharditem_removed_count")
ShardContextAcquisitionLatency = NewTimerDef("sharditem_acquisition_latency")
ShardInfoImmediateQueueLagHistogram = NewDimensionlessHistogramDef(
"shardinfo_immediate_queue_lag",
WithDescription("A histogram across history shards for the difference between the smallest taskID of pending history tasks and the last generated history task ID."),
)
ShardInfoScheduledQueueLagTimer = NewTimerDef(
"shardinfo_scheduled_queue_lag",
WithDescription("A histogram across history shards for the difference between the earliest scheduled time of pending history tasks and current time."),
)
SyncShardFromRemoteCounter = NewCounterDef("syncshard_remote_count")
SyncShardFromRemoteFailure = NewCounterDef("syncshard_remote_failed")
TaskRequests = NewCounterDef(
"task_requests",
WithDescription("The number of history tasks processed."),
)
TaskLoadLatency = NewTimerDef(
"task_latency_load",
WithDescription("Latency from history task generation to loading into memory (persistence schedule to start latency)."),
)
TaskScheduleLatency = NewTimerDef(
"task_latency_schedule",
WithDescription("Latency from history task loading to start processing (in-memory schedule to start latency)."),
)
TaskProcessingLatency = NewTimerDef(
"task_latency_processing",
WithDescription("Latency for processing a history task one time."),
)
TaskLatency = NewTimerDef(
"task_latency",
WithDescription("Latency for procsssing and completing a history task. This latency is across all attempts but excludes any latencies related to workflow lock or user qutoa limit."),
)
TaskQueueLatency = NewTimerDef(
"task_latency_queue",
WithDescription("End-to-end latency for processing and completing a history task, from task generation to completion."),
)
TaskAttempt = NewDimensionlessHistogramDef(
"task_attempt",
WithDescription("The number of attempts took to complete a history task."),
)
TaskFailures = NewCounterDef(
"task_errors",
WithDescription("The number of unexpected history task processing errors."),
)
TaskDiscarded = NewCounterDef("task_errors_discarded")
TaskSkipped = NewCounterDef("task_skipped")
TaskVersionMisMatch = NewCounterDef("task_errors_version_mismatch")
TasksDependencyTaskNotCompleted = NewCounterDef("task_dependency_task_not_completed")
TaskStandbyRetryCounter = NewCounterDef("task_errors_standby_retry_counter")
TaskWorkflowBusyCounter = NewCounterDef(
"task_errors_workflow_busy",
WithDescription("The number of history task processing errors caused by failing to acquire workflow lock within the configured timeout (history.cacheNonUserContextLockTimeout)."),
)
TaskNotActiveCounter = NewCounterDef("task_errors_not_active_counter")
TaskNamespaceHandoverCounter = NewCounterDef("task_errors_namespace_handover")
TaskInternalErrorCounter = NewCounterDef("task_errors_internal")
TaskThrottledCounter = NewCounterDef(
"task_errors_throttled",
WithDescription("The number of history task processing errors caused by resource exhausted errors, excluding workflow busy case."),
)
TaskCorruptionCounter = NewCounterDef("task_errors_corruption")
TaskScheduleToStartLatency = NewTimerDef("task_schedule_to_start_latency")
TaskBatchCompleteCounter = NewCounterDef("task_batch_complete_counter")
TaskReschedulerPendingTasks = NewDimensionlessHistogramDef("task_rescheduler_pending_tasks")
PendingTasksCounter = NewDimensionlessHistogramDef(
"pending_tasks",
WithDescription("A histogram across history shards for the number of in-memory pending history tasks."),
)
TaskSchedulerThrottled = NewCounterDef("task_scheduler_throttled")
QueueScheduleLatency = NewTimerDef("queue_latency_schedule") // latency for scheduling 100 tasks in one task channel
QueueReaderCountHistogram = NewDimensionlessHistogramDef("queue_reader_count")
QueueSliceCountHistogram = NewDimensionlessHistogramDef("queue_slice_count")
QueueActionCounter = NewCounterDef("queue_actions")
QueueActionFailures = NewCounterDef("queue_action_errors")
ActivityE2ELatency = NewTimerDef("activity_end_to_end_latency")
AckLevelUpdateCounter = NewCounterDef("ack_level_update")
AckLevelUpdateFailedCounter = NewCounterDef("ack_level_update_failed")
CommandTypeScheduleActivityCounter = NewCounterDef("schedule_activity_command")
CommandTypeCompleteWorkflowCounter = NewCounterDef("complete_workflow_command")
CommandTypeFailWorkflowCounter = NewCounterDef("fail_workflow_command")
CommandTypeCancelWorkflowCounter = NewCounterDef("cancel_workflow_command")
CommandTypeStartTimerCounter = NewCounterDef("start_timer_command")
CommandTypeCancelActivityCounter = NewCounterDef("cancel_activity_command")
CommandTypeCancelTimerCounter = NewCounterDef("cancel_timer_command")
CommandTypeRecordMarkerCounter = NewCounterDef("record_marker_command")
CommandTypeCancelExternalWorkflowCounter = NewCounterDef("cancel_external_workflow_command")
CommandTypeContinueAsNewCounter = NewCounterDef("continue_as_new_command")
CommandTypeSignalExternalWorkflowCounter = NewCounterDef("signal_external_workflow_command")
CommandTypeUpsertWorkflowSearchAttributesCounter = NewCounterDef("upsert_workflow_search_attributes_command")
CommandTypeModifyWorkflowPropertiesCounter = NewCounterDef("modify_workflow_properties_command")
CommandTypeChildWorkflowCounter = NewCounterDef("child_workflow_command")
CommandTypeProtocolMessage = NewCounterDef("protocol_message_command")
MessageTypeRequestWorkflowExecutionUpdateCounter = NewCounterDef("request_workflow_update_message")
MessageTypeAcceptWorkflowExecutionUpdateCounter = NewCounterDef("accept_workflow_update_message")
MessageTypeRespondWorkflowExecutionUpdateCounter = NewCounterDef("respond_workflow_update_message")
MessageTypeRejectWorkflowExecutionUpdateCounter = NewCounterDef("reject_workflow_update_message")
InvalidStateTransitionWorkflowExecutionUpdateCounter = NewCounterDef("invalid_state_transition_workflow_update_message")
ActivityEagerExecutionCounter = NewCounterDef("activity_eager_execution")
// WorkflowEagerExecutionCounter is emitted any time eager workflow start is requested.
WorkflowEagerExecutionCounter = NewCounterDef("workflow_eager_execution")
// WorkflowEagerExecutionDeniedCounter is emitted any time eager workflow start is requested and the serer fell back
// to standard dispatch.
// Timeouts and failures are not counted in this metric.
// This metric has a "reason" tag attached to it to understand why eager start was denied.
WorkflowEagerExecutionDeniedCounter = NewCounterDef("workflow_eager_execution_denied")
EmptyCompletionCommandsCounter = NewCounterDef("empty_completion_commands")
MultipleCompletionCommandsCounter = NewCounterDef("multiple_completion_commands")
FailedWorkflowTasksCounter = NewCounterDef("failed_workflow_tasks")
WorkflowTaskAttempt = NewDimensionlessHistogramDef("workflow_task_attempt")
StaleMutableStateCounter = NewCounterDef("stale_mutable_state")
AutoResetPointsLimitExceededCounter = NewCounterDef("auto_reset_points_exceed_limit")
AutoResetPointCorruptionCounter = NewCounterDef("auto_reset_point_corruption")
ConcurrencyUpdateFailureCounter = NewCounterDef("concurrency_update_failure")
ServiceErrShardOwnershipLostCounter = NewCounterDef("service_errors_shard_ownership_lost")
HeartbeatTimeoutCounter = NewCounterDef("heartbeat_timeout")
ScheduleToStartTimeoutCounter = NewCounterDef("schedule_to_start_timeout")
StartToCloseTimeoutCounter = NewCounterDef("start_to_close_timeout")
ScheduleToCloseTimeoutCounter = NewCounterDef("schedule_to_close_timeout")
NewTimerNotifyCounter = NewCounterDef("new_timer_notifications")
AcquireShardsCounter = NewCounterDef("acquire_shards_count")
AcquireShardsLatency = NewTimerDef("acquire_shards_latency")
MembershipChangedCounter = NewCounterDef("membership_changed_count")
NumShardsGauge = NewGaugeDef("numshards_gauge")
GetEngineForShardErrorCounter = NewCounterDef("get_engine_for_shard_errors")
GetEngineForShardLatency = NewTimerDef("get_engine_for_shard_latency")
RemoveEngineForShardLatency = NewTimerDef("remove_engine_for_shard_latency")
CompleteWorkflowTaskWithStickyEnabledCounter = NewCounterDef("complete_workflow_task_sticky_enabled_count")
CompleteWorkflowTaskWithStickyDisabledCounter = NewCounterDef("complete_workflow_task_sticky_disabled_count")
WorkflowTaskHeartbeatTimeoutCounter = NewCounterDef("workflow_task_heartbeat_timeout_count")
DuplicateReplicationEventsCounter = NewCounterDef("duplicate_replication_events")
AcquireLockFailedCounter = NewCounterDef("acquire_lock_failed")
WorkflowContextCleared = NewCounterDef("workflow_context_cleared")
MutableStateSize = NewBytesHistogramDef(
"mutable_state_size",
WithDescription("The size of an individual Workflow Execution's state, emitted each time a workflow execution is retrieved or updated."),
)
ExecutionInfoSize = NewBytesHistogramDef("execution_info_size")
ExecutionStateSize = NewBytesHistogramDef("execution_state_size")
ActivityInfoSize = NewBytesHistogramDef("activity_info_size")
TimerInfoSize = NewBytesHistogramDef("timer_info_size")
ChildInfoSize = NewBytesHistogramDef("child_info_size")
RequestCancelInfoSize = NewBytesHistogramDef("request_cancel_info_size")
SignalInfoSize = NewBytesHistogramDef("signal_info_size")
SignalRequestIDSize = NewBytesHistogramDef("signal_request_id_size")
BufferedEventsSize = NewBytesHistogramDef("buffered_events_size")
ActivityInfoCount = NewDimensionlessHistogramDef("activity_info_count")
TimerInfoCount = NewDimensionlessHistogramDef("timer_info_count")
ChildInfoCount = NewDimensionlessHistogramDef("child_info_count")
SignalInfoCount = NewDimensionlessHistogramDef("signal_info_count")
RequestCancelInfoCount = NewDimensionlessHistogramDef("request_cancel_info_count")
SignalRequestIDCount = NewDimensionlessHistogramDef("signal_request_id_count")
BufferedEventsCount = NewDimensionlessHistogramDef("buffered_events_count")
TaskCount = NewDimensionlessHistogramDef("task_count")
TotalActivityCount = NewDimensionlessHistogramDef("total_activity_count")
TotalUserTimerCount = NewDimensionlessHistogramDef("total_user_timer_count")
TotalChildExecutionCount = NewDimensionlessHistogramDef("total_child_execution_count")
TotalRequestCancelExternalCount = NewDimensionlessHistogramDef("total_request_cancel_external_count")
TotalSignalExternalCount = NewDimensionlessHistogramDef("total_signal_external_count")
TotalSignalCount = NewDimensionlessHistogramDef("total_signal_count")
WorkflowRetryBackoffTimerCount = NewCounterDef("workflow_retry_backoff_timer")
WorkflowCronBackoffTimerCount = NewCounterDef("workflow_cron_backoff_timer")
WorkflowDelayedStartBackoffTimerCount = NewCounterDef("workflow_delayed_start_backoff_timer")
WorkflowCleanupDeleteCount = NewCounterDef("workflow_cleanup_delete")
WorkflowCleanupArchiveCount = NewCounterDef("workflow_cleanup_archive")
WorkflowCleanupNopCount = NewCounterDef("workflow_cleanup_nop")
WorkflowCleanupDeleteHistoryInlineCount = NewCounterDef("workflow_cleanup_delete_history_inline")
WorkflowSuccessCount = NewCounterDef("workflow_success")
WorkflowCancelCount = NewCounterDef("workflow_cancel")
WorkflowFailedCount = NewCounterDef("workflow_failed")
WorkflowTimeoutCount = NewCounterDef("workflow_timeout")
WorkflowTerminateCount = NewCounterDef("workflow_terminate")
WorkflowContinuedAsNewCount = NewCounterDef("workflow_continued_as_new")
ReplicationTasksSend = NewCounterDef("replication_tasks_send")
ReplicationTasksRecv = NewCounterDef("replication_tasks_recv")
ReplicationTasksRecvBacklog = NewDimensionlessHistogramDef("replication_tasks_recv_backlog")
ReplicationTasksSkipped = NewCounterDef("replication_tasks_skipped")
ReplicationTasksApplied = NewCounterDef("replication_tasks_applied")
ReplicationTasksFailed = NewCounterDef("replication_tasks_failed")
// ReplicationTasksLag is a heuristic for how far behind the remote DC is for a given cluster. It measures the
// difference between task IDs so its unit should be "tasks".
ReplicationTasksLag = NewDimensionlessHistogramDef("replication_tasks_lag")
// ReplicationTasksFetched records the number of tasks fetched by the poller.
ReplicationTasksFetched = NewDimensionlessHistogramDef("replication_tasks_fetched")
ReplicationLatency = NewTimerDef("replication_latency")
ReplicationDLQFailed = NewCounterDef("replication_dlq_enqueue_failed")
ReplicationDLQMaxLevelGauge = NewGaugeDef("replication_dlq_max_level")
ReplicationDLQAckLevelGauge = NewGaugeDef("replication_dlq_ack_level")
ReplicationNonEmptyDLQCount = NewCounterDef("replication_dlq_non_empty")
ReplicationOutlierNamespace = NewCounterDef("replication_outlier_namespace")
EventReapplySkippedCount = NewCounterDef("event_reapply_skipped_count")
DirectQueryDispatchLatency = NewTimerDef("direct_query_dispatch_latency")
DirectQueryDispatchStickyLatency = NewTimerDef("direct_query_dispatch_sticky_latency")
DirectQueryDispatchNonStickyLatency = NewTimerDef("direct_query_dispatch_non_sticky_latency")
DirectQueryDispatchStickySuccessCount = NewCounterDef("direct_query_dispatch_sticky_success")
DirectQueryDispatchNonStickySuccessCount = NewCounterDef("direct_query_dispatch_non_sticky_success")
DirectQueryDispatchClearStickinessLatency = NewTimerDef("direct_query_dispatch_clear_stickiness_latency")
DirectQueryDispatchClearStickinessSuccessCount = NewCounterDef("direct_query_dispatch_clear_stickiness_success")
DirectQueryDispatchTimeoutBeforeNonStickyCount = NewCounterDef("direct_query_dispatch_timeout_before_non_sticky")
WorkflowTaskQueryLatency = NewTimerDef("workflow_task_query_latency")
ConsistentQueryTimeoutCount = NewCounterDef("consistent_query_timeout")
QueryBufferExceededCount = NewCounterDef("query_buffer_exceeded")
QueryRegistryInvalidStateCount = NewCounterDef("query_registry_invalid_state")
WorkflowTaskTimeoutOverrideCount = NewCounterDef("workflow_task_timeout_overrides")
WorkflowRunTimeoutOverrideCount = NewCounterDef("workflow_run_timeout_overrides")
ReplicationTaskCleanupCount = NewCounterDef("replication_task_cleanup_count")
ReplicationTaskCleanupFailure = NewCounterDef("replication_task_cleanup_failed")
MutableStateDirty = NewCounterDef("mutable_state_dirty")
MutableStateChecksumMismatch = NewCounterDef("mutable_state_checksum_mismatch")
MutableStateChecksumInvalidated = NewCounterDef("mutable_state_checksum_invalidated")
ClusterMetadataLockLatency = NewTimerDef("cluster_metadata_lock_latency")
ClusterMetadataCallbackLockLatency = NewTimerDef("cluster_metadata_callback_lock_latency")
ShardControllerLockLatency = NewTimerDef("shard_controller_lock_latency")
ShardLockLatency = NewTimerDef("shard_lock_latency")
NamespaceRegistryLockLatency = NewTimerDef("namespace_registry_lock_latency")
ClosedWorkflowBufferEventCount = NewCounterDef("closed_workflow_buffer_event_counter")
InorderBufferedEventsCounter = NewCounterDef("inordered_buffered_events")
ShardLingerSuccess = NewTimerDef("shard_linger_success")
ShardLingerTimeouts = NewCounterDef("shard_linger_timeouts")
DynamicRateLimiterMultiplier = NewGaugeDef("dynamic_rate_limit_multiplier")
// Matching
MatchingClientForwardedCounter = NewCounterDef("forwarded")
MatchingClientInvalidTaskQueueName = NewCounterDef("invalid_task_queue_name")
SyncMatchLatencyPerTaskQueue = NewTimerDef("syncmatch_latency")
AsyncMatchLatencyPerTaskQueue = NewTimerDef("asyncmatch_latency")
PollSuccessPerTaskQueueCounter = NewCounterDef("poll_success")
PollTimeoutPerTaskQueueCounter = NewCounterDef("poll_timeouts")
PollSuccessWithSyncPerTaskQueueCounter = NewCounterDef("poll_success_sync")
LeaseRequestPerTaskQueueCounter = NewCounterDef("lease_requests")
LeaseFailurePerTaskQueueCounter = NewCounterDef("lease_failures")
ConditionFailedErrorPerTaskQueueCounter = NewCounterDef("condition_failed_errors")
RespondQueryTaskFailedPerTaskQueueCounter = NewCounterDef("respond_query_failed")
SyncThrottlePerTaskQueueCounter = NewCounterDef("sync_throttle_count")
BufferThrottlePerTaskQueueCounter = NewCounterDef("buffer_throttle_count")
ExpiredTasksPerTaskQueueCounter = NewCounterDef("tasks_expired")
ForwardedPerTaskQueueCounter = NewCounterDef("forwarded_per_tl")
ForwardTaskErrorsPerTaskQueue = NewCounterDef("forward_task_errors")
LocalToLocalMatchPerTaskQueueCounter = NewCounterDef("local_to_local_matches")
LocalToRemoteMatchPerTaskQueueCounter = NewCounterDef("local_to_remote_matches")
RemoteToLocalMatchPerTaskQueueCounter = NewCounterDef("remote_to_local_matches")
RemoteToRemoteMatchPerTaskQueueCounter = NewCounterDef("remote_to_remote_matches")
LoadedTaskQueueGauge = NewGaugeDef("loaded_task_queue_count")
TaskQueueStartedCounter = NewCounterDef("task_queue_started")
TaskQueueStoppedCounter = NewCounterDef("task_queue_stopped")
TaskWriteThrottlePerTaskQueueCounter = NewCounterDef("task_write_throttle_count")
TaskWriteLatencyPerTaskQueue = NewTimerDef("task_write_latency")
TaskLagPerTaskQueueGauge = NewGaugeDef("task_lag_per_tl")
NoRecentPollerTasksPerTaskQueueCounter = NewCounterDef("no_poller_tasks")
UnknownBuildPollsCounter = NewCounterDef("unknown_build_polls")
UnknownBuildTasksCounter = NewCounterDef("unknown_build_tasks")
// Worker
ExecutorTasksDoneCount = NewCounterDef("executor_done")
ExecutorTasksErrCount = NewCounterDef("executor_err")
ExecutorTasksDeferredCount = NewCounterDef("executor_deferred")
ExecutorTasksDroppedCount = NewCounterDef("executor_dropped")
StartedCount = NewCounterDef("started")
StoppedCount = NewCounterDef("stopped")
TaskProcessedCount = NewGaugeDef("task_processed")
TaskDeletedCount = NewGaugeDef("task_deleted")
TaskQueueProcessedCount = NewGaugeDef("taskqueue_processed")
TaskQueueDeletedCount = NewGaugeDef("taskqueue_deleted")
TaskQueueOutstandingCount = NewGaugeDef("taskqueue_outstanding")
HistoryArchiverArchiveNonRetryableErrorCount = NewCounterDef("history_archiver_archive_non_retryable_error")
HistoryArchiverArchiveTransientErrorCount = NewCounterDef("history_archiver_archive_transient_error")
HistoryArchiverArchiveSuccessCount = NewCounterDef("history_archiver_archive_success")
HistoryArchiverTotalUploadSize = NewBytesHistogramDef("history_archiver_total_upload_size")
HistoryArchiverHistorySize = NewBytesHistogramDef("history_archiver_history_size")
HistoryArchiverDuplicateArchivalsCount = NewCounterDef("history_archiver_duplicate_archivals")
HistoryArchiverBlobExistsCount = NewCounterDef("history_archiver_blob_exists")
HistoryArchiverBlobSize = NewBytesHistogramDef("history_archiver_blob_size")
HistoryWorkflowExecutionCacheLatency = NewTimerDef("history_workflow_execution_cache_latency")
VisibilityArchiverArchiveNonRetryableErrorCount = NewCounterDef("visibility_archiver_archive_non_retryable_error")
VisibilityArchiverArchiveTransientErrorCount = NewCounterDef("visibility_archiver_archive_transient_error")
VisibilityArchiveSuccessCount = NewCounterDef("visibility_archiver_archive_success")
HistoryScavengerSuccessCount = NewCounterDef("scavenger_success")
HistoryScavengerErrorCount = NewCounterDef("scavenger_errors")
HistoryScavengerSkipCount = NewCounterDef("scavenger_skips")
ExecutionsOutstandingCount = NewGaugeDef("executions_outstanding")
ArchiverNonRetryableErrorCount = NewCounterDef("archiver_non_retryable_error")
ArchiverStartedCount = NewCounterDef("archiver_started")
ArchiverStoppedCount = NewCounterDef("archiver_stopped")
ArchiverCoroutineStartedCount = NewCounterDef("archiver_coroutine_started")
ArchiverCoroutineStoppedCount = NewCounterDef("archiver_coroutine_stopped")
ArchiverHandleHistoryRequestLatency = NewTimerDef("archiver_handle_history_request_latency")
ArchiverHandleVisibilityRequestLatency = NewTimerDef("archiver_handle_visibility_request_latency")
ArchiverUploadWithRetriesLatency = NewTimerDef("archiver_upload_with_retries_latency")
ArchiverDeleteWithRetriesLatency = NewTimerDef("archiver_delete_with_retries_latency")
ArchiverUploadFailedAllRetriesCount = NewCounterDef("archiver_upload_failed_all_retries")
ArchiverUploadSuccessCount = NewCounterDef("archiver_upload_success")
ArchiverDeleteFailedAllRetriesCount = NewCounterDef("archiver_delete_failed_all_retries")
ArchiverDeleteSuccessCount = NewCounterDef("archiver_delete_success")
ArchiverHandleVisibilityFailedAllRetiresCount = NewCounterDef("archiver_handle_visibility_failed_all_retries")
ArchiverHandleVisibilitySuccessCount = NewCounterDef("archiver_handle_visibility_success")
ArchiverBacklogSizeGauge = NewGaugeDef("archiver_backlog_size")
ArchiverPumpTimeoutCount = NewCounterDef("archiver_pump_timeout")
ArchiverPumpSignalThresholdCount = NewCounterDef("archiver_pump_signal_threshold")
ArchiverPumpTimeoutWithoutSignalsCount = NewCounterDef("archiver_pump_timeout_without_signals")
ArchiverPumpSignalChannelClosedCount = NewCounterDef("archiver_pump_signal_channel_closed")
ArchiverWorkflowStartedCount = NewCounterDef("archiver_workflow_started")
ArchiverNumPumpedRequestsCount = NewCounterDef("archiver_num_pumped_requests")
ArchiverNumHandledRequestsCount = NewCounterDef("archiver_num_handled_requests")
ArchiverPumpedNotEqualHandledCount = NewCounterDef("archiver_pumped_not_equal_handled")
ArchiverHandleAllRequestsLatency = NewTimerDef("archiver_handle_all_requests_latency")
ArchiverWorkflowStoppingCount = NewCounterDef("archiver_workflow_stopping")
ScavengerValidationRequestsCount = NewCounterDef("scavenger_validation_requests")
ScavengerValidationFailuresCount = NewCounterDef("scavenger_validation_failures")
ScavengerValidationSkipsCount = NewCounterDef("scavenger_validation_skips")
AddSearchAttributesFailuresCount = NewCounterDef("add_search_attributes_failures")
DeleteNamespaceSuccessCount = NewCounterDef("delete_namespace_success")
RenameNamespaceSuccessCount = NewCounterDef("rename_namespace_success")
DeleteExecutionsSuccessCount = NewCounterDef("delete_executions_success")
DeleteNamespaceFailuresCount = NewCounterDef("delete_namespace_failures")
UpdateNamespaceFailuresCount = NewCounterDef("update_namespace_failures")
RenameNamespaceFailuresCount = NewCounterDef("rename_namespace_failures")
ReadNamespaceFailuresCount = NewCounterDef("read_namespace_failures")
ListExecutionsFailuresCount = NewCounterDef("list_executions_failures")
CountExecutionsFailuresCount = NewCounterDef("count_executions_failures")
DeleteExecutionFailuresCount = NewCounterDef("delete_execution_failures")
DeleteExecutionNotFoundCount = NewCounterDef("delete_execution_not_found")
RateLimiterFailuresCount = NewCounterDef("rate_limiter_failures")
BatcherProcessorSuccess = NewCounterDef(
"batcher_processor_requests",
WithDescription("The number of individual workflow execution tasks successfully processed by the batch request processor"),
)
BatcherProcessorFailures = NewCounterDef("batcher_processor_errors")
BatcherOperationFailures = NewCounterDef("batcher_operation_errors")
ElasticsearchBulkProcessorRequests = NewCounterDef("elasticsearch_bulk_processor_requests")
ElasticsearchBulkProcessorQueuedRequests = NewDimensionlessHistogramDef("elasticsearch_bulk_processor_queued_requests")
ElasticsearchBulkProcessorFailures = NewCounterDef("elasticsearch_bulk_processor_errors")
ElasticsearchBulkProcessorCorruptedData = NewCounterDef("elasticsearch_bulk_processor_corrupted_data")
ElasticsearchBulkProcessorDuplicateRequest = NewCounterDef("elasticsearch_bulk_processor_duplicate_request")
ElasticsearchBulkProcessorRequestLatency = NewTimerDef("elasticsearch_bulk_processor_request_latency")
ElasticsearchBulkProcessorCommitLatency = NewTimerDef("elasticsearch_bulk_processor_commit_latency")
ElasticsearchBulkProcessorWaitAddLatency = NewTimerDef("elasticsearch_bulk_processor_wait_add_latency")
ElasticsearchBulkProcessorWaitStartLatency = NewTimerDef("elasticsearch_bulk_processor_wait_start_latency")
ElasticsearchBulkProcessorBulkSize = NewDimensionlessHistogramDef("elasticsearch_bulk_processor_bulk_size")
ElasticsearchBulkProcessorBulkResquestTookLatency = NewTimerDef("elasticsearch_bulk_processor_bulk_request_took_latency")
ElasticsearchDocumentParseFailuresCount = NewCounterDef("elasticsearch_document_parse_failures_counter")
ElasticsearchDocumentGenerateFailuresCount = NewCounterDef("elasticsearch_document_generate_failures_counter")
ElasticsearchCustomOrderByClauseCount = NewCounterDef("elasticsearch_custom_order_by_clause_counter")
CatchUpReadyShardCountGauge = NewGaugeDef("catchup_ready_shard_count")
HandoverReadyShardCountGauge = NewGaugeDef("handover_ready_shard_count")
ReplicatorMessages = NewCounterDef("replicator_messages")
ReplicatorFailures = NewCounterDef("replicator_errors")
ReplicatorLatency = NewTimerDef("replicator_latency")
ReplicatorDLQFailures = NewCounterDef("replicator_dlq_enqueue_fails")
NamespaceReplicationEnqueueDLQCount = NewCounterDef("namespace_replication_dlq_enqueue_requests")
ParentClosePolicyProcessorSuccess = NewCounterDef("parent_close_policy_processor_requests")
ParentClosePolicyProcessorFailures = NewCounterDef("parent_close_policy_processor_errors")
ScheduleMissedCatchupWindow = NewCounterDef(
"schedule_missed_catchup_window",
WithDescription("The number of times a schedule missed an action due to the configured catchup window"),
)
ScheduleRateLimited = NewCounterDef(
"schedule_rate_limited",
WithDescription("The number of times a schedule action was delayed by more than 1s due to rate limiting"),
)
ScheduleBufferOverruns = NewCounterDef(
"schedule_buffer_overruns",
WithDescription("The number of schedule actions that were dropped due to the action buffer being full"),
)
ScheduleActionSuccess = NewCounterDef(
"schedule_action_success",
WithDescription("The number of schedule actions that were successfully taken by a schedule"),
)
ScheduleActionErrors = NewCounterDef(
"schedule_action_errors",
WithDescription("The number of schedule actions that failed to start"),
)
ScheduleCancelWorkflowErrors = NewCounterDef(
"schedule_cancel_workflow_errors",
WithDescription("The number of times a schedule got an error trying to cancel a previous run"),
)
ScheduleTerminateWorkflowErrors = NewCounterDef(
"schedule_terminate_workflow_errors",
WithDescription("The number of times a schedule got an error trying to terminate a previous run"),
)
// Force replication
EncounterZombieWorkflowCount = NewCounterDef("encounter_zombie_workflow_count")
EncounterNotFoundWorkflowCount = NewCounterDef("encounter_not_found_workflow_count")
EncounterPassRetentionWorkflowCount = NewCounterDef("encounter_pass_retention_workflow_count")
GenerateReplicationTasksLatency = NewTimerDef("generate_replication_tasks_latency")
VerifyReplicationTaskSuccess = NewCounterDef("verify_replication_task_success")
VerifyReplicationTaskNotFound = NewCounterDef("verify_replication_task_not_found")
VerifyReplicationTaskFailed = NewCounterDef("verify_replication_task_failed")
VerifyReplicationTasksLatency = NewTimerDef("verify_replication_tasks_latency")
VerifyDescribeMutableStateLatency = NewTimerDef("verify_describe_mutable_state_latency")
// Replication
NamespaceReplicationTaskAckLevelGauge = NewGaugeDef("namespace_replication_task_ack_level")
NamespaceReplicationDLQAckLevelGauge = NewGaugeDef("namespace_dlq_ack_level")
NamespaceReplicationDLQMaxLevelGauge = NewGaugeDef("namespace_dlq_max_level")
// Persistence
PersistenceRequests = NewCounterDef(
"persistence_requests",
WithDescription("Persistence requests, keyed by `operation`"),
)
PersistenceFailures = NewCounterDef("persistence_errors")
PersistenceErrorWithType = NewCounterDef(
"persistence_error_with_type",
WithDescription("Persistence errors, keyed by `error_type`"),
)
PersistenceLatency = NewTimerDef(
"persistence_latency",
WithDescription("Persistence latency, keyed by `operation`"),
)
PersistenceShardRPS = NewDimensionlessHistogramDef("persistence_shard_rps")
PersistenceErrResourceExhaustedCounter = NewCounterDef("persistence_errors_resource_exhausted")
VisibilityPersistenceRequests = NewCounterDef("visibility_persistence_requests")
VisibilityPersistenceErrorWithType = NewCounterDef("visibility_persistence_error_with_type")
VisibilityPersistenceFailures = NewCounterDef("visibility_persistence_errors")
VisibilityPersistenceResourceExhausted = NewCounterDef("visibility_persistence_resource_exhausted")
VisibilityPersistenceLatency = NewTimerDef("visibility_persistence_latency")
)