common/metrics/defs.go (2,528 lines of code) (raw):
// Copyright (c) 2017 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
import (
"time"
"github.com/uber-go/tally"
)
// types used/defined by the package
type (
// MetricName is the name of the metric
MetricName string
// MetricType is the type of the metric
MetricType int
// metricDefinition contains the definition for a metric
metricDefinition struct {
metricType MetricType // metric type
metricName MetricName // metric name
metricRollupName MetricName // optional. if non-empty, this name must be used for rolled-up version of this metric
buckets tally.Buckets // buckets if we are emitting histograms
}
// scopeDefinition holds the tag definitions for a scope
scopeDefinition struct {
operation string // 'operation' tag for scope
tags map[string]string // additional tags for scope
}
// ServiceIdx is an index that uniquely identifies the service
ServiceIdx int
)
// MetricTypes which are supported
const (
Counter MetricType = iota
Timer
Gauge
Histogram
)
// Service names for all services that emit metrics.
const (
Common = iota
Frontend
History
Matching
Worker
NumServices
)
// This package should hold all the metrics and tags for cadence
// Note that to better support Prometheus, metric name and tag name
// should match the regex [a-zA-Z_][a-zA-Z0-9_]*, tag value can be any Unicode characters.
// See more https://prometheus.io/docs/concepts/data_model/#metric-names-and-labels
// Common tags for all services
const (
OperationTagName = "operation"
CadenceRoleTagName = "cadence_role"
CadenceServiceTagName = "cadence_service"
StatsTypeTagName = "stats_type"
CacheTypeTagName = "cache_type"
)
// Common tag values
const (
HistoryClientRoleTagValue = "history_client"
MatchingClientRoleTagValue = "matching_client"
FrontendClientRoleTagValue = "frontend_client"
AdminClientRoleTagValue = "admin_client"
DCRedirectionRoleTagValue = "dc_redirection"
BlobstoreRoleTagValue = "blobstore"
SizeStatsTypeTagValue = "size"
CountStatsTypeTagValue = "count"
MutableStateCacheTypeTagValue = "mutablestate"
EventsCacheTypeTagValue = "events"
)
// 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"
)
// ServiceMetrics are types for common service base metrics
var ServiceMetrics = map[MetricName]MetricType{
RestartCount: Counter,
}
// GoRuntimeMetrics represent the runtime stats from go runtime
var GoRuntimeMetrics = map[MetricName]MetricType{
NumGoRoutinesGauge: Gauge,
GoMaxProcsGauge: Gauge,
MemoryAllocatedGauge: Gauge,
MemoryHeapGauge: Gauge,
MemoryHeapIdleGauge: Gauge,
MemoryHeapInuseGauge: Gauge,
MemoryStackGauge: Gauge,
NumGCCounter: Counter,
GcPauseMsTimer: Timer,
}
// Scopes enum
const (
// -- Common Operation scopes --
// PersistenceCreateShardScope tracks CreateShard calls made by service to persistence layer
PersistenceCreateShardScope = iota
// PersistenceGetShardScope tracks GetShard calls made by service to persistence layer
PersistenceGetShardScope
// PersistenceUpdateShardScope tracks UpdateShard calls made by service to persistence layer
PersistenceUpdateShardScope
// PersistenceCreateWorkflowExecutionScope tracks CreateWorkflowExecution calls made by service to persistence layer
PersistenceCreateWorkflowExecutionScope
// PersistenceGetWorkflowExecutionScope tracks GetWorkflowExecution calls made by service to persistence layer
PersistenceGetWorkflowExecutionScope
// PersistenceUpdateWorkflowExecutionScope tracks UpdateWorkflowExecution calls made by service to persistence layer
PersistenceUpdateWorkflowExecutionScope
// PersistenceConflictResolveWorkflowExecutionScope tracks ConflictResolveWorkflowExecution calls made by service to persistence layer
PersistenceConflictResolveWorkflowExecutionScope
// PersistenceResetWorkflowExecutionScope tracks ResetWorkflowExecution calls made by service to persistence layer
PersistenceResetWorkflowExecutionScope
// PersistenceDeleteWorkflowExecutionScope tracks DeleteWorkflowExecution calls made by service to persistence layer
PersistenceDeleteWorkflowExecutionScope
// PersistenceDeleteCurrentWorkflowExecutionScope tracks DeleteCurrentWorkflowExecution calls made by service to persistence layer
PersistenceDeleteCurrentWorkflowExecutionScope
// PersistenceGetCurrentExecutionScope tracks GetCurrentExecution calls made by service to persistence layer
PersistenceGetCurrentExecutionScope
// PersistenceIsWorkflowExecutionExistsScope tracks IsWorkflowExecutionExists calls made by service to persistence layer
PersistenceIsWorkflowExecutionExistsScope
// PersistenceListCurrentExecutionsScope tracks ListCurrentExecutions calls made by service to persistence layer
PersistenceListCurrentExecutionsScope
// PersistenceListConcreteExecutionsScope tracks ListConcreteExecutions calls made by service to persistence layer
PersistenceListConcreteExecutionsScope
// PersistenceGetTransferTasksScope tracks GetTransferTasks calls made by service to persistence layer
PersistenceGetTransferTasksScope
// PersistenceCompleteTransferTaskScope tracks CompleteTransferTasks calls made by service to persistence layer
PersistenceCompleteTransferTaskScope
// PersistenceRangeCompleteTransferTaskScope tracks CompleteTransferTasks calls made by service to persistence layer
PersistenceRangeCompleteTransferTaskScope
// PersistenceGetCrossClusterTasksScope tracks GetCrossClusterTasks calls made by service to persistence layer
PersistenceGetCrossClusterTasksScope
// PersistenceCompleteCrossClusterTaskScope tracks CompleteCrossClusterTasks calls made by service to persistence layer
PersistenceCompleteCrossClusterTaskScope
// PersistenceRangeCompleteCrossClusterTaskScope tracks CompleteCrossClusterTasks calls made by service to persistence layer
PersistenceRangeCompleteCrossClusterTaskScope
// PersistenceGetReplicationTasksScope tracks GetReplicationTasks calls made by service to persistence layer
PersistenceGetReplicationTasksScope
// PersistenceCompleteReplicationTaskScope tracks CompleteReplicationTasks calls made by service to persistence layer
PersistenceCompleteReplicationTaskScope
// PersistenceRangeCompleteReplicationTaskScope tracks RangeCompleteReplicationTasks calls made by service to persistence layer
PersistenceRangeCompleteReplicationTaskScope
// PersistencePutReplicationTaskToDLQScope tracks PersistencePutReplicationTaskToDLQScope calls made by service to persistence layer
PersistencePutReplicationTaskToDLQScope
// PersistenceGetReplicationTasksFromDLQScope tracks PersistenceGetReplicationTasksFromDLQScope calls made by service to persistence layer
PersistenceGetReplicationTasksFromDLQScope
// PersistenceGetReplicationDLQSizeScope tracks PersistenceGetReplicationDLQSizeScope calls made by service to persistence layer
PersistenceGetReplicationDLQSizeScope
// PersistenceDeleteReplicationTaskFromDLQScope tracks PersistenceDeleteReplicationTaskFromDLQScope calls made by service to persistence layer
PersistenceDeleteReplicationTaskFromDLQScope
// PersistenceRangeDeleteReplicationTaskFromDLQScope tracks PersistenceRangeDeleteReplicationTaskFromDLQScope calls made by service to persistence layer
PersistenceRangeDeleteReplicationTaskFromDLQScope
// PersistenceCreateFailoverMarkerTasksScope tracks CreateFailoverMarkerTasks calls made by service to persistence layer
PersistenceCreateFailoverMarkerTasksScope
// PersistenceGetTimerIndexTasksScope tracks GetTimerIndexTasks calls made by service to persistence layer
PersistenceGetTimerIndexTasksScope
// PersistenceCompleteTimerTaskScope tracks CompleteTimerTasks calls made by service to persistence layer
PersistenceCompleteTimerTaskScope
// PersistenceRangeCompleteTimerTaskScope tracks CompleteTimerTasks calls made by service to persistence layer
PersistenceRangeCompleteTimerTaskScope
// PersistenceCreateTasksScope tracks CreateTask calls made by service to persistence layer
PersistenceCreateTasksScope
// PersistenceGetTasksScope tracks GetTasks calls made by service to persistence layer
PersistenceGetTasksScope
// PersistenceCompleteTaskScope tracks CompleteTask calls made by service to persistence layer
PersistenceCompleteTaskScope
// PersistenceCompleteTasksLessThanScope is the metric scope for persistence.TaskManager.PersistenceCompleteTasksLessThan API
PersistenceCompleteTasksLessThanScope
// PersistenceGetOrphanTasksScope is the metric scope for persistence.TaskManager.GetOrphanTasks API
PersistenceGetOrphanTasksScope
// PersistenceLeaseTaskListScope tracks LeaseTaskList calls made by service to persistence layer
PersistenceLeaseTaskListScope
// PersistenceUpdateTaskListScope tracks PersistenceUpdateTaskListScope calls made by service to persistence layer
PersistenceUpdateTaskListScope
// PersistenceListTaskListScope is the metric scope for persistence.TaskManager.ListTaskList API
PersistenceListTaskListScope
// PersistenceDeleteTaskListScope is the metric scope for persistence.TaskManager.DeleteTaskList API
PersistenceDeleteTaskListScope
// PersistenceGetTaskListSizeScope is the metric scope for persistence.TaskManager.GetTaskListSize API
PersistenceGetTaskListSizeScope
// PersistenceAppendHistoryEventsScope tracks AppendHistoryEvents calls made by service to persistence layer
PersistenceAppendHistoryEventsScope
// PersistenceGetWorkflowExecutionHistoryScope tracks GetWorkflowExecutionHistory calls made by service to persistence layer
PersistenceGetWorkflowExecutionHistoryScope
// PersistenceDeleteWorkflowExecutionHistoryScope tracks DeleteWorkflowExecutionHistory calls made by service to persistence layer
PersistenceDeleteWorkflowExecutionHistoryScope
// PersistenceCreateDomainScope tracks CreateDomain calls made by service to persistence layer
PersistenceCreateDomainScope
// PersistenceGetDomainScope tracks GetDomain calls made by service to persistence layer
PersistenceGetDomainScope
// PersistenceUpdateDomainScope tracks UpdateDomain calls made by service to persistence layer
PersistenceUpdateDomainScope
// PersistenceDeleteDomainScope tracks DeleteDomain calls made by service to persistence layer
PersistenceDeleteDomainScope
// PersistenceDeleteDomainByNameScope tracks DeleteDomainByName calls made by service to persistence layer
PersistenceDeleteDomainByNameScope
// PersistenceListDomainsScope tracks DeleteDomainByName calls made by service to persistence layer
PersistenceListDomainsScope
// PersistenceGetMetadataScope tracks DeleteDomainByName calls made by service to persistence layer
PersistenceGetMetadataScope
// PersistenceRecordWorkflowExecutionStartedScope tracks RecordWorkflowExecutionStarted calls made by service to persistence layer
PersistenceRecordWorkflowExecutionStartedScope
// PersistenceRecordWorkflowExecutionClosedScope tracks RecordWorkflowExecutionClosed calls made by service to persistence layer
PersistenceRecordWorkflowExecutionClosedScope
// PersistenceRecordWorkflowExecutionUninitializedScope tracks RecordWorkflowExecutionUninitialized calls made by service to persistence layer
PersistenceRecordWorkflowExecutionUninitializedScope
// PersistenceUpsertWorkflowExecutionScope tracks UpsertWorkflowExecution calls made by service to persistence layer
PersistenceUpsertWorkflowExecutionScope
// PersistenceListOpenWorkflowExecutionsScope tracks ListOpenWorkflowExecutions calls made by service to persistence layer
PersistenceListOpenWorkflowExecutionsScope
// PersistenceListClosedWorkflowExecutionsScope tracks ListClosedWorkflowExecutions calls made by service to persistence layer
PersistenceListClosedWorkflowExecutionsScope
// PersistenceListOpenWorkflowExecutionsByTypeScope tracks ListOpenWorkflowExecutionsByType calls made by service to persistence layer
PersistenceListOpenWorkflowExecutionsByTypeScope
// PersistenceListClosedWorkflowExecutionsByTypeScope tracks ListClosedWorkflowExecutionsByType calls made by service to persistence layer
PersistenceListClosedWorkflowExecutionsByTypeScope
// PersistenceListOpenWorkflowExecutionsByWorkflowIDScope tracks ListOpenWorkflowExecutionsByWorkflowID calls made by service to persistence layer
PersistenceListOpenWorkflowExecutionsByWorkflowIDScope
// PersistenceListClosedWorkflowExecutionsByWorkflowIDScope tracks ListClosedWorkflowExecutionsByWorkflowID calls made by service to persistence layer
PersistenceListClosedWorkflowExecutionsByWorkflowIDScope
// PersistenceListClosedWorkflowExecutionsByStatusScope tracks ListClosedWorkflowExecutionsByStatus calls made by service to persistence layer
PersistenceListClosedWorkflowExecutionsByStatusScope
// PersistenceGetClosedWorkflowExecutionScope tracks GetClosedWorkflowExecution calls made by service to persistence layer
PersistenceGetClosedWorkflowExecutionScope
// PersistenceVisibilityDeleteWorkflowExecutionScope is the metrics scope for persistence.VisibilityManager.DeleteWorkflowExecution
PersistenceVisibilityDeleteWorkflowExecutionScope
// PersistenceDeleteUninitializedWorkflowExecutionScope tracks DeleteUninitializedWorkflowExecution calls made by service to persistence layer
PersistenceDeleteUninitializedWorkflowExecutionScope
// PersistenceListWorkflowExecutionsScope tracks ListWorkflowExecutions calls made by service to persistence layer
PersistenceListWorkflowExecutionsScope
// PersistenceScanWorkflowExecutionsScope tracks ScanWorkflowExecutions calls made by service to persistence layer
PersistenceScanWorkflowExecutionsScope
// PersistenceCountWorkflowExecutionsScope tracks CountWorkflowExecutions calls made by service to persistence layer
PersistenceCountWorkflowExecutionsScope
// PersistenceEnqueueMessageScope tracks Enqueue calls made by service to persistence layer
PersistenceEnqueueMessageScope
// PersistenceEnqueueMessageToDLQScope tracks Enqueue DLQ calls made by service to persistence layer
PersistenceEnqueueMessageToDLQScope
// PersistenceReadMessagesScope tracks ReadMessages calls made by service to persistence layer
PersistenceReadMessagesScope
// PersistenceReadMessagesFromDLQScope tracks ReadMessagesFromDLQ calls made by service to persistence layer
PersistenceReadMessagesFromDLQScope
// PersistenceDeleteMessagesBeforeScope tracks DeleteMessages calls made by service to persistence layer
PersistenceDeleteMessagesBeforeScope
// PersistenceDeleteMessageFromDLQScope tracks DeleteMessageFromDLQ calls made by service to persistence layer
PersistenceDeleteMessageFromDLQScope
// PersistenceRangeDeleteMessagesFromDLQScope tracks RangeDeleteMessagesFromDLQ calls made by service to persistence layer
PersistenceRangeDeleteMessagesFromDLQScope
// PersistenceUpdateAckLevelScope tracks UpdateAckLevel calls made by service to persistence layer
PersistenceUpdateAckLevelScope
// PersistenceGetAckLevelsScope tracks GetAckLevel calls made by service to persistence layer
PersistenceGetAckLevelsScope
// PersistenceUpdateDLQAckLevelScope tracks UpdateDLQAckLevel calls made by service to persistence layer
PersistenceUpdateDLQAckLevelScope
// PersistenceGetDLQAckLevelsScope tracks GetDLQAckLevel calls made by service to persistence layer
PersistenceGetDLQAckLevelsScope
// PersistenceGetDLQSizeScope tracks GetDLQSize calls made by service to persistence layer
PersistenceGetDLQSizeScope
// PersistenceFetchDynamicConfigScope tracks FetchDynamicConfig calls made by service to persistence layer
PersistenceFetchDynamicConfigScope
// PersistenceUpdateDynamicConfigScope tracks UpdateDynamicConfig calls made by service to persistence layer
PersistenceUpdateDynamicConfigScope
// PersistenceShardRequestCountScope tracks number of persistence calls made to each shard
PersistenceShardRequestCountScope
// ResolverHostNotFoundScope is a simple low level error indicating a lookup failed in the membership resolver
ResolverHostNotFoundScope
// HashringScope is a metrics scope for emitting events for the service hashrhing
HashringScope
// HistoryClientStartWorkflowExecutionScope tracks RPC calls to history service
HistoryClientStartWorkflowExecutionScope
// HistoryClientDescribeHistoryHostScope tracks RPC calls to history service
HistoryClientDescribeHistoryHostScope
// HistoryClientRemoveTaskScope tracks RPC calls to history service
HistoryClientRemoveTaskScope
// HistoryClientCloseShardScope tracks RPC calls to history service
HistoryClientCloseShardScope
// HistoryClientResetQueueScope tracks RPC calls to history service
HistoryClientResetQueueScope
// HistoryClientDescribeQueueScope tracks RPC calls to history service
HistoryClientDescribeQueueScope
// HistoryClientRecordActivityTaskHeartbeatScope tracks RPC calls to history service
HistoryClientRecordActivityTaskHeartbeatScope
// HistoryClientRespondDecisionTaskCompletedScope tracks RPC calls to history service
HistoryClientRespondDecisionTaskCompletedScope
// HistoryClientRespondDecisionTaskFailedScope tracks RPC calls to history service
HistoryClientRespondDecisionTaskFailedScope
// HistoryClientRespondActivityTaskCompletedScope tracks RPC calls to history service
HistoryClientRespondActivityTaskCompletedScope
// HistoryClientRespondActivityTaskFailedScope tracks RPC calls to history service
HistoryClientRespondActivityTaskFailedScope
// HistoryClientRespondActivityTaskCanceledScope tracks RPC calls to history service
HistoryClientRespondActivityTaskCanceledScope
// HistoryClientDescribeMutableStateScope tracks RPC calls to history service
HistoryClientDescribeMutableStateScope
// HistoryClientGetMutableStateScope tracks RPC calls to history service
HistoryClientGetMutableStateScope
// HistoryClientPollMutableStateScope tracks RPC calls to history service
HistoryClientPollMutableStateScope
// HistoryClientResetStickyTaskListScope tracks RPC calls to history service
HistoryClientResetStickyTaskListScope
// HistoryClientDescribeWorkflowExecutionScope tracks RPC calls to history service
HistoryClientDescribeWorkflowExecutionScope
// HistoryClientRecordDecisionTaskStartedScope tracks RPC calls to history service
HistoryClientRecordDecisionTaskStartedScope
// HistoryClientRecordActivityTaskStartedScope tracks RPC calls to history service
HistoryClientRecordActivityTaskStartedScope
// HistoryClientRequestCancelWorkflowExecutionScope tracks RPC calls to history service
HistoryClientRequestCancelWorkflowExecutionScope
// HistoryClientSignalWorkflowExecutionScope tracks RPC calls to history service
HistoryClientSignalWorkflowExecutionScope
// HistoryClientSignalWithStartWorkflowExecutionScope tracks RPC calls to history service
HistoryClientSignalWithStartWorkflowExecutionScope
// HistoryClientRemoveSignalMutableStateScope tracks RPC calls to history service
HistoryClientRemoveSignalMutableStateScope
// HistoryClientTerminateWorkflowExecutionScope tracks RPC calls to history service
HistoryClientTerminateWorkflowExecutionScope
// HistoryClientResetWorkflowExecutionScope tracks RPC calls to history service
HistoryClientResetWorkflowExecutionScope
// HistoryClientScheduleDecisionTaskScope tracks RPC calls to history service
HistoryClientScheduleDecisionTaskScope
// HistoryClientRecordChildExecutionCompletedScope tracks RPC calls to history service
HistoryClientRecordChildExecutionCompletedScope
// HistoryClientSyncShardStatusScope tracks RPC calls to history service
HistoryClientReplicateEventsV2Scope
// HistoryClientReplicateRawEventsV2Scope tracks RPC calls to history service
HistoryClientSyncShardStatusScope
// HistoryClientSyncActivityScope tracks RPC calls to history service
HistoryClientSyncActivityScope
// HistoryClientGetReplicationTasksScope tracks RPC calls to history service
HistoryClientGetReplicationTasksScope
// HistoryClientGetDLQReplicationTasksScope tracks RPC calls to history service
HistoryClientGetDLQReplicationTasksScope
// HistoryClientQueryWorkflowScope tracks RPC calls to history service
HistoryClientQueryWorkflowScope
// HistoryClientReapplyEventsScope tracks RPC calls to history service
HistoryClientReapplyEventsScope
// HistoryClientCountDLQMessagesScope tracks RPC calls to history service
HistoryClientCountDLQMessagesScope
// HistoryClientReadDLQMessagesScope tracks RPC calls to history service
HistoryClientReadDLQMessagesScope
// HistoryClientPurgeDLQMessagesScope tracks RPC calls to history service
HistoryClientPurgeDLQMessagesScope
// HistoryClientMergeDLQMessagesScope tracks RPC calls to history service
HistoryClientMergeDLQMessagesScope
// HistoryClientRefreshWorkflowTasksScope tracks RPC calls to history service
HistoryClientRefreshWorkflowTasksScope
// HistoryClientNotifyFailoverMarkersScope tracks RPC calls to history service
HistoryClientNotifyFailoverMarkersScope
// HistoryClientGetCrossClusterTasksScope tracks RPC calls to history service
HistoryClientGetCrossClusterTasksScope
// HistoryClientRespondCrossClusterTasksCompletedScope tracks RPC calls to history service
HistoryClientRespondCrossClusterTasksCompletedScope
// HistoryClientGetFailoverInfoScope tracks RPC calls to history service
HistoryClientGetFailoverInfoScope
// HistoryClientGetDLQReplicationMessagesScope tracks RPC calls to history service
HistoryClientGetDLQReplicationMessagesScope
// HistoryClientGetReplicationMessagesScope tracks RPC calls to history service
HistoryClientGetReplicationMessagesScope
// HistoryClientWfIDCacheScope tracks workflow ID cache metrics
HistoryClientWfIDCacheScope
// MatchingClientPollForDecisionTaskScope tracks RPC calls to matching service
MatchingClientPollForDecisionTaskScope
// MatchingClientPollForActivityTaskScope tracks RPC calls to matching service
MatchingClientPollForActivityTaskScope
// MatchingClientAddActivityTaskScope tracks RPC calls to matching service
MatchingClientAddActivityTaskScope
// MatchingClientAddDecisionTaskScope tracks RPC calls to matching service
MatchingClientAddDecisionTaskScope
// MatchingClientQueryWorkflowScope tracks RPC calls to matching service
MatchingClientQueryWorkflowScope
// MatchingClientRespondQueryTaskCompletedScope tracks RPC calls to matching service
MatchingClientRespondQueryTaskCompletedScope
// MatchingClientCancelOutstandingPollScope tracks RPC calls to matching service
MatchingClientCancelOutstandingPollScope
// MatchingClientDescribeTaskListScope tracks RPC calls to matching service
MatchingClientDescribeTaskListScope
// MatchingClientListTaskListPartitionsScope tracks RPC calls to matching service
MatchingClientListTaskListPartitionsScope
// MatchingClientGetTaskListsByDomainScope tracks RPC calls to matching service
MatchingClientGetTaskListsByDomainScope
// FrontendClientDeprecateDomainScope tracks RPC calls to frontend service
FrontendClientDeprecateDomainScope
// FrontendClientDescribeDomainScope tracks RPC calls to frontend service
FrontendClientDescribeDomainScope
// FrontendClientDescribeTaskListScope tracks RPC calls to frontend service
FrontendClientDescribeTaskListScope
// FrontendClientDescribeWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientDescribeWorkflowExecutionScope
// FrontendClientGetWorkflowExecutionHistoryScope tracks RPC calls to frontend service
FrontendClientGetWorkflowExecutionHistoryScope
// FrontendClientGetWorkflowExecutionRawHistoryScope tracks RPC calls to frontend service
FrontendClientGetWorkflowExecutionRawHistoryScope
// FrontendClientPollForWorkflowExecutionRawHistoryScope tracks RPC calls to frontend service
FrontendClientPollForWorkflowExecutionRawHistoryScope
// FrontendClientListArchivedWorkflowExecutionsScope tracks RPC calls to frontend service
FrontendClientListArchivedWorkflowExecutionsScope
// FrontendClientListClosedWorkflowExecutionsScope tracks RPC calls to frontend service
FrontendClientListClosedWorkflowExecutionsScope
// FrontendClientListDomainsScope tracks RPC calls to frontend service
FrontendClientListDomainsScope
// FrontendClientListOpenWorkflowExecutionsScope tracks RPC calls to frontend service
FrontendClientListOpenWorkflowExecutionsScope
// FrontendClientPollForActivityTaskScope tracks RPC calls to frontend service
FrontendClientPollForActivityTaskScope
// FrontendClientPollForDecisionTaskScope tracks RPC calls to frontend service
FrontendClientPollForDecisionTaskScope
// FrontendClientQueryWorkflowScope tracks RPC calls to frontend service
FrontendClientQueryWorkflowScope
// FrontendClientRecordActivityTaskHeartbeatScope tracks RPC calls to frontend service
FrontendClientRecordActivityTaskHeartbeatScope
// FrontendClientRecordActivityTaskHeartbeatByIDScope tracks RPC calls to frontend service
FrontendClientRecordActivityTaskHeartbeatByIDScope
// FrontendClientRegisterDomainScope tracks RPC calls to frontend service
FrontendClientRegisterDomainScope
// FrontendClientRequestCancelWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientRequestCancelWorkflowExecutionScope
// FrontendClientResetStickyTaskListScope tracks RPC calls to frontend service
FrontendClientResetStickyTaskListScope
// FrontendClientRefreshWorkflowTasksScope tracks RPC calls to frontend service
FrontendClientRefreshWorkflowTasksScope
// FrontendClientResetWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientResetWorkflowExecutionScope
// FrontendClientRespondActivityTaskCanceledScope tracks RPC calls to frontend service
FrontendClientRespondActivityTaskCanceledScope
// FrontendClientRespondActivityTaskCanceledByIDScope tracks RPC calls to frontend service
FrontendClientRespondActivityTaskCanceledByIDScope
// FrontendClientRespondActivityTaskCompletedScope tracks RPC calls to frontend service
FrontendClientRespondActivityTaskCompletedScope
// FrontendClientRespondActivityTaskCompletedByIDScope tracks RPC calls to frontend service
FrontendClientRespondActivityTaskCompletedByIDScope
// FrontendClientRespondActivityTaskFailedScope tracks RPC calls to frontend service
FrontendClientRespondActivityTaskFailedScope
// FrontendClientRespondActivityTaskFailedByIDScope tracks RPC calls to frontend service
FrontendClientRespondActivityTaskFailedByIDScope
// FrontendClientRespondDecisionTaskCompletedScope tracks RPC calls to frontend service
FrontendClientRespondDecisionTaskCompletedScope
// FrontendClientRespondDecisionTaskFailedScope tracks RPC calls to frontend service
FrontendClientRespondDecisionTaskFailedScope
// FrontendClientRespondQueryTaskCompletedScope tracks RPC calls to frontend service
FrontendClientRespondQueryTaskCompletedScope
// FrontendClientSignalWithStartWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientSignalWithStartWorkflowExecutionScope
// FrontendClientSignalWorkflowExecutionAsyncScope tracks RPC calls to frontend service
FrontendClientSignalWithStartWorkflowExecutionAsyncScope
// FrontendClientSignalWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientSignalWorkflowExecutionScope
// FrontendClientStartWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientStartWorkflowExecutionScope
// FrontendClientStartWorkflowExecutionAsyncScope tracks RPC calls to frontend service
FrontendClientStartWorkflowExecutionAsyncScope
// FrontendClientRestartWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientRestartWorkflowExecutionScope
// FrontendClientTerminateWorkflowExecutionScope tracks RPC calls to frontend service
FrontendClientTerminateWorkflowExecutionScope
// FrontendClientUpdateDomainScope tracks RPC calls to frontend service
FrontendClientUpdateDomainScope
// FrontendClientListWorkflowExecutionsScope tracks RPC calls to frontend service
FrontendClientListWorkflowExecutionsScope
// FrontendClientScanWorkflowExecutionsScope tracks RPC calls to frontend service
FrontendClientScanWorkflowExecutionsScope
// FrontendClientCountWorkflowExecutionsScope tracks RPC calls to frontend service
FrontendClientCountWorkflowExecutionsScope
// FrontendClientGetSearchAttributesScope tracks RPC calls to frontend service
FrontendClientGetSearchAttributesScope
// FrontendClientGetReplicationTasksScope tracks RPC calls to frontend service
FrontendClientGetReplicationTasksScope
// FrontendClientGetDomainReplicationTasksScope tracks RPC calls to frontend service
FrontendClientGetDomainReplicationTasksScope
// FrontendClientGetDLQReplicationTasksScope tracks RPC calls to frontend service
FrontendClientGetDLQReplicationTasksScope
// FrontendClientReapplyEventsScope tracks RPC calls to frontend service
FrontendClientReapplyEventsScope
// FrontendClientGetClusterInfoScope tracks RPC calls to frontend
FrontendClientGetClusterInfoScope
// FrontendClientListTaskListPartitionsScope tracks RPC calls to frontend service
FrontendClientListTaskListPartitionsScope
// FrontendClientGetTaskListsByDomainScope tracks RPC calls to frontend service
FrontendClientGetTaskListsByDomainScope
// AdminClientAddSearchAttributeScope tracks RPC calls to admin service
AdminClientAddSearchAttributeScope
// AdminClientCloseShardScope tracks RPC calls to admin service
AdminClientCloseShardScope
// AdminClientRemoveTaskScope tracks RPC calls to admin service
AdminClientRemoveTaskScope
// AdminClientResetQueueScope tracks RPC calls to admin service
AdminClientResetQueueScope
// AdminClientDescribeQueueScope tracks RPC calls to admin service
AdminClientDescribeQueueScope
// AdminClientDescribeHistoryHostScope tracks RPC calls to admin service
AdminClientDescribeHistoryHostScope
// AdminClientDescribeShardDistributionScope tracks RPC calls to admin service
AdminClientDescribeShardDistributionScope
// AdminClientDescribeWorkflowExecutionScope tracks RPC calls to admin service
AdminClientDescribeWorkflowExecutionScope
// AdminClientGetWorkflowExecutionRawHistoryV2Scope tracks RPC calls to admin service
AdminClientGetWorkflowExecutionRawHistoryV2Scope
// AdminClientDescribeClusterScope tracks RPC calls to admin service
AdminClientDescribeClusterScope
// AdminClientCountDLQMessagesScope tracks RPC calls to admin service
AdminClientCountDLQMessagesScope
// AdminClientReadDLQMessagesScope tracks RPC calls to admin service
AdminClientReadDLQMessagesScope
// AdminClientPurgeDLQMessagesScope tracks RPC calls to admin service
AdminClientPurgeDLQMessagesScope
// AdminClientMergeDLQMessagesScope tracks RPC calls to admin service
AdminClientMergeDLQMessagesScope
// AdminClientRefreshWorkflowTasksScope tracks RPC calls to admin service
AdminClientRefreshWorkflowTasksScope
// AdminClientResendReplicationTasksScope tracks RPC calls to admin service
AdminClientResendReplicationTasksScope
// AdminClientGetCrossClusterTasksScope tracks RPC calls to Admin service
AdminClientGetCrossClusterTasksScope
// AdminClientRespondCrossClusterTasksCompletedScope tracks RPC calls to Admin service
AdminClientRespondCrossClusterTasksCompletedScope
// AdminClientGetDynamicConfigScope tracks RPC calls to admin service
AdminClientGetDynamicConfigScope
// AdminClientUpdateDynamicConfigScope tracks RPC calls to admin service
AdminClientUpdateDynamicConfigScope
// AdminClientRestoreDynamicConfigScope tracks RPC calls to admin service
AdminClientRestoreDynamicConfigScope
// AdminClientListDynamicConfigScope tracks RPC calls to admin service
AdminClientListDynamicConfigScope
// AdminClientGetGlobalIsolationGroupsScope is a request to get all the global isolation-groups
AdminClientGetGlobalIsolationGroupsScope
// AdminClientUpdateGlobalIsolationGroupsScope is a request to update the global isolation-groups
AdminClientUpdateGlobalIsolationGroupsScope
// AdminClientGetDomainIsolationGroupsScope is a request to get the domains' isolation groups
AdminClientGetDomainIsolationGroupsScope
// AdminClientUpdateDomainIsolationGroupsScope is a request to update the domains isolation-groups
AdminClientUpdateDomainIsolationGroupsScope
// AdminClientDeleteWorkflowScope is the metric scope for admin.DeleteWorkflow
AdminClientDeleteWorkflowScope
// AdminClientMaintainCorruptWorkflowScope is the metric scope for admin.MaintainCorruptWorkflow
AdminClientMaintainCorruptWorkflowScope
// AdminClientGetReplicationTasksScope is the metric scope for admin.GetReplicationTasks
AdminClientGetReplicationTasksScope
// AdminClientReapplyEventsScope is the metric scope for admin.ReapplyEvents
AdminClientReapplyEventsScope
// AdminClientGetDLQReplicationMessagesScope is the metric scope for admin.GetDLQReplicationMessages
AdminClientGetDLQReplicationMessagesScope
// AdminClientGetDomainReplicationMessagesScope is the metric scope for admin.GetDomainReplicationMessages
AdminClientGetDomainReplicationMessagesScope
// AdminClientGetReplicationMessagesScope is the metric scope for admin.GetReplicationMessages
AdminClientGetReplicationMessagesScope
// AdminClientGetWorkflowExecutionRawHistoryScope is the metric scope for admin.GetDomainAsyncWorkflow
AdminClientGetDomainAsyncWorkflowConfiguratonScope
// AdminClientGetWorkflowExecutionRawHistoryScope is the metric scope for admin.UpdateDomainAsyncWorkflowConfiguration
AdminClientUpdateDomainAsyncWorkflowConfiguratonScope
// DCRedirectionDeprecateDomainScope tracks RPC calls for dc redirection
DCRedirectionDeprecateDomainScope
// DCRedirectionDescribeDomainScope tracks RPC calls for dc redirection
DCRedirectionDescribeDomainScope
// DCRedirectionDescribeTaskListScope tracks RPC calls for dc redirection
DCRedirectionDescribeTaskListScope
// DCRedirectionDescribeWorkflowExecutionScope tracks RPC calls for dc redirection
DCRedirectionDescribeWorkflowExecutionScope
// DCRedirectionGetWorkflowExecutionHistoryScope tracks RPC calls for dc redirection
DCRedirectionGetWorkflowExecutionHistoryScope
// DCRedirectionGetWorkflowExecutionRawHistoryScope tracks RPC calls for dc redirection
DCRedirectionGetWorkflowExecutionRawHistoryScope
// DCRedirectionPollForWorklfowExecutionRawHistoryScope tracks RPC calls for dc redirection
DCRedirectionPollForWorklfowExecutionRawHistoryScope
// DCRedirectionListArchivedWorkflowExecutionsScope tracks RPC calls for dc redirection
DCRedirectionListArchivedWorkflowExecutionsScope
// DCRedirectionListClosedWorkflowExecutionsScope tracks RPC calls for dc redirection
DCRedirectionListClosedWorkflowExecutionsScope
// DCRedirectionListDomainsScope tracks RPC calls for dc redirection
DCRedirectionListDomainsScope
// DCRedirectionListOpenWorkflowExecutionsScope tracks RPC calls for dc redirection
DCRedirectionListOpenWorkflowExecutionsScope
// DCRedirectionListWorkflowExecutionsScope tracks RPC calls for dc redirection
DCRedirectionListWorkflowExecutionsScope
// DCRedirectionScanWorkflowExecutionsScope tracks RPC calls for dc redirection
DCRedirectionScanWorkflowExecutionsScope
// DCRedirectionCountWorkflowExecutionsScope tracks RPC calls for dc redirection
DCRedirectionCountWorkflowExecutionsScope
// DCRedirectionGetSearchAttributesScope tracks RPC calls for dc redirection
DCRedirectionGetSearchAttributesScope
// DCRedirectionPollForActivityTaskScope tracks RPC calls for dc redirection
DCRedirectionPollForActivityTaskScope
// DCRedirectionPollForDecisionTaskScope tracks RPC calls for dc redirection
DCRedirectionPollForDecisionTaskScope
// DCRedirectionQueryWorkflowScope tracks RPC calls for dc redirection
DCRedirectionQueryWorkflowScope
// DCRedirectionRecordActivityTaskHeartbeatScope tracks RPC calls for dc redirection
DCRedirectionRecordActivityTaskHeartbeatScope
// DCRedirectionRecordActivityTaskHeartbeatByIDScope tracks RPC calls for dc redirection
DCRedirectionRecordActivityTaskHeartbeatByIDScope
// DCRedirectionRegisterDomainScope tracks RPC calls for dc redirection
DCRedirectionRegisterDomainScope
// DCRedirectionRequestCancelWorkflowExecutionScope tracks RPC calls for dc redirection
DCRedirectionRequestCancelWorkflowExecutionScope
// DCRedirectionResetStickyTaskListScope tracks RPC calls for dc redirection
DCRedirectionResetStickyTaskListScope
// DCRedirectionResetWorkflowExecutionScope tracks RPC calls for dc redirection
DCRedirectionResetWorkflowExecutionScope
// DCRedirectionRespondActivityTaskCanceledScope tracks RPC calls for dc redirection
DCRedirectionRespondActivityTaskCanceledScope
// DCRedirectionRespondActivityTaskCanceledByIDScope tracks RPC calls for dc redirection
DCRedirectionRespondActivityTaskCanceledByIDScope
// DCRedirectionRespondActivityTaskCompletedScope tracks RPC calls for dc redirection
DCRedirectionRespondActivityTaskCompletedScope
// DCRedirectionRespondActivityTaskCompletedByIDScope tracks RPC calls for dc redirection
DCRedirectionRespondActivityTaskCompletedByIDScope
// DCRedirectionRespondActivityTaskFailedScope tracks RPC calls for dc redirection
DCRedirectionRespondActivityTaskFailedScope
// DCRedirectionRespondActivityTaskFailedByIDScope tracks RPC calls for dc redirection
DCRedirectionRespondActivityTaskFailedByIDScope
// DCRedirectionRespondDecisionTaskCompletedScope tracks RPC calls for dc redirection
DCRedirectionRespondDecisionTaskCompletedScope
// DCRedirectionRespondDecisionTaskFailedScope tracks RPC calls for dc redirection
DCRedirectionRespondDecisionTaskFailedScope
// DCRedirectionRespondQueryTaskCompletedScope tracks RPC calls for dc redirection
DCRedirectionRespondQueryTaskCompletedScope
// DCRedirectionSignalWithStartWorkflowExecutionScope tracks RPC calls for dc redirection
DCRedirectionSignalWithStartWorkflowExecutionScope
// DCRedirectionSignalWithStartWorkflowExecutionAsyncScope tracks RPC calls for dc redirection
DCRedirectionSignalWithStartWorkflowExecutionAsyncScope
// DCRedirectionSignalWorkflowExecutionScope tracks RPC calls for dc redirection
DCRedirectionSignalWorkflowExecutionScope
// DCRedirectionStartWorkflowExecutionScope tracks RPC calls for dc redirection
DCRedirectionStartWorkflowExecutionScope
// DCRedirectionStartWorkflowExecutionAsyncScope tracks RPC calls for dc redirection
DCRedirectionStartWorkflowExecutionAsyncScope
// DCRedirectionTerminateWorkflowExecutionScope tracks RPC calls for dc redirection
DCRedirectionTerminateWorkflowExecutionScope
// DCRedirectionUpdateDomainScope tracks RPC calls for dc redirection
DCRedirectionUpdateDomainScope
// DCRedirectionListTaskListPartitionsScope tracks RPC calls for dc redirection
DCRedirectionListTaskListPartitionsScope
// DCRedirectionGetTaskListsByDomainScope tracks RPC calls for dc redirection
DCRedirectionGetTaskListsByDomainScope
// DCRedirectionRefreshWorkflowTasksScope tracks RPC calls for dc redirection
DCRedirectionRefreshWorkflowTasksScope
// DCRedirectionRestartWorkflowExecutionScope tracks RPC calls for dc redirection
DCRedirectionRestartWorkflowExecutionScope
// MessagingPublishScope tracks Publish calls made by service to messaging layer
MessagingClientPublishScope
// MessagingPublishBatchScope tracks Publish calls made by service to messaging layer
MessagingClientPublishBatchScope
// MessagingClientConsumerScope tracks the consumer activities
MessagingClientConsumerScope
// DomainCacheScope tracks domain cache callbacks
DomainCacheScope
// HistoryRereplicationByTransferTaskScope tracks history replication calls made by transfer task
HistoryRereplicationByTransferTaskScope
// HistoryRereplicationByTimerTaskScope tracks history replication calls made by timer task
HistoryRereplicationByTimerTaskScope
// HistoryRereplicationByHistoryReplicationScope tracks history replication calls made by history replication
HistoryRereplicationByHistoryReplicationScope
// HistoryRereplicationByHistoryMetadataReplicationScope tracks history replication calls made by history replication
HistoryRereplicationByHistoryMetadataReplicationScope
// HistoryRereplicationByActivityReplicationScope tracks history replication calls made by activity replication
HistoryRereplicationByActivityReplicationScope
// PersistenceAppendHistoryNodesScope tracks AppendHistoryNodes calls made by service to persistence layer
PersistenceAppendHistoryNodesScope
// PersistenceReadHistoryBranchScope tracks ReadHistoryBranch calls made by service to persistence layer
PersistenceReadHistoryBranchScope
// PersistenceReadHistoryBranchByBatchScope tracks ReadHistoryBranch calls made by service to persistence layer
PersistenceReadHistoryBranchByBatchScope
// PersistenceReadRawHistoryBranchScope tracks ReadHistoryBranch calls made by service to persistence layer
PersistenceReadRawHistoryBranchScope
// PersistenceForkHistoryBranchScope tracks ForkHistoryBranch calls made by service to persistence layer
PersistenceForkHistoryBranchScope
// PersistenceDeleteHistoryBranchScope tracks DeleteHistoryBranch calls made by service to persistence layer
PersistenceDeleteHistoryBranchScope
// PersistenceCompleteForkBranchScope tracks CompleteForkBranch calls made by service to persistence layer
PersistenceCompleteForkBranchScope
// PersistenceGetHistoryTreeScope tracks GetHistoryTree calls made by service to persistence layer
PersistenceGetHistoryTreeScope
// PersistenceGetAllHistoryTreeBranchesScope tracks GetHistoryTree calls made by service to persistence layer
PersistenceGetAllHistoryTreeBranchesScope
// ClusterMetadataArchivalConfigScope tracks ArchivalConfig calls to ClusterMetadata
ClusterMetadataArchivalConfigScope
// ElasticsearchRecordWorkflowExecutionStartedScope tracks RecordWorkflowExecutionStarted calls made by service to persistence layer
ElasticsearchRecordWorkflowExecutionStartedScope
// ElasticsearchRecordWorkflowExecutionClosedScope tracks RecordWorkflowExecutionClosed calls made by service to persistence layer
ElasticsearchRecordWorkflowExecutionClosedScope
// ElasticsearchRecordWorkflowExecutionUninitializedScope tracks RecordWorkflowExecutionUninitialized calls made by service to persistence layer
ElasticsearchRecordWorkflowExecutionUninitializedScope
// ElasticsearchUpsertWorkflowExecutionScope tracks UpsertWorkflowExecution calls made by service to persistence layer
ElasticsearchUpsertWorkflowExecutionScope
// ElasticsearchListOpenWorkflowExecutionsScope tracks ListOpenWorkflowExecutions calls made by service to persistence layer
ElasticsearchListOpenWorkflowExecutionsScope
// ElasticsearchListClosedWorkflowExecutionsScope tracks ListClosedWorkflowExecutions calls made by service to persistence layer
ElasticsearchListClosedWorkflowExecutionsScope
// ElasticsearchListOpenWorkflowExecutionsByTypeScope tracks ListOpenWorkflowExecutionsByType calls made by service to persistence layer
ElasticsearchListOpenWorkflowExecutionsByTypeScope
// ElasticsearchListClosedWorkflowExecutionsByTypeScope tracks ListClosedWorkflowExecutionsByType calls made by service to persistence layer
ElasticsearchListClosedWorkflowExecutionsByTypeScope
// ElasticsearchListOpenWorkflowExecutionsByWorkflowIDScope tracks ListOpenWorkflowExecutionsByWorkflowID calls made by service to persistence layer
ElasticsearchListOpenWorkflowExecutionsByWorkflowIDScope
// ElasticsearchListClosedWorkflowExecutionsByWorkflowIDScope tracks ListClosedWorkflowExecutionsByWorkflowID calls made by service to persistence layer
ElasticsearchListClosedWorkflowExecutionsByWorkflowIDScope
// ElasticsearchListClosedWorkflowExecutionsByStatusScope tracks ListClosedWorkflowExecutionsByStatus calls made by service to persistence layer
ElasticsearchListClosedWorkflowExecutionsByStatusScope
// ElasticsearchGetClosedWorkflowExecutionScope tracks GetClosedWorkflowExecution calls made by service to persistence layer
ElasticsearchGetClosedWorkflowExecutionScope
// ElasticsearchListWorkflowExecutionsScope tracks ListWorkflowExecutions calls made by service to persistence layer
ElasticsearchListWorkflowExecutionsScope
// ElasticsearchScanWorkflowExecutionsScope tracks ScanWorkflowExecutions calls made by service to persistence layer
ElasticsearchScanWorkflowExecutionsScope
// ElasticsearchCountWorkflowExecutionsScope tracks CountWorkflowExecutions calls made by service to persistence layer
ElasticsearchCountWorkflowExecutionsScope
// ElasticsearchDeleteWorkflowExecutionsScope tracks DeleteWorkflowExecution calls made by service to persistence layer
ElasticsearchDeleteWorkflowExecutionsScope
// ElasticsearchDeleteUninitializedWorkflowExecutionsScope tracks DeleteUninitializedWorkflowExecution calls made by service to persistence layer
ElasticsearchDeleteUninitializedWorkflowExecutionsScope
// PinotRecordWorkflowExecutionStartedScope tracks RecordWorkflowExecutionStarted calls made by service to persistence layer
PinotRecordWorkflowExecutionStartedScope
// PinotRecordWorkflowExecutionClosedScope tracks RecordWorkflowExecutionClosed calls made by service to persistence layer
PinotRecordWorkflowExecutionClosedScope
// PinotRecordWorkflowExecutionUninitializedScope tracks RecordWorkflowExecutionUninitialized calls made by service to persistence layer
PinotRecordWorkflowExecutionUninitializedScope
// PinotUpsertWorkflowExecutionScope tracks UpsertWorkflowExecution calls made by service to persistence layer
PinotUpsertWorkflowExecutionScope
// PinotListOpenWorkflowExecutionsScope tracks ListOpenWorkflowExecutions calls made by service to persistence layer
PinotListOpenWorkflowExecutionsScope
// PinotListClosedWorkflowExecutionsScope tracks ListClosedWorkflowExecutions calls made by service to persistence layer
PinotListClosedWorkflowExecutionsScope
// PinotListOpenWorkflowExecutionsByTypeScope tracks ListOpenWorkflowExecutionsByType calls made by service to persistence layer
PinotListOpenWorkflowExecutionsByTypeScope
// PinotListClosedWorkflowExecutionsByTypeScope tracks ListClosedWorkflowExecutionsByType calls made by service to persistence layer
PinotListClosedWorkflowExecutionsByTypeScope
// PinotListOpenWorkflowExecutionsByWorkflowIDScope tracks ListOpenWorkflowExecutionsByWorkflowID calls made by service to persistence layer
PinotListOpenWorkflowExecutionsByWorkflowIDScope
// PinotListClosedWorkflowExecutionsByWorkflowIDScope tracks ListClosedWorkflowExecutionsByWorkflowID calls made by service to persistence layer
PinotListClosedWorkflowExecutionsByWorkflowIDScope
// PinotListClosedWorkflowExecutionsByStatusScope tracks ListClosedWorkflowExecutionsByStatus calls made by service to persistence layer
PinotListClosedWorkflowExecutionsByStatusScope
// PinotGetClosedWorkflowExecutionScope tracks GetClosedWorkflowExecution calls made by service to persistence layer
PinotGetClosedWorkflowExecutionScope
// PinotListWorkflowExecutionsScope tracks ListWorkflowExecutions calls made by service to persistence layer
PinotListWorkflowExecutionsScope
// PinotScanWorkflowExecutionsScope tracks ScanWorkflowExecutions calls made by service to persistence layer
PinotScanWorkflowExecutionsScope
// PinotCountWorkflowExecutionsScope tracks CountWorkflowExecutions calls made by service to persistence layer
PinotCountWorkflowExecutionsScope
// PinotDeleteWorkflowExecutionsScope tracks DeleteWorkflowExecution calls made by service to persistence layer
PinotDeleteWorkflowExecutionsScope
// PinotDeleteUninitializedWorkflowExecutionsScope tracks DeleteUninitializedWorkflowExecution calls made by service to persistence layer
PinotDeleteUninitializedWorkflowExecutionsScope
// SequentialTaskProcessingScope is used by sequential task processing logic
SequentialTaskProcessingScope
// ParallelTaskProcessingScope is used by parallel task processing logic
ParallelTaskProcessingScope
// TaskSchedulerScope is used by task scheduler logic
TaskSchedulerScope
// HistoryArchiverScope is used by history archivers
HistoryArchiverScope
// VisibilityArchiverScope is used by visibility archivers
VisibilityArchiverScope
// The following metrics are only used by internal archiver implemention.
// TODO: move them to internal repo once cadence plugin model is in place.
// BlobstoreClientUploadScope tracks Upload calls to blobstore
BlobstoreClientUploadScope
// BlobstoreClientDownloadScope tracks Download calls to blobstore
BlobstoreClientDownloadScope
// BlobstoreClientGetMetadataScope tracks GetMetadata calls to blobstore
BlobstoreClientGetMetadataScope
// BlobstoreClientExistsScope tracks Exists calls to blobstore
BlobstoreClientExistsScope
// BlobstoreClientDeleteScope tracks Delete calls to blobstore
BlobstoreClientDeleteScope
// BlobstoreClientDirectoryExistsScope tracks DirectoryExists calls to blobstore
BlobstoreClientDirectoryExistsScope
// DomainFailoverScope is used in domain failover processor
DomainFailoverScope
// DomainReplicationQueueScope is used in domainreplication queue
DomainReplicationQueueScope
// ClusterMetadataScope is used for the cluster metadata
ClusterMetadataScope
// GetAvailableIsolationGroupsScope is the metric for the default partitioner's getIsolationGroups operation
GetAvailableIsolationGroupsScope
// TaskValidatorScope is the metric for the taskvalidator's workflow check operation.
TaskValidatorScope
NumCommonScopes
)
// -- Operation scopes for Admin service --
const (
// AdminDescribeHistoryHostScope is the metric scope for admin.AdminDescribeHistoryHostScope
AdminDescribeHistoryHostScope = iota + NumCommonScopes
// AdminDescribeClusterScope is the metric scope for admin.AdminDescribeClusterScope
AdminDescribeClusterScope
// AdminAddSearchAttributeScope is the metric scope for admin.AdminAddSearchAttributeScope
AdminAddSearchAttributeScope
// AdminDescribeWorkflowExecutionScope is the metric scope for admin.AdminDescribeWorkflowExecutionScope
AdminDescribeWorkflowExecutionScope
// AdminGetWorkflowExecutionRawHistoryScope is the metric scope for admin.GetWorkflowExecutionRawHistoryScope
AdminGetWorkflowExecutionRawHistoryScope
// AdminGetWorkflowExecutionRawHistoryV2Scope is the metric scope for admin.GetWorkflowExecutionRawHistoryScope
AdminGetWorkflowExecutionRawHistoryV2Scope
// AdminGetReplicationMessagesScope is the metric scope for admin.GetReplicationMessages
AdminGetReplicationMessagesScope
// AdminGetDomainReplicationMessagesScope is the metric scope for admin.GetDomainReplicationMessages
AdminGetDomainReplicationMessagesScope
// AdminGetDLQReplicationMessagesScope is the metric scope for admin.GetDLQReplicationMessages
AdminGetDLQReplicationMessagesScope
// AdminReapplyEventsScope is the metric scope for admin.ReapplyEvents
AdminReapplyEventsScope
// AdminRefreshWorkflowTasksScope is the metric scope for admin.RefreshWorkflowTasks
AdminRefreshWorkflowTasksScope
// AdminResendReplicationTasksScope is the metric scope for admin.ResendReplicationTasks
AdminResendReplicationTasksScope
// AdminRemoveTaskScope is the metric scope for admin.AdminRemoveTaskScope
AdminRemoveTaskScope
// AdminCloseShardScope is the metric scope for admin.AdminCloseShardScope
AdminCloseShardScope
// AdminResetQueueScope is the metric scope for admin.AdminResetQueueScope
AdminResetQueueScope
// AdminDescribeQueueScope is the metrics scope for admin.AdminDescribeQueueScope
AdminDescribeQueueScope
// AdminCountDLQMessagesScope is the metric scope for admin.AdminCountDLQMessagesScope
AdminCountDLQMessagesScope
// AdminReadDLQMessagesScope is the metric scope for admin.AdminReadDLQMessagesScope
AdminReadDLQMessagesScope
// AdminPurgeDLQMessagesScope is the metric scope for admin.AdminPurgeDLQMessagesScope
AdminPurgeDLQMessagesScope
// AdminMergeDLQMessagesScope is the metric scope for admin.AdminMergeDLQMessagesScope
AdminMergeDLQMessagesScope
// AdminDescribeShardDistributionScope is the metric scope for admin.DescribeShardDistribution
AdminDescribeShardDistributionScope
// AdminGetCrossClusterTasksScope is the metric scope for admin.GetCrossClusterTasks
AdminGetCrossClusterTasksScope
// AdminRespondCrossClusterTasksCompletedScope is the metric scope for admin.AdminRespondCrossClusterTasksCompleted
AdminRespondCrossClusterTasksCompletedScope
// AdminGetDynamicConfigScope is the metric scope for admin.GetDynamicConfig
AdminGetDynamicConfigScope
// AdminUpdateDynamicConfigScope is the metric scope for admin.UpdateDynamicConfig
AdminUpdateDynamicConfigScope
// AdminRestoreDynamicConfigScope is the metric scope for admin.RestoreDynamicConfig
AdminRestoreDynamicConfigScope
// AdminListDynamicConfigScope is the metric scope for admin.ListDynamicConfig
AdminListDynamicConfigScope
// AdminDeleteWorkflowScope is the metric scope for admin.DeleteWorkflow
AdminDeleteWorkflowScope
// GetGlobalIsolationGroups is the scope for getting global isolation groups
GetGlobalIsolationGroups
// UpdateGlobalIsolationGroups is the scope for getting global isolation groups
UpdateGlobalIsolationGroups
// GetDomainIsolationGroups is the scope for getting domain isolation groups
GetDomainIsolationGroups
// UpdateDomainIsolationGroups is the scope for getting domain isolation groups
UpdateDomainIsolationGroups
// GetDomainAsyncWorkflowConfiguraton is the scope for getting domain async workflow configuration
GetDomainAsyncWorkflowConfiguraton
// UpdateDomainAsyncWorkflowConfiguraton is the scope for updating domain async workflow configuration
UpdateDomainAsyncWorkflowConfiguraton
NumAdminScopes
)
// -- Operation scopes for Frontend service --
const (
// FrontendRestartWorkflowExecutionScope is the metric for frontend.RestartWorkflowExecution
FrontendRestartWorkflowExecutionScope = iota + NumAdminScopes
// FrontendStartWorkflowExecutionScope is the metric scope for frontend.StartWorkflowExecution
FrontendStartWorkflowExecutionScope
// FrontendStartWorkflowExecutionAsyncScope is the metric scope for frontend.StartWorkflowExecutionAsync
FrontendStartWorkflowExecutionAsyncScope
// PollForDecisionTaskScope is the metric scope for frontend.PollForDecisionTask
FrontendPollForDecisionTaskScope
// FrontendPollForActivityTaskScope is the metric scope for frontend.PollForActivityTask
FrontendPollForActivityTaskScope
// FrontendRecordActivityTaskHeartbeatScope is the metric scope for frontend.RecordActivityTaskHeartbeat
FrontendRecordActivityTaskHeartbeatScope
// FrontendRecordActivityTaskHeartbeatByIDScope is the metric scope for frontend.RespondDecisionTaskCompleted
FrontendRecordActivityTaskHeartbeatByIDScope
// FrontendRespondDecisionTaskCompletedScope is the metric scope for frontend.RespondDecisionTaskCompleted
FrontendRespondDecisionTaskCompletedScope
// FrontendRespondDecisionTaskFailedScope is the metric scope for frontend.RespondDecisionTaskFailed
FrontendRespondDecisionTaskFailedScope
// FrontendRespondQueryTaskCompletedScope is the metric scope for frontend.RespondQueryTaskCompleted
FrontendRespondQueryTaskCompletedScope
// FrontendRespondActivityTaskCompletedScope is the metric scope for frontend.RespondActivityTaskCompleted
FrontendRespondActivityTaskCompletedScope
// FrontendRespondActivityTaskFailedScope is the metric scope for frontend.RespondActivityTaskFailed
FrontendRespondActivityTaskFailedScope
// FrontendRespondActivityTaskCanceledScope is the metric scope for frontend.RespondActivityTaskCanceled
FrontendRespondActivityTaskCanceledScope
// FrontendRespondActivityTaskCompletedScope is the metric scope for frontend.RespondActivityTaskCompletedByID
FrontendRespondActivityTaskCompletedByIDScope
// FrontendRespondActivityTaskFailedScope is the metric scope for frontend.RespondActivityTaskFailedByID
FrontendRespondActivityTaskFailedByIDScope
// FrontendRespondActivityTaskCanceledScope is the metric scope for frontend.RespondActivityTaskCanceledByID
FrontendRespondActivityTaskCanceledByIDScope
// FrontendGetWorkflowExecutionHistoryScope is the metric scope for frontend.GetWorkflowExecutionHistory
FrontendGetWorkflowExecutionHistoryScope
// FrontendGetWorkflowExecutionRawHistoryScope is the metric scope for frontend.GetWorkflowExecutionRawHistory
FrontendGetWorkflowExecutionRawHistoryScope
// FrontendPollForWorklfowExecutionRawHistoryScope is the metric scope for frontend.GetWorkflowExecutionRawHistory
FrontendPollForWorklfowExecutionRawHistoryScope
// FrontendSignalWorkflowExecutionScope is the metric scope for frontend.SignalWorkflowExecution
FrontendSignalWorkflowExecutionScope
// FrontendSignalWithStartWorkflowExecutionScope is the metric scope for frontend.SignalWithStartWorkflowExecution
FrontendSignalWithStartWorkflowExecutionScope
// FrontendSignalWithStartWorkflowExecutionAsyncScope is the metric scope for frontend.SignalWithStartWorkflowExecutionAsync
FrontendSignalWithStartWorkflowExecutionAsyncScope
// FrontendTerminateWorkflowExecutionScope is the metric scope for frontend.TerminateWorkflowExecution
FrontendTerminateWorkflowExecutionScope
// FrontendRequestCancelWorkflowExecutionScope is the metric scope for frontend.RequestCancelWorkflowExecution
FrontendRequestCancelWorkflowExecutionScope
// FrontendListArchivedWorkflowExecutionsScope is the metric scope for frontend.ListArchivedWorkflowExecutions
FrontendListArchivedWorkflowExecutionsScope
// FrontendListOpenWorkflowExecutionsScope is the metric scope for frontend.ListOpenWorkflowExecutions
FrontendListOpenWorkflowExecutionsScope
// FrontendListClosedWorkflowExecutionsScope is the metric scope for frontend.ListClosedWorkflowExecutions
FrontendListClosedWorkflowExecutionsScope
// FrontendListWorkflowExecutionsScope is the metric scope for frontend.ListWorkflowExecutions
FrontendListWorkflowExecutionsScope
// FrontendScanWorkflowExecutionsScope is the metric scope for frontend.ListWorkflowExecutions
FrontendScanWorkflowExecutionsScope
// FrontendCountWorkflowExecutionsScope is the metric scope for frontend.CountWorkflowExecutions
FrontendCountWorkflowExecutionsScope
// FrontendRegisterDomainScope is the metric scope for frontend.RegisterDomain
FrontendRegisterDomainScope
// FrontendDescribeDomainScope is the metric scope for frontend.DescribeDomain
FrontendDescribeDomainScope
// FrontendUpdateDomainScope is the metric scope for frontend.DescribeDomain
FrontendUpdateDomainScope
// FrontendDeprecateDomainScope is the metric scope for frontend.DeprecateDomain
FrontendDeprecateDomainScope
// FrontendQueryWorkflowScope is the metric scope for frontend.QueryWorkflow
FrontendQueryWorkflowScope
// FrontendDescribeWorkflowExecutionScope is the metric scope for frontend.DescribeWorkflowExecution
FrontendDescribeWorkflowExecutionScope
// FrontendDescribeTaskListScope is the metric scope for frontend.DescribeTaskList
FrontendDescribeTaskListScope
// FrontendResetStickyTaskListScope is the metric scope for frontend.ResetStickyTaskList
FrontendListTaskListPartitionsScope
// FrontendGetTaskListsByDomainScope is the metric scope for frontend.ResetStickyTaskList
FrontendGetTaskListsByDomainScope
// FrontendRefreshWorkflowTasksScope is the metric scope for frontend.RefreshWorkflowTasks
FrontendRefreshWorkflowTasksScope
// FrontendResetStickyTaskListScope is the metric scope for frontend.ResetStickyTaskList
FrontendResetStickyTaskListScope
// FrontendListDomainsScope is the metric scope for frontend.ListDomain
FrontendListDomainsScope
// FrontendResetWorkflowExecutionScope is the metric scope for frontend.ResetWorkflowExecution
FrontendResetWorkflowExecutionScope
// FrontendGetSearchAttributesScope is the metric scope for frontend.GetSearchAttributes
FrontendGetSearchAttributesScope
// FrontendGetClusterInfoScope is the metric scope for frontend.GetClusterInfo
FrontendGetClusterInfoScope
NumFrontendScopes
)
// -- Operation scopes for History service --
const (
// HistoryStartWorkflowExecutionScope tracks StartWorkflowExecution API calls received by service
HistoryStartWorkflowExecutionScope = iota + NumCommonScopes
// HistoryRecordActivityTaskHeartbeatScope tracks RecordActivityTaskHeartbeat API calls received by service
HistoryRecordActivityTaskHeartbeatScope
// HistoryRespondDecisionTaskCompletedScope tracks RespondDecisionTaskCompleted API calls received by service
HistoryRespondDecisionTaskCompletedScope
// HistoryRespondDecisionTaskFailedScope tracks RespondDecisionTaskFailed API calls received by service
HistoryRespondDecisionTaskFailedScope
// HistoryRespondActivityTaskCompletedScope tracks RespondActivityTaskCompleted API calls received by service
HistoryRespondActivityTaskCompletedScope
// HistoryRespondActivityTaskFailedScope tracks RespondActivityTaskFailed API calls received by service
HistoryRespondActivityTaskFailedScope
// HistoryRespondActivityTaskCanceledScope tracks RespondActivityTaskCanceled API calls received by service
HistoryRespondActivityTaskCanceledScope
// HistoryResetQueueScope tracks ResetQueue API calls received by service
HistoryResetQueueScope
// HistoryDescribeQueueScope tracks DescribeQueue API calls received by service
HistoryDescribeQueueScope
// HistoryDescribeMutabelStateScope tracks DescribeMutableState API calls received by service
HistoryDescribeMutabelStateScope
// HistoryGetMutableStateScope tracks GetMutableState API calls received by service
HistoryGetMutableStateScope
// HistoryPollMutableStateScope tracks PollMutableState API calls received by service
HistoryPollMutableStateScope
// HistoryResetStickyTaskListScope tracks ResetStickyTaskList API calls received by service
HistoryResetStickyTaskListScope
// HistoryDescribeWorkflowExecutionScope tracks DescribeWorkflowExecution API calls received by service
HistoryDescribeWorkflowExecutionScope
// HistoryRecordDecisionTaskStartedScope tracks RecordDecisionTaskStarted API calls received by service
HistoryRecordDecisionTaskStartedScope
// HistoryRecordActivityTaskStartedScope tracks RecordActivityTaskStarted API calls received by service
HistoryRecordActivityTaskStartedScope
// HistorySignalWorkflowExecutionScope tracks SignalWorkflowExecution API calls received by service
HistorySignalWorkflowExecutionScope
// HistorySignalWithStartWorkflowExecutionScope tracks SignalWithStartWorkflowExecution API calls received by service
HistorySignalWithStartWorkflowExecutionScope
// HistoryRemoveSignalMutableStateScope tracks RemoveSignalMutableState API calls received by service
HistoryRemoveSignalMutableStateScope
// HistoryTerminateWorkflowExecutionScope tracks TerminateWorkflowExecution API calls received by service
HistoryTerminateWorkflowExecutionScope
// HistoryScheduleDecisionTaskScope tracks ScheduleDecisionTask API calls received by service
HistoryScheduleDecisionTaskScope
// HistoryRecordChildExecutionCompletedScope tracks CompleteChildExecution API calls received by service
HistoryRecordChildExecutionCompletedScope
// HistoryRequestCancelWorkflowExecutionScope tracks RequestCancelWorkflowExecution API calls received by service
HistoryRequestCancelWorkflowExecutionScope
// HistoryReplicateEventsScope tracks ReplicateEvents API calls received by service
HistoryReplicateEventsScope
// HistoryReplicateRawEventsScope tracks ReplicateEvents API calls received by service
HistoryReplicateRawEventsScope
// HistoryReplicateEventsV2Scope tracks ReplicateEvents API calls received by service
HistoryReplicateEventsV2Scope
// HistorySyncShardStatusScope tracks HistorySyncShardStatus API calls received by service
HistorySyncShardStatusScope
// HistorySyncActivityScope tracks HistoryActivity API calls received by service
HistorySyncActivityScope
// HistoryDescribeMutableStateScope tracks HistoryActivity API calls received by service
HistoryDescribeMutableStateScope
// GetReplicationMessages tracks GetReplicationMessages API calls received by service
HistoryGetReplicationMessagesScope
// HistoryGetDLQReplicationMessagesScope tracks GetReplicationMessages API calls received by service
HistoryGetDLQReplicationMessagesScope
// HistoryCountDLQMessagesScope tracks CountDLQMessages API calls received by service
HistoryCountDLQMessagesScope
// HistoryReadDLQMessagesScope tracks ReadDLQMessages API calls received by service
HistoryReadDLQMessagesScope
// HistoryPurgeDLQMessagesScope tracks PurgeDLQMessages API calls received by service
HistoryPurgeDLQMessagesScope
// HistoryMergeDLQMessagesScope tracks MergeDLQMessages API calls received by service
HistoryMergeDLQMessagesScope
// HistoryShardControllerScope is the scope used by shard controller
HistoryShardControllerScope
// HistoryReapplyEventsScope tracks ReapplyEvents API calls received by service
HistoryReapplyEventsScope
// HistoryRefreshWorkflowTasksScope tracks RefreshWorkflowTasks API calls received by service
HistoryRefreshWorkflowTasksScope
// HistoryNotifyFailoverMarkersScope is the scope used by notify failover marker API
HistoryNotifyFailoverMarkersScope
// HistoryGetCrossClusterTasksScope tracks GetCrossClusterTasks API calls received by service
HistoryGetCrossClusterTasksScope
// HistoryRespondCrossClusterTasksCompletedScope tracks RespondCrossClusterTasksCompleted API calls received by service
HistoryRespondCrossClusterTasksCompletedScope
// HistoryGetFailoverInfoScope tracks HistoryGetFailoverInfo API calls received by service
HistoryGetFailoverInfoScope
// TaskPriorityAssignerScope is the scope used by all metric emitted by task priority assigner
TaskPriorityAssignerScope
// TransferQueueProcessorScope is the scope used by all metric emitted by transfer queue processor
TransferQueueProcessorScope
// TransferActiveQueueProcessorScope is the scope used by all metric emitted by transfer queue processor
TransferActiveQueueProcessorScope
// TransferStandbyQueueProcessorScope is the scope used by all metric emitted by transfer queue processor
TransferStandbyQueueProcessorScope
// TransferActiveTaskActivityScope is the scope used for activity task processing by transfer queue processor
TransferActiveTaskActivityScope
// TransferActiveTaskDecisionScope is the scope used for decision task processing by transfer queue processor
TransferActiveTaskDecisionScope
// TransferActiveTaskCloseExecutionScope is the scope used for close execution task processing by transfer queue processor
TransferActiveTaskCloseExecutionScope
// TransferActiveTaskCancelExecutionScope is the scope used for cancel execution task processing by transfer queue processor
TransferActiveTaskCancelExecutionScope
// TransferActiveTaskSignalExecutionScope is the scope used for signal execution task processing by transfer queue processor
TransferActiveTaskSignalExecutionScope
// TransferActiveTaskStartChildExecutionScope is the scope used for start child execution task processing by transfer queue processor
TransferActiveTaskStartChildExecutionScope
// TransferActiveTaskRecordWorkflowStartedScope is the scope used for record workflow started task processing by transfer queue processor
TransferActiveTaskRecordWorkflowStartedScope
// TransferActiveTaskResetWorkflowScope is the scope used for record workflow started task processing by transfer queue processor
TransferActiveTaskResetWorkflowScope
// TransferActiveTaskUpsertWorkflowSearchAttributesScope is the scope used for upsert search attributes processing by transfer queue processor
TransferActiveTaskUpsertWorkflowSearchAttributesScope
// TransferActiveTaskRecordWorkflowClosedScope is the scope used for record workflow closed task processing by transfer queue processor
TransferActiveTaskRecordWorkflowClosedScope
// TransferActiveTaskRecordChildExecutionCompletedScope is the scope used for record child execution completed task processing by transfer queue processor
TransferActiveTaskRecordChildExecutionCompletedScope
// TransferActiveTaskApplyParentClosePolicyScope is the scope used for apply parent close policy task processing by transfer queue processor
TransferActiveTaskApplyParentClosePolicyScope
// TransferStandbyTaskResetWorkflowScope is the scope used for record workflow started task processing by transfer queue processor
TransferStandbyTaskResetWorkflowScope
// TransferStandbyTaskActivityScope is the scope used for activity task processing by transfer queue processor
TransferStandbyTaskActivityScope
// TransferStandbyTaskDecisionScope is the scope used for decision task processing by transfer queue processor
TransferStandbyTaskDecisionScope
// TransferStandbyTaskCloseExecutionScope is the scope used for close execution task processing by transfer queue processor
TransferStandbyTaskCloseExecutionScope
// TransferStandbyTaskCancelExecutionScope is the scope used for cancel execution task processing by transfer queue processor
TransferStandbyTaskCancelExecutionScope
// TransferStandbyTaskSignalExecutionScope is the scope used for signal execution task processing by transfer queue processor
TransferStandbyTaskSignalExecutionScope
// TransferStandbyTaskStartChildExecutionScope is the scope used for start child execution task processing by transfer queue processor
TransferStandbyTaskStartChildExecutionScope
// TransferStandbyTaskRecordWorkflowStartedScope is the scope used for record workflow started task processing by transfer queue processor
TransferStandbyTaskRecordWorkflowStartedScope
// TransferStandbyTaskUpsertWorkflowSearchAttributesScope is the scope used for upsert search attributes processing by transfer queue processor
TransferStandbyTaskUpsertWorkflowSearchAttributesScope
// TransferActiveTaskRecordWorkflowClosedScope is the scope used for record workflow closed task processing by transfer queue processor
TransferStandbyTaskRecordWorkflowClosedScope
// TransferActiveTaskRecordChildExecutionCompletedScope is the scope used for record child execution completed task processing by transfer queue processor
TransferStandbyTaskRecordChildExecutionCompletedScope
// TransferActiveTaskApplyParentClosePolicyScope is the scope used for apply parent close policy task processing by transfer queue processor
TransferStandbyTaskApplyParentClosePolicyScope
// TimerQueueProcessorScope is the scope used by all metric emitted by timer queue processor
TimerQueueProcessorScope
// TimerActiveQueueProcessorScope is the scope used by all metric emitted by timer queue processor
TimerActiveQueueProcessorScope
// TimerQueueProcessorScope is the scope used by all metric emitted by timer queue processor
TimerStandbyQueueProcessorScope
// TimerActiveTaskActivityTimeoutScope is the scope used by metric emitted by timer queue processor for processing activity timeouts
TimerActiveTaskActivityTimeoutScope
// TimerActiveTaskDecisionTimeoutScope is the scope used by metric emitted by timer queue processor for processing decision timeouts
TimerActiveTaskDecisionTimeoutScope
// TimerActiveTaskUserTimerScope is the scope used by metric emitted by timer queue processor for processing user timers
TimerActiveTaskUserTimerScope
// TimerActiveTaskWorkflowTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow timeouts.
TimerActiveTaskWorkflowTimeoutScope
// TimerActiveTaskActivityRetryTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
TimerActiveTaskActivityRetryTimerScope
// TimerActiveTaskWorkflowBackoffTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
TimerActiveTaskWorkflowBackoffTimerScope
// TimerActiveTaskDeleteHistoryEventScope is the scope used by metric emitted by timer queue processor for processing history event cleanup
TimerActiveTaskDeleteHistoryEventScope
// TimerStandbyTaskActivityTimeoutScope is the scope used by metric emitted by timer queue processor for processing activity timeouts
TimerStandbyTaskActivityTimeoutScope
// TimerStandbyTaskDecisionTimeoutScope is the scope used by metric emitted by timer queue processor for processing decision timeouts
TimerStandbyTaskDecisionTimeoutScope
// TimerStandbyTaskUserTimerScope is the scope used by metric emitted by timer queue processor for processing user timers
TimerStandbyTaskUserTimerScope
// TimerStandbyTaskWorkflowTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow timeouts.
TimerStandbyTaskWorkflowTimeoutScope
// TimerStandbyTaskActivityRetryTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
TimerStandbyTaskActivityRetryTimerScope
// TimerStandbyTaskDeleteHistoryEventScope is the scope used by metric emitted by timer queue processor for processing history event cleanup
TimerStandbyTaskDeleteHistoryEventScope
// TimerStandbyTaskWorkflowBackoffTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
TimerStandbyTaskWorkflowBackoffTimerScope
// CrossClusterQueueProcessorScope is the scope used by all metric emitted by cross cluster queue processor in the source cluster
CrossClusterQueueProcessorScope
// CrossClusterTaskProcessorScope is the scope used by all metric emitted by cross cluster task processor in the target cluster
CrossClusterTaskProcessorScope
// CrossClusterTaskFetcherScope is the scope used by all metrics emitted by cross cluster task fetcher in the target cluster
CrossClusterTaskFetcherScope
// CrossClusterSourceTaskStartChildExecutionScope is the scope used by metric emitted by cross cluster queue processor for processing start child workflow task.
CrossClusterSourceTaskStartChildExecutionScope
// CrossClusterSourceTaskCancelExecutionScope is the scope used by metric emitted by cross cluster queue processor for processing cancel workflow task.
CrossClusterSourceTaskCancelExecutionScope
// CrossClusterSourceTaskSignalExecutionScope is the scope used by metric emitted by cross cluster queue processor for processing signal workflow task.
CrossClusterSourceTaskSignalExecutionScope
// CrossClusterSourceTaskRecordChildWorkflowExecutionCompleteScope is the scope used by metric emitted by cross cluster queue processor for recording child workflow completion task.
CrossClusterSourceTaskRecordChildWorkflowExecutionCompleteScope
// CrossClusterSourceTaskApplyParentClosePolicyScope is the scope used by metric emitted by cross cluster queue processor for processing applying parent close policy
CrossClusterSourceTaskApplyParentClosePolicyScope
// CrossClusterTargetTaskStartChildExecutionScope is the scope used by metric emitted by cross cluster queue processor for processing start child workflow task.
CrossClusterTargetTaskStartChildExecutionScope
// CrossClusterTargetTaskCancelExecutionScope is the scope used by metric emitted by cross cluster queue processor for processing cancel workflow task.
CrossClusterTargetTaskCancelExecutionScope
// CrossClusterTargetTaskSignalExecutionScope is the scope used by metric emitted by cross cluster queue processor for processing signal workflow task.
CrossClusterTargetTaskSignalExecutionScope
// CrossClusterTargetTaskRecordChildWorkflowExecutionCompleteScope is the scope used by metric emitted by cross cluster queue processor for recording child workflow completion task.
CrossClusterTargetTaskRecordChildWorkflowExecutionCompleteScope
// CrossClusterTargetTaskApplyParentClosePolicyScope is the scope used by metric emitted by cross cluster queue processor for processing applying parent close policy
CrossClusterTargetTaskApplyParentClosePolicyScope
// HistoryEventNotificationScope is the scope used by shard history event notification
HistoryEventNotificationScope
// ReplicatorQueueProcessorScope is the scope used by all metric emitted by replicator queue processor
ReplicatorQueueProcessorScope
// ReplicatorCacheManagerScope is the scope used by all metric emitted by replicator cache manager
ReplicatorCacheManagerScope
// ReplicatorTaskHistoryScope is the scope used for history task processing by replicator queue processor
ReplicatorTaskHistoryScope
// ReplicatorTaskSyncActivityScope is the scope used for sync activity by replicator queue processor
ReplicatorTaskSyncActivityScope
// ReplicateHistoryEventsScope is the scope used by historyReplicator API for applying events
ReplicateHistoryEventsScope
// ReplicationMetricEmitterScope is the scope used by all metrics emitted by replication metric emitter
ReplicationMetricEmitterScope
// ShardInfoScope is the scope used when updating shard info
ShardInfoScope
// WorkflowContextScope is the scope used by WorkflowContext component
WorkflowContextScope
// HistoryCacheGetAndCreateScope is the scope used by history cache
HistoryCacheGetAndCreateScope
// HistoryCacheGetOrCreateScope is the scope used by history cache
HistoryCacheGetOrCreateScope
// HistoryCacheGetOrCreateCurrentScope is the scope used by history cache
HistoryCacheGetOrCreateCurrentScope
// HistoryCacheGetCurrentExecutionScope is the scope used by history cache for getting current execution
HistoryCacheGetCurrentExecutionScope
// EventsCacheGetEventScope is the scope used by events cache
EventsCacheGetEventScope
// EventsCachePutEventScope is the scope used by events cache
EventsCachePutEventScope
// EventsCacheGetFromStoreScope is the scope used by events cache
EventsCacheGetFromStoreScope
// ExecutionSizeStatsScope is the scope used for emiting workflow execution size related stats
ExecutionSizeStatsScope
// ExecutionCountStatsScope is the scope used for emiting workflow execution count related stats
ExecutionCountStatsScope
// SessionSizeStatsScope is the scope used for emiting session update size related stats
SessionSizeStatsScope
// SessionCountStatsScope is the scope used for emiting session update count related stats
SessionCountStatsScope
// HistoryResetWorkflowExecutionScope tracks ResetWorkflowExecution API calls received by service
HistoryResetWorkflowExecutionScope
// HistoryQueryWorkflowScope tracks QueryWorkflow API calls received by service
HistoryQueryWorkflowScope
// HistoryProcessDeleteHistoryEventScope tracks ProcessDeleteHistoryEvent processing calls
HistoryProcessDeleteHistoryEventScope
// WorkflowCompletionStatsScope tracks workflow completion updates
WorkflowCompletionStatsScope
// ArchiverClientScope is scope used by all metrics emitted by archiver.Client
ArchiverClientScope
// ReplicationTaskFetcherScope is scope used by all metrics emitted by ReplicationTaskFetcher
ReplicationTaskFetcherScope
// ReplicationTaskCleanupScope is scope used by all metrics emitted by ReplicationTaskProcessor cleanup
ReplicationTaskCleanupScope
// ReplicationDLQStatsScope is scope used by all metrics emitted related to replication DLQ
ReplicationDLQStatsScope
// FailoverMarkerScope is scope used by all metrics emitted related to failover marker
FailoverMarkerScope
// HistoryReplicationV2TaskScope is the scope used by history task replication processing
HistoryReplicationV2TaskScope
// SyncActivityTaskScope is the scope used by sync activity information processing
SyncActivityTaskScope
// LargeExecutionSizeShardScope is the scope to track large history size for hotshard detection
LargeExecutionSizeShardScope
// LargeExecutionCountShardScope is the scope to track large history count for hotshard detection
LargeExecutionCountShardScope
// LargeExecutionBlobShardScope is the scope to track large blobs for hotshard detection
LargeExecutionBlobShardScope
NumHistoryScopes
)
// -- Operation scopes for Matching service --
const (
// PollForDecisionTaskScope tracks PollForDecisionTask API calls received by service
MatchingPollForDecisionTaskScope = iota + NumCommonScopes
// PollForActivityTaskScope tracks PollForActivityTask API calls received by service
MatchingPollForActivityTaskScope
// MatchingAddActivityTaskScope tracks AddActivityTask API calls received by service
MatchingAddActivityTaskScope
// MatchingAddDecisionTaskScope tracks AddDecisionTask API calls received by service
MatchingAddDecisionTaskScope
// MatchingAddTaskScope tracks both AddActivityTask and AddDevisionTask API calls received by service
MatchingAddTaskScope
// MatchingTaskListMgrScope is the metrics scope for matching.TaskListManager component
MatchingTaskListMgrScope
// MatchingQueryWorkflowScope tracks AddDecisionTask API calls received by service
MatchingQueryWorkflowScope
// MatchingRespondQueryTaskCompletedScope tracks AddDecisionTask API calls received by service
MatchingRespondQueryTaskCompletedScope
// MatchingCancelOutstandingPollScope tracks CancelOutstandingPoll API calls received by service
MatchingCancelOutstandingPollScope
// MatchingDescribeTaskListScope tracks DescribeTaskList API calls received by service
MatchingDescribeTaskListScope
// MatchingListTaskListPartitionsScope tracks ListTaskListPartitions API calls received by service
MatchingListTaskListPartitionsScope
// MatchingGetTaskListsByDomainScope tracks GetTaskListsByDomain API calls received by service
MatchingGetTaskListsByDomainScope
NumMatchingScopes
)
// -- Operation scopes for Worker service --
const (
// ReplicationScope is the scope used by all metric emitted by replicator
ReplicatorScope = iota + NumCommonScopes
// DomainReplicationTaskScope is the scope used by domain task replication processing
DomainReplicationTaskScope
// ESProcessorScope is scope used by all metric emitted by esProcessor
ESProcessorScope
// IndexProcessorScope is scope used by all metric emitted by index processor
IndexProcessorScope
// ArchiverDeleteHistoryActivityScope is scope used by all metrics emitted by archiver.DeleteHistoryActivity
ArchiverDeleteHistoryActivityScope
// ArchiverUploadHistoryActivityScope is scope used by all metrics emitted by archiver.UploadHistoryActivity
ArchiverUploadHistoryActivityScope
// ArchiverArchiveVisibilityActivityScope is scope used by all metrics emitted by archiver.ArchiveVisibilityActivity
ArchiverArchiveVisibilityActivityScope
// ArchiverScope is scope used by all metrics emitted by archiver.Archiver
ArchiverScope
// ArchiverPumpScope is scope used by all metrics emitted by archiver.Pump
ArchiverPumpScope
// ArchiverArchivalWorkflowScope is scope used by all metrics emitted by archiver.ArchivalWorkflow
ArchiverArchivalWorkflowScope
// TaskListScavengerScope is scope used by all metrics emitted by worker.tasklist.Scavenger module
TaskListScavengerScope
// ExecutionsScannerScope is scope used by all metrics emitted by worker.executions.Scanner module
ExecutionsScannerScope
// ExecutionsFixerScope is the scope used by all metrics emitted by worker.executions.Fixer module
ExecutionsFixerScope
// BatcherScope is scope used by all metrics emitted by worker.Batcher module
BatcherScope
// HistoryScavengerScope is scope used by all metrics emitted by worker.history.Scavenger module
HistoryScavengerScope
// ParentClosePolicyProcessorScope is scope used by all metrics emitted by worker.ParentClosePolicyProcessor
ParentClosePolicyProcessorScope
// ShardScannerScope is scope used by all metrics emitted by worker.shardscanner module
ShardScannerScope
// CheckDataCorruptionWorkflowScope is scope used by the data corruption workflow
CheckDataCorruptionWorkflowScope
// ESAnalyzerScope is scope used by ElasticSearch Analyzer (esanalyzer) workflow
ESAnalyzerScope
// AsyncWorkflowConsumerScope is scope used by async workflow consumer
AsyncWorkflowConsumerScope
NumWorkerScopes
)
// ScopeDefs record the scopes for all services
var ScopeDefs = map[ServiceIdx]map[int]scopeDefinition{
// common scope Names
Common: {
PersistenceCreateShardScope: {operation: "CreateShard"},
PersistenceGetShardScope: {operation: "GetShard"},
PersistenceUpdateShardScope: {operation: "UpdateShard"},
PersistenceCreateWorkflowExecutionScope: {operation: "CreateWorkflowExecution"},
PersistenceGetWorkflowExecutionScope: {operation: "GetWorkflowExecution"},
PersistenceUpdateWorkflowExecutionScope: {operation: "UpdateWorkflowExecution"},
PersistenceConflictResolveWorkflowExecutionScope: {operation: "ConflictResolveWorkflowExecution"},
PersistenceResetWorkflowExecutionScope: {operation: "ResetWorkflowExecution"},
PersistenceDeleteWorkflowExecutionScope: {operation: "DeleteWorkflowExecution"},
PersistenceDeleteCurrentWorkflowExecutionScope: {operation: "DeleteCurrentWorkflowExecution"},
PersistenceGetCurrentExecutionScope: {operation: "GetCurrentExecution"},
PersistenceIsWorkflowExecutionExistsScope: {operation: "IsWorkflowExecutionExists"},
PersistenceListCurrentExecutionsScope: {operation: "ListCurrentExecutions"},
PersistenceListConcreteExecutionsScope: {operation: "ListConcreteExecutions"},
PersistenceGetTransferTasksScope: {operation: "GetTransferTasks"},
PersistenceCompleteTransferTaskScope: {operation: "CompleteTransferTask"},
PersistenceRangeCompleteTransferTaskScope: {operation: "RangeCompleteTransferTask"},
PersistenceGetCrossClusterTasksScope: {operation: "GetCrossClusterTasks"},
PersistenceCompleteCrossClusterTaskScope: {operation: "GetCrossClusterTasks"},
PersistenceRangeCompleteCrossClusterTaskScope: {operation: "GetCrossClusterTasks"},
PersistenceGetReplicationTasksScope: {operation: "GetReplicationTasks"},
PersistenceCompleteReplicationTaskScope: {operation: "CompleteReplicationTask"},
PersistenceRangeCompleteReplicationTaskScope: {operation: "RangeCompleteReplicationTask"},
PersistencePutReplicationTaskToDLQScope: {operation: "PutReplicationTaskToDLQ"},
PersistenceGetReplicationTasksFromDLQScope: {operation: "GetReplicationTasksFromDLQ"},
PersistenceGetReplicationDLQSizeScope: {operation: "GetReplicationDLQSize"},
PersistenceDeleteReplicationTaskFromDLQScope: {operation: "DeleteReplicationTaskFromDLQ"},
PersistenceRangeDeleteReplicationTaskFromDLQScope: {operation: "RangeDeleteReplicationTaskFromDLQ"},
PersistenceCreateFailoverMarkerTasksScope: {operation: "CreateFailoverMarkerTasks"},
PersistenceGetTimerIndexTasksScope: {operation: "GetTimerIndexTasks"},
PersistenceCompleteTimerTaskScope: {operation: "CompleteTimerTask"},
PersistenceRangeCompleteTimerTaskScope: {operation: "RangeCompleteTimerTask"},
PersistenceCreateTasksScope: {operation: "CreateTask"},
PersistenceGetTasksScope: {operation: "GetTasks"},
PersistenceCompleteTaskScope: {operation: "CompleteTask"},
PersistenceCompleteTasksLessThanScope: {operation: "CompleteTasksLessThan"},
PersistenceGetOrphanTasksScope: {operation: "GetOrphanTasks"},
PersistenceLeaseTaskListScope: {operation: "LeaseTaskList"},
PersistenceUpdateTaskListScope: {operation: "UpdateTaskList"},
PersistenceListTaskListScope: {operation: "ListTaskList"},
PersistenceDeleteTaskListScope: {operation: "DeleteTaskList"},
PersistenceGetTaskListSizeScope: {operation: "GetTaskListSize"},
PersistenceAppendHistoryEventsScope: {operation: "AppendHistoryEvents"},
PersistenceGetWorkflowExecutionHistoryScope: {operation: "GetWorkflowExecutionHistory"},
PersistenceDeleteWorkflowExecutionHistoryScope: {operation: "DeleteWorkflowExecutionHistory"},
PersistenceCreateDomainScope: {operation: "CreateDomain"},
PersistenceGetDomainScope: {operation: "GetDomain"},
PersistenceUpdateDomainScope: {operation: "UpdateDomain"},
PersistenceDeleteDomainScope: {operation: "DeleteDomain"},
PersistenceDeleteDomainByNameScope: {operation: "DeleteDomainByName"},
PersistenceListDomainsScope: {operation: "ListDomain"},
PersistenceGetMetadataScope: {operation: "GetMetadata"},
PersistenceRecordWorkflowExecutionStartedScope: {operation: "RecordWorkflowExecutionStarted"},
PersistenceRecordWorkflowExecutionClosedScope: {operation: "RecordWorkflowExecutionClosed"},
PersistenceRecordWorkflowExecutionUninitializedScope: {operation: "RecordWorkflowExecutionUninitialized"},
PersistenceUpsertWorkflowExecutionScope: {operation: "UpsertWorkflowExecution"},
PersistenceListOpenWorkflowExecutionsScope: {operation: "ListOpenWorkflowExecutions"},
PersistenceListClosedWorkflowExecutionsScope: {operation: "ListClosedWorkflowExecutions"},
PersistenceListOpenWorkflowExecutionsByTypeScope: {operation: "ListOpenWorkflowExecutionsByType"},
PersistenceListClosedWorkflowExecutionsByTypeScope: {operation: "ListClosedWorkflowExecutionsByType"},
PersistenceListOpenWorkflowExecutionsByWorkflowIDScope: {operation: "ListOpenWorkflowExecutionsByWorkflowID"},
PersistenceListClosedWorkflowExecutionsByWorkflowIDScope: {operation: "ListClosedWorkflowExecutionsByWorkflowID"},
PersistenceListClosedWorkflowExecutionsByStatusScope: {operation: "ListClosedWorkflowExecutionsByStatus"},
PersistenceGetClosedWorkflowExecutionScope: {operation: "GetClosedWorkflowExecution"},
PersistenceVisibilityDeleteWorkflowExecutionScope: {operation: "VisibilityDeleteWorkflowExecution"},
PersistenceDeleteUninitializedWorkflowExecutionScope: {operation: "VisibilityDeleteUninitializedWorkflowExecution"},
PersistenceListWorkflowExecutionsScope: {operation: "ListWorkflowExecutions"},
PersistenceScanWorkflowExecutionsScope: {operation: "ScanWorkflowExecutions"},
PersistenceCountWorkflowExecutionsScope: {operation: "CountWorkflowExecutions"},
PersistenceAppendHistoryNodesScope: {operation: "AppendHistoryNodes"},
PersistenceReadHistoryBranchScope: {operation: "ReadHistoryBranch"},
PersistenceReadHistoryBranchByBatchScope: {operation: "ReadHistoryBranch"},
PersistenceReadRawHistoryBranchScope: {operation: "ReadHistoryBranch"},
PersistenceForkHistoryBranchScope: {operation: "ForkHistoryBranch"},
PersistenceDeleteHistoryBranchScope: {operation: "DeleteHistoryBranch"},
PersistenceCompleteForkBranchScope: {operation: "CompleteForkBranch"},
PersistenceGetHistoryTreeScope: {operation: "GetHistoryTree"},
PersistenceGetAllHistoryTreeBranchesScope: {operation: "GetAllHistoryTreeBranches"},
PersistenceEnqueueMessageScope: {operation: "EnqueueMessage"},
PersistenceEnqueueMessageToDLQScope: {operation: "EnqueueMessageToDLQ"},
PersistenceReadMessagesScope: {operation: "ReadQueueMessages"},
PersistenceReadMessagesFromDLQScope: {operation: "ReadQueueMessagesFromDLQ"},
PersistenceDeleteMessagesBeforeScope: {operation: "DeleteQueueMessages"},
PersistenceDeleteMessageFromDLQScope: {operation: "DeleteQueueMessageFromDLQ"},
PersistenceRangeDeleteMessagesFromDLQScope: {operation: "RangeDeleteMessagesFromDLQ"},
PersistenceUpdateAckLevelScope: {operation: "UpdateAckLevel"},
PersistenceGetAckLevelsScope: {operation: "GetAckLevel"},
PersistenceUpdateDLQAckLevelScope: {operation: "UpdateDLQAckLevel"},
PersistenceGetDLQAckLevelsScope: {operation: "GetDLQAckLevel"},
PersistenceGetDLQSizeScope: {operation: "GetDLQSize"},
PersistenceFetchDynamicConfigScope: {operation: "FetchDynamicConfig"},
PersistenceUpdateDynamicConfigScope: {operation: "UpdateDynamicConfig"},
PersistenceShardRequestCountScope: {operation: "ShardIdPersistenceRequest"},
ResolverHostNotFoundScope: {operation: "ResolverHostNotFound"},
ClusterMetadataArchivalConfigScope: {operation: "ArchivalConfig"},
HistoryClientStartWorkflowExecutionScope: {operation: "HistoryClientStartWorkflowExecution", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientDescribeHistoryHostScope: {operation: "HistoryClientDescribeHistoryHost", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientRemoveTaskScope: {operation: "HistoryClientRemoveTask", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientCloseShardScope: {operation: "HistoryClientCloseShard", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientResetQueueScope: {operation: "HistoryClientResetQueue", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientDescribeQueueScope: {operation: "HistoryClientDescribeQueue", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientRecordActivityTaskHeartbeatScope: {operation: "HistoryClientRecordActivityTaskHeartbeat", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientRespondDecisionTaskCompletedScope: {operation: "HistoryClientRespondDecisionTaskCompleted", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientRespondDecisionTaskFailedScope: {operation: "HistoryClientRespondDecisionTaskFailed", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientRespondActivityTaskCompletedScope: {operation: "HistoryClientRespondActivityTaskCompleted", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientRespondActivityTaskFailedScope: {operation: "HistoryClientRespondActivityTaskFailed", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientRespondActivityTaskCanceledScope: {operation: "HistoryClientRespondActivityTaskCanceled", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientDescribeMutableStateScope: {operation: "HistoryClientDescribeMutableState", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientGetMutableStateScope: {operation: "HistoryClientGetMutableState", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientPollMutableStateScope: {operation: "HistoryClientPollMutableState", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientResetStickyTaskListScope: {operation: "HistoryClientResetStickyTaskList", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientDescribeWorkflowExecutionScope: {operation: "HistoryClientDescribeWorkflowExecution", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientRecordDecisionTaskStartedScope: {operation: "HistoryClientRecordDecisionTaskStarted", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientRecordActivityTaskStartedScope: {operation: "HistoryClientRecordActivityTaskStarted", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientRequestCancelWorkflowExecutionScope: {operation: "HistoryClientRequestCancelWorkflowExecution", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientSignalWorkflowExecutionScope: {operation: "HistoryClientSignalWorkflowExecution", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientSignalWithStartWorkflowExecutionScope: {operation: "HistoryClientSignalWithStartWorkflowExecution", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientRemoveSignalMutableStateScope: {operation: "HistoryClientRemoveSignalMutableState", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientTerminateWorkflowExecutionScope: {operation: "HistoryClientTerminateWorkflowExecution", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientResetWorkflowExecutionScope: {operation: "HistoryClientResetWorkflowExecution", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientScheduleDecisionTaskScope: {operation: "HistoryClientScheduleDecisionTask", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientRecordChildExecutionCompletedScope: {operation: "HistoryClientRecordChildExecutionCompleted", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientReplicateEventsV2Scope: {operation: "HistoryClientReplicateEventsV2", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientSyncShardStatusScope: {operation: "HistoryClientSyncShardStatus", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientSyncActivityScope: {operation: "HistoryClientSyncActivity", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientGetReplicationTasksScope: {operation: "HistoryClientGetReplicationTasks", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientGetDLQReplicationTasksScope: {operation: "HistoryClientGetDLQReplicationTasks", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientQueryWorkflowScope: {operation: "HistoryClientQueryWorkflow", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientReapplyEventsScope: {operation: "HistoryClientReapplyEvents", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientCountDLQMessagesScope: {operation: "HistoryClientCountDLQMessages", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientReadDLQMessagesScope: {operation: "HistoryClientReadDLQMessages", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientPurgeDLQMessagesScope: {operation: "HistoryClientPurgeDLQMessages", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientMergeDLQMessagesScope: {operation: "HistoryClientMergeDLQMessages", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientRefreshWorkflowTasksScope: {operation: "HistoryClientRefreshWorkflowTasks", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientNotifyFailoverMarkersScope: {operation: "HistoryClientNotifyFailoverMarkers", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientGetCrossClusterTasksScope: {operation: "HistoryClientGetCrossClusterTasks", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientRespondCrossClusterTasksCompletedScope: {operation: "HistoryClientRespondCrossClusterTasksCompleted", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientGetFailoverInfoScope: {operation: "HistoryClientGetFailoverInfo", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientGetDLQReplicationMessagesScope: {operation: "HistoryClientGetDLQReplicationMessages", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientGetReplicationMessagesScope: {operation: "HistoryClientGetReplicationMessages", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
HistoryClientWfIDCacheScope: {operation: "HistoryClientWfIDCache", tags: map[string]string{CadenceRoleTagName: HistoryClientRoleTagValue}},
MatchingClientPollForDecisionTaskScope: {operation: "MatchingClientPollForDecisionTask", tags: map[string]string{CadenceRoleTagName: MatchingClientRoleTagValue}},
MatchingClientPollForActivityTaskScope: {operation: "MatchingClientPollForActivityTask", tags: map[string]string{CadenceRoleTagName: MatchingClientRoleTagValue}},
MatchingClientAddActivityTaskScope: {operation: "MatchingClientAddActivityTask", tags: map[string]string{CadenceRoleTagName: MatchingClientRoleTagValue}},
MatchingClientAddDecisionTaskScope: {operation: "MatchingClientAddDecisionTask", tags: map[string]string{CadenceRoleTagName: MatchingClientRoleTagValue}},
MatchingClientQueryWorkflowScope: {operation: "MatchingClientQueryWorkflow", tags: map[string]string{CadenceRoleTagName: MatchingClientRoleTagValue}},
MatchingClientRespondQueryTaskCompletedScope: {operation: "MatchingClientRespondQueryTaskCompleted", tags: map[string]string{CadenceRoleTagName: MatchingClientRoleTagValue}},
MatchingClientCancelOutstandingPollScope: {operation: "MatchingClientCancelOutstandingPoll", tags: map[string]string{CadenceRoleTagName: MatchingClientRoleTagValue}},
MatchingClientDescribeTaskListScope: {operation: "MatchingClientDescribeTaskList", tags: map[string]string{CadenceRoleTagName: MatchingClientRoleTagValue}},
MatchingClientListTaskListPartitionsScope: {operation: "MatchingClientListTaskListPartitions", tags: map[string]string{CadenceRoleTagName: MatchingClientRoleTagValue}},
MatchingClientGetTaskListsByDomainScope: {operation: "MatchingClientGetTaskListsByDomain", tags: map[string]string{CadenceRoleTagName: MatchingClientRoleTagValue}},
FrontendClientDeprecateDomainScope: {operation: "FrontendClientDeprecateDomain", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientDescribeDomainScope: {operation: "FrontendClientDescribeDomain", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientDescribeTaskListScope: {operation: "FrontendClientDescribeTaskList", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientDescribeWorkflowExecutionScope: {operation: "FrontendClientDescribeWorkflowExecution", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientGetWorkflowExecutionHistoryScope: {operation: "FrontendClientGetWorkflowExecutionHistory", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientGetWorkflowExecutionRawHistoryScope: {operation: "FrontendClientGetWorkflowExecutionRawHistory", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientPollForWorkflowExecutionRawHistoryScope: {operation: "FrontendClientPollForWorkflowExecutionRawHistory", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientListArchivedWorkflowExecutionsScope: {operation: "FrontendClientListArchivedWorkflowExecutions", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientListClosedWorkflowExecutionsScope: {operation: "FrontendClientListClosedWorkflowExecutions", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientListDomainsScope: {operation: "FrontendClientListDomains", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientListOpenWorkflowExecutionsScope: {operation: "FrontendClientListOpenWorkflowExecutions", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientPollForActivityTaskScope: {operation: "FrontendClientPollForActivityTask", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientPollForDecisionTaskScope: {operation: "FrontendClientPollForDecisionTask", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientQueryWorkflowScope: {operation: "FrontendClientQueryWorkflow", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRecordActivityTaskHeartbeatScope: {operation: "FrontendClientRecordActivityTaskHeartbeat", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRecordActivityTaskHeartbeatByIDScope: {operation: "FrontendClientRecordActivityTaskHeartbeatByID", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRegisterDomainScope: {operation: "FrontendClientRegisterDomain", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRequestCancelWorkflowExecutionScope: {operation: "FrontendClientRequestCancelWorkflowExecution", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientResetStickyTaskListScope: {operation: "FrontendClientResetStickyTaskList", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRefreshWorkflowTasksScope: {operation: "FrontendClientRefreshWorkflowTasks", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientResetWorkflowExecutionScope: {operation: "FrontendClientResetWorkflowExecution", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRespondActivityTaskCanceledScope: {operation: "FrontendClientRespondActivityTaskCanceled", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRespondActivityTaskCanceledByIDScope: {operation: "FrontendClientRespondActivityTaskCanceledByID", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRespondActivityTaskCompletedScope: {operation: "FrontendClientRespondActivityTaskCompleted", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRespondActivityTaskCompletedByIDScope: {operation: "FrontendClientRespondActivityTaskCompletedByID", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRespondActivityTaskFailedScope: {operation: "FrontendClientRespondActivityTaskFailed", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRespondActivityTaskFailedByIDScope: {operation: "FrontendClientRespondActivityTaskFailedByID", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRespondDecisionTaskCompletedScope: {operation: "FrontendClientRespondDecisionTaskCompleted", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRespondDecisionTaskFailedScope: {operation: "FrontendClientRespondDecisionTaskFailed", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRespondQueryTaskCompletedScope: {operation: "FrontendClientRespondQueryTaskCompleted", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientSignalWithStartWorkflowExecutionScope: {operation: "FrontendClientSignalWithStartWorkflowExecution", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientSignalWithStartWorkflowExecutionAsyncScope: {operation: "FrontendClientSignalWithStartWorkflowExecutionAsync", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientSignalWorkflowExecutionScope: {operation: "FrontendClientSignalWorkflowExecution", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientStartWorkflowExecutionScope: {operation: "FrontendClientStartWorkflowExecution", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientStartWorkflowExecutionAsyncScope: {operation: "FrontendClientStartWorkflowExecutionAsync", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientTerminateWorkflowExecutionScope: {operation: "FrontendClientTerminateWorkflowExecution", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientUpdateDomainScope: {operation: "FrontendClientUpdateDomain", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientListWorkflowExecutionsScope: {operation: "FrontendClientListWorkflowExecutions", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientScanWorkflowExecutionsScope: {operation: "FrontendClientScanWorkflowExecutions", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientCountWorkflowExecutionsScope: {operation: "FrontendClientCountWorkflowExecutions", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientGetSearchAttributesScope: {operation: "FrontendClientGetSearchAttributes", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientGetReplicationTasksScope: {operation: "FrontendClientGetReplicationTasks", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientGetDomainReplicationTasksScope: {operation: "FrontendClientGetDomainReplicationTasks", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientGetDLQReplicationTasksScope: {operation: "FrontendClientGetDLQReplicationTasks", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientReapplyEventsScope: {operation: "FrontendClientReapplyEvents", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientGetClusterInfoScope: {operation: "FrontendClientGetClusterInfo", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientListTaskListPartitionsScope: {operation: "FrontendClientListTaskListPartitions", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientGetTaskListsByDomainScope: {operation: "FrontendClientGetTaskListsByDomain", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
FrontendClientRestartWorkflowExecutionScope: {operation: "FrontendClientRestartWorkflowExecution", tags: map[string]string{CadenceRoleTagName: FrontendClientRoleTagValue}},
AdminClientGetReplicationTasksScope: {operation: "AdminClientGetReplicationTasks", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientAddSearchAttributeScope: {operation: "AdminClientAddSearchAttribute", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientDescribeHistoryHostScope: {operation: "AdminClientDescribeHistoryHost", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientDescribeShardDistributionScope: {operation: "AdminClientDescribeShardDistribution", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientDescribeWorkflowExecutionScope: {operation: "AdminClientDescribeWorkflowExecution", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientGetWorkflowExecutionRawHistoryV2Scope: {operation: "AdminClientGetWorkflowExecutionRawHistoryV2", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientDescribeClusterScope: {operation: "AdminClientDescribeCluster", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientRefreshWorkflowTasksScope: {operation: "AdminClientRefreshWorkflowTasks", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientResendReplicationTasksScope: {operation: "AdminClientResendReplicationTasks", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientCloseShardScope: {operation: "AdminClientCloseShard", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientRemoveTaskScope: {operation: "AdminClientRemoveTask", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientResetQueueScope: {operation: "AdminClientResetQueue", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientDescribeQueueScope: {operation: "AdminClientDescribeQueue", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientCountDLQMessagesScope: {operation: "AdminClientCountDLQMessages", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientReadDLQMessagesScope: {operation: "AdminClientReadDLQMessages", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientPurgeDLQMessagesScope: {operation: "AdminClientPurgeDLQMessages", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientMergeDLQMessagesScope: {operation: "AdminClientMergeDLQMessages", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientGetCrossClusterTasksScope: {operation: "AdminClientGetCrossClusterTasks", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientRespondCrossClusterTasksCompletedScope: {operation: "AdminClientRespondCrossClusterTasksCompleted", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientGetDynamicConfigScope: {operation: "AdminClientGetDynamicConfig", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientUpdateDynamicConfigScope: {operation: "AdminClientUpdateDynamicConfig", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientRestoreDynamicConfigScope: {operation: "AdminClientRestoreDynamicConfig", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientListDynamicConfigScope: {operation: "AdminClientListDynamicConfigScope", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientGetGlobalIsolationGroupsScope: {operation: "AdminClientGetGlobalIsolationGroups", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientUpdateGlobalIsolationGroupsScope: {operation: "AdminClientUpdateGlobalIsolationGroups", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientGetDomainIsolationGroupsScope: {operation: "AdminClientGetDomainIsolationGroups", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientUpdateDomainIsolationGroupsScope: {operation: "AdminClientUpdateDomainIsolationGroups", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientDeleteWorkflowScope: {operation: "AdminClientDeleteWorkflow", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientMaintainCorruptWorkflowScope: {operation: "AdminClientMaintainCorruptWorkflow", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientReapplyEventsScope: {operation: "AdminClientReapplyEvents", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientGetDLQReplicationMessagesScope: {operation: "AdminClientGetDLQReplicationMessages", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientGetDomainReplicationMessagesScope: {operation: "AdminClientGetDomainReplicationMessages", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientGetReplicationMessagesScope: {operation: "AdminClientGetReplicationMessages", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientGetDomainAsyncWorkflowConfiguratonScope: {operation: "AdminClientGetDomainAsyncWorkflowConfiguraton", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
AdminClientUpdateDomainAsyncWorkflowConfiguratonScope: {operation: "AdminClientUpdateDomainAsyncWorkflowConfiguraton", tags: map[string]string{CadenceRoleTagName: AdminClientRoleTagValue}},
DCRedirectionDeprecateDomainScope: {operation: "DCRedirectionDeprecateDomain", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionDescribeDomainScope: {operation: "DCRedirectionDescribeDomain", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionDescribeTaskListScope: {operation: "DCRedirectionDescribeTaskList", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionDescribeWorkflowExecutionScope: {operation: "DCRedirectionDescribeWorkflowExecution", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionGetWorkflowExecutionHistoryScope: {operation: "DCRedirectionGetWorkflowExecutionHistory", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionGetWorkflowExecutionRawHistoryScope: {operation: "DCRedirectionGetWorkflowExecutionRawHistoryScope", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionPollForWorklfowExecutionRawHistoryScope: {operation: "DCRedirectionPollForWorklfowExecutionRawHistory", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionListArchivedWorkflowExecutionsScope: {operation: "DCRedirectionListArchivedWorkflowExecutions", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionListClosedWorkflowExecutionsScope: {operation: "DCRedirectionListClosedWorkflowExecutions", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionListDomainsScope: {operation: "DCRedirectionListDomains", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionListOpenWorkflowExecutionsScope: {operation: "DCRedirectionListOpenWorkflowExecutions", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionListWorkflowExecutionsScope: {operation: "DCRedirectionListWorkflowExecutions", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionScanWorkflowExecutionsScope: {operation: "DCRedirectionScanWorkflowExecutions", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionCountWorkflowExecutionsScope: {operation: "DCRedirectionCountWorkflowExecutions", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionGetSearchAttributesScope: {operation: "DCRedirectionGetSearchAttributes", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionPollForActivityTaskScope: {operation: "DCRedirectionPollForActivityTask", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionPollForDecisionTaskScope: {operation: "DCRedirectionPollForDecisionTask", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionQueryWorkflowScope: {operation: "DCRedirectionQueryWorkflow", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRecordActivityTaskHeartbeatScope: {operation: "DCRedirectionRecordActivityTaskHeartbeat", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRecordActivityTaskHeartbeatByIDScope: {operation: "DCRedirectionRecordActivityTaskHeartbeatByID", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRegisterDomainScope: {operation: "DCRedirectionRegisterDomain", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRequestCancelWorkflowExecutionScope: {operation: "DCRedirectionRequestCancelWorkflowExecution", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionResetStickyTaskListScope: {operation: "DCRedirectionResetStickyTaskList", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionResetWorkflowExecutionScope: {operation: "DCRedirectionResetWorkflowExecution", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRespondActivityTaskCanceledScope: {operation: "DCRedirectionRespondActivityTaskCanceled", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRespondActivityTaskCanceledByIDScope: {operation: "DCRedirectionRespondActivityTaskCanceledByID", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRespondActivityTaskCompletedScope: {operation: "DCRedirectionRespondActivityTaskCompleted", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRespondActivityTaskCompletedByIDScope: {operation: "DCRedirectionRespondActivityTaskCompletedByID", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRespondActivityTaskFailedScope: {operation: "DCRedirectionRespondActivityTaskFailed", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRespondActivityTaskFailedByIDScope: {operation: "DCRedirectionRespondActivityTaskFailedByID", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRespondDecisionTaskCompletedScope: {operation: "DCRedirectionRespondDecisionTaskCompleted", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRespondDecisionTaskFailedScope: {operation: "DCRedirectionRespondDecisionTaskFailed", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRespondQueryTaskCompletedScope: {operation: "DCRedirectionRespondQueryTaskCompleted", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionSignalWithStartWorkflowExecutionScope: {operation: "DCRedirectionSignalWithStartWorkflowExecution", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionSignalWithStartWorkflowExecutionAsyncScope: {operation: "DCRedirectionSignalWithStartWorkflowExecutionAsync", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionSignalWorkflowExecutionScope: {operation: "DCRedirectionSignalWorkflowExecution", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionStartWorkflowExecutionScope: {operation: "DCRedirectionStartWorkflowExecution", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionStartWorkflowExecutionAsyncScope: {operation: "DCRedirectionStartWorkflowExecutionAsync", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionTerminateWorkflowExecutionScope: {operation: "DCRedirectionTerminateWorkflowExecution", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionUpdateDomainScope: {operation: "DCRedirectionUpdateDomain", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionListTaskListPartitionsScope: {operation: "DCRedirectionListTaskListPartitions", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionGetTaskListsByDomainScope: {operation: "DCRedirectionGetTaskListsByDomain", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRefreshWorkflowTasksScope: {operation: "DCRedirectionRefreshWorkflowTasks", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
DCRedirectionRestartWorkflowExecutionScope: {operation: "DCRedirectionRestartWorkflowExecution", tags: map[string]string{CadenceRoleTagName: DCRedirectionRoleTagValue}},
MessagingClientPublishScope: {operation: "MessagingClientPublish"},
MessagingClientPublishBatchScope: {operation: "MessagingClientPublishBatch"},
MessagingClientConsumerScope: {operation: "MessagingClientConsumerScope"},
DomainCacheScope: {operation: "DomainCache"},
HistoryRereplicationByTransferTaskScope: {operation: "HistoryRereplicationByTransferTask"},
HistoryRereplicationByTimerTaskScope: {operation: "HistoryRereplicationByTimerTask"},
HistoryRereplicationByHistoryReplicationScope: {operation: "HistoryRereplicationByHistoryReplication"},
HistoryRereplicationByHistoryMetadataReplicationScope: {operation: "HistoryRereplicationByHistoryMetadataReplication"},
HistoryRereplicationByActivityReplicationScope: {operation: "HistoryRereplicationByActivityReplication"},
ElasticsearchRecordWorkflowExecutionStartedScope: {operation: "RecordWorkflowExecutionStarted"},
ElasticsearchRecordWorkflowExecutionClosedScope: {operation: "RecordWorkflowExecutionClosed"},
ElasticsearchRecordWorkflowExecutionUninitializedScope: {operation: "RecordWorkflowExecutionUninitialized"},
ElasticsearchUpsertWorkflowExecutionScope: {operation: "UpsertWorkflowExecution"},
ElasticsearchListOpenWorkflowExecutionsScope: {operation: "ListOpenWorkflowExecutions"},
ElasticsearchListClosedWorkflowExecutionsScope: {operation: "ListClosedWorkflowExecutions"},
ElasticsearchListOpenWorkflowExecutionsByTypeScope: {operation: "ListOpenWorkflowExecutionsByType"},
ElasticsearchListClosedWorkflowExecutionsByTypeScope: {operation: "ListClosedWorkflowExecutionsByType"},
ElasticsearchListOpenWorkflowExecutionsByWorkflowIDScope: {operation: "ListOpenWorkflowExecutionsByWorkflowID"},
ElasticsearchListClosedWorkflowExecutionsByWorkflowIDScope: {operation: "ListClosedWorkflowExecutionsByWorkflowID"},
ElasticsearchListClosedWorkflowExecutionsByStatusScope: {operation: "ListClosedWorkflowExecutionsByStatus"},
ElasticsearchGetClosedWorkflowExecutionScope: {operation: "GetClosedWorkflowExecution"},
ElasticsearchListWorkflowExecutionsScope: {operation: "ListWorkflowExecutions"},
ElasticsearchScanWorkflowExecutionsScope: {operation: "ScanWorkflowExecutions"},
ElasticsearchCountWorkflowExecutionsScope: {operation: "CountWorkflowExecutions"},
ElasticsearchDeleteWorkflowExecutionsScope: {operation: "DeleteWorkflowExecution"},
ElasticsearchDeleteUninitializedWorkflowExecutionsScope: {operation: "DeleteUninitializedWorkflowExecution"},
PinotRecordWorkflowExecutionStartedScope: {operation: "RecordWorkflowExecutionStarted"},
PinotRecordWorkflowExecutionClosedScope: {operation: "RecordWorkflowExecutionClosed"},
PinotRecordWorkflowExecutionUninitializedScope: {operation: "RecordWorkflowExecutionUninitialized"},
PinotUpsertWorkflowExecutionScope: {operation: "UpsertWorkflowExecution"},
PinotListOpenWorkflowExecutionsScope: {operation: "ListOpenWorkflowExecutions"},
PinotListClosedWorkflowExecutionsScope: {operation: "ListClosedWorkflowExecutions"},
PinotListOpenWorkflowExecutionsByTypeScope: {operation: "ListOpenWorkflowExecutionsByType"},
PinotListClosedWorkflowExecutionsByTypeScope: {operation: "ListClosedWorkflowExecutionsByType"},
PinotListOpenWorkflowExecutionsByWorkflowIDScope: {operation: "ListOpenWorkflowExecutionsByWorkflowID"},
PinotListClosedWorkflowExecutionsByWorkflowIDScope: {operation: "ListClosedWorkflowExecutionsByWorkflowID"},
PinotListClosedWorkflowExecutionsByStatusScope: {operation: "ListClosedWorkflowExecutionsByStatus"},
PinotGetClosedWorkflowExecutionScope: {operation: "GetClosedWorkflowExecution"},
PinotListWorkflowExecutionsScope: {operation: "ListWorkflowExecutions"},
PinotScanWorkflowExecutionsScope: {operation: "ScanWorkflowExecutions"},
PinotCountWorkflowExecutionsScope: {operation: "CountWorkflowExecutions"},
PinotDeleteWorkflowExecutionsScope: {operation: "DeleteWorkflowExecution"},
PinotDeleteUninitializedWorkflowExecutionsScope: {operation: "DeleteUninitializedWorkflowExecution"},
SequentialTaskProcessingScope: {operation: "SequentialTaskProcessing"},
ParallelTaskProcessingScope: {operation: "ParallelTaskProcessing"},
TaskSchedulerScope: {operation: "TaskScheduler"},
HistoryArchiverScope: {operation: "HistoryArchiver"},
VisibilityArchiverScope: {operation: "VisibilityArchiver"},
BlobstoreClientUploadScope: {operation: "BlobstoreClientUpload", tags: map[string]string{CadenceRoleTagName: BlobstoreRoleTagValue}},
BlobstoreClientDownloadScope: {operation: "BlobstoreClientDownload", tags: map[string]string{CadenceRoleTagName: BlobstoreRoleTagValue}},
BlobstoreClientGetMetadataScope: {operation: "BlobstoreClientGetMetadata", tags: map[string]string{CadenceRoleTagName: BlobstoreRoleTagValue}},
BlobstoreClientExistsScope: {operation: "BlobstoreClientExists", tags: map[string]string{CadenceRoleTagName: BlobstoreRoleTagValue}},
BlobstoreClientDeleteScope: {operation: "BlobstoreClientDelete", tags: map[string]string{CadenceRoleTagName: BlobstoreRoleTagValue}},
BlobstoreClientDirectoryExistsScope: {operation: "BlobstoreClientDirectoryExists", tags: map[string]string{CadenceRoleTagName: BlobstoreRoleTagValue}},
GetAvailableIsolationGroupsScope: {operation: "GetAvailableIsolationGroups"},
DomainFailoverScope: {operation: "DomainFailover"},
TaskValidatorScope: {operation: "TaskValidation"},
DomainReplicationQueueScope: {operation: "DomainReplicationQueue"},
ClusterMetadataScope: {operation: "ClusterMetadata"},
HashringScope: {operation: "Hashring"},
},
// Frontend Scope Names
Frontend: {
// Admin API scope co-locates with with frontend
AdminRemoveTaskScope: {operation: "AdminRemoveTask"},
AdminCloseShardScope: {operation: "AdminCloseShard"},
AdminResetQueueScope: {operation: "AdminResetQueue"},
AdminDescribeQueueScope: {operation: "AdminDescribeQueue"},
AdminCountDLQMessagesScope: {operation: "AdminCountDLQMessages"},
AdminReadDLQMessagesScope: {operation: "AdminReadDLQMessages"},
AdminPurgeDLQMessagesScope: {operation: "AdminPurgeDLQMessages"},
AdminMergeDLQMessagesScope: {operation: "AdminMergeDLQMessages"},
AdminDescribeHistoryHostScope: {operation: "DescribeHistoryHost"},
AdminDescribeShardDistributionScope: {operation: "AdminShardList"},
AdminDescribeClusterScope: {operation: "DescribeCluster"},
AdminAddSearchAttributeScope: {operation: "AddSearchAttribute"},
AdminDescribeWorkflowExecutionScope: {operation: "DescribeWorkflowExecution"},
AdminGetWorkflowExecutionRawHistoryScope: {operation: "GetWorkflowExecutionRawHistory"},
AdminGetWorkflowExecutionRawHistoryV2Scope: {operation: "GetWorkflowExecutionRawHistoryV2"},
AdminGetReplicationMessagesScope: {operation: "GetReplicationMessages"},
AdminGetDomainReplicationMessagesScope: {operation: "GetDomainReplicationMessages"},
AdminGetDLQReplicationMessagesScope: {operation: "AdminGetDLQReplicationMessages"},
AdminReapplyEventsScope: {operation: "ReapplyEvents"},
AdminRefreshWorkflowTasksScope: {operation: "RefreshWorkflowTasks"},
AdminResendReplicationTasksScope: {operation: "ResendReplicationTasks"},
AdminGetCrossClusterTasksScope: {operation: "AdminGetCrossClusterTasks"},
AdminRespondCrossClusterTasksCompletedScope: {operation: "AdminRespondCrossClusterTasksCompleted"},
AdminGetDynamicConfigScope: {operation: "AdminGetDynamicConfig"},
AdminUpdateDynamicConfigScope: {operation: "AdminUpdateDynamicConfig"},
AdminRestoreDynamicConfigScope: {operation: "AdminRestoreDynamicConfig"},
AdminListDynamicConfigScope: {operation: "AdminListDynamicConfig"},
AdminDeleteWorkflowScope: {operation: "AdminDeleteWorkflow"},
GetGlobalIsolationGroups: {operation: "GetGlobalIsolationGroups"},
UpdateGlobalIsolationGroups: {operation: "UpdateGlobalIsolationGroups"},
GetDomainIsolationGroups: {operation: "GetDomainIsolationGroups"},
UpdateDomainIsolationGroups: {operation: "UpdateDomainIsolationGroups"},
GetDomainAsyncWorkflowConfiguraton: {operation: "GetDomainAsyncWorkflowConfiguraton"},
UpdateDomainAsyncWorkflowConfiguraton: {operation: "UpdateDomainAsyncWorkflowConfiguraton"},
FrontendRestartWorkflowExecutionScope: {operation: "RestartWorkflowExecution"},
FrontendStartWorkflowExecutionScope: {operation: "StartWorkflowExecution"},
FrontendStartWorkflowExecutionAsyncScope: {operation: "StartWorkflowExecutionAsync"},
FrontendPollForDecisionTaskScope: {operation: "PollForDecisionTask"},
FrontendPollForActivityTaskScope: {operation: "PollForActivityTask"},
FrontendRecordActivityTaskHeartbeatScope: {operation: "RecordActivityTaskHeartbeat"},
FrontendRecordActivityTaskHeartbeatByIDScope: {operation: "RecordActivityTaskHeartbeatByID"},
FrontendRespondDecisionTaskCompletedScope: {operation: "RespondDecisionTaskCompleted"},
FrontendRespondDecisionTaskFailedScope: {operation: "RespondDecisionTaskFailed"},
FrontendRespondQueryTaskCompletedScope: {operation: "RespondQueryTaskCompleted"},
FrontendRespondActivityTaskCompletedScope: {operation: "RespondActivityTaskCompleted"},
FrontendRespondActivityTaskFailedScope: {operation: "RespondActivityTaskFailed"},
FrontendRespondActivityTaskCanceledScope: {operation: "RespondActivityTaskCanceled"},
FrontendRespondActivityTaskCompletedByIDScope: {operation: "RespondActivityTaskCompletedByID"},
FrontendRespondActivityTaskFailedByIDScope: {operation: "RespondActivityTaskFailedByID"},
FrontendRespondActivityTaskCanceledByIDScope: {operation: "RespondActivityTaskCanceledByID"},
FrontendGetWorkflowExecutionHistoryScope: {operation: "GetWorkflowExecutionHistory"},
FrontendGetWorkflowExecutionRawHistoryScope: {operation: "GetWorkflowExecutionRawHistory"},
FrontendPollForWorklfowExecutionRawHistoryScope: {operation: "PollForWorklfowExecutionRawHistory"},
FrontendSignalWorkflowExecutionScope: {operation: "SignalWorkflowExecution"},
FrontendSignalWithStartWorkflowExecutionScope: {operation: "SignalWithStartWorkflowExecution"},
FrontendSignalWithStartWorkflowExecutionAsyncScope: {operation: "SignalWithStartWorkflowExecutionAsync"},
FrontendTerminateWorkflowExecutionScope: {operation: "TerminateWorkflowExecution"},
FrontendResetWorkflowExecutionScope: {operation: "ResetWorkflowExecution"},
FrontendRequestCancelWorkflowExecutionScope: {operation: "RequestCancelWorkflowExecution"},
FrontendListArchivedWorkflowExecutionsScope: {operation: "ListArchivedWorkflowExecutions"},
FrontendListOpenWorkflowExecutionsScope: {operation: "ListOpenWorkflowExecutions"},
FrontendListClosedWorkflowExecutionsScope: {operation: "ListClosedWorkflowExecutions"},
FrontendListWorkflowExecutionsScope: {operation: "ListWorkflowExecutions"},
FrontendScanWorkflowExecutionsScope: {operation: "ScanWorkflowExecutions"},
FrontendCountWorkflowExecutionsScope: {operation: "CountWorkflowExecutions"},
FrontendRegisterDomainScope: {operation: "RegisterDomain"},
FrontendDescribeDomainScope: {operation: "DescribeDomain"},
FrontendListDomainsScope: {operation: "ListDomain"},
FrontendUpdateDomainScope: {operation: "UpdateDomain"},
FrontendDeprecateDomainScope: {operation: "DeprecateDomain"},
FrontendQueryWorkflowScope: {operation: "QueryWorkflow"},
FrontendDescribeWorkflowExecutionScope: {operation: "DescribeWorkflowExecution"},
FrontendListTaskListPartitionsScope: {operation: "FrontendListTaskListPartitions"},
FrontendGetTaskListsByDomainScope: {operation: "FrontendGetTaskListsByDomain"},
FrontendRefreshWorkflowTasksScope: {operation: "FrontendRefreshWorkflowTasks"},
FrontendDescribeTaskListScope: {operation: "DescribeTaskList"},
FrontendResetStickyTaskListScope: {operation: "ResetStickyTaskList"},
FrontendGetSearchAttributesScope: {operation: "GetSearchAttributes"},
FrontendGetClusterInfoScope: {operation: "GetClusterInfo"},
},
// History Scope Names
History: {
HistoryStartWorkflowExecutionScope: {operation: "StartWorkflowExecution"},
HistoryRecordActivityTaskHeartbeatScope: {operation: "RecordActivityTaskHeartbeat"},
HistoryRespondDecisionTaskCompletedScope: {operation: "RespondDecisionTaskCompleted"},
HistoryRespondDecisionTaskFailedScope: {operation: "RespondDecisionTaskFailed"},
HistoryRespondActivityTaskCompletedScope: {operation: "RespondActivityTaskCompleted"},
HistoryRespondActivityTaskFailedScope: {operation: "RespondActivityTaskFailed"},
HistoryRespondActivityTaskCanceledScope: {operation: "RespondActivityTaskCanceled"},
HistoryResetQueueScope: {operation: "ResetQueue"},
HistoryDescribeQueueScope: {operation: "DescribeQueue"},
HistoryDescribeMutabelStateScope: {operation: "DescribeMutableState"},
HistoryGetMutableStateScope: {operation: "GetMutableState"},
HistoryPollMutableStateScope: {operation: "PollMutableState"},
HistoryResetStickyTaskListScope: {operation: "ResetStickyTaskListScope"},
HistoryDescribeWorkflowExecutionScope: {operation: "DescribeWorkflowExecution"},
HistoryRecordDecisionTaskStartedScope: {operation: "RecordDecisionTaskStarted"},
HistoryRecordActivityTaskStartedScope: {operation: "RecordActivityTaskStarted"},
HistorySignalWorkflowExecutionScope: {operation: "SignalWorkflowExecution"},
HistorySignalWithStartWorkflowExecutionScope: {operation: "SignalWithStartWorkflowExecution"},
HistoryRemoveSignalMutableStateScope: {operation: "RemoveSignalMutableState"},
HistoryTerminateWorkflowExecutionScope: {operation: "TerminateWorkflowExecution"},
HistoryResetWorkflowExecutionScope: {operation: "ResetWorkflowExecution"},
HistoryQueryWorkflowScope: {operation: "QueryWorkflow"},
HistoryProcessDeleteHistoryEventScope: {operation: "ProcessDeleteHistoryEvent"},
HistoryScheduleDecisionTaskScope: {operation: "ScheduleDecisionTask"},
HistoryRecordChildExecutionCompletedScope: {operation: "RecordChildExecutionCompleted"},
HistoryRequestCancelWorkflowExecutionScope: {operation: "RequestCancelWorkflowExecution"},
HistoryReplicateEventsScope: {operation: "ReplicateEvents"},
HistoryReplicateRawEventsScope: {operation: "ReplicateRawEvents"},
HistoryReplicateEventsV2Scope: {operation: "ReplicateEventsV2"},
HistorySyncShardStatusScope: {operation: "SyncShardStatus"},
HistorySyncActivityScope: {operation: "SyncActivity"},
HistoryDescribeMutableStateScope: {operation: "DescribeMutableState"},
HistoryGetReplicationMessagesScope: {operation: "GetReplicationMessages"},
HistoryGetDLQReplicationMessagesScope: {operation: "GetDLQReplicationMessages"},
HistoryCountDLQMessagesScope: {operation: "CountDLQMessages"},
HistoryReadDLQMessagesScope: {operation: "ReadDLQMessages"},
HistoryPurgeDLQMessagesScope: {operation: "PurgeDLQMessages"},
HistoryMergeDLQMessagesScope: {operation: "MergeDLQMessages"},
HistoryShardControllerScope: {operation: "ShardController"},
HistoryReapplyEventsScope: {operation: "EventReapplication"},
HistoryRefreshWorkflowTasksScope: {operation: "RefreshWorkflowTasks"},
HistoryNotifyFailoverMarkersScope: {operation: "NotifyFailoverMarkers"},
HistoryGetCrossClusterTasksScope: {operation: "GetCrossClusterTasks"},
HistoryRespondCrossClusterTasksCompletedScope: {operation: "RespondCrossClusterTasksCompleted"},
HistoryGetFailoverInfoScope: {operation: "GetFailoverInfo"},
TaskPriorityAssignerScope: {operation: "TaskPriorityAssigner"},
TransferQueueProcessorScope: {operation: "TransferQueueProcessor"},
TransferActiveQueueProcessorScope: {operation: "TransferActiveQueueProcessor"},
TransferStandbyQueueProcessorScope: {operation: "TransferStandbyQueueProcessor"},
TransferActiveTaskActivityScope: {operation: "TransferActiveTaskActivity"},
TransferActiveTaskDecisionScope: {operation: "TransferActiveTaskDecision"},
TransferActiveTaskCloseExecutionScope: {operation: "TransferActiveTaskCloseExecution"},
TransferActiveTaskCancelExecutionScope: {operation: "TransferActiveTaskCancelExecution"},
TransferActiveTaskSignalExecutionScope: {operation: "TransferActiveTaskSignalExecution"},
TransferActiveTaskStartChildExecutionScope: {operation: "TransferActiveTaskStartChildExecution"},
TransferActiveTaskRecordWorkflowStartedScope: {operation: "TransferActiveTaskRecordWorkflowStarted"},
TransferActiveTaskResetWorkflowScope: {operation: "TransferActiveTaskResetWorkflow"},
TransferActiveTaskUpsertWorkflowSearchAttributesScope: {operation: "TransferActiveTaskUpsertWorkflowSearchAttributes"},
TransferActiveTaskRecordWorkflowClosedScope: {operation: "TransferActiveTaskRecordWorkflowClosed"},
TransferActiveTaskRecordChildExecutionCompletedScope: {operation: "TransferActiveTaskRecordChildExecutionCompleted"},
TransferActiveTaskApplyParentClosePolicyScope: {operation: "TransferActiveTaskApplyParentClosePolicy"},
TransferStandbyTaskActivityScope: {operation: "TransferStandbyTaskActivity"},
TransferStandbyTaskDecisionScope: {operation: "TransferStandbyTaskDecision"},
TransferStandbyTaskCloseExecutionScope: {operation: "TransferStandbyTaskCloseExecution"},
TransferStandbyTaskCancelExecutionScope: {operation: "TransferStandbyTaskCancelExecution"},
TransferStandbyTaskSignalExecutionScope: {operation: "TransferStandbyTaskSignalExecution"},
TransferStandbyTaskStartChildExecutionScope: {operation: "TransferStandbyTaskStartChildExecution"},
TransferStandbyTaskRecordWorkflowStartedScope: {operation: "TransferStandbyTaskRecordWorkflowStarted"},
TransferStandbyTaskResetWorkflowScope: {operation: "TransferStandbyTaskResetWorkflow"},
TransferStandbyTaskUpsertWorkflowSearchAttributesScope: {operation: "TransferStandbyTaskUpsertWorkflowSearchAttributes"},
TransferStandbyTaskRecordWorkflowClosedScope: {operation: "TransferStandbyTaskRecordWorkflowClosed"},
TransferStandbyTaskRecordChildExecutionCompletedScope: {operation: "TransferStandbyTaskRecordChildExecutionCompleted"},
TransferStandbyTaskApplyParentClosePolicyScope: {operation: "TransferStandbyTaskApplyParentClosePolicy"},
TimerQueueProcessorScope: {operation: "TimerQueueProcessor"},
TimerActiveQueueProcessorScope: {operation: "TimerActiveQueueProcessor"},
TimerStandbyQueueProcessorScope: {operation: "TimerStandbyQueueProcessor"},
TimerActiveTaskActivityTimeoutScope: {operation: "TimerActiveTaskActivityTimeout"},
TimerActiveTaskDecisionTimeoutScope: {operation: "TimerActiveTaskDecisionTimeout"},
TimerActiveTaskUserTimerScope: {operation: "TimerActiveTaskUserTimer"},
TimerActiveTaskWorkflowTimeoutScope: {operation: "TimerActiveTaskWorkflowTimeout"},
TimerActiveTaskActivityRetryTimerScope: {operation: "TimerActiveTaskActivityRetryTimer"},
TimerActiveTaskWorkflowBackoffTimerScope: {operation: "TimerActiveTaskWorkflowBackoffTimer"},
TimerActiveTaskDeleteHistoryEventScope: {operation: "TimerActiveTaskDeleteHistoryEvent"},
TimerStandbyTaskActivityTimeoutScope: {operation: "TimerStandbyTaskActivityTimeout"},
TimerStandbyTaskDecisionTimeoutScope: {operation: "TimerStandbyTaskDecisionTimeout"},
TimerStandbyTaskUserTimerScope: {operation: "TimerStandbyTaskUserTimer"},
TimerStandbyTaskWorkflowTimeoutScope: {operation: "TimerStandbyTaskWorkflowTimeout"},
TimerStandbyTaskActivityRetryTimerScope: {operation: "TimerStandbyTaskActivityRetryTimer"},
TimerStandbyTaskWorkflowBackoffTimerScope: {operation: "TimerStandbyTaskWorkflowBackoffTimer"},
TimerStandbyTaskDeleteHistoryEventScope: {operation: "TimerStandbyTaskDeleteHistoryEvent"},
CrossClusterQueueProcessorScope: {operation: "CrossClusterQueueProcessor"},
CrossClusterTaskProcessorScope: {operation: "CrossClusterTaskProcessor"},
CrossClusterTaskFetcherScope: {operation: "CrossClusterTaskFetcher"},
CrossClusterSourceTaskStartChildExecutionScope: {operation: "CrossClusterSourceTaskStartChildExecution"},
CrossClusterSourceTaskCancelExecutionScope: {operation: "CrossClusterSourceTaskCancelExecution"},
CrossClusterSourceTaskSignalExecutionScope: {operation: "CrossClusterSourceTaskSignalExecution"},
CrossClusterSourceTaskRecordChildWorkflowExecutionCompleteScope: {operation: "CrossClusterSourceTaskTypeRecordChildWorkflowExecutionComplete"},
CrossClusterSourceTaskApplyParentClosePolicyScope: {operation: "CrossClusterSourceTaskTypeApplyParentClosePolicy"},
CrossClusterTargetTaskStartChildExecutionScope: {operation: "CrossClusterTargetTaskStartChildExecution"},
CrossClusterTargetTaskCancelExecutionScope: {operation: "CrossClusterTargetTaskCancelExecution"},
CrossClusterTargetTaskSignalExecutionScope: {operation: "CrossClusterTargetTaskSignalExecution"},
CrossClusterTargetTaskRecordChildWorkflowExecutionCompleteScope: {operation: "CrossClusterTargetTaskTypeRecordChildWorkflowExecutionComplete"},
CrossClusterTargetTaskApplyParentClosePolicyScope: {operation: "CrossClusterTargetTaskTypeApplyParentClosePolicy"},
HistoryEventNotificationScope: {operation: "HistoryEventNotification"},
ReplicatorQueueProcessorScope: {operation: "ReplicatorQueueProcessor"},
ReplicatorCacheManagerScope: {operation: "ReplicatorCacheManager"},
ReplicatorTaskHistoryScope: {operation: "ReplicatorTaskHistory"},
ReplicatorTaskSyncActivityScope: {operation: "ReplicatorTaskSyncActivity"},
ReplicateHistoryEventsScope: {operation: "ReplicateHistoryEvents"},
ReplicationMetricEmitterScope: {operation: "ReplicationMetricEmitter"},
ShardInfoScope: {operation: "ShardInfo"},
WorkflowContextScope: {operation: "WorkflowContext"},
HistoryCacheGetAndCreateScope: {operation: "HistoryCacheGetAndCreate", tags: map[string]string{CacheTypeTagName: MutableStateCacheTypeTagValue}},
HistoryCacheGetOrCreateScope: {operation: "HistoryCacheGetOrCreate", tags: map[string]string{CacheTypeTagName: MutableStateCacheTypeTagValue}},
HistoryCacheGetOrCreateCurrentScope: {operation: "HistoryCacheGetOrCreateCurrent", tags: map[string]string{CacheTypeTagName: MutableStateCacheTypeTagValue}},
HistoryCacheGetCurrentExecutionScope: {operation: "HistoryCacheGetCurrentExecution", tags: map[string]string{CacheTypeTagName: MutableStateCacheTypeTagValue}},
EventsCacheGetEventScope: {operation: "EventsCacheGetEvent", tags: map[string]string{CacheTypeTagName: EventsCacheTypeTagValue}},
EventsCachePutEventScope: {operation: "EventsCachePutEvent", tags: map[string]string{CacheTypeTagName: EventsCacheTypeTagValue}},
EventsCacheGetFromStoreScope: {operation: "EventsCacheGetFromStore", tags: map[string]string{CacheTypeTagName: EventsCacheTypeTagValue}},
ExecutionSizeStatsScope: {operation: "ExecutionStats", tags: map[string]string{StatsTypeTagName: SizeStatsTypeTagValue}},
ExecutionCountStatsScope: {operation: "ExecutionStats", tags: map[string]string{StatsTypeTagName: CountStatsTypeTagValue}},
SessionSizeStatsScope: {operation: "SessionStats", tags: map[string]string{StatsTypeTagName: SizeStatsTypeTagValue}},
SessionCountStatsScope: {operation: "SessionStats", tags: map[string]string{StatsTypeTagName: CountStatsTypeTagValue}},
WorkflowCompletionStatsScope: {operation: "CompletionStats", tags: map[string]string{StatsTypeTagName: CountStatsTypeTagValue}},
ArchiverClientScope: {operation: "ArchiverClient"},
ReplicationTaskFetcherScope: {operation: "ReplicationTaskFetcher"},
ReplicationTaskCleanupScope: {operation: "ReplicationTaskCleanup"},
ReplicationDLQStatsScope: {operation: "ReplicationDLQStats"},
FailoverMarkerScope: {operation: "FailoverMarker"},
HistoryReplicationV2TaskScope: {operation: "HistoryReplicationV2Task"},
SyncActivityTaskScope: {operation: "SyncActivityTask"},
LargeExecutionSizeShardScope: {operation: "LargeExecutionSizeShard"},
LargeExecutionCountShardScope: {operation: "LargeExecutionCountShard"},
LargeExecutionBlobShardScope: {operation: "LargeExecutionBlobShard"},
},
// Matching Scope Names
Matching: {
MatchingPollForDecisionTaskScope: {operation: "PollForDecisionTask"},
MatchingPollForActivityTaskScope: {operation: "PollForActivityTask"},
MatchingAddActivityTaskScope: {operation: "AddActivityTask"},
MatchingAddDecisionTaskScope: {operation: "AddDecisionTask"},
MatchingAddTaskScope: {operation: "AddTask"},
MatchingTaskListMgrScope: {operation: "TaskListMgr"},
MatchingQueryWorkflowScope: {operation: "QueryWorkflow"},
MatchingRespondQueryTaskCompletedScope: {operation: "RespondQueryTaskCompleted"},
MatchingCancelOutstandingPollScope: {operation: "CancelOutstandingPoll"},
MatchingDescribeTaskListScope: {operation: "DescribeTaskList"},
MatchingListTaskListPartitionsScope: {operation: "ListTaskListPartitions"},
MatchingGetTaskListsByDomainScope: {operation: "GetTaskListsByDomain"},
},
// Worker Scope Names
Worker: {
ReplicatorScope: {operation: "Replicator"},
DomainReplicationTaskScope: {operation: "DomainReplicationTask"},
ESProcessorScope: {operation: "ESProcessor"},
IndexProcessorScope: {operation: "IndexProcessor"},
ArchiverDeleteHistoryActivityScope: {operation: "ArchiverDeleteHistoryActivity"},
ArchiverUploadHistoryActivityScope: {operation: "ArchiverUploadHistoryActivity"},
ArchiverArchiveVisibilityActivityScope: {operation: "ArchiverArchiveVisibilityActivity"},
ArchiverScope: {operation: "Archiver"},
ArchiverPumpScope: {operation: "ArchiverPump"},
ArchiverArchivalWorkflowScope: {operation: "ArchiverArchivalWorkflow"},
TaskListScavengerScope: {operation: "tasklistscavenger"},
ExecutionsScannerScope: {operation: "ExecutionsScanner"},
ShardScannerScope: {operation: "ShardScanner"},
CheckDataCorruptionWorkflowScope: {operation: "CheckDataCorruptionWorkflow"},
ExecutionsFixerScope: {operation: "ExecutionsFixer"},
HistoryScavengerScope: {operation: "historyscavenger"},
BatcherScope: {operation: "batcher"},
ParentClosePolicyProcessorScope: {operation: "ParentClosePolicyProcessor"},
ESAnalyzerScope: {operation: "ESAnalyzer"},
AsyncWorkflowConsumerScope: {operation: "AsyncWorkflowConsumer"},
},
}
// Common Metrics enum
const (
CadenceRequests = iota
CadenceFailures
CadenceLatency
CadenceErrBadRequestCounter
CadenceErrDomainNotActiveCounter
CadenceErrServiceBusyCounter
CadenceErrEntityNotExistsCounter
CadenceErrWorkflowExecutionAlreadyCompletedCounter
CadenceErrExecutionAlreadyStartedCounter
CadenceErrDomainAlreadyExistsCounter
CadenceErrCancellationAlreadyRequestedCounter
CadenceErrQueryFailedCounter
CadenceErrLimitExceededCounter
CadenceErrContextTimeoutCounter
CadenceErrRetryTaskCounter
CadenceErrBadBinaryCounter
CadenceErrClientVersionNotSupportedCounter
CadenceErrIncompleteHistoryCounter
CadenceErrNonDeterministicCounter
CadenceErrUnauthorizedCounter
CadenceErrAuthorizeFailedCounter
CadenceErrRemoteSyncMatchFailedCounter
CadenceErrDomainNameExceededWarnLimit
CadenceErrIdentityExceededWarnLimit
CadenceErrWorkflowIDExceededWarnLimit
CadenceErrSignalNameExceededWarnLimit
CadenceErrWorkflowTypeExceededWarnLimit
CadenceErrRequestIDExceededWarnLimit
CadenceErrTaskListNameExceededWarnLimit
CadenceErrActivityIDExceededWarnLimit
CadenceErrActivityTypeExceededWarnLimit
CadenceErrMarkerNameExceededWarnLimit
CadenceErrTimerIDExceededWarnLimit
PersistenceRequests
PersistenceFailures
PersistenceLatency
PersistenceLatencyHistogram
PersistenceErrShardExistsCounter
PersistenceErrShardOwnershipLostCounter
PersistenceErrConditionFailedCounter
PersistenceErrCurrentWorkflowConditionFailedCounter
PersistenceErrTimeoutCounter
PersistenceErrBusyCounter
PersistenceErrEntityNotExistsCounter
PersistenceErrExecutionAlreadyStartedCounter
PersistenceErrDomainAlreadyExistsCounter
PersistenceErrBadRequestCounter
PersistenceErrDBUnavailableCounter
PersistenceSampledCounter
PersistenceEmptyResponseCounter
PersistenceRequestsPerDomain
PersistenceRequestsPerShard
PersistenceFailuresPerDomain
PersistenceLatencyPerDomain
PersistenceLatencyPerShard
PersistenceErrShardExistsCounterPerDomain
PersistenceErrShardOwnershipLostCounterPerDomain
PersistenceErrConditionFailedCounterPerDomain
PersistenceErrCurrentWorkflowConditionFailedCounterPerDomain
PersistenceErrTimeoutCounterPerDomain
PersistenceErrBusyCounterPerDomain
PersistenceErrEntityNotExistsCounterPerDomain
PersistenceErrExecutionAlreadyStartedCounterPerDomain
PersistenceErrDomainAlreadyExistsCounterPerDomain
PersistenceErrBadRequestCounterPerDomain
PersistenceErrDBUnavailableCounterPerDomain
PersistenceSampledCounterPerDomain
PersistenceEmptyResponseCounterPerDomain
CadenceClientRequests
CadenceClientFailures
CadenceClientLatency
CadenceTasklistRequests
CadenceDcRedirectionClientRequests
CadenceDcRedirectionClientFailures
CadenceDcRedirectionClientLatency
CadenceAuthorizationLatency
DomainCachePrepareCallbacksLatency
DomainCacheCallbacksLatency
DomainCacheCallbacksCount
HistorySize
HistoryCount
EventBlobSize
DecisionResultCount
ArchivalConfigFailures
ActiveClusterGauge
ElasticsearchRequests
ElasticsearchFailures
ElasticsearchLatency
ElasticsearchErrBadRequestCounter
ElasticsearchErrBusyCounter
ElasticsearchRequestsPerDomain
ElasticsearchFailuresPerDomain
ElasticsearchLatencyPerDomain
ElasticsearchErrBadRequestCounterPerDomain
ElasticsearchErrBusyCounterPerDomain
PinotRequests
PinotFailures
PinotLatency
PinotErrBadRequestCounter
PinotErrBusyCounter
PinotRequestsPerDomain
PinotFailuresPerDomain
PinotLatencyPerDomain
PinotErrBadRequestCounterPerDomain
PinotErrBusyCounterPerDomain
SequentialTaskSubmitRequest
SequentialTaskSubmitRequestTaskQueueExist
SequentialTaskSubmitRequestTaskQueueMissing
SequentialTaskSubmitLatency
SequentialTaskQueueSize
SequentialTaskQueueProcessingLatency
SequentialTaskTaskProcessingLatency
ParallelTaskSubmitRequest
ParallelTaskSubmitLatency
ParallelTaskTaskProcessingLatency
PriorityTaskSubmitRequest
PriorityTaskSubmitLatency
KafkaConsumerMessageIn
KafkaConsumerMessageAck
KafkaConsumerMessageNack
KafkaConsumerMessageNackDlqErr
KafkaConsumerSessionStart
GracefulFailoverLatency
GracefulFailoverFailure
HistoryArchiverArchiveNonRetryableErrorCount
HistoryArchiverArchiveTransientErrorCount
HistoryArchiverArchiveSuccessCount
HistoryArchiverHistoryMutatedCount
HistoryArchiverTotalUploadSize
HistoryArchiverHistorySize
HistoryArchiverDuplicateArchivalsCount
// The following metrics are only used by internal history archiver implemention.
// TODO: move them to internal repo once cadence plugin model is in place.
HistoryArchiverBlobExistsCount
HistoryArchiverBlobSize
HistoryArchiverRunningDeterministicConstructionCheckCount
HistoryArchiverDeterministicConstructionCheckFailedCount
HistoryArchiverRunningBlobIntegrityCheckCount
HistoryArchiverBlobIntegrityCheckFailedCount
VisibilityArchiverArchiveNonRetryableErrorCount
VisibilityArchiverArchiveTransientErrorCount
VisibilityArchiveSuccessCount
MatchingClientForwardedCounter
MatchingClientInvalidTaskListName
// common metrics that are emitted per task list
CadenceRequestsPerTaskList
CadenceFailuresPerTaskList
CadenceLatencyPerTaskList
CadenceErrBadRequestPerTaskListCounter
CadenceErrDomainNotActivePerTaskListCounter
CadenceErrServiceBusyPerTaskListCounter
CadenceErrEntityNotExistsPerTaskListCounter
CadenceErrExecutionAlreadyStartedPerTaskListCounter
CadenceErrDomainAlreadyExistsPerTaskListCounter
CadenceErrCancellationAlreadyRequestedPerTaskListCounter
CadenceErrQueryFailedPerTaskListCounter
CadenceErrLimitExceededPerTaskListCounter
CadenceErrContextTimeoutPerTaskListCounter
CadenceErrRetryTaskPerTaskListCounter
CadenceErrBadBinaryPerTaskListCounter
CadenceErrClientVersionNotSupportedPerTaskListCounter
CadenceErrIncompleteHistoryPerTaskListCounter
CadenceErrNonDeterministicPerTaskListCounter
CadenceErrUnauthorizedPerTaskListCounter
CadenceErrAuthorizeFailedPerTaskListCounter
CadenceErrRemoteSyncMatchFailedPerTaskListCounter
CadenceErrStickyWorkerUnavailablePerTaskListCounter
CadenceShardSuccessGauge
CadenceShardFailureGauge
DomainReplicationQueueSizeGauge
DomainReplicationQueueSizeErrorCount
ParentClosePolicyProcessorSuccess
ParentClosePolicyProcessorFailures
IsolationGroupStatePollerUnavailable
IsolationGroupStateDrained
IsolationGroupStateHealthy
ValidatedWorkflowCount
HashringViewIdentifier
NumCommonMetrics // Needs to be last on this list for iota numbering
)
// History Metrics enum
const (
TaskRequests = iota + NumCommonMetrics
TaskLatency
TaskFailures
TaskDiscarded
TaskAttemptTimer
TaskStandbyRetryCounter
TaskNotActiveCounter
TaskLimitExceededCounter
TaskBatchCompleteCounter
TaskBatchCompleteFailure
TaskProcessingLatency
TaskQueueLatency
TaskRequestsPerDomain
TaskLatencyPerDomain
TaskFailuresPerDomain
TaskWorkflowBusyPerDomain
TaskDiscardedPerDomain
TaskUnsupportedPerDomain
TaskAttemptTimerPerDomain
TaskStandbyRetryCounterPerDomain
TaskPendingActiveCounterPerDomain
TaskNotActiveCounterPerDomain
TaskTargetNotActiveCounterPerDomain
TaskLimitExceededCounterPerDomain
TaskProcessingLatencyPerDomain
TaskQueueLatencyPerDomain
TransferTaskMissingEventCounterPerDomain
ReplicationTasksAppliedPerDomain
TaskRedispatchQueuePendingTasksTimer
TransferTaskThrottledCounter
TimerTaskThrottledCounter
CrossClusterTaskThrottledCounter
TransferTaskMissingEventCounter
ProcessingQueueNumTimer
ProcessingQueueMaxLevelTimer
ProcessingQueuePendingTaskSplitCounter
ProcessingQueueStuckTaskSplitCounter
ProcessingQueueSelectedDomainSplitCounter
ProcessingQueueRandomSplitCounter
ProcessingQueueThrottledCounter
QueueValidatorLostTaskCounter
QueueValidatorDropTaskCounter
QueueValidatorInvalidLoadCounter
QueueValidatorValidationCounter
QueueValidatorValidationFailure
CrossClusterFetchLatency
CrossClusterFetchRequests
CrossClusterFetchFailures
CrossClusterFetchServiceBusyFailures
CrossClusterTaskRespondLatency
CrossClusterTaskRespondRequests
CrossClusterTaskRespondFailures
CrossClusterTaskFetchedTimer
CrossClusterTaskPendingTimer
ClusterMetadataFailureToResolveCounter
ClusterMetadataGettingMinFailoverVersionCounter
ClusterMetadataGettingFailoverVersionCounter
ClusterMetadataResolvingFailoverVersionCounter
ClusterMetadataResolvingMinFailoverVersionCounter
ActivityE2ELatency
ActivityLostCounter
AckLevelUpdateCounter
AckLevelUpdateFailedCounter
DecisionTypeScheduleActivityCounter
DecisionTypeScheduleActivityDispatchSucceedCounter
DecisionTypeScheduleActivityDispatchCounter
DecisionTypeCompleteWorkflowCounter
DecisionTypeFailWorkflowCounter
DecisionTypeCancelWorkflowCounter
DecisionTypeStartTimerCounter
DecisionTypeCancelActivityCounter
DecisionTypeCancelTimerCounter
DecisionTypeRecordMarkerCounter
DecisionTypeCancelExternalWorkflowCounter
DecisionTypeChildWorkflowCounter
DecisionTypeContinueAsNewCounter
DecisionTypeSignalExternalWorkflowCounter
DecisionTypeUpsertWorkflowSearchAttributesCounter
EmptyCompletionDecisionsCounter
MultipleCompletionDecisionsCounter
FailedDecisionsCounter
DecisionAttemptTimer
DecisionRetriesExceededCounter
StaleMutableStateCounter
DataInconsistentCounter
TimerResurrectionCounter
ActivityResurrectionCounter
AutoResetPointsLimitExceededCounter
AutoResetPointCorruptionCounter
ConcurrencyUpdateFailureCounter
CadenceErrEventAlreadyStartedCounter
CadenceErrShardOwnershipLostCounter
HeartbeatTimeoutCounter
ScheduleToStartTimeoutCounter
StartToCloseTimeoutCounter
ScheduleToCloseTimeoutCounter
NewTimerCounter
NewTimerNotifyCounter
AcquireShardsCounter
AcquireShardsLatency
ShardClosedCounter
ShardItemCreatedCounter
ShardItemRemovedCounter
ShardItemAcquisitionLatency
ShardInfoReplicationPendingTasksTimer
ShardInfoTransferActivePendingTasksTimer
ShardInfoTransferStandbyPendingTasksTimer
ShardInfoTimerActivePendingTasksTimer
ShardInfoTimerStandbyPendingTasksTimer
ShardInfoCrossClusterPendingTasksTimer
ShardInfoReplicationLagTimer
ShardInfoTransferLagTimer
ShardInfoTimerLagTimer
ShardInfoCrossClusterLagTimer
ShardInfoTransferDiffTimer
ShardInfoTimerDiffTimer
ShardInfoTransferFailoverInProgressTimer
ShardInfoTimerFailoverInProgressTimer
ShardInfoTransferFailoverLatencyTimer
ShardInfoTimerFailoverLatencyTimer
SyncShardFromRemoteCounter
SyncShardFromRemoteFailure
MembershipChangedCounter
NumShardsGauge
GetEngineForShardErrorCounter
GetEngineForShardLatency
RemoveEngineForShardLatency
CompleteDecisionWithStickyEnabledCounter
CompleteDecisionWithStickyDisabledCounter
DecisionHeartbeatTimeoutCounter
HistoryEventNotificationQueueingLatency
HistoryEventNotificationFanoutLatency
HistoryEventNotificationInFlightMessageGauge
HistoryEventNotificationFailDeliveryCount
EmptyReplicationEventsCounter
DuplicateReplicationEventsCounter
StaleReplicationEventsCounter
ReplicationEventsSizeTimer
BufferReplicationTaskTimer
UnbufferReplicationTaskTimer
HistoryConflictsCounter
CompleteTaskFailedCounter
CacheSize
CacheRequests
CacheFailures
CacheLatency
CacheHitCounter
CacheMissCounter
CacheFullCounter
AcquireLockFailedCounter
WorkflowContextCleared
MutableStateSize
ExecutionInfoSize
ActivityInfoSize
TimerInfoSize
ChildInfoSize
SignalInfoSize
BufferedEventsSize
ActivityInfoCount
TimerInfoCount
ChildInfoCount
SignalInfoCount
RequestCancelInfoCount
BufferedEventsCount
TransferTasksCount
TimerTasksCount
CrossClusterTasksCount
ReplicationTasksCount
DeleteActivityInfoCount
DeleteTimerInfoCount
DeleteChildInfoCount
DeleteSignalInfoCount
DeleteRequestCancelInfoCount
WorkflowRetryBackoffTimerCount
WorkflowCronBackoffTimerCount
WorkflowCleanupDeleteCount
WorkflowCleanupArchiveCount
WorkflowCleanupNopCount
WorkflowCleanupDeleteHistoryInlineCount
WorkflowSuccessCount
WorkflowCancelCount
WorkflowFailedCount
WorkflowTimeoutCount
WorkflowTerminateCount
WorkflowContinuedAsNew
WorkflowCompletedUnknownType
ArchiverClientSendSignalCount
ArchiverClientSendSignalFailureCount
ArchiverClientHistoryRequestCount
ArchiverClientHistoryInlineArchiveAttemptCount
ArchiverClientHistoryInlineArchiveFailureCount
ArchiverClientHistoryInlineArchiveThrottledCount
ArchiverClientVisibilityRequestCount
ArchiverClientVisibilityInlineArchiveAttemptCount
ArchiverClientVisibilityInlineArchiveFailureCount
ArchiverClientVisibilityInlineArchiveThrottledCount
ArchiverClientSendSignalCountPerDomain
ArchiverClientSendSignalFailureCountPerDomain
ArchiverClientHistoryRequestCountPerDomain
ArchiverClientHistoryInlineArchiveAttemptCountPerDomain
ArchiverClientHistoryInlineArchiveFailureCountPerDomain
ArchiverClientHistoryInlineArchiveThrottledCountPerDomain
ArchiverClientVisibilityRequestCountPerDomain
ArchiverClientVisibilityInlineArchiveAttemptCountPerDomain
ArchiverClientVisibilityInlineArchiveFailureCountPerDomain
ArchiverClientVisibilityInlineArchiveThrottledCountPerDomain
LastRetrievedMessageID
LastProcessedMessageID
ReplicationLatency
ReplicationTasksApplied
ReplicationTasksFailed
ReplicationTasksLag
ReplicationTasksFetched
ReplicationTasksReturned
ReplicationTasksReturnedDiff
ReplicationTasksAppliedLatency
ReplicationDLQFailed
ReplicationDLQMaxLevelGauge
ReplicationDLQAckLevelGauge
ReplicationDLQProbeFailed
ReplicationDLQSize
ReplicationDLQValidationFailed
GetReplicationMessagesForShardLatency
GetDLQReplicationMessagesLatency
EventReapplySkippedCount
DirectQueryDispatchLatency
DirectQueryDispatchStickyLatency
DirectQueryDispatchNonStickyLatency
DirectQueryDispatchStickySuccessCount
DirectQueryDispatchNonStickySuccessCount
DirectQueryDispatchClearStickinessLatency
DirectQueryDispatchClearStickinessSuccessCount
DirectQueryDispatchTimeoutBeforeNonStickyCount
DecisionTaskQueryLatency
ConsistentQueryPerShard
ConsistentQueryTimeoutCount
QueryBeforeFirstDecisionCount
QueryBufferExceededCount
QueryRegistryInvalidStateCount
WorkerNotSupportsConsistentQueryCount
DecisionStartToCloseTimeoutOverrideCount
ReplicationTaskCleanupCount
ReplicationTaskCleanupFailure
ReplicationTaskLatency
MutableStateChecksumMismatch
MutableStateChecksumInvalidated
FailoverMarkerCount
FailoverMarkerReplicationLatency
FailoverMarkerInsertFailure
FailoverMarkerNotificationFailure
FailoverMarkerUpdateShardFailure
FailoverMarkerCallbackCount
HistoryFailoverCallbackCount
WorkflowVersionCount
WorkflowTypeCount
WorkflowStartedCount
LargeHistoryBlobCount
LargeHistoryEventCount
LargeHistorySizeCount
UpdateWorkflowExecutionCount
WorkflowIDCacheSizeGauge
WorkflowIDCacheRequestsExternalRatelimitedCounter
WorkflowIDCacheRequestsInternalRatelimitedCounter
NumHistoryMetrics
)
// Matching metrics enum
const (
PollSuccessPerTaskListCounter = iota + NumCommonMetrics
PollTimeoutPerTaskListCounter
PollSuccessWithSyncPerTaskListCounter
LeaseRequestPerTaskListCounter
LeaseFailurePerTaskListCounter
ConditionFailedErrorPerTaskListCounter
RespondQueryTaskFailedPerTaskListCounter
SyncThrottlePerTaskListCounter
BufferThrottlePerTaskListCounter
BufferUnknownTaskDispatchError
BufferIsolationGroupRedirectCounter
BufferIsolationGroupRedirectFailureCounter
BufferIsolationGroupMisconfiguredCounter
SyncMatchLatencyPerTaskList
AsyncMatchLatencyPerTaskList
AsyncMatchDispatchLatencyPerTaskList
AsyncMatchDispatchTimeoutCounterPerTaskList
ExpiredTasksPerTaskListCounter
ForwardedPerTaskListCounter
ForwardTaskCallsPerTaskList
ForwardTaskErrorsPerTaskList
ForwardTaskLatencyPerTaskList
ForwardQueryCallsPerTaskList
ForwardQueryErrorsPerTaskList
ForwardQueryLatencyPerTaskList
ForwardPollCallsPerTaskList
ForwardPollErrorsPerTaskList
ForwardPollLatencyPerTaskList
LocalToLocalMatchPerTaskListCounter
LocalToRemoteMatchPerTaskListCounter
RemoteToLocalMatchPerTaskListCounter
RemoteToRemoteMatchPerTaskListCounter
IsolationTaskMatchPerTaskListCounter
PollerPerTaskListCounter
PollerInvalidIsolationGroupCounter
TaskListManagersGauge
TaskLagPerTaskListGauge
TaskBacklogPerTaskListGauge
TaskCountPerTaskListGauge
NumMatchingMetrics
)
// Worker metrics enum
const (
ReplicatorMessages = iota + NumCommonMetrics
ReplicatorFailures
ReplicatorMessagesDropped
ReplicatorLatency
ReplicatorDLQFailures
ESProcessorRequests
ESProcessorRetries
ESProcessorFailures
ESProcessorCorruptedData
ESProcessorProcessMsgLatency
IndexProcessorCorruptedData
IndexProcessorProcessMsgLatency
ArchiverNonRetryableErrorCount
ArchiverStartedCount
ArchiverStoppedCount
ArchiverCoroutineStartedCount
ArchiverCoroutineStoppedCount
ArchiverHandleHistoryRequestLatency
ArchiverHandleVisibilityRequestLatency
ArchiverUploadWithRetriesLatency
ArchiverDeleteWithRetriesLatency
ArchiverUploadFailedAllRetriesCount
ArchiverUploadSuccessCount
ArchiverDeleteFailedAllRetriesCount
ArchiverDeleteSuccessCount
ArchiverHandleVisibilityFailedAllRetiresCount
ArchiverHandleVisibilitySuccessCount
ArchiverBacklogSizeGauge
ArchiverPumpTimeoutCount
ArchiverPumpSignalThresholdCount
ArchiverPumpTimeoutWithoutSignalsCount
ArchiverPumpSignalChannelClosedCount
ArchiverWorkflowStartedCount
ArchiverNumPumpedRequestsCount
ArchiverNumHandledRequestsCount
ArchiverPumpedNotEqualHandledCount
ArchiverHandleAllRequestsLatency
ArchiverWorkflowStoppingCount
TaskProcessedCount
TaskDeletedCount
TaskListProcessedCount
TaskListDeletedCount
TaskListOutstandingCount
ExecutionsOutstandingCount
StartedCount
StoppedCount
ExecutorTasksDeferredCount
ExecutorTasksDroppedCount
BatcherProcessorSuccess
BatcherProcessorFailures
HistoryScavengerSuccessCount
HistoryScavengerErrorCount
HistoryScavengerSkipCount
DomainReplicationEnqueueDLQCount
ScannerExecutionsGauge
ScannerCorruptedGauge
ScannerCheckFailedGauge
ScannerCorruptionByTypeGauge
ScannerCorruptedOpenExecutionGauge
ScannerShardSizeMaxGauge
ScannerShardSizeMedianGauge
ScannerShardSizeMinGauge
ScannerShardSizeNinetyGauge
ScannerShardSizeSeventyFiveGauge
ScannerShardSizeTwentyFiveGauge
ScannerShardSizeTenGauge
ShardScannerScan
ShardScannerFix
DataCorruptionWorkflowCount
DataCorruptionWorkflowFailure
DataCorruptionWorkflowSuccessCount
DataCorruptionWorkflowSkipCount
ESAnalyzerNumStuckWorkflowsDiscovered
ESAnalyzerNumStuckWorkflowsRefreshed
ESAnalyzerNumStuckWorkflowsFailedToRefresh
ESAnalyzerNumLongRunningWorkflows
AsyncWorkflowConsumerCount
AsyncWorkflowProcessMsgLatency
AsyncWorkflowFailureCorruptMsgCount
AsyncWorkflowFailureByFrontendCount
AsyncWorkflowSuccessCount
NumWorkerMetrics
)
// MetricDefs record the metrics for all services
var MetricDefs = map[ServiceIdx]map[int]metricDefinition{
Common: {
CadenceRequests: {metricName: "cadence_requests", metricType: Counter},
CadenceFailures: {metricName: "cadence_errors", metricType: Counter},
CadenceLatency: {metricName: "cadence_latency", metricType: Timer},
CadenceErrBadRequestCounter: {metricName: "cadence_errors_bad_request", metricType: Counter},
CadenceErrDomainNotActiveCounter: {metricName: "cadence_errors_domain_not_active", metricType: Counter},
CadenceErrServiceBusyCounter: {metricName: "cadence_errors_service_busy", metricType: Counter},
CadenceErrEntityNotExistsCounter: {metricName: "cadence_errors_entity_not_exists", metricType: Counter},
CadenceErrWorkflowExecutionAlreadyCompletedCounter: {metricName: "cadence_errors_workflow_execution_already_completed", metricType: Counter},
CadenceErrExecutionAlreadyStartedCounter: {metricName: "cadence_errors_execution_already_started", metricType: Counter},
CadenceErrDomainAlreadyExistsCounter: {metricName: "cadence_errors_domain_already_exists", metricType: Counter},
CadenceErrCancellationAlreadyRequestedCounter: {metricName: "cadence_errors_cancellation_already_requested", metricType: Counter},
CadenceErrQueryFailedCounter: {metricName: "cadence_errors_query_failed", metricType: Counter},
CadenceErrLimitExceededCounter: {metricName: "cadence_errors_limit_exceeded", metricType: Counter},
CadenceErrContextTimeoutCounter: {metricName: "cadence_errors_context_timeout", metricType: Counter},
CadenceErrRetryTaskCounter: {metricName: "cadence_errors_retry_task", metricType: Counter},
CadenceErrBadBinaryCounter: {metricName: "cadence_errors_bad_binary", metricType: Counter},
CadenceErrClientVersionNotSupportedCounter: {metricName: "cadence_errors_client_version_not_supported", metricType: Counter},
CadenceErrIncompleteHistoryCounter: {metricName: "cadence_errors_incomplete_history", metricType: Counter},
CadenceErrNonDeterministicCounter: {metricName: "cadence_errors_nondeterministic", metricType: Counter},
CadenceErrUnauthorizedCounter: {metricName: "cadence_errors_unauthorized", metricType: Counter},
CadenceErrAuthorizeFailedCounter: {metricName: "cadence_errors_authorize_failed", metricType: Counter},
CadenceErrRemoteSyncMatchFailedCounter: {metricName: "cadence_errors_remote_syncmatch_failed", metricType: Counter},
CadenceErrDomainNameExceededWarnLimit: {metricName: "cadence_errors_domain_name_exceeded_warn_limit", metricType: Counter},
CadenceErrIdentityExceededWarnLimit: {metricName: "cadence_errors_identity_exceeded_warn_limit", metricType: Counter},
CadenceErrWorkflowIDExceededWarnLimit: {metricName: "cadence_errors_workflow_id_exceeded_warn_limit", metricType: Counter},
CadenceErrSignalNameExceededWarnLimit: {metricName: "cadence_errors_signal_name_exceeded_warn_limit", metricType: Counter},
CadenceErrWorkflowTypeExceededWarnLimit: {metricName: "cadence_errors_workflow_type_exceeded_warn_limit", metricType: Counter},
CadenceErrRequestIDExceededWarnLimit: {metricName: "cadence_errors_request_id_exceeded_warn_limit", metricType: Counter},
CadenceErrTaskListNameExceededWarnLimit: {metricName: "cadence_errors_task_list_name_exceeded_warn_limit", metricType: Counter},
CadenceErrActivityIDExceededWarnLimit: {metricName: "cadence_errors_activity_id_exceeded_warn_limit", metricType: Counter},
CadenceErrActivityTypeExceededWarnLimit: {metricName: "cadence_errors_activity_type_exceeded_warn_limit", metricType: Counter},
CadenceErrMarkerNameExceededWarnLimit: {metricName: "cadence_errors_marker_name_exceeded_warn_limit", metricType: Counter},
CadenceErrTimerIDExceededWarnLimit: {metricName: "cadence_errors_timer_id_exceeded_warn_limit", metricType: Counter},
PersistenceRequests: {metricName: "persistence_requests", metricType: Counter},
PersistenceFailures: {metricName: "persistence_errors", metricType: Counter},
PersistenceLatency: {metricName: "persistence_latency", metricType: Timer},
PersistenceLatencyHistogram: {metricName: "persistence_latency_histogram", metricType: Histogram, buckets: PersistenceLatencyBuckets},
PersistenceErrShardExistsCounter: {metricName: "persistence_errors_shard_exists", metricType: Counter},
PersistenceErrShardOwnershipLostCounter: {metricName: "persistence_errors_shard_ownership_lost", metricType: Counter},
PersistenceErrConditionFailedCounter: {metricName: "persistence_errors_condition_failed", metricType: Counter},
PersistenceErrCurrentWorkflowConditionFailedCounter: {metricName: "persistence_errors_current_workflow_condition_failed", metricType: Counter},
PersistenceErrTimeoutCounter: {metricName: "persistence_errors_timeout", metricType: Counter},
PersistenceErrBusyCounter: {metricName: "persistence_errors_busy", metricType: Counter},
PersistenceErrEntityNotExistsCounter: {metricName: "persistence_errors_entity_not_exists", metricType: Counter},
PersistenceErrExecutionAlreadyStartedCounter: {metricName: "persistence_errors_execution_already_started", metricType: Counter},
PersistenceErrDomainAlreadyExistsCounter: {metricName: "persistence_errors_domain_already_exists", metricType: Counter},
PersistenceErrBadRequestCounter: {metricName: "persistence_errors_bad_request", metricType: Counter},
PersistenceErrDBUnavailableCounter: {metricName: "persistence_errors_db_unavailable", metricType: Counter},
PersistenceSampledCounter: {metricName: "persistence_sampled", metricType: Counter},
PersistenceEmptyResponseCounter: {metricName: "persistence_empty_response", metricType: Counter},
PersistenceRequestsPerDomain: {metricName: "persistence_requests_per_domain", metricRollupName: "persistence_requests", metricType: Counter},
PersistenceRequestsPerShard: {metricName: "persistence_requests_per_shard", metricType: Counter},
PersistenceFailuresPerDomain: {metricName: "persistence_errors_per_domain", metricRollupName: "persistence_errors", metricType: Counter},
PersistenceLatencyPerDomain: {metricName: "persistence_latency_per_domain", metricRollupName: "persistence_latency", metricType: Timer},
PersistenceLatencyPerShard: {metricName: "persistence_latency_per_shard", metricType: Timer},
PersistenceErrShardExistsCounterPerDomain: {metricName: "persistence_errors_shard_exists_per_domain", metricRollupName: "persistence_errors_shard_exists", metricType: Counter},
PersistenceErrShardOwnershipLostCounterPerDomain: {metricName: "persistence_errors_shard_ownership_lost_per_domain", metricRollupName: "persistence_errors_shard_ownership_lost", metricType: Counter},
PersistenceErrConditionFailedCounterPerDomain: {metricName: "persistence_errors_condition_failed_per_domain", metricRollupName: "persistence_errors_condition_failed", metricType: Counter},
PersistenceErrCurrentWorkflowConditionFailedCounterPerDomain: {metricName: "persistence_errors_current_workflow_condition_failed_per_domain", metricRollupName: "persistence_errors_current_workflow_condition_failed", metricType: Counter},
PersistenceErrTimeoutCounterPerDomain: {metricName: "persistence_errors_timeout_per_domain", metricRollupName: "persistence_errors_timeout", metricType: Counter},
PersistenceErrBusyCounterPerDomain: {metricName: "persistence_errors_busy_per_domain", metricRollupName: "persistence_errors_busy", metricType: Counter},
PersistenceErrEntityNotExistsCounterPerDomain: {metricName: "persistence_errors_entity_not_exists_per_domain", metricRollupName: "persistence_errors_entity_not_exists", metricType: Counter},
PersistenceErrExecutionAlreadyStartedCounterPerDomain: {metricName: "persistence_errors_execution_already_started_per_domain", metricRollupName: "persistence_errors_execution_already_started", metricType: Counter},
PersistenceErrDomainAlreadyExistsCounterPerDomain: {metricName: "persistence_errors_domain_already_exists_per_domain", metricRollupName: "persistence_errors_domain_already_exists", metricType: Counter},
PersistenceErrBadRequestCounterPerDomain: {metricName: "persistence_errors_bad_request_per_domain", metricRollupName: "persistence_errors_bad_request", metricType: Counter},
PersistenceErrDBUnavailableCounterPerDomain: {metricName: "persistence_errors_db_unavailable_per_domain", metricRollupName: "persistence_errors_db_unavailable", metricType: Counter},
PersistenceSampledCounterPerDomain: {metricName: "persistence_sampled_per_domain", metricRollupName: "persistence_sampled", metricType: Counter},
PersistenceEmptyResponseCounterPerDomain: {metricName: "persistence_empty_response_per_domain", metricRollupName: "persistence_empty_response", metricType: Counter},
CadenceClientRequests: {metricName: "cadence_client_requests", metricType: Counter},
CadenceClientFailures: {metricName: "cadence_client_errors", metricType: Counter},
CadenceClientLatency: {metricName: "cadence_client_latency", metricType: Timer},
CadenceTasklistRequests: {metricName: "cadence_tasklist_request", metricType: Counter},
CadenceDcRedirectionClientRequests: {metricName: "cadence_client_requests_redirection", metricType: Counter},
CadenceDcRedirectionClientFailures: {metricName: "cadence_client_errors_redirection", metricType: Counter},
CadenceDcRedirectionClientLatency: {metricName: "cadence_client_latency_redirection", metricType: Timer},
CadenceAuthorizationLatency: {metricName: "cadence_authorization_latency", metricType: Timer},
DomainCachePrepareCallbacksLatency: {metricName: "domain_cache_prepare_callbacks_latency", metricType: Timer},
DomainCacheCallbacksLatency: {metricName: "domain_cache_callbacks_latency", metricType: Timer},
DomainCacheCallbacksCount: {metricName: "domain_cache_callbacks_count", metricType: Counter},
HistorySize: {metricName: "history_size", metricType: Timer},
HistoryCount: {metricName: "history_count", metricType: Timer},
EventBlobSize: {metricName: "event_blob_size", metricType: Timer},
DecisionResultCount: {metricName: "decision_result_count", metricType: Timer},
ArchivalConfigFailures: {metricName: "archivalconfig_failures", metricType: Counter},
ActiveClusterGauge: {metricName: "active_cluster", metricType: Gauge},
ElasticsearchRequests: {metricName: "elasticsearch_requests", metricType: Counter},
ElasticsearchFailures: {metricName: "elasticsearch_errors", metricType: Counter},
ElasticsearchLatency: {metricName: "elasticsearch_latency", metricType: Timer},
ElasticsearchErrBadRequestCounter: {metricName: "elasticsearch_errors_bad_request", metricType: Counter},
ElasticsearchErrBusyCounter: {metricName: "elasticsearch_errors_busy", metricType: Counter},
ElasticsearchRequestsPerDomain: {metricName: "elasticsearch_requests_per_domain", metricRollupName: "elasticsearch_requests", metricType: Counter},
ElasticsearchFailuresPerDomain: {metricName: "elasticsearch_errors_per_domain", metricRollupName: "elasticsearch_errors", metricType: Counter},
ElasticsearchLatencyPerDomain: {metricName: "elasticsearch_latency_per_domain", metricRollupName: "elasticsearch_latency", metricType: Timer},
ElasticsearchErrBadRequestCounterPerDomain: {metricName: "elasticsearch_errors_bad_request_per_domain", metricRollupName: "elasticsearch_errors_bad_request", metricType: Counter},
ElasticsearchErrBusyCounterPerDomain: {metricName: "elasticsearch_errors_busy_per_domain", metricRollupName: "elasticsearch_errors_busy", metricType: Counter},
PinotRequests: {metricName: "pinot_requests", metricType: Counter},
PinotFailures: {metricName: "pinot_errors", metricType: Counter},
PinotLatency: {metricName: "pinot_latency", metricType: Timer},
PinotErrBadRequestCounter: {metricName: "pinot_errors_bad_request", metricType: Counter},
PinotErrBusyCounter: {metricName: "pinot_errors_busy", metricType: Counter},
PinotRequestsPerDomain: {metricName: "pinot_requests_per_domain", metricRollupName: "pinot_requests", metricType: Counter},
PinotFailuresPerDomain: {metricName: "pinot_errors_per_domain", metricRollupName: "pinot_errors", metricType: Counter},
PinotLatencyPerDomain: {metricName: "pinot_latency_per_domain", metricRollupName: "pinot_latency", metricType: Timer},
PinotErrBadRequestCounterPerDomain: {metricName: "pinot_errors_bad_request_per_domain", metricRollupName: "pinot_errors_bad_request", metricType: Counter},
PinotErrBusyCounterPerDomain: {metricName: "pinot_errors_busy_per_domain", metricRollupName: "pinot_errors_busy", metricType: Counter},
SequentialTaskSubmitRequest: {metricName: "sequentialtask_submit_request", metricType: Counter},
SequentialTaskSubmitRequestTaskQueueExist: {metricName: "sequentialtask_submit_request_taskqueue_exist", metricType: Counter},
SequentialTaskSubmitRequestTaskQueueMissing: {metricName: "sequentialtask_submit_request_taskqueue_missing", metricType: Counter},
SequentialTaskSubmitLatency: {metricName: "sequentialtask_submit_latency", metricType: Timer},
SequentialTaskQueueSize: {metricName: "sequentialtask_queue_size", metricType: Timer},
SequentialTaskQueueProcessingLatency: {metricName: "sequentialtask_queue_processing_latency", metricType: Timer},
SequentialTaskTaskProcessingLatency: {metricName: "sequentialtask_task_processing_latency", metricType: Timer},
ParallelTaskSubmitRequest: {metricName: "paralleltask_submit_request", metricType: Counter},
ParallelTaskSubmitLatency: {metricName: "paralleltask_submit_latency", metricType: Timer},
ParallelTaskTaskProcessingLatency: {metricName: "paralleltask_task_processing_latency", metricType: Timer},
PriorityTaskSubmitRequest: {metricName: "prioritytask_submit_request", metricType: Counter},
PriorityTaskSubmitLatency: {metricName: "prioritytask_submit_latency", metricType: Timer},
KafkaConsumerMessageIn: {metricName: "kafka_consumer_message_in", metricType: Counter},
KafkaConsumerMessageAck: {metricName: "kafka_consumer_message_ack", metricType: Counter},
KafkaConsumerMessageNack: {metricName: "kafka_consumer_message_nack", metricType: Counter},
KafkaConsumerMessageNackDlqErr: {metricName: "kafka_consumer_message_nack_dlq_err", metricType: Counter},
KafkaConsumerSessionStart: {metricName: "kafka_consumer_session_start", metricType: Counter},
GracefulFailoverLatency: {metricName: "graceful_failover_latency", metricType: Timer},
GracefulFailoverFailure: {metricName: "graceful_failover_failures", metricType: Counter},
HistoryArchiverArchiveNonRetryableErrorCount: {metricName: "history_archiver_archive_non_retryable_error", metricType: Counter},
HistoryArchiverArchiveTransientErrorCount: {metricName: "history_archiver_archive_transient_error", metricType: Counter},
HistoryArchiverArchiveSuccessCount: {metricName: "history_archiver_archive_success", metricType: Counter},
HistoryArchiverHistoryMutatedCount: {metricName: "history_archiver_history_mutated", metricType: Counter},
HistoryArchiverTotalUploadSize: {metricName: "history_archiver_total_upload_size", metricType: Timer},
HistoryArchiverHistorySize: {metricName: "history_archiver_history_size", metricType: Timer},
HistoryArchiverDuplicateArchivalsCount: {metricName: "history_archiver_duplicate_archivals", metricType: Counter},
HistoryArchiverBlobExistsCount: {metricName: "history_archiver_blob_exists", metricType: Counter},
HistoryArchiverBlobSize: {metricName: "history_archiver_blob_size", metricType: Timer},
HistoryArchiverRunningDeterministicConstructionCheckCount: {metricName: "history_archiver_running_deterministic_construction_check", metricType: Counter},
HistoryArchiverDeterministicConstructionCheckFailedCount: {metricName: "history_archiver_deterministic_construction_check_failed", metricType: Counter},
HistoryArchiverRunningBlobIntegrityCheckCount: {metricName: "history_archiver_running_blob_integrity_check", metricType: Counter},
HistoryArchiverBlobIntegrityCheckFailedCount: {metricName: "history_archiver_blob_integrity_check_failed", metricType: Counter},
VisibilityArchiverArchiveNonRetryableErrorCount: {metricName: "visibility_archiver_archive_non_retryable_error", metricType: Counter},
VisibilityArchiverArchiveTransientErrorCount: {metricName: "visibility_archiver_archive_transient_error", metricType: Counter},
VisibilityArchiveSuccessCount: {metricName: "visibility_archiver_archive_success", metricType: Counter},
MatchingClientForwardedCounter: {metricName: "forwarded", metricType: Counter},
MatchingClientInvalidTaskListName: {metricName: "invalid_task_list_name", metricType: Counter},
// per task list common metrics
CadenceRequestsPerTaskList: {
metricName: "cadence_requests_per_tl", metricRollupName: "cadence_requests", metricType: Counter,
},
CadenceFailuresPerTaskList: {
metricName: "cadence_errors_per_tl", metricRollupName: "cadence_errors", metricType: Counter,
},
CadenceLatencyPerTaskList: {
metricName: "cadence_latency_per_tl", metricRollupName: "cadence_latency", metricType: Timer,
},
CadenceErrBadRequestPerTaskListCounter: {
metricName: "cadence_errors_bad_request_per_tl", metricRollupName: "cadence_errors_bad_request", metricType: Counter,
},
CadenceErrDomainNotActivePerTaskListCounter: {
metricName: "cadence_errors_domain_not_active_per_tl", metricRollupName: "cadence_errors_domain_not_active", metricType: Counter,
},
CadenceErrServiceBusyPerTaskListCounter: {
metricName: "cadence_errors_service_busy_per_tl", metricRollupName: "cadence_errors_service_busy", metricType: Counter,
},
CadenceErrEntityNotExistsPerTaskListCounter: {
metricName: "cadence_errors_entity_not_exists_per_tl", metricRollupName: "cadence_errors_entity_not_exists", metricType: Counter,
},
CadenceErrExecutionAlreadyStartedPerTaskListCounter: {
metricName: "cadence_errors_execution_already_started_per_tl", metricRollupName: "cadence_errors_execution_already_started", metricType: Counter,
},
CadenceErrDomainAlreadyExistsPerTaskListCounter: {
metricName: "cadence_errors_domain_already_exists_per_tl", metricRollupName: "cadence_errors_domain_already_exists", metricType: Counter,
},
CadenceErrCancellationAlreadyRequestedPerTaskListCounter: {
metricName: "cadence_errors_cancellation_already_requested_per_tl", metricRollupName: "cadence_errors_cancellation_already_requested", metricType: Counter,
},
CadenceErrQueryFailedPerTaskListCounter: {
metricName: "cadence_errors_query_failed_per_tl", metricRollupName: "cadence_errors_query_failed", metricType: Counter,
},
CadenceErrLimitExceededPerTaskListCounter: {
metricName: "cadence_errors_limit_exceeded_per_tl", metricRollupName: "cadence_errors_limit_exceeded", metricType: Counter,
},
CadenceErrContextTimeoutPerTaskListCounter: {
metricName: "cadence_errors_context_timeout_per_tl", metricRollupName: "cadence_errors_context_timeout", metricType: Counter,
},
CadenceErrRetryTaskPerTaskListCounter: {
metricName: "cadence_errors_retry_task_per_tl", metricRollupName: "cadence_errors_retry_task", metricType: Counter,
},
CadenceErrBadBinaryPerTaskListCounter: {
metricName: "cadence_errors_bad_binary_per_tl", metricRollupName: "cadence_errors_bad_binary", metricType: Counter,
},
CadenceErrClientVersionNotSupportedPerTaskListCounter: {
metricName: "cadence_errors_client_version_not_supported_per_tl", metricRollupName: "cadence_errors_client_version_not_supported", metricType: Counter,
},
CadenceErrIncompleteHistoryPerTaskListCounter: {
metricName: "cadence_errors_incomplete_history_per_tl", metricRollupName: "cadence_errors_incomplete_history", metricType: Counter,
},
CadenceErrNonDeterministicPerTaskListCounter: {
metricName: "cadence_errors_nondeterministic_per_tl", metricRollupName: "cadence_errors_nondeterministic", metricType: Counter,
},
CadenceErrUnauthorizedPerTaskListCounter: {
metricName: "cadence_errors_unauthorized_per_tl", metricRollupName: "cadence_errors_unauthorized", metricType: Counter,
},
CadenceErrAuthorizeFailedPerTaskListCounter: {
metricName: "cadence_errors_authorize_failed_per_tl", metricRollupName: "cadence_errors_authorize_failed", metricType: Counter,
},
CadenceErrRemoteSyncMatchFailedPerTaskListCounter: {
metricName: "cadence_errors_remote_syncmatch_failed_per_tl", metricRollupName: "cadence_errors_remote_syncmatch_failed", metricType: Counter,
},
CadenceErrStickyWorkerUnavailablePerTaskListCounter: {
metricName: "cadence_errors_sticky_worker_unavailable_per_tl", metricRollupName: "cadence_errors_sticky_worker_unavailable_per_tl", metricType: Counter,
},
CadenceShardSuccessGauge: {metricName: "cadence_shard_success", metricType: Gauge},
CadenceShardFailureGauge: {metricName: "cadence_shard_failure", metricType: Gauge},
DomainReplicationQueueSizeGauge: {metricName: "domain_replication_queue_size", metricType: Gauge},
DomainReplicationQueueSizeErrorCount: {metricName: "domain_replication_queue_failed", metricType: Counter},
ParentClosePolicyProcessorSuccess: {metricName: "parent_close_policy_processor_requests", metricType: Counter},
ParentClosePolicyProcessorFailures: {metricName: "parent_close_policy_processor_errors", metricType: Counter},
IsolationGroupStatePollerUnavailable: {metricName: "isolation_group_poller_unavailable", metricType: Counter},
IsolationGroupStateDrained: {metricName: "isolation_group_drained", metricType: Counter},
IsolationGroupStateHealthy: {metricName: "isolation_group_healthy", metricType: Counter},
ValidatedWorkflowCount: {metricName: "task_validator_count", metricType: Counter},
HashringViewIdentifier: {metricName: "hashring_view_identifier", metricType: Counter},
},
History: {
TaskRequests: {metricName: "task_requests", metricType: Counter},
TaskLatency: {metricName: "task_latency", metricType: Timer},
TaskAttemptTimer: {metricName: "task_attempt", metricType: Timer},
TaskFailures: {metricName: "task_errors", metricType: Counter},
TaskDiscarded: {metricName: "task_errors_discarded", metricType: Counter},
TaskStandbyRetryCounter: {metricName: "task_errors_standby_retry_counter", metricType: Counter},
TaskNotActiveCounter: {metricName: "task_errors_not_active_counter", metricType: Counter},
TaskLimitExceededCounter: {metricName: "task_errors_limit_exceeded_counter", metricType: Counter},
TaskProcessingLatency: {metricName: "task_latency_processing", metricType: Timer},
TaskQueueLatency: {metricName: "task_latency_queue", metricType: Timer},
// per domain task metrics
TaskRequestsPerDomain: {metricName: "task_requests_per_domain", metricRollupName: "task_requests", metricType: Counter},
TaskLatencyPerDomain: {metricName: "task_latency_per_domain", metricRollupName: "task_latency", metricType: Timer},
TaskAttemptTimerPerDomain: {metricName: "task_attempt_per_domain", metricRollupName: "task_attempt", metricType: Timer},
TaskFailuresPerDomain: {metricName: "task_errors_per_domain", metricRollupName: "task_errors", metricType: Counter},
TaskWorkflowBusyPerDomain: {metricName: "task_errors_workflow_busy_per_domain", metricRollupName: "task_errors_workflow_busy", metricType: Counter},
TaskDiscardedPerDomain: {metricName: "task_errors_discarded_per_domain", metricRollupName: "task_errors_discarded", metricType: Counter},
TaskUnsupportedPerDomain: {metricName: "task_errors_unsupported_per_domain", metricRollupName: "task_errors_discarded", metricType: Counter},
TaskStandbyRetryCounterPerDomain: {metricName: "task_errors_standby_retry_counter_per_domain", metricRollupName: "task_errors_standby_retry_counter", metricType: Counter},
TaskPendingActiveCounterPerDomain: {metricName: "task_errors_pending_active_counter_per_domain", metricRollupName: "task_errors_pending_active_counter", metricType: Counter},
TaskNotActiveCounterPerDomain: {metricName: "task_errors_not_active_counter_per_domain", metricRollupName: "task_errors_not_active_counter", metricType: Counter},
TaskTargetNotActiveCounterPerDomain: {metricName: "task_errors_target_not_active_counter_per_domain", metricRollupName: "task_errors_target_not_active_counter", metricType: Counter},
TaskLimitExceededCounterPerDomain: {metricName: "task_errors_limit_exceeded_counter_per_domain", metricRollupName: "task_errors_limit_exceeded_counter", metricType: Counter},
TaskProcessingLatencyPerDomain: {metricName: "task_latency_processing_per_domain", metricRollupName: "task_latency_processing", metricType: Timer},
TaskQueueLatencyPerDomain: {metricName: "task_latency_queue_per_domain", metricRollupName: "task_latency_queue", metricType: Timer},
TransferTaskMissingEventCounterPerDomain: {metricName: "transfer_task_missing_event_counter_per_domain", metricRollupName: "transfer_task_missing_event_counter", metricType: Counter},
ReplicationTasksAppliedPerDomain: {metricName: "replication_tasks_applied_per_domain", metricRollupName: "replication_tasks_applied", metricType: Counter},
TaskBatchCompleteCounter: {metricName: "task_batch_complete_counter", metricType: Counter},
TaskBatchCompleteFailure: {metricName: "task_batch_complete_error", metricType: Counter},
TaskRedispatchQueuePendingTasksTimer: {metricName: "task_redispatch_queue_pending_tasks", metricType: Timer},
TransferTaskThrottledCounter: {metricName: "transfer_task_throttled_counter", metricType: Counter},
TimerTaskThrottledCounter: {metricName: "timer_task_throttled_counter", metricType: Counter},
CrossClusterTaskThrottledCounter: {metricName: "cross_cluster_task_throttled_counter", metricType: Counter},
TransferTaskMissingEventCounter: {metricName: "transfer_task_missing_event_counter", metricType: Counter},
ProcessingQueueNumTimer: {metricName: "processing_queue_num", metricType: Timer},
ProcessingQueueMaxLevelTimer: {metricName: "processing_queue_max_level", metricType: Timer},
ProcessingQueuePendingTaskSplitCounter: {metricName: "processing_queue_pending_task_split_counter", metricType: Counter},
ProcessingQueueStuckTaskSplitCounter: {metricName: "processing_queue_stuck_task_split_counter", metricType: Counter},
ProcessingQueueSelectedDomainSplitCounter: {metricName: "processing_queue_selected_domain_split_counter", metricType: Counter},
ProcessingQueueRandomSplitCounter: {metricName: "processing_queue_random_split_counter", metricType: Counter},
ProcessingQueueThrottledCounter: {metricName: "processing_queue_throttled_counter", metricType: Counter},
QueueValidatorLostTaskCounter: {metricName: "queue_validator_lost_task_counter", metricType: Counter},
QueueValidatorDropTaskCounter: {metricName: "queue_validator_drop_task_counter", metricType: Counter},
QueueValidatorInvalidLoadCounter: {metricName: "queue_validator_invalid_load_counter", metricType: Counter},
QueueValidatorValidationCounter: {metricName: "queue_validator_validation_counter", metricType: Counter},
QueueValidatorValidationFailure: {metricName: "queue_validator_validation_error", metricType: Counter},
CrossClusterFetchLatency: {metricName: "cross_cluster_fetch_latency", metricType: Timer},
CrossClusterFetchRequests: {metricName: "cross_cluster_fetch_requests", metricType: Counter},
CrossClusterFetchFailures: {metricName: "cross_cluster_fetch_errors", metricType: Counter},
CrossClusterFetchServiceBusyFailures: {metricName: "cross_cluster_fetch_errors_service_busy", metricType: Counter},
CrossClusterTaskRespondLatency: {metricName: "cross_cluster_respond_latency", metricType: Timer},
CrossClusterTaskRespondRequests: {metricName: "cross_cluster_respond_requests", metricType: Counter},
CrossClusterTaskRespondFailures: {metricName: "cross_cluster_fetch_errors", metricType: Counter},
CrossClusterTaskFetchedTimer: {metricName: "cross_cluster_task_fetched", metricType: Timer},
CrossClusterTaskPendingTimer: {metricName: "cross_cluster_task_pending", metricType: Timer},
ClusterMetadataFailureToResolveCounter: {metricName: "failed_to_resolve_failover_version", metricType: Counter},
ClusterMetadataGettingMinFailoverVersionCounter: {metricName: "getting_min_failover_version_counter", metricType: Counter},
ClusterMetadataGettingFailoverVersionCounter: {metricName: "getting_failover_version_counter", metricType: Counter},
ClusterMetadataResolvingFailoverVersionCounter: {metricName: "resolving_failover_version_counter", metricType: Counter},
ClusterMetadataResolvingMinFailoverVersionCounter: {metricName: "resolving_min_failover_version_counter", metricType: Counter},
ActivityE2ELatency: {metricName: "activity_end_to_end_latency", metricType: Timer},
ActivityLostCounter: {metricName: "activity_lost", metricType: Counter},
AckLevelUpdateCounter: {metricName: "ack_level_update", metricType: Counter},
AckLevelUpdateFailedCounter: {metricName: "ack_level_update_failed", metricType: Counter},
DecisionTypeScheduleActivityCounter: {metricName: "schedule_activity_decision", metricType: Counter},
DecisionTypeScheduleActivityDispatchSucceedCounter: {metricName: "schedule_activity_decision_sync_match_succeed", metricType: Counter},
DecisionTypeScheduleActivityDispatchCounter: {metricName: "schedule_activity_decision_try_sync_match", metricType: Counter},
DecisionTypeCompleteWorkflowCounter: {metricName: "complete_workflow_decision", metricType: Counter},
DecisionTypeFailWorkflowCounter: {metricName: "fail_workflow_decision", metricType: Counter},
DecisionTypeCancelWorkflowCounter: {metricName: "cancel_workflow_decision", metricType: Counter},
DecisionTypeStartTimerCounter: {metricName: "start_timer_decision", metricType: Counter},
DecisionTypeCancelActivityCounter: {metricName: "cancel_activity_decision", metricType: Counter},
DecisionTypeCancelTimerCounter: {metricName: "cancel_timer_decision", metricType: Counter},
DecisionTypeRecordMarkerCounter: {metricName: "record_marker_decision", metricType: Counter},
DecisionTypeCancelExternalWorkflowCounter: {metricName: "cancel_external_workflow_decision", metricType: Counter},
DecisionTypeContinueAsNewCounter: {metricName: "continue_as_new_decision", metricType: Counter},
DecisionTypeSignalExternalWorkflowCounter: {metricName: "signal_external_workflow_decision", metricType: Counter},
DecisionTypeUpsertWorkflowSearchAttributesCounter: {metricName: "upsert_workflow_search_attributes_decision", metricType: Counter},
DecisionTypeChildWorkflowCounter: {metricName: "child_workflow_decision", metricType: Counter},
EmptyCompletionDecisionsCounter: {metricName: "empty_completion_decisions", metricType: Counter},
MultipleCompletionDecisionsCounter: {metricName: "multiple_completion_decisions", metricType: Counter},
FailedDecisionsCounter: {metricName: "failed_decisions", metricType: Counter},
DecisionAttemptTimer: {metricName: "decision_attempt", metricType: Timer},
DecisionRetriesExceededCounter: {metricName: "decision_retries_exceeded", metricType: Counter},
StaleMutableStateCounter: {metricName: "stale_mutable_state", metricType: Counter},
DataInconsistentCounter: {metricName: "data_inconsistent", metricType: Counter},
TimerResurrectionCounter: {metricName: "timer_resurrection", metricType: Counter},
ActivityResurrectionCounter: {metricName: "activity_resurrection", metricType: Counter},
AutoResetPointsLimitExceededCounter: {metricName: "auto_reset_points_exceed_limit", metricType: Counter},
AutoResetPointCorruptionCounter: {metricName: "auto_reset_point_corruption", metricType: Counter},
ConcurrencyUpdateFailureCounter: {metricName: "concurrency_update_failure", metricType: Counter},
CadenceErrShardOwnershipLostCounter: {metricName: "cadence_errors_shard_ownership_lost", metricType: Counter},
CadenceErrEventAlreadyStartedCounter: {metricName: "cadence_errors_event_already_started", metricType: Counter},
HeartbeatTimeoutCounter: {metricName: "heartbeat_timeout", metricType: Counter},
ScheduleToStartTimeoutCounter: {metricName: "schedule_to_start_timeout", metricType: Counter},
StartToCloseTimeoutCounter: {metricName: "start_to_close_timeout", metricType: Counter},
ScheduleToCloseTimeoutCounter: {metricName: "schedule_to_close_timeout", metricType: Counter},
NewTimerCounter: {metricName: "new_timer", metricType: Counter},
NewTimerNotifyCounter: {metricName: "new_timer_notifications", metricType: Counter},
AcquireShardsCounter: {metricName: "acquire_shards_count", metricType: Counter},
AcquireShardsLatency: {metricName: "acquire_shards_latency", metricType: Timer},
ShardClosedCounter: {metricName: "shard_closed_count", metricType: Counter},
ShardItemCreatedCounter: {metricName: "sharditem_created_count", metricType: Counter},
ShardItemRemovedCounter: {metricName: "sharditem_removed_count", metricType: Counter},
ShardItemAcquisitionLatency: {metricName: "sharditem_acquisition_latency", metricType: Timer},
ShardInfoReplicationPendingTasksTimer: {metricName: "shardinfo_replication_pending_task", metricType: Timer},
ShardInfoTransferActivePendingTasksTimer: {metricName: "shardinfo_transfer_active_pending_task", metricType: Timer},
ShardInfoTransferStandbyPendingTasksTimer: {metricName: "shardinfo_transfer_standby_pending_task", metricType: Timer},
ShardInfoTimerActivePendingTasksTimer: {metricName: "shardinfo_timer_active_pending_task", metricType: Timer},
ShardInfoTimerStandbyPendingTasksTimer: {metricName: "shardinfo_timer_standby_pending_task", metricType: Timer},
ShardInfoCrossClusterPendingTasksTimer: {metricName: "shardinfo_cross_cluster_pending_task", metricType: Timer},
ShardInfoReplicationLagTimer: {metricName: "shardinfo_replication_lag", metricType: Timer},
ShardInfoTransferLagTimer: {metricName: "shardinfo_transfer_lag", metricType: Timer},
ShardInfoTimerLagTimer: {metricName: "shardinfo_timer_lag", metricType: Timer},
ShardInfoCrossClusterLagTimer: {metricName: "shardinfo_cross_cluster_lag", metricType: Timer},
ShardInfoTransferDiffTimer: {metricName: "shardinfo_transfer_diff", metricType: Timer},
ShardInfoTimerDiffTimer: {metricName: "shardinfo_timer_diff", metricType: Timer},
ShardInfoTransferFailoverInProgressTimer: {metricName: "shardinfo_transfer_failover_in_progress", metricType: Timer},
ShardInfoTimerFailoverInProgressTimer: {metricName: "shardinfo_timer_failover_in_progress", metricType: Timer},
ShardInfoTransferFailoverLatencyTimer: {metricName: "shardinfo_transfer_failover_latency", metricType: Timer},
ShardInfoTimerFailoverLatencyTimer: {metricName: "shardinfo_timer_failover_latency", metricType: Timer},
SyncShardFromRemoteCounter: {metricName: "syncshard_remote_count", metricType: Counter},
SyncShardFromRemoteFailure: {metricName: "syncshard_remote_failed", metricType: Counter},
MembershipChangedCounter: {metricName: "membership_changed_count", metricType: Counter},
NumShardsGauge: {metricName: "numshards_gauge", metricType: Gauge},
GetEngineForShardErrorCounter: {metricName: "get_engine_for_shard_errors", metricType: Counter},
GetEngineForShardLatency: {metricName: "get_engine_for_shard_latency", metricType: Timer},
RemoveEngineForShardLatency: {metricName: "remove_engine_for_shard_latency", metricType: Timer},
CompleteDecisionWithStickyEnabledCounter: {metricName: "complete_decision_sticky_enabled_count", metricType: Counter},
CompleteDecisionWithStickyDisabledCounter: {metricName: "complete_decision_sticky_disabled_count", metricType: Counter},
DecisionHeartbeatTimeoutCounter: {metricName: "decision_heartbeat_timeout_count", metricType: Counter},
HistoryEventNotificationQueueingLatency: {metricName: "history_event_notification_queueing_latency", metricType: Timer},
HistoryEventNotificationFanoutLatency: {metricName: "history_event_notification_fanout_latency", metricType: Timer},
HistoryEventNotificationInFlightMessageGauge: {metricName: "history_event_notification_inflight_message_gauge", metricType: Gauge},
HistoryEventNotificationFailDeliveryCount: {metricName: "history_event_notification_fail_delivery_count", metricType: Counter},
EmptyReplicationEventsCounter: {metricName: "empty_replication_events", metricType: Counter},
DuplicateReplicationEventsCounter: {metricName: "duplicate_replication_events", metricType: Counter},
StaleReplicationEventsCounter: {metricName: "stale_replication_events", metricType: Counter},
ReplicationEventsSizeTimer: {metricName: "replication_events_size", metricType: Timer},
BufferReplicationTaskTimer: {metricName: "buffer_replication_tasks", metricType: Timer},
UnbufferReplicationTaskTimer: {metricName: "unbuffer_replication_tasks", metricType: Timer},
HistoryConflictsCounter: {metricName: "history_conflicts", metricType: Counter},
CompleteTaskFailedCounter: {metricName: "complete_task_fail_count", metricType: Counter},
CacheSize: {metricName: "cache_size", metricType: Timer},
CacheRequests: {metricName: "cache_requests", metricType: Counter},
CacheFailures: {metricName: "cache_errors", metricType: Counter},
CacheLatency: {metricName: "cache_latency", metricType: Timer},
CacheHitCounter: {metricName: "cache_hit", metricType: Counter},
CacheMissCounter: {metricName: "cache_miss", metricType: Counter},
CacheFullCounter: {metricName: "cache_full", metricType: Counter},
AcquireLockFailedCounter: {metricName: "acquire_lock_failed", metricType: Counter},
WorkflowContextCleared: {metricName: "workflow_context_cleared", metricType: Counter},
MutableStateSize: {metricName: "mutable_state_size", metricType: Timer},
ExecutionInfoSize: {metricName: "execution_info_size", metricType: Timer},
ActivityInfoSize: {metricName: "activity_info_size", metricType: Timer},
TimerInfoSize: {metricName: "timer_info_size", metricType: Timer},
ChildInfoSize: {metricName: "child_info_size", metricType: Timer},
SignalInfoSize: {metricName: "signal_info_size", metricType: Timer},
BufferedEventsSize: {metricName: "buffered_events_size", metricType: Timer},
ActivityInfoCount: {metricName: "activity_info_count", metricType: Timer},
TimerInfoCount: {metricName: "timer_info_count", metricType: Timer},
ChildInfoCount: {metricName: "child_info_count", metricType: Timer},
SignalInfoCount: {metricName: "signal_info_count", metricType: Timer},
RequestCancelInfoCount: {metricName: "request_cancel_info_count", metricType: Timer},
BufferedEventsCount: {metricName: "buffered_events_count", metricType: Timer},
DeleteActivityInfoCount: {metricName: "delete_activity_info", metricType: Timer},
DeleteTimerInfoCount: {metricName: "delete_timer_info", metricType: Timer},
DeleteChildInfoCount: {metricName: "delete_child_info", metricType: Timer},
DeleteSignalInfoCount: {metricName: "delete_signal_info", metricType: Timer},
DeleteRequestCancelInfoCount: {metricName: "delete_request_cancel_info", metricType: Timer},
WorkflowRetryBackoffTimerCount: {metricName: "workflow_retry_backoff_timer", metricType: Counter},
WorkflowCronBackoffTimerCount: {metricName: "workflow_cron_backoff_timer", metricType: Counter},
WorkflowCleanupDeleteCount: {metricName: "workflow_cleanup_delete", metricType: Counter},
WorkflowCleanupArchiveCount: {metricName: "workflow_cleanup_archive", metricType: Counter},
WorkflowCleanupNopCount: {metricName: "workflow_cleanup_nop", metricType: Counter},
WorkflowCleanupDeleteHistoryInlineCount: {metricName: "workflow_cleanup_delete_history_inline", metricType: Counter},
WorkflowSuccessCount: {metricName: "workflow_success", metricType: Counter},
WorkflowCancelCount: {metricName: "workflow_cancel", metricType: Counter},
WorkflowFailedCount: {metricName: "workflow_failed", metricType: Counter},
WorkflowTimeoutCount: {metricName: "workflow_timeout", metricType: Counter},
WorkflowTerminateCount: {metricName: "workflow_terminate", metricType: Counter},
WorkflowContinuedAsNew: {metricName: "workflow_continued_as_new", metricType: Counter},
WorkflowCompletedUnknownType: {metricName: "workflow_completed_unknown_type", metricType: Counter},
ArchiverClientSendSignalCount: {metricName: "archiver_client_sent_signal", metricType: Counter},
ArchiverClientSendSignalFailureCount: {metricName: "archiver_client_send_signal_error", metricType: Counter},
ArchiverClientHistoryRequestCount: {metricName: "archiver_client_history_request", metricType: Counter},
ArchiverClientHistoryInlineArchiveAttemptCount: {metricName: "archiver_client_history_inline_archive_attempt", metricType: Counter},
ArchiverClientHistoryInlineArchiveFailureCount: {metricName: "archiver_client_history_inline_archive_failure", metricType: Counter},
ArchiverClientHistoryInlineArchiveThrottledCount: {metricName: "archiver_client_history_inline_archive_throttled", metricType: Counter},
ArchiverClientVisibilityRequestCount: {metricName: "archiver_client_visibility_request", metricType: Counter},
ArchiverClientVisibilityInlineArchiveAttemptCount: {metricName: "archiver_client_visibility_inline_archive_attempt", metricType: Counter},
ArchiverClientVisibilityInlineArchiveFailureCount: {metricName: "archiver_client_visibility_inline_archive_failure", metricType: Counter},
ArchiverClientVisibilityInlineArchiveThrottledCount: {metricName: "archiver_client_visibility_inline_archive_throttled", metricType: Counter},
ArchiverClientSendSignalCountPerDomain: {metricName: "archiver_client_sent_signal_per_domain", metricRollupName: "archiver_client_sent_signal", metricType: Counter},
ArchiverClientSendSignalFailureCountPerDomain: {metricName: "archiver_client_send_signal_error_per_domain", metricRollupName: "archiver_client_send_signal_error", metricType: Counter},
ArchiverClientHistoryRequestCountPerDomain: {metricName: "archiver_client_history_request_per_domain", metricRollupName: "archiver_client_history_request", metricType: Counter},
ArchiverClientHistoryInlineArchiveAttemptCountPerDomain: {metricName: "archiver_client_history_inline_archive_attempt_per_domain", metricRollupName: "archiver_client_history_inline_archive_attempt", metricType: Counter},
ArchiverClientHistoryInlineArchiveFailureCountPerDomain: {metricName: "archiver_client_history_inline_archive_failure_per_domain", metricRollupName: "archiver_client_history_inline_archive_failure", metricType: Counter},
ArchiverClientHistoryInlineArchiveThrottledCountPerDomain: {metricName: "archiver_client_history_inline_archive_throttled_per_domain", metricRollupName: "archiver_client_history_inline_archive_throttled", metricType: Counter},
ArchiverClientVisibilityRequestCountPerDomain: {metricName: "archiver_client_visibility_request_per_domain", metricRollupName: "archiver_client_visibility_request", metricType: Counter},
ArchiverClientVisibilityInlineArchiveAttemptCountPerDomain: {metricName: "archiver_client_visibility_inline_archive_attempt_per_domain", metricRollupName: "archiver_client_visibility_inline_archive_attempt", metricType: Counter},
ArchiverClientVisibilityInlineArchiveFailureCountPerDomain: {metricName: "archiver_client_visibility_inline_archive_failure_per_domain", metricRollupName: "archiver_client_visibility_inline_archive_failure", metricType: Counter},
ArchiverClientVisibilityInlineArchiveThrottledCountPerDomain: {metricName: "archiver_client_visibility_inline_archive_throttled_per_domain", metricRollupName: "archiver_client_visibility_inline_archive_throttled", metricType: Counter},
LastRetrievedMessageID: {metricName: "last_retrieved_message_id", metricType: Gauge},
LastProcessedMessageID: {metricName: "last_processed_message_id", metricType: Gauge},
ReplicationLatency: {metricName: "replication_latency", metricType: Gauge},
ReplicationTasksApplied: {metricName: "replication_tasks_applied", metricType: Counter},
ReplicationTasksFailed: {metricName: "replication_tasks_failed", metricType: Counter},
ReplicationTasksLag: {metricName: "replication_tasks_lag", metricType: Timer},
ReplicationTasksFetched: {metricName: "replication_tasks_fetched", metricType: Timer},
ReplicationTasksReturned: {metricName: "replication_tasks_returned", metricType: Timer},
ReplicationTasksReturnedDiff: {metricName: "replication_tasks_returned_diff", metricType: Timer},
ReplicationTasksAppliedLatency: {metricName: "replication_tasks_applied_latency", metricType: Timer},
ReplicationDLQFailed: {metricName: "replication_dlq_enqueue_failed", metricType: Counter},
ReplicationDLQMaxLevelGauge: {metricName: "replication_dlq_max_level", metricType: Gauge},
ReplicationDLQAckLevelGauge: {metricName: "replication_dlq_ack_level", metricType: Gauge},
ReplicationDLQProbeFailed: {metricName: "replication_dlq_probe_failed", metricType: Counter},
ReplicationDLQSize: {metricName: "replication_dlq_size", metricType: Gauge},
ReplicationDLQValidationFailed: {metricName: "replication_dlq_validation_failed", metricType: Counter},
GetReplicationMessagesForShardLatency: {metricName: "get_replication_messages_for_shard", metricType: Timer},
GetDLQReplicationMessagesLatency: {metricName: "get_dlq_replication_messages", metricType: Timer},
EventReapplySkippedCount: {metricName: "event_reapply_skipped_count", metricType: Counter},
DirectQueryDispatchLatency: {metricName: "direct_query_dispatch_latency", metricType: Timer},
DirectQueryDispatchStickyLatency: {metricName: "direct_query_dispatch_sticky_latency", metricType: Timer},
DirectQueryDispatchNonStickyLatency: {metricName: "direct_query_dispatch_non_sticky_latency", metricType: Timer},
DirectQueryDispatchStickySuccessCount: {metricName: "direct_query_dispatch_sticky_success", metricType: Counter},
DirectQueryDispatchNonStickySuccessCount: {metricName: "direct_query_dispatch_non_sticky_success", metricType: Counter},
DirectQueryDispatchClearStickinessLatency: {metricName: "direct_query_dispatch_clear_stickiness_latency", metricType: Timer},
DirectQueryDispatchClearStickinessSuccessCount: {metricName: "direct_query_dispatch_clear_stickiness_success", metricType: Counter},
DirectQueryDispatchTimeoutBeforeNonStickyCount: {metricName: "direct_query_dispatch_timeout_before_non_sticky", metricType: Counter},
DecisionTaskQueryLatency: {metricName: "decision_task_query_latency", metricType: Timer},
ConsistentQueryPerShard: {metricName: "consistent_query_per_shard", metricType: Counter},
ConsistentQueryTimeoutCount: {metricName: "consistent_query_timeout", metricType: Counter},
QueryBeforeFirstDecisionCount: {metricName: "query_before_first_decision", metricType: Counter},
QueryBufferExceededCount: {metricName: "query_buffer_exceeded", metricType: Counter},
QueryRegistryInvalidStateCount: {metricName: "query_registry_invalid_state", metricType: Counter},
WorkerNotSupportsConsistentQueryCount: {metricName: "worker_not_supports_consistent_query", metricType: Counter},
DecisionStartToCloseTimeoutOverrideCount: {metricName: "decision_start_to_close_timeout_overrides", metricType: Counter},
ReplicationTaskCleanupCount: {metricName: "replication_task_cleanup_count", metricType: Counter},
ReplicationTaskCleanupFailure: {metricName: "replication_task_cleanup_failed", metricType: Counter},
ReplicationTaskLatency: {metricName: "replication_task_latency", metricType: Timer},
MutableStateChecksumMismatch: {metricName: "mutable_state_checksum_mismatch", metricType: Counter},
MutableStateChecksumInvalidated: {metricName: "mutable_state_checksum_invalidated", metricType: Counter},
FailoverMarkerCount: {metricName: "failover_marker_count", metricType: Counter},
FailoverMarkerReplicationLatency: {metricName: "failover_marker_replication_latency", metricType: Timer},
FailoverMarkerInsertFailure: {metricName: "failover_marker_insert_failures", metricType: Counter},
FailoverMarkerNotificationFailure: {metricName: "failover_marker_notification_failures", metricType: Counter},
FailoverMarkerUpdateShardFailure: {metricName: "failover_marker_update_shard_failures", metricType: Counter},
FailoverMarkerCallbackCount: {metricName: "failover_marker_callback_count", metricType: Counter},
HistoryFailoverCallbackCount: {metricName: "failover_callback_handler_count", metricType: Counter},
TransferTasksCount: {metricName: "transfer_tasks_count", metricType: Timer},
TimerTasksCount: {metricName: "timer_tasks_count", metricType: Timer},
CrossClusterTasksCount: {metricName: "cross_cluster_tasks_count", metricType: Timer},
ReplicationTasksCount: {metricName: "replication_tasks_count", metricType: Timer},
WorkflowVersionCount: {metricName: "workflow_version_count", metricType: Gauge},
WorkflowTypeCount: {metricName: "workflow_type_count", metricType: Gauge},
WorkflowStartedCount: {metricName: "workflow_started_count", metricType: Counter},
LargeHistoryBlobCount: {metricName: "large_history_blob_count", metricType: Counter},
LargeHistoryEventCount: {metricName: "large_history_event_count", metricType: Counter},
LargeHistorySizeCount: {metricName: "large_history_size_count", metricType: Counter},
UpdateWorkflowExecutionCount: {metricName: "update_workflow_execution_count", metricType: Counter},
WorkflowIDCacheSizeGauge: {metricName: "workflow_id_cache_size", metricType: Gauge},
WorkflowIDCacheRequestsExternalRatelimitedCounter: {metricName: "workflow_id_external_requests_ratelimited", metricType: Counter},
WorkflowIDCacheRequestsInternalRatelimitedCounter: {metricName: "workflow_id_internal_requests_ratelimited", metricType: Counter},
},
Matching: {
PollSuccessPerTaskListCounter: {metricName: "poll_success_per_tl", metricRollupName: "poll_success"},
PollTimeoutPerTaskListCounter: {metricName: "poll_timeouts_per_tl", metricRollupName: "poll_timeouts"},
PollSuccessWithSyncPerTaskListCounter: {metricName: "poll_success_sync_per_tl", metricRollupName: "poll_success_sync"},
LeaseRequestPerTaskListCounter: {metricName: "lease_requests_per_tl", metricRollupName: "lease_requests"},
LeaseFailurePerTaskListCounter: {metricName: "lease_failures_per_tl", metricRollupName: "lease_failures"},
ConditionFailedErrorPerTaskListCounter: {metricName: "condition_failed_errors_per_tl", metricRollupName: "condition_failed_errors"},
RespondQueryTaskFailedPerTaskListCounter: {metricName: "respond_query_failed_per_tl", metricRollupName: "respond_query_failed"},
SyncThrottlePerTaskListCounter: {metricName: "sync_throttle_count_per_tl", metricRollupName: "sync_throttle_count"},
BufferThrottlePerTaskListCounter: {metricName: "buffer_throttle_count_per_tl", metricRollupName: "buffer_throttle_count"},
BufferUnknownTaskDispatchError: {metricName: "buffer_unknown_task_dispatch_error_per_tl", metricRollupName: "buffer_unknown_task_dispatch_error"},
BufferIsolationGroupRedirectCounter: {metricName: "buffer_isolation_group_redirected_per_tl", metricRollupName: "buffer_isolation_group_redirected"},
BufferIsolationGroupRedirectFailureCounter: {metricName: "buffer_isolation_group_redirect_failure_per_tl", metricRollupName: "buffer_isolation_group_redirect_failure"},
BufferIsolationGroupMisconfiguredCounter: {metricName: "buffer_isolation_group_misconfigured_failure_per_tl", metricRollupName: "buffer_isolation_group_misconfigured_failure"},
ExpiredTasksPerTaskListCounter: {metricName: "tasks_expired_per_tl", metricRollupName: "tasks_expired"},
ForwardedPerTaskListCounter: {metricName: "forwarded_per_tl", metricRollupName: "forwarded"},
ForwardTaskCallsPerTaskList: {metricName: "forward_task_calls_per_tl", metricRollupName: "forward_task_calls"},
ForwardTaskErrorsPerTaskList: {metricName: "forward_task_errors_per_tl", metricRollupName: "forward_task_errors"},
ForwardQueryCallsPerTaskList: {metricName: "forward_query_calls_per_tl", metricRollupName: "forward_query_calls"},
ForwardQueryErrorsPerTaskList: {metricName: "forward_query_errors_per_tl", metricRollupName: "forward_query_errors"},
ForwardPollCallsPerTaskList: {metricName: "forward_poll_calls_per_tl", metricRollupName: "forward_poll_calls"},
ForwardPollErrorsPerTaskList: {metricName: "forward_poll_errors_per_tl", metricRollupName: "forward_poll_errors"},
SyncMatchLatencyPerTaskList: {metricName: "syncmatch_latency_per_tl", metricRollupName: "syncmatch_latency", metricType: Timer},
AsyncMatchLatencyPerTaskList: {metricName: "asyncmatch_latency_per_tl", metricRollupName: "asyncmatch_latency", metricType: Timer},
AsyncMatchDispatchLatencyPerTaskList: {metricName: "asyncmatch_dispatch_latency_per_tl", metricRollupName: "asyncmatch_dispatch_latency", metricType: Timer},
AsyncMatchDispatchTimeoutCounterPerTaskList: {metricName: "asyncmatch_dispatch_timeouts_per_tl", metricRollupName: "asyncmatch_dispatch_timeouts"},
ForwardTaskLatencyPerTaskList: {metricName: "forward_task_latency_per_tl", metricRollupName: "forward_task_latency"},
ForwardQueryLatencyPerTaskList: {metricName: "forward_query_latency_per_tl", metricRollupName: "forward_query_latency"},
ForwardPollLatencyPerTaskList: {metricName: "forward_poll_latency_per_tl", metricRollupName: "forward_poll_latency"},
LocalToLocalMatchPerTaskListCounter: {metricName: "local_to_local_matches_per_tl", metricRollupName: "local_to_local_matches"},
LocalToRemoteMatchPerTaskListCounter: {metricName: "local_to_remote_matches_per_tl", metricRollupName: "local_to_remote_matches"},
RemoteToLocalMatchPerTaskListCounter: {metricName: "remote_to_local_matches_per_tl", metricRollupName: "remote_to_local_matches"},
RemoteToRemoteMatchPerTaskListCounter: {metricName: "remote_to_remote_matches_per_tl", metricRollupName: "remote_to_remote_matches"},
IsolationTaskMatchPerTaskListCounter: {metricName: "isolation_task_matches_per_tl", metricType: Counter},
PollerPerTaskListCounter: {metricName: "poller_count_per_tl", metricRollupName: "poller_count"},
PollerInvalidIsolationGroupCounter: {metricName: "poller_invalid_isolation_group_per_tl", metricType: Counter},
TaskListManagersGauge: {metricName: "tasklist_managers", metricType: Gauge},
TaskLagPerTaskListGauge: {metricName: "task_lag_per_tl", metricType: Gauge},
TaskBacklogPerTaskListGauge: {metricName: "task_backlog_per_tl", metricType: Gauge},
TaskCountPerTaskListGauge: {metricName: "task_count_per_tl", metricType: Gauge},
},
Worker: {
ReplicatorMessages: {metricName: "replicator_messages"},
ReplicatorFailures: {metricName: "replicator_errors"},
ReplicatorMessagesDropped: {metricName: "replicator_messages_dropped"},
ReplicatorLatency: {metricName: "replicator_latency"},
ReplicatorDLQFailures: {metricName: "replicator_dlq_enqueue_fails", metricType: Counter},
ESProcessorRequests: {metricName: "es_processor_requests"},
ESProcessorRetries: {metricName: "es_processor_retries"},
ESProcessorFailures: {metricName: "es_processor_errors"},
ESProcessorCorruptedData: {metricName: "es_processor_corrupted_data"},
ESProcessorProcessMsgLatency: {metricName: "es_processor_process_msg_latency", metricType: Timer},
IndexProcessorCorruptedData: {metricName: "index_processor_corrupted_data"},
IndexProcessorProcessMsgLatency: {metricName: "index_processor_process_msg_latency", metricType: Timer},
ArchiverNonRetryableErrorCount: {metricName: "archiver_non_retryable_error"},
ArchiverStartedCount: {metricName: "archiver_started"},
ArchiverStoppedCount: {metricName: "archiver_stopped"},
ArchiverCoroutineStartedCount: {metricName: "archiver_coroutine_started"},
ArchiverCoroutineStoppedCount: {metricName: "archiver_coroutine_stopped"},
ArchiverHandleHistoryRequestLatency: {metricName: "archiver_handle_history_request_latency"},
ArchiverHandleVisibilityRequestLatency: {metricName: "archiver_handle_visibility_request_latency"},
ArchiverUploadWithRetriesLatency: {metricName: "archiver_upload_with_retries_latency"},
ArchiverDeleteWithRetriesLatency: {metricName: "archiver_delete_with_retries_latency"},
ArchiverUploadFailedAllRetriesCount: {metricName: "archiver_upload_failed_all_retries"},
ArchiverUploadSuccessCount: {metricName: "archiver_upload_success"},
ArchiverDeleteFailedAllRetriesCount: {metricName: "archiver_delete_failed_all_retries"},
ArchiverDeleteSuccessCount: {metricName: "archiver_delete_success"},
ArchiverHandleVisibilityFailedAllRetiresCount: {metricName: "archiver_handle_visibility_failed_all_retries"},
ArchiverHandleVisibilitySuccessCount: {metricName: "archiver_handle_visibility_success"},
ArchiverBacklogSizeGauge: {metricName: "archiver_backlog_size"},
ArchiverPumpTimeoutCount: {metricName: "archiver_pump_timeout"},
ArchiverPumpSignalThresholdCount: {metricName: "archiver_pump_signal_threshold"},
ArchiverPumpTimeoutWithoutSignalsCount: {metricName: "archiver_pump_timeout_without_signals"},
ArchiverPumpSignalChannelClosedCount: {metricName: "archiver_pump_signal_channel_closed"},
ArchiverWorkflowStartedCount: {metricName: "archiver_workflow_started"},
ArchiverNumPumpedRequestsCount: {metricName: "archiver_num_pumped_requests"},
ArchiverNumHandledRequestsCount: {metricName: "archiver_num_handled_requests"},
ArchiverPumpedNotEqualHandledCount: {metricName: "archiver_pumped_not_equal_handled"},
ArchiverHandleAllRequestsLatency: {metricName: "archiver_handle_all_requests_latency"},
ArchiverWorkflowStoppingCount: {metricName: "archiver_workflow_stopping"},
TaskProcessedCount: {metricName: "task_processed", metricType: Gauge},
TaskDeletedCount: {metricName: "task_deleted", metricType: Gauge},
TaskListProcessedCount: {metricName: "tasklist_processed", metricType: Gauge},
TaskListDeletedCount: {metricName: "tasklist_deleted", metricType: Gauge},
TaskListOutstandingCount: {metricName: "tasklist_outstanding", metricType: Gauge},
ExecutionsOutstandingCount: {metricName: "executions_outstanding", metricType: Gauge},
StartedCount: {metricName: "started", metricType: Counter},
StoppedCount: {metricName: "stopped", metricType: Counter},
ExecutorTasksDeferredCount: {metricName: "executor_deferred", metricType: Counter},
ExecutorTasksDroppedCount: {metricName: "executor_dropped", metricType: Counter},
BatcherProcessorSuccess: {metricName: "batcher_processor_requests", metricType: Counter},
BatcherProcessorFailures: {metricName: "batcher_processor_errors", metricType: Counter},
HistoryScavengerSuccessCount: {metricName: "scavenger_success", metricType: Counter},
HistoryScavengerErrorCount: {metricName: "scavenger_errors", metricType: Counter},
HistoryScavengerSkipCount: {metricName: "scavenger_skips", metricType: Counter},
DomainReplicationEnqueueDLQCount: {metricName: "domain_replication_dlq_enqueue_requests", metricType: Counter},
ScannerExecutionsGauge: {metricName: "scanner_executions", metricType: Gauge},
ScannerCorruptedGauge: {metricName: "scanner_corrupted", metricType: Gauge},
ScannerCheckFailedGauge: {metricName: "scanner_check_failed", metricType: Gauge},
ScannerCorruptionByTypeGauge: {metricName: "scanner_corruption_by_type", metricType: Gauge},
ScannerCorruptedOpenExecutionGauge: {metricName: "scanner_corrupted_open_execution", metricType: Gauge},
ScannerShardSizeMaxGauge: {metricName: "scanner_shard_size_max", metricType: Gauge},
ScannerShardSizeMedianGauge: {metricName: "scanner_shard_size_median", metricType: Gauge},
ScannerShardSizeMinGauge: {metricName: "scanner_shard_size_min", metricType: Gauge},
ScannerShardSizeNinetyGauge: {metricName: "scanner_shard_size_ninety", metricType: Gauge},
ScannerShardSizeSeventyFiveGauge: {metricName: "scanner_shard_size_seventy_five", metricType: Gauge},
ScannerShardSizeTwentyFiveGauge: {metricName: "scanner_shard_size_twenty_five", metricType: Gauge},
ScannerShardSizeTenGauge: {metricName: "scanner_shard_size_ten", metricType: Gauge},
ShardScannerScan: {metricName: "shardscanner_scan", metricType: Counter},
ShardScannerFix: {metricName: "shardscanner_fix", metricType: Counter},
DataCorruptionWorkflowFailure: {metricName: "data_corruption_workflow_failure", metricType: Counter},
DataCorruptionWorkflowSuccessCount: {metricName: "data_corruption_workflow_success", metricType: Counter},
DataCorruptionWorkflowCount: {metricName: "data_corruption_workflow_count", metricType: Counter},
DataCorruptionWorkflowSkipCount: {metricName: "data_corruption_workflow_skips", metricType: Counter},
ESAnalyzerNumStuckWorkflowsDiscovered: {metricName: "es_analyzer_num_stuck_workflows_discovered", metricType: Counter},
ESAnalyzerNumStuckWorkflowsRefreshed: {metricName: "es_analyzer_num_stuck_workflows_refreshed", metricType: Counter},
ESAnalyzerNumStuckWorkflowsFailedToRefresh: {metricName: "es_analyzer_num_stuck_workflows_failed_to_refresh", metricType: Counter},
ESAnalyzerNumLongRunningWorkflows: {metricName: "es_analyzer_num_long_running_workflows", metricType: Counter},
AsyncWorkflowConsumerCount: {metricName: "async_workflow_consumer_count", metricType: Gauge},
AsyncWorkflowProcessMsgLatency: {metricName: "async_workflow_process_msg_latency", metricType: Timer},
AsyncWorkflowFailureCorruptMsgCount: {metricName: "async_workflow_failure_corrupt_msg", metricType: Counter},
AsyncWorkflowFailureByFrontendCount: {metricName: "async_workflow_failure_by_frontend", metricType: Counter},
AsyncWorkflowSuccessCount: {metricName: "async_workflow_success", metricType: Counter},
},
}
// PersistenceLatencyBuckets contains duration buckets for measuring persistence latency
var PersistenceLatencyBuckets = tally.DurationBuckets([]time.Duration{
1 * time.Millisecond,
2 * time.Millisecond,
3 * time.Millisecond,
4 * time.Millisecond,
5 * time.Millisecond,
6 * time.Millisecond,
7 * time.Millisecond,
8 * time.Millisecond,
9 * time.Millisecond,
10 * time.Millisecond,
12 * time.Millisecond,
15 * time.Millisecond,
17 * time.Millisecond,
20 * time.Millisecond,
25 * time.Millisecond,
30 * time.Millisecond,
35 * time.Millisecond,
40 * time.Millisecond,
50 * time.Millisecond,
60 * time.Millisecond,
70 * time.Millisecond,
80 * time.Millisecond,
90 * time.Millisecond,
100 * time.Millisecond,
120 * time.Millisecond,
150 * time.Millisecond,
170 * time.Millisecond,
200 * time.Millisecond,
250 * time.Millisecond,
300 * time.Millisecond,
400 * time.Millisecond,
500 * time.Millisecond,
600 * time.Millisecond,
700 * time.Millisecond,
800 * time.Millisecond,
900 * time.Millisecond,
1 * time.Second,
2 * time.Second,
3 * time.Second,
4 * time.Second,
5 * time.Second,
6 * time.Second,
7 * time.Second,
8 * time.Second,
9 * time.Second,
10 * time.Second,
12 * time.Second,
15 * time.Second,
20 * time.Second,
25 * time.Second,
30 * time.Second,
35 * time.Second,
40 * time.Second,
50 * time.Second,
60 * time.Second,
})
// ErrorClass is an enum to help with classifying SLA vs. non-SLA errors (SLA = "service level agreement")
type ErrorClass uint8
const (
// NoError indicates that there is no error (error should be nil)
NoError = ErrorClass(iota)
// UserError indicates that this is NOT an SLA-reportable error
UserError
// InternalError indicates that this is an SLA-reportable error
InternalError
)
// Empty returns true if the metricName is an empty string
func (mn MetricName) Empty() bool {
return mn == ""
}
// String returns string representation of this metric name
func (mn MetricName) String() string {
return string(mn)
}