metrics

package
v1.14.0 Latest Latest
Warning

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

 Go to latest Published: Dec 13, 2021 License: MIT Imports: 46 Imported by: 13

Documentation

Overview

Package metrics is a generated GoMock package.

Package metrics is a generated GoMock package.

Index

Constants

View Source 
const (

	// FrameworkTally tally framework id
	FrameworkTally = "tally"
	// FrameworkOpentelemetry OpenTelemetry framework id
	FrameworkOpentelemetry = "opentelemetry"
)
View Source 
const (
	Dimensionless = "dimensionless"
	Milliseconds  = "milliseconds"
	Bytes         = "bytes"
)

MetricUnit supported values

View Source 
const (
	OperationTagName   = "operation"
	ServiceRoleTagName = "service_role"
	StatsTypeTagName   = "stats_type"
	CacheTypeTagName   = "cache_type"
	FailureTagName     = "failure"
	TaskTypeTagName    = "task_type"
	QueueTypeTagName   = "queue_type"
)

Common tags for all services

View Source 
const (
	HistoryRoleTagValue       = "history"
	MatchingRoleTagValue      = "matching"
	FrontendRoleTagValue      = "frontend"
	AdminRoleTagValue         = "admin"
	DCRedirectionRoleTagValue = "dc_redirection"
	BlobstoreRoleTagValue     = "blobstore"

	SizeStatsTypeTagValue  = "size"
	CountStatsTypeTagValue = "count"

	MutableStateCacheTypeTagValue = "mutablestate"
	EventsCacheTypeTagValue       = "events"
)

This package should hold all the metrics and tags for temporal

View Source 
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"
)

Common service base metrics

View Source 
const (
	UnknownScope = iota

	// PersistenceGetOrCreateShardScope tracks GetOrCreateShard calls made by service to persistence layer
	PersistenceGetOrCreateShardScope
	// 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
	// PersistenceListConcreteExecutionsScope tracks ListConcreteExecutions calls made by service to persistence layer
	PersistenceListConcreteExecutionsScope
	// PersistenceAddTasksScope tracks AddTasks calls made by service to persistence layer
	PersistenceAddTasksScope
	// PersistenceGetTransferTaskScope tracks GetTransferTask calls made by service to persistence layer
	PersistenceGetTransferTaskScope
	// 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

	// PersistenceGetVisibilityTaskScope tracks GetVisibilityTask calls made by service to persistence layer
	PersistenceGetVisibilityTaskScope
	// PersistenceGetVisibilityTasksScope tracks GetVisibilityTasks calls made by service to persistence layer
	PersistenceGetVisibilityTasksScope
	// PersistenceCompleteVisibilityTaskScope tracks CompleteVisibilityTasks calls made by service to persistence layer
	PersistenceCompleteVisibilityTaskScope
	// PersistenceRangeCompleteVisibilityTaskScope tracks CompleteVisibilityTasks calls made by service to persistence layer
	PersistenceRangeCompleteVisibilityTaskScope

	// PersistenceGetTieredStorageTaskScope tracks GetTieredStorageTask calls made by service to persistence layer
	PersistenceGetTieredStorageTaskScope
	// PersistenceGetTieredStorageTasksScope tracks GetTieredStorageTasks calls made by service to persistence layer
	PersistenceGetTieredStorageTasksScope
	// PersistenceCompleteTieredStorageTaskScope tracks CompleteTieredStorageTasks calls made by service to persistence layer
	PersistenceCompleteTieredStorageTaskScope
	// PersistenceRangeCompleteTieredStorageTaskScope tracks CompleteTieredStorageTasks calls made by service to persistence layer
	PersistenceRangeCompleteTieredStorageTaskScope

	// PersistenceGetReplicationTaskScope tracks GetReplicationTask calls made by service to persistence layer
	PersistenceGetReplicationTaskScope
	// 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
	// PersistenceDeleteReplicationTaskFromDLQScope tracks PersistenceDeleteReplicationTaskFromDLQScope calls made by service to persistence layer
	PersistenceDeleteReplicationTaskFromDLQScope
	// PersistenceRangeDeleteReplicationTaskFromDLQScope tracks PersistenceRangeDeleteReplicationTaskFromDLQScope calls made by service to persistence layer
	PersistenceRangeDeleteReplicationTaskFromDLQScope
	// PersistenceGetTimerTaskScope tracks GetTimerTask calls made by service to persistence layer
	PersistenceGetTimerTaskScope
	// PersistenceGetTimerTasksScope tracks GetTimerTasks calls made by service to persistence layer
	PersistenceGetTimerTasksScope
	// PersistenceCompleteTimerTaskScope tracks CompleteTimerTasks calls made by service to persistence layer
	PersistenceCompleteTimerTaskScope
	// PersistenceRangeCompleteTimerTaskScope tracks CompleteTimerTasks calls made by service to persistence layer
	PersistenceRangeCompleteTimerTaskScope
	// PersistenceCreateTaskScope tracks CreateTask calls made by service to persistence layer
	PersistenceCreateTaskScope
	// 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
	// PersistenceLeaseTaskQueueScope tracks LeaseTaskQueue calls made by service to persistence layer
	PersistenceLeaseTaskQueueScope
	// PersistenceUpdateTaskQueueScope tracks PersistenceUpdateTaskQueueScope calls made by service to persistence layer
	PersistenceUpdateTaskQueueScope
	// PersistenceListTaskQueueScope is the metric scope for persistence.TaskManager.ListTaskQueue API
	PersistenceListTaskQueueScope
	// PersistenceDeleteTaskQueueScope is the metric scope for persistence.TaskManager.DeleteTaskQueue API
	PersistenceDeleteTaskQueueScope
	// 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
	// PersistenceInitializeSystemNamespaceScope tracks InitializeSystemNamespaceScope calls made by service to persistence layer
	PersistenceInitializeSystemNamespaceScope
	// PersistenceCreateNamespaceScope tracks CreateNamespace calls made by service to persistence layer
	PersistenceCreateNamespaceScope
	// PersistenceGetNamespaceScope tracks GetNamespace calls made by service to persistence layer
	PersistenceGetNamespaceScope
	// PersistenceUpdateNamespaceScope tracks UpdateNamespace calls made by service to persistence layer
	PersistenceUpdateNamespaceScope
	// PersistenceDeleteNamespaceScope tracks DeleteNamespace calls made by service to persistence layer
	PersistenceDeleteNamespaceScope
	// PersistenceDeleteNamespaceByNameScope tracks DeleteNamespaceByName calls made by service to persistence layer
	PersistenceDeleteNamespaceByNameScope
	// PersistenceListNamespaceScope tracks DeleteNamespaceByName calls made by service to persistence layer
	PersistenceListNamespaceScope
	// PersistenceGetMetadataScope tracks DeleteNamespaceByName calls made by service to persistence layer
	PersistenceGetMetadataScope

	// VisibilityPersistenceRecordWorkflowExecutionStartedScope tracks RecordWorkflowExecutionStarted calls made by service to visibility persistence layer
	VisibilityPersistenceRecordWorkflowExecutionStartedScope
	// VisibilityPersistenceRecordWorkflowExecutionClosedScope tracks RecordWorkflowExecutionClosed calls made by service to visibility persistence layer
	VisibilityPersistenceRecordWorkflowExecutionClosedScope
	// VisibilityPersistenceUpsertWorkflowExecutionScope tracks UpsertWorkflowExecution calls made by service to persistence visibility layer
	VisibilityPersistenceUpsertWorkflowExecutionScope
	// VisibilityPersistenceListOpenWorkflowExecutionsScope tracks ListOpenWorkflowExecutions calls made by service to visibility persistence layer
	VisibilityPersistenceListOpenWorkflowExecutionsScope
	// VisibilityPersistenceListClosedWorkflowExecutionsScope tracks ListClosedWorkflowExecutions calls made by service to visibility persistence layer
	VisibilityPersistenceListClosedWorkflowExecutionsScope
	// VisibilityPersistenceListOpenWorkflowExecutionsByTypeScope tracks ListOpenWorkflowExecutionsByType calls made by service to visibility persistence layer
	VisibilityPersistenceListOpenWorkflowExecutionsByTypeScope
	// VisibilityPersistenceListClosedWorkflowExecutionsByTypeScope tracks ListClosedWorkflowExecutionsByType calls made by service to visibility persistence layer
	VisibilityPersistenceListClosedWorkflowExecutionsByTypeScope
	// VisibilityPersistenceListOpenWorkflowExecutionsByWorkflowIDScope tracks ListOpenWorkflowExecutionsByWorkflowID calls made by service to visibility persistence layer
	VisibilityPersistenceListOpenWorkflowExecutionsByWorkflowIDScope
	// VisibilityPersistenceListClosedWorkflowExecutionsByWorkflowIDScope tracks ListClosedWorkflowExecutionsByWorkflowID calls made by service to visibility persistence layer
	VisibilityPersistenceListClosedWorkflowExecutionsByWorkflowIDScope
	// VisibilityPersistenceListClosedWorkflowExecutionsByStatusScope tracks ListClosedWorkflowExecutionsByStatus calls made by service to visibility persistence layer
	VisibilityPersistenceListClosedWorkflowExecutionsByStatusScope
	// VisibilityPersistenceDeleteWorkflowExecutionScope tracks DeleteWorkflowExecutions calls made by service to visibility persistence layer
	VisibilityPersistenceDeleteWorkflowExecutionScope
	// VisibilityPersistenceListWorkflowExecutionsScope tracks ListWorkflowExecutions calls made by service to visibility persistence layer
	VisibilityPersistenceListWorkflowExecutionsScope
	// VisibilityPersistenceScanWorkflowExecutionsScope tracks ScanWorkflowExecutions calls made by service to visibility persistence layer
	VisibilityPersistenceScanWorkflowExecutionsScope
	// VisibilityPersistenceCountWorkflowExecutionsScope tracks CountWorkflowExecutions calls made by service to visibility persistence layer
	VisibilityPersistenceCountWorkflowExecutionsScope

	// PersistenceEnqueueMessageScope tracks Enqueue calls made by service to persistence layer
	PersistenceEnqueueMessageScope
	// PersistenceEnqueueMessageToDLQScope tracks Enqueue DLQ calls made by service to persistence layer
	PersistenceEnqueueMessageToDLQScope
	// PersistenceReadQueueMessagesScope tracks ReadMessages calls made by service to persistence layer
	PersistenceReadQueueMessagesScope
	// PersistenceReadQueueMessagesFromDLQScope tracks ReadMessagesFromDLQ calls made by service to persistence layer
	PersistenceReadQueueMessagesFromDLQScope
	// PersistenceDeleteQueueMessagesScope tracks DeleteMessages calls made by service to persistence layer
	PersistenceDeleteQueueMessagesScope
	// PersistenceDeleteQueueMessageFromDLQScope tracks DeleteMessageFromDLQ calls made by service to persistence layer
	PersistenceDeleteQueueMessageFromDLQScope
	// PersistenceRangeDeleteMessagesFromDLQScope tracks RangeDeleteMessagesFromDLQ calls made by service to persistence layer
	PersistenceRangeDeleteMessagesFromDLQScope
	// PersistenceUpdateAckLevelScope tracks UpdateAckLevel calls made by service to persistence layer
	PersistenceUpdateAckLevelScope
	// PersistenceGetAckLevelScope tracks GetAckLevel calls made by service to persistence layer
	PersistenceGetAckLevelScope
	// PersistenceUpdateDLQAckLevelScope tracks UpdateDLQAckLevel calls made by service to persistence layer
	PersistenceUpdateDLQAckLevelScope
	// PersistenceGetDLQAckLevelScope tracks GetDLQAckLevel calls made by service to persistence layer
	PersistenceGetDLQAckLevelScope
	// PersistenceListClusterMetadataScope tracks ListClusterMetadata calls made by service to persistence layer
	PersistenceListClusterMetadataScope
	// PersistenceGetClusterMetadataScope tracks GetClusterMetadata calls made by service to persistence layer
	PersistenceGetClusterMetadataScope
	// PersistenceSaveClusterMetadataScope tracks SaveClusterMetadata calls made by service to persistence layer
	PersistenceSaveClusterMetadataScope
	// PersistenceDeleteClusterMetadataScope tracks DeleteClusterMetadata calls made by service to persistence layer
	PersistenceDeleteClusterMetadataScope
	// PersistenceUpsertClusterMembershipScope tracks UpsertClusterMembership calls made by service to persistence layer
	PersistenceUpsertClusterMembershipScope
	// PersistencePruneClusterMembershipScope tracks PruneClusterMembership calls made by service to persistence layer
	PersistencePruneClusterMembershipScope
	// PersistenceGetClusterMembersScope tracks GetClusterMembers calls made by service to persistence layer
	PersistenceGetClusterMembersScope
	// HistoryClientStartWorkflowExecutionScope tracks RPC calls to history service
	HistoryClientStartWorkflowExecutionScope
	// HistoryClientRecordActivityTaskHeartbeatScope tracks RPC calls to history service
	HistoryClientRecordActivityTaskHeartbeatScope
	// HistoryClientRespondWorkflowTaskCompletedScope tracks RPC calls to history service
	HistoryClientRespondWorkflowTaskCompletedScope
	// HistoryClientRespondWorkflowTaskFailedScope tracks RPC calls to history service
	HistoryClientRespondWorkflowTaskFailedScope
	// HistoryClientRespondActivityTaskCompletedScope tracks RPC calls to history service
	HistoryClientRespondActivityTaskCompletedScope
	// HistoryClientRespondActivityTaskFailedScope tracks RPC calls to history service
	HistoryClientRespondActivityTaskFailedScope
	// HistoryClientRespondActivityTaskCanceledScope tracks RPC calls to history service
	HistoryClientRespondActivityTaskCanceledScope
	// HistoryClientGetMutableStateScope tracks RPC calls to history service
	HistoryClientGetMutableStateScope
	// HistoryClientPollMutableStateScope tracks RPC calls to history service
	HistoryClientPollMutableStateScope
	// HistoryClientResetStickyTaskQueueScope tracks RPC calls to history service
	HistoryClientResetStickyTaskQueueScope
	// HistoryClientDescribeWorkflowExecutionScope tracks RPC calls to history service
	HistoryClientDescribeWorkflowExecutionScope
	// HistoryClientRecordWorkflowTaskStartedScope tracks RPC calls to history service
	HistoryClientRecordWorkflowTaskStartedScope
	// 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
	// HistoryClientScheduleWorkflowTaskScope tracks RPC calls to history service
	HistoryClientScheduleWorkflowTaskScope
	// HistoryClientRecordChildExecutionCompletedScope tracks RPC calls to history service
	HistoryClientRecordChildExecutionCompletedScope
	// HistoryClientReplicateEventsV2Scope tracks RPC calls to history service
	HistoryClientReplicateEventsV2Scope
	// HistoryClientSyncShardStatusScope 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
	// HistoryClientGetDLQMessagesScope tracks RPC calls to history service
	HistoryClientGetDLQMessagesScope
	// HistoryClientPurgeDLQMessagesScope tracks RPC calls to history service
	HistoryClientPurgeDLQMessagesScope
	// HistoryClientMergeDLQMessagesScope tracks RPC calls to history service
	HistoryClientMergeDLQMessagesScope
	// HistoryClientRefreshWorkflowTasksScope tracks RPC calls to history service
	HistoryClientRefreshWorkflowTasksScope
	// HistoryClientGenerateLastHistoryReplicationTasksScope tracks RPC calls to history service
	HistoryClientGenerateLastHistoryReplicationTasksScope
	// HistoryClientGetReplicationStatusScope tracks RPC calls to history service
	HistoryClientGetReplicationStatusScope
	// MatchingClientPollWorkflowTaskQueueScope tracks RPC calls to matching service
	MatchingClientPollWorkflowTaskQueueScope
	// MatchingClientPollActivityTaskQueueScope tracks RPC calls to matching service
	MatchingClientPollActivityTaskQueueScope
	// MatchingClientAddActivityTaskScope tracks RPC calls to matching service
	MatchingClientAddActivityTaskScope
	// MatchingClientAddWorkflowTaskScope tracks RPC calls to matching service
	MatchingClientAddWorkflowTaskScope
	// MatchingClientQueryWorkflowScope tracks RPC calls to matching service
	MatchingClientQueryWorkflowScope
	// MatchingClientRespondQueryTaskCompletedScope tracks RPC calls to matching service
	MatchingClientRespondQueryTaskCompletedScope
	// MatchingClientCancelOutstandingPollScope tracks RPC calls to matching service
	MatchingClientCancelOutstandingPollScope
	// MatchingClientDescribeTaskQueueScope tracks RPC calls to matching service
	MatchingClientDescribeTaskQueueScope
	// MatchingClientListTaskQueuePartitionsScope tracks RPC calls to matching service
	MatchingClientListTaskQueuePartitionsScope
	// FrontendClientDeprecateNamespaceScope tracks RPC calls to frontend service
	FrontendClientDeprecateNamespaceScope
	// FrontendClientDescribeNamespaceScope tracks RPC calls to frontend service
	FrontendClientDescribeNamespaceScope
	// FrontendClientDescribeTaskQueueScope tracks RPC calls to frontend service
	FrontendClientDescribeTaskQueueScope
	// 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
	// FrontendClientListNamespacesScope tracks RPC calls to frontend service
	FrontendClientListNamespacesScope
	// FrontendClientListOpenWorkflowExecutionsScope tracks RPC calls to frontend service
	FrontendClientListOpenWorkflowExecutionsScope
	// FrontendClientPollActivityTaskQueueScope tracks RPC calls to frontend service
	FrontendClientPollActivityTaskQueueScope
	// FrontendClientPollWorkflowTaskQueueScope tracks RPC calls to frontend service
	FrontendClientPollWorkflowTaskQueueScope
	// FrontendClientQueryWorkflowScope tracks RPC calls to frontend service
	FrontendClientQueryWorkflowScope
	// FrontendClientRecordActivityTaskHeartbeatScope tracks RPC calls to frontend service
	FrontendClientRecordActivityTaskHeartbeatScope
	// FrontendClientRecordActivityTaskHeartbeatByIdScope tracks RPC calls to frontend service
	FrontendClientRecordActivityTaskHeartbeatByIdScope
	// FrontendClientRegisterNamespaceScope tracks RPC calls to frontend service
	FrontendClientRegisterNamespaceScope
	// FrontendClientRequestCancelWorkflowExecutionScope tracks RPC calls to frontend service
	FrontendClientRequestCancelWorkflowExecutionScope
	// FrontendClientResetStickyTaskQueueScope tracks RPC calls to frontend service
	FrontendClientResetStickyTaskQueueScope
	// 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
	// FrontendClientRespondWorkflowTaskCompletedScope tracks RPC calls to frontend service
	FrontendClientRespondWorkflowTaskCompletedScope
	// FrontendClientRespondWorkflowTaskFailedScope tracks RPC calls to frontend service
	FrontendClientRespondWorkflowTaskFailedScope
	// FrontendClientRespondQueryTaskCompletedScope tracks RPC calls to frontend service
	FrontendClientRespondQueryTaskCompletedScope
	// FrontendClientSignalWithStartWorkflowExecutionScope tracks RPC calls to frontend service
	FrontendClientSignalWithStartWorkflowExecutionScope
	// FrontendClientSignalWorkflowExecutionScope tracks RPC calls to frontend service
	FrontendClientSignalWorkflowExecutionScope
	// FrontendClientStartWorkflowExecutionScope tracks RPC calls to frontend service
	FrontendClientStartWorkflowExecutionScope
	// FrontendClientTerminateWorkflowExecutionScope tracks RPC calls to frontend service
	FrontendClientTerminateWorkflowExecutionScope
	// FrontendClientUpdateNamespaceScope tracks RPC calls to frontend service
	FrontendClientUpdateNamespaceScope
	// 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
	// FrontendClientGetNamespaceReplicationTasksScope tracks RPC calls to frontend service
	FrontendClientGetNamespaceReplicationTasksScope
	// FrontendClientGetDLQReplicationTasksScope tracks RPC calls to frontend service
	FrontendClientGetDLQReplicationTasksScope
	// FrontendClientReapplyEventsScope tracks RPC calls to frontend service
	FrontendClientReapplyEventsScope
	// FrontendClientGetClusterInfoScope tracks RPC calls to frontend
	FrontendClientGetClusterInfoScope
	// FrontendClientListTaskQueuePartitionsScope tracks RPC calls to frontend service
	FrontendClientListTaskQueuePartitionsScope
	// AdminClientAddSearchAttributesScope tracks RPC calls to admin service
	AdminClientAddSearchAttributesScope
	// AdminClientRemoveSearchAttributesScope tracks RPC calls to admin service
	AdminClientRemoveSearchAttributesScope
	// AdminClientGetSearchAttributesScope tracks RPC calls to admin service
	AdminClientGetSearchAttributesScope
	// AdminClientCloseShardScope tracks RPC calls to admin service
	AdminClientCloseShardScope
	// AdminClientGetShardScope tracks RPC calls to admin service
	AdminClientGetShardScope
	// AdminClientListTransferTasksScope tracks RPC calls to admin service
	AdminClientListTransferTasksScope
	// AdminClientListTimerTasksScope tracks RPC calls to admin service
	AdminClientListTimerTasksScope
	// AdminClientListReplicationTasksScope tracks RPC calls to admin service
	AdminClientListReplicationTasksScope
	// AdminClientListVisibilityTasksScope tracks RPC calls to admin service
	AdminClientListVisibilityTasksScope
	// AdminClientDescribeHistoryHostScope tracks RPC calls to admin service
	AdminClientDescribeHistoryHostScope
	// AdminClientDescribeWorkflowMutableStateScope tracks RPC calls to admin service
	AdminClientDescribeWorkflowMutableStateScope
	// AdminClientGetWorkflowExecutionRawHistoryScope tracks RPC calls to admin service
	AdminClientGetWorkflowExecutionRawHistoryScope
	// AdminClientGetWorkflowExecutionRawHistoryV2Scope tracks RPC calls to admin service
	AdminClientGetWorkflowExecutionRawHistoryV2Scope
	// AdminClientDescribeClusterScope tracks RPC calls to admin service
	AdminClientDescribeClusterScope
	// AdminClientListClusterMembersScope tracks RPC calls to admin service
	AdminClientListClusterMembersScope
	// AdminClientAddOrUpdateRemoteClusterScope tracks RPC calls to admin service
	AdminClientAddOrUpdateRemoteClusterScope
	// AdminClientRemoveRemoteClusterScope tracks RPC calls to admin service
	AdminClientRemoveRemoteClusterScope
	// AdminClientGetDLQMessagesScope tracks RPC calls to admin service
	AdminClientGetDLQMessagesScope
	// 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
	// AdminClientGetTaskQueueTasksScope tracks RPC calls to admin service
	AdminClientGetTaskQueueTasksScope
	// DCRedirectionDeprecateNamespaceScope tracks RPC calls for dc redirection
	DCRedirectionDeprecateNamespaceScope
	// DCRedirectionDescribeNamespaceScope tracks RPC calls for dc redirection
	DCRedirectionDescribeNamespaceScope
	// DCRedirectionDescribeTaskQueueScope tracks RPC calls for dc redirection
	DCRedirectionDescribeTaskQueueScope
	// DCRedirectionDescribeWorkflowExecutionScope tracks RPC calls for dc redirection
	DCRedirectionDescribeWorkflowExecutionScope
	// DCRedirectionGetWorkflowExecutionHistoryScope tracks RPC calls for dc redirection
	DCRedirectionGetWorkflowExecutionHistoryScope
	// DCRedirectionGetWorkflowExecutionRawHistoryScope tracks RPC calls for dc redirection
	DCRedirectionGetWorkflowExecutionRawHistoryScope
	// DCRedirectionPollForWorkflowExecutionRawHistoryScope tracks RPC calls for dc redirection
	DCRedirectionPollForWorkflowExecutionRawHistoryScope
	// DCRedirectionListArchivedWorkflowExecutionsScope tracks RPC calls for dc redirection
	DCRedirectionListArchivedWorkflowExecutionsScope
	// DCRedirectionListClosedWorkflowExecutionsScope tracks RPC calls for dc redirection
	DCRedirectionListClosedWorkflowExecutionsScope
	// DCRedirectionListNamespacesScope tracks RPC calls for dc redirection
	DCRedirectionListNamespacesScope
	// 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
	// DCRedirectionPollActivityTaskQueueScope tracks RPC calls for dc redirection
	DCRedirectionPollActivityTaskQueueScope
	// DCRedirectionPollWorkflowTaskQueueScope tracks RPC calls for dc redirection
	DCRedirectionPollWorkflowTaskQueueScope
	// DCRedirectionQueryWorkflowScope tracks RPC calls for dc redirection
	DCRedirectionQueryWorkflowScope
	// DCRedirectionRecordActivityTaskHeartbeatScope tracks RPC calls for dc redirection
	DCRedirectionRecordActivityTaskHeartbeatScope
	// DCRedirectionRecordActivityTaskHeartbeatByIdScope tracks RPC calls for dc redirection
	DCRedirectionRecordActivityTaskHeartbeatByIdScope
	// DCRedirectionRegisterNamespaceScope tracks RPC calls for dc redirection
	DCRedirectionRegisterNamespaceScope
	// DCRedirectionRequestCancelWorkflowExecutionScope tracks RPC calls for dc redirection
	DCRedirectionRequestCancelWorkflowExecutionScope
	// DCRedirectionResetStickyTaskQueueScope tracks RPC calls for dc redirection
	DCRedirectionResetStickyTaskQueueScope
	// 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
	// DCRedirectionRespondWorkflowTaskCompletedScope tracks RPC calls for dc redirection
	DCRedirectionRespondWorkflowTaskCompletedScope
	// DCRedirectionRespondWorkflowTaskFailedScope tracks RPC calls for dc redirection
	DCRedirectionRespondWorkflowTaskFailedScope
	// DCRedirectionRespondQueryTaskCompletedScope tracks RPC calls for dc redirection
	DCRedirectionRespondQueryTaskCompletedScope
	// DCRedirectionSignalWithStartWorkflowExecutionScope tracks RPC calls for dc redirection
	DCRedirectionSignalWithStartWorkflowExecutionScope
	// DCRedirectionSignalWorkflowExecutionScope tracks RPC calls for dc redirection
	DCRedirectionSignalWorkflowExecutionScope
	// DCRedirectionStartWorkflowExecutionScope tracks RPC calls for dc redirection
	DCRedirectionStartWorkflowExecutionScope
	// DCRedirectionTerminateWorkflowExecutionScope tracks RPC calls for dc redirection
	DCRedirectionTerminateWorkflowExecutionScope
	// DCRedirectionUpdateNamespaceScope tracks RPC calls for dc redirection
	DCRedirectionUpdateNamespaceScope
	// DCRedirectionListTaskQueuePartitionsScope tracks RPC calls for dc redirection
	DCRedirectionListTaskQueuePartitionsScope

	// MessagingClientPublishScope tracks Publish calls made by service to messaging layer
	MessagingClientPublishScope
	// MessagingClientPublishBatchScope tracks Publish calls made by service to messaging layer
	MessagingClientPublishBatchScope

	// NamespaceCacheScope tracks namespace cache callbacks
	NamespaceCacheScope
	// 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
	// PersistenceDeleteHistoryNodesScope tracks DeleteHistoryNodes calls made by service to persistence layer
	PersistenceDeleteHistoryNodesScope
	// PersistenceReadHistoryBranchScope tracks ReadHistoryBranch calls made by service to persistence layer
	PersistenceReadHistoryBranchScope
	// PersistenceForkHistoryBranchScope tracks ForkHistoryBranch calls made by service to persistence layer
	PersistenceForkHistoryBranchScope
	// PersistenceDeleteHistoryBranchScope tracks DeleteHistoryBranch calls made by service to persistence layer
	PersistenceDeleteHistoryBranchScope
	// PersistenceTrimHistoryBranchScope tracks TrimHistoryBranch calls made by service to persistence layer
	PersistenceTrimHistoryBranchScope
	// 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
	// PersistenceNamespaceReplicationQueueScope is the metrics scope for namespace replication queue
	PersistenceNamespaceReplicationQueueScope

	// ClusterMetadataArchivalConfigScope tracks ArchivalConfig calls to ClusterMetadata
	ClusterMetadataArchivalConfigScope

	// ElasticsearchBulkProcessor is scope used by all metric emitted by Elasticsearch bulk processor
	ElasticsearchBulkProcessor

	// ElasticsearchVisibility is scope used by all Elasticsearch visibility metrics
	ElasticsearchVisibility

	// 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

	// 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

	DynamicConfigScope

	// TieredStorageQueueProcessorScope is the scope used by all metric emitted by tiered storage queue processor
	TieredStorageQueueProcessorScope

	NumCommonScopes
)

Scopes enum

View Source 
const (
	// AdminDescribeHistoryHostScope is the metric scope for admin.AdminDescribeHistoryHostScope
	AdminDescribeHistoryHostScope = iota + NumCommonScopes
	// AdminAddSearchAttributesScope is the metric scope for admin.AdminAddSearchAttributesScope
	AdminAddSearchAttributesScope
	// AdminRemoveSearchAttributesScope is the metric scope for admin.AdminRemoveSearchAttributesScope
	AdminRemoveSearchAttributesScope
	// AdminGetSearchAttributesScope is the metric scope for admin.AdminGetSearchAttributesScope
	AdminGetSearchAttributesScope
	// 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
	// AdminGetNamespaceReplicationMessagesScope is the metric scope for admin.GetNamespaceReplicationMessages
	AdminGetNamespaceReplicationMessagesScope
	// 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
	// AdminGetTaskQueueTasksScope is the metric scope for admin.GetTaskQueueTasks
	AdminGetTaskQueueTasksScope
	// AdminRemoveTaskScope is the metric scope for admin.AdminRemoveTaskScope
	AdminRemoveTaskScope
	// AdminCloseShardScope is the metric scope for admin.AdminCloseShardScope
	AdminCloseShardScope
	// AdminGetShardScope is the metric scope for admin.AdminGetShardScope
	AdminGetShardScope
	// AdminListTransferTasksScope is the metric scope for admin.ListTransferTasksScope
	AdminListTransferTasksScope
	// AdminListTimerTasksScope is the metric scope for admin.ListTimerTasksScope
	AdminListTimerTasksScope
	// AdminListReplicationTasksScope is the metric scope for admin.ListReplicationTasksScope
	AdminListReplicationTasksScope
	// AdminListVisibilityTasksScope is the metric scope for admin.ListVisibilityTasksScope
	AdminListVisibilityTasksScope
	// 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
	// AdminListClusterMembersScope is the metric scope for admin.AdminListClusterMembersScope
	AdminListClusterMembersScope
	// AdminDescribeClusterScope is the metric scope for admin.AdminDescribeClusterScope
	AdminDescribeClusterScope
	// AdminAddOrUpdateRemoteClusterScope is the metric scope for admin.AdminAddOrUpdateRemoteClusterScope
	AdminAddOrUpdateRemoteClusterScope
	// AdminRemoveRemoteClusterScope is the metric scope for admin.AdminRemoveRemoteClusterScope
	AdminRemoveRemoteClusterScope

	NumAdminScopes
)

-- Operation scopes for Admin service --

View Source 
const (
	// FrontendStartWorkflowExecutionScope is the metric scope for frontend.StartWorkflowExecution
	FrontendStartWorkflowExecutionScope = iota + NumAdminScopes
	// FrontendPollWorkflowTaskQueueScope is the metric scope for frontend.PollWorkflowTaskQueue
	FrontendPollWorkflowTaskQueueScope
	// FrontendPollActivityTaskQueueScope is the metric scope for frontend.PollActivityTaskQueue
	FrontendPollActivityTaskQueueScope
	// FrontendRecordActivityTaskHeartbeatScope is the metric scope for frontend.RecordActivityTaskHeartbeat
	FrontendRecordActivityTaskHeartbeatScope
	// FrontendRecordActivityTaskHeartbeatByIdScope is the metric scope for frontend.RespondWorkflowTaskCompleted
	FrontendRecordActivityTaskHeartbeatByIdScope
	// FrontendRespondWorkflowTaskCompletedScope is the metric scope for frontend.RespondWorkflowTaskCompleted
	FrontendRespondWorkflowTaskCompletedScope
	// FrontendRespondWorkflowTaskFailedScope is the metric scope for frontend.RespondWorkflowTaskFailed
	FrontendRespondWorkflowTaskFailedScope
	// 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
	// FrontendRespondActivityTaskCompletedByIdScope is the metric scope for frontend.RespondActivityTaskCompletedById
	FrontendRespondActivityTaskCompletedByIdScope
	// FrontendRespondActivityTaskFailedByIdScope is the metric scope for frontend.RespondActivityTaskFailedById
	FrontendRespondActivityTaskFailedByIdScope
	// FrontendRespondActivityTaskCanceledByIdScope is the metric scope for frontend.RespondActivityTaskCanceledById
	FrontendRespondActivityTaskCanceledByIdScope
	// FrontendGetWorkflowExecutionHistoryScope is the metric scope for non-long-poll frontend.GetWorkflowExecutionHistory
	FrontendGetWorkflowExecutionHistoryScope
	// FrontendPollWorkflowExecutionHistoryScope is the metric scope for long poll case of frontend.GetWorkflowExecutionHistory
	FrontendPollWorkflowExecutionHistoryScope
	// FrontendGetWorkflowExecutionRawHistoryScope is the metric scope for frontend.GetWorkflowExecutionRawHistory
	FrontendGetWorkflowExecutionRawHistoryScope
	// FrontendPollForWorkflowExecutionRawHistoryScope is the metric scope for frontend.GetWorkflowExecutionRawHistory
	FrontendPollForWorkflowExecutionRawHistoryScope
	// FrontendSignalWorkflowExecutionScope is the metric scope for frontend.SignalWorkflowExecution
	FrontendSignalWorkflowExecutionScope
	// FrontendSignalWithStartWorkflowExecutionScope is the metric scope for frontend.SignalWithStartWorkflowExecution
	FrontendSignalWithStartWorkflowExecutionScope
	// 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
	// FrontendRegisterNamespaceScope is the metric scope for frontend.RegisterNamespace
	FrontendRegisterNamespaceScope
	// FrontendDescribeNamespaceScope is the metric scope for frontend.DescribeNamespace
	FrontendDescribeNamespaceScope
	// FrontendUpdateNamespaceScope is the metric scope for frontend.DescribeNamespace
	FrontendUpdateNamespaceScope
	// FrontendDeprecateNamespaceScope is the metric scope for frontend.DeprecateNamespace
	FrontendDeprecateNamespaceScope
	// FrontendQueryWorkflowScope is the metric scope for frontend.QueryWorkflow
	FrontendQueryWorkflowScope
	// FrontendDescribeWorkflowExecutionScope is the metric scope for frontend.DescribeWorkflowExecution
	FrontendDescribeWorkflowExecutionScope
	// FrontendDescribeTaskQueueScope is the metric scope for frontend.DescribeTaskQueue
	FrontendDescribeTaskQueueScope
	// FrontendListTaskQueuePartitionsScope is the metric scope for frontend.ResetStickyTaskQueue
	FrontendListTaskQueuePartitionsScope
	// FrontendResetStickyTaskQueueScope is the metric scope for frontend.ResetStickyTaskQueue
	FrontendResetStickyTaskQueueScope
	// FrontendListNamespacesScope is the metric scope for frontend.ListNamespace
	FrontendListNamespacesScope
	// 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

	// VersionCheckScope is scope used by version checker
	VersionCheckScope
	// AuthorizationScope is the scope used by all metric emitted by authorization code
	AuthorizationScope

	NumFrontendScopes
)

-- Operation scopes for Frontend service --

View Source 
const (
	// HistoryStartWorkflowExecutionScope tracks StartWorkflowExecution API calls received by service
	HistoryStartWorkflowExecutionScope = iota + NumFrontendScopes
	// HistoryRecordActivityTaskHeartbeatScope tracks RecordActivityTaskHeartbeat API calls received by service
	HistoryRecordActivityTaskHeartbeatScope
	// HistoryRespondWorkflowTaskCompletedScope tracks RespondWorkflowTaskCompleted API calls received by service
	HistoryRespondWorkflowTaskCompletedScope
	// HistoryRespondWorkflowTaskFailedScope tracks RespondWorkflowTaskFailed API calls received by service
	HistoryRespondWorkflowTaskFailedScope
	// 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
	// HistoryGetMutableStateScope tracks GetMutableStateScope API calls received by service
	HistoryGetMutableStateScope
	// HistoryPollMutableStateScope tracks PollMutableStateScope API calls received by service
	HistoryPollMutableStateScope
	// HistoryResetStickyTaskQueueScope tracks ResetStickyTaskQueueScope API calls received by service
	HistoryResetStickyTaskQueueScope
	// HistoryDescribeWorkflowExecutionScope tracks DescribeWorkflowExecution API calls received by service
	HistoryDescribeWorkflowExecutionScope
	// HistoryRecordWorkflowTaskStartedScope tracks RecordWorkflowTaskStarted API calls received by service
	HistoryRecordWorkflowTaskStartedScope
	// 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
	// HistoryScheduleWorkflowTaskScope tracks ScheduleWorkflowTask API calls received by service
	HistoryScheduleWorkflowTaskScope
	// HistoryRecordChildExecutionCompletedScope tracks CompleteChildExecution API calls received by service
	HistoryRecordChildExecutionCompletedScope
	// HistoryRequestCancelWorkflowExecutionScope tracks RequestCancelWorkflowExecution API calls received by service
	HistoryRequestCancelWorkflowExecutionScope
	// 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
	// HistoryGetReplicationMessagesScope tracks GetReplicationMessages API calls received by service
	HistoryGetReplicationMessagesScope
	// HistoryGetDLQReplicationMessagesScope tracks GetReplicationMessages API calls received by service
	HistoryGetDLQReplicationMessagesScope
	// HistoryReadDLQMessagesScope tracks GetDLQMessages 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 is the scope used by event reapplication
	HistoryReapplyEventsScope
	// HistoryRefreshWorkflowTasksScope is the scope used by refresh workflow tasks API
	HistoryRefreshWorkflowTasksScope
	// HistoryGenerateLastHistoryReplicationTasksScope is the scope used by generate last replication tasks API
	HistoryGenerateLastHistoryReplicationTasksScope
	// HistoryGetReplicationStatusScope is the scope used by GetReplicationStatus API
	HistoryGetReplicationStatusScope
	// HistoryHistoryRemoveTaskScope is the scope used by remove task API
	HistoryHistoryRemoveTaskScope
	// HistoryCloseShard is the scope used by close shard API
	HistoryCloseShard
	// HistoryGetShard is the scope used by get shard API
	HistoryGetShard
	// HistoryReplicateEventsV2 is the scope used by replicate events API
	HistoryReplicateEventsV2
	// HistoryResetStickyTaskQueue is the scope used by reset sticky task queue API
	HistoryResetStickyTaskQueue
	// HistoryReapplyEvents is the scope used by reapply events API
	HistoryReapplyEvents
	// HistoryDescribeHistoryHost is the scope used by describe history host API
	HistoryDescribeHistoryHost
	// 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
	// TransferActiveTaskWorkflowTaskScope is the scope used for workflow task processing by transfer queue processor
	TransferActiveTaskWorkflowTaskScope
	// 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
	// TransferActiveTaskResetWorkflowScope is the scope used for record workflow started task processing by transfer queue processor
	TransferActiveTaskResetWorkflowScope
	// 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
	// TransferStandbyTaskWorkflowTaskScope is the scope used for workflow task processing by transfer queue processor
	TransferStandbyTaskWorkflowTaskScope
	// 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

	// VisibilityQueueProcessorScope is the scope used by all metric emitted by visibility queue processor
	VisibilityQueueProcessorScope
	// VisibilityTaskStartExecutionScope is the scope used for start execution processing by visibility queue processor
	VisibilityTaskStartExecutionScope
	// VisibilityTaskUpsertExecutionScope is the scope used for upsert execution processing by visibility queue processor
	VisibilityTaskUpsertExecutionScope
	// VisibilityTaskCloseExecutionScope is the scope used for close execution attributes processing by visibility queue processor
	VisibilityTaskCloseExecutionScope
	// VisibilityTaskDeleteExecutionScope is the scope used for delete by visibility queue processor
	VisibilityTaskDeleteExecutionScope

	// 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
	// TimerStandbyQueueProcessorScope 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
	// TimerActiveTaskWorkflowTaskTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow task timeouts
	TimerActiveTaskWorkflowTaskTimeoutScope
	// 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
	// TimerStandbyTaskWorkflowTaskTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow task timeouts
	TimerStandbyTaskWorkflowTaskTimeoutScope
	// 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
	// HistoryEventNotificationScope is the scope used by shard history event nitification
	HistoryEventNotificationScope
	// ReplicatorQueueProcessorScope is the scope used by all metric emitted by replicator queue processor
	ReplicatorQueueProcessorScope
	// 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
	// ShardInfoScope is the scope used when updating shard info
	ShardInfoScope
	// WorkflowContextScope is the scope used by WorkflowContext component
	WorkflowContextScope
	// HistoryCacheGetOrCreateScope is the scope used by history cache
	HistoryCacheGetOrCreateScope
	// HistoryCacheGetOrCreateCurrentScope is the scope used by history cache
	HistoryCacheGetOrCreateCurrentScope
	// EventsCacheGetEventScope is the scope used by events cache
	EventsCacheGetEventScope
	// EventsCachePutEventScope is the scope used by events cache
	EventsCachePutEventScope
	// EventsCacheDeleteEventScope is the scope used by events cache
	EventsCacheDeleteEventScope
	// 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

	NumHistoryScopes
)

-- Operation scopes for History service --

View Source 
const (
	// MatchingPollWorkflowTaskQueueScope tracks PollWorkflowTaskQueue API calls received by service
	MatchingPollWorkflowTaskQueueScope = iota + NumHistoryScopes
	// MatchingPollActivityTaskQueueScope tracks PollActivityTaskQueue API calls received by service
	MatchingPollActivityTaskQueueScope
	// MatchingAddActivityTaskScope tracks AddActivityTask API calls received by service
	MatchingAddActivityTaskScope
	// MatchingAddWorkflowTaskScope tracks AddWorkflowTask API calls received by service
	MatchingAddWorkflowTaskScope
	// MatchingTaskQueueMgrScope is the metrics scope for matching.TaskQueueManager component
	MatchingTaskQueueMgrScope
	// MatchingEngineScope is the metrics scope for matchingEngine component
	MatchingEngineScope
	// MatchingQueryWorkflowScope tracks AddWorkflowTask API calls received by service
	MatchingQueryWorkflowScope
	// MatchingRespondQueryTaskCompletedScope tracks AddWorkflowTask API calls received by service
	MatchingRespondQueryTaskCompletedScope
	// MatchingCancelOutstandingPollScope tracks CancelOutstandingPoll API calls received by service
	MatchingCancelOutstandingPollScope
	// MatchingDescribeTaskQueueScope tracks DescribeTaskQueue API calls received by service
	MatchingDescribeTaskQueueScope
	// MatchingListTaskQueuePartitionsScope tracks ListTaskQueuePartitions API calls received by service
	MatchingListTaskQueuePartitionsScope

	NumMatchingScopes
)

-- Operation scopes for Matching service --

View Source 
const (
	// ReplicatorScope is the scope used by all metric emitted by replicator
	ReplicatorScope = iota + NumMatchingScopes
	// NamespaceReplicationTaskScope is the scope used by namespace task replication processing
	NamespaceReplicationTaskScope
	// HistoryReplicationTaskScope is the scope used by history task replication processing
	HistoryReplicationTaskScope
	// HistoryMetadataReplicationTaskScope is the scope used by history metadata task replication processing
	HistoryMetadataReplicationTaskScope
	// SyncShardTaskScope is the scope used by sync shrad information processing
	SyncShardTaskScope
	// SyncActivityTaskScope is the scope used by sync activity information processing
	SyncActivityTaskScope
	// 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
	// TaskQueueScavengerScope is scope used by all metrics emitted by worker.taskqueue.Scavenger module
	TaskQueueScavengerScope
	// ExecutionsScavengerScope is scope used by all metrics emitted by worker.executions.Scavenger module
	ExecutionsScavengerScope
	// 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
	// AddSearchAttributesWorkflowScope is scope used by all metrics emitted by worker.AddSearchAttributesWorkflowScope module
	AddSearchAttributesWorkflowScope

	NumWorkerScopes
)

-- Operation scopes for Worker service --

View Source 
const (
	ServerTlsScope = iota + NumWorkerScopes

	NumServerScopes
)

-- Scopes for Server --

View Source 
const (
	ServiceRequests = iota
	ServicePendingRequests
	ServiceFailures
	ServiceCriticalFailures
	ServiceLatency
	ServiceLatencyNoUserLatency
	ServiceLatencyUserLatency
	ServiceErrInvalidArgumentCounter
	ServiceErrNamespaceNotActiveCounter
	ServiceErrResourceExhaustedCounter
	ServiceErrNotFoundCounter
	ServiceErrExecutionAlreadyStartedCounter
	ServiceErrNamespaceAlreadyExistsCounter
	ServiceErrCancellationAlreadyRequestedCounter
	ServiceErrQueryFailedCounter
	ServiceErrContextCancelledCounter
	ServiceErrContextTimeoutCounter
	ServiceErrRetryTaskCounter
	ServiceErrBadBinaryCounter
	ServiceErrClientVersionNotSupportedCounter
	ServiceErrIncompleteHistoryCounter
	ServiceErrNonDeterministicCounter
	ServiceErrUnauthorizedCounter
	ServiceErrAuthorizeFailedCounter

	PersistenceRequests
	PersistenceFailures
	PersistenceLatency
	PersistenceErrShardExistsCounter
	PersistenceErrShardOwnershipLostCounter
	PersistenceErrConditionFailedCounter
	PersistenceErrCurrentWorkflowConditionFailedCounter
	PersistenceErrWorkflowConditionFailedCounter
	PersistenceErrTimeoutCounter
	PersistenceErrBusyCounter
	PersistenceErrEntityNotExistsCounter
	PersistenceErrNamespaceAlreadyExistsCounter
	PersistenceErrBadRequestCounter

	ClientRequests
	ClientFailures
	ClientLatency

	ClientRedirectionRequests
	ClientRedirectionFailures
	ClientRedirectionLatency

	ServiceAuthorizationLatency

	NamespaceCachePrepareCallbacksLatency
	NamespaceCacheCallbacksLatency

	StateTransitionCount
	HistorySize
	HistoryCount
	EventBlobSize
	SearchAttributesSize

	LockRequests
	LockFailures
	LockLatency

	ArchivalConfigFailures

	VisibilityPersistenceRequests
	VisibilityPersistenceFailures
	VisibilityPersistenceLatency
	VisibilityPersistenceInvalidArgument
	VisibilityPersistenceResourceExhausted
	VisibilityPersistenceConditionFailed
	VisibilityPersistenceTimeout
	VisibilityPersistenceNotFound
	VisibilityPersistenceInternal
	VisibilityPersistenceUnavailable

	SequentialTaskSubmitRequest
	SequentialTaskSubmitRequestTaskQueueExist
	SequentialTaskSubmitRequestTaskQueueMissing
	SequentialTaskSubmitLatency
	SequentialTaskQueueSize
	SequentialTaskQueueProcessingLatency
	SequentialTaskTaskProcessingLatency

	ParallelTaskSubmitRequest
	ParallelTaskSubmitLatency
	ParallelTaskTaskProcessingLatency

	PriorityTaskSubmitRequest
	PriorityTaskSubmitLatency

	HistoryArchiverArchiveNonRetryableErrorCount
	HistoryArchiverArchiveTransientErrorCount
	HistoryArchiverArchiveSuccessCount
	HistoryArchiverHistoryMutatedCount
	HistoryArchiverTotalUploadSize
	HistoryArchiverHistorySize

	HistoryArchiverBlobExistsCount
	HistoryArchiverBlobSize
	HistoryArchiverRunningDeterministicConstructionCheckCount
	HistoryArchiverDeterministicConstructionCheckFailedCount
	HistoryArchiverRunningBlobIntegrityCheckCount
	HistoryArchiverBlobIntegrityCheckFailedCount
	HistoryArchiverDuplicateArchivalsCount

	VisibilityArchiverArchiveNonRetryableErrorCount
	VisibilityArchiverArchiveTransientErrorCount
	VisibilityArchiveSuccessCount

	MatchingClientForwardedCounter
	MatchingClientInvalidTaskQueueName

	NamespaceReplicationTaskAckLevelGauge
	NamespaceReplicationDLQAckLevelGauge
	NamespaceReplicationDLQMaxLevelGauge

	ServiceRequestsPerTaskQueue
	ServiceFailuresPerTaskQueue
	ServiceLatencyPerTaskQueue
	ServiceErrInvalidArgumentPerTaskQueueCounter
	ServiceErrNamespaceNotActivePerTaskQueueCounter
	ServiceErrResourceExhaustedPerTaskQueueCounter
	ServiceErrNotFoundPerTaskQueueCounter
	ServiceErrExecutionAlreadyStartedPerTaskQueueCounter
	ServiceErrNamespaceAlreadyExistsPerTaskQueueCounter
	ServiceErrCancellationAlreadyRequestedPerTaskQueueCounter
	ServiceErrQueryFailedPerTaskQueueCounter
	ServiceErrContextTimeoutPerTaskQueueCounter
	ServiceErrRetryTaskPerTaskQueueCounter
	ServiceErrBadBinaryPerTaskQueueCounter
	ServiceErrClientVersionNotSupportedPerTaskQueueCounter
	ServiceErrIncompleteHistoryPerTaskQueueCounter
	ServiceErrNonDeterministicPerTaskQueueCounter
	ServiceErrUnauthorizedPerTaskQueueCounter
	ServiceErrAuthorizeFailedPerTaskQueueCounter
	VersionCheckSuccessCount
	VersionCheckRequestFailedCount
	VersionCheckFailedCount
	VersionCheckLatency

	ParentClosePolicyProcessorSuccess
	ParentClosePolicyProcessorFailures

	AddSearchAttributesWorkflowSuccessCount
	AddSearchAttributesWorkflowFailuresCount

	ElasticsearchDocumentParseFailuresCount
	ElasticsearchDocumentGenerateFailuresCount

	NoopImplementationIsUsed

	NumCommonMetrics // Needs to be last on this list for iota numbering
)

Common Metrics enum

View Source 
const (
	TaskRequests = iota + NumCommonMetrics
	TaskLatency
	TaskFailures
	TaskDiscarded
	TaskAttemptTimer
	TaskStandbyRetryCounter
	TaskNotActiveCounter
	TaskLimitExceededCounter
	TaskBatchCompleteCounter
	TaskProcessingLatency
	TaskNoUserProcessingLatency
	TaskQueueLatency
	TaskUserLatency
	TaskNoUserLatency
	TaskNoUserQueueLatency
	TaskRedispatchQueuePendingTasksTimer
	TaskScheduleToStartLatency

	TransferTaskMissingEventCounter

	TransferTaskThrottledCounter
	TimerTaskThrottledCounter

	ActivityE2ELatency
	AckLevelUpdateCounter
	AckLevelUpdateFailedCounter
	CommandTypeScheduleActivityCounter
	CommandTypeCompleteWorkflowCounter
	CommandTypeFailWorkflowCounter
	CommandTypeCancelWorkflowCounter
	CommandTypeStartTimerCounter
	CommandTypeCancelActivityCounter
	CommandTypeCancelTimerCounter
	CommandTypeRecordMarkerCounter
	CommandTypeCancelExternalWorkflowCounter
	CommandTypeChildWorkflowCounter
	CommandTypeContinueAsNewCounter
	CommandTypeSignalExternalWorkflowCounter
	CommandTypeUpsertWorkflowSearchAttributesCounter
	EmptyCompletionCommandsCounter
	MultipleCompletionCommandsCounter
	FailedWorkflowTasksCounter
	StaleMutableStateCounter
	AutoResetPointsLimitExceededCounter
	AutoResetPointCorruptionCounter
	ConcurrencyUpdateFailureCounter
	ServiceErrTaskAlreadyStartedCounter
	ServiceErrShardOwnershipLostCounter
	HeartbeatTimeoutCounter
	ScheduleToStartTimeoutCounter
	StartToCloseTimeoutCounter
	ScheduleToCloseTimeoutCounter
	NewTimerNotifyCounter
	AcquireShardsCounter
	AcquireShardsLatency
	ShardContextClosedCounter
	ShardContextCreatedCounter
	ShardContextRemovedCounter
	ShardContextAcquisitionLatency
	ShardInfoReplicationPendingTasksTimer
	ShardInfoTransferActivePendingTasksTimer
	ShardInfoTransferStandbyPendingTasksTimer
	ShardInfoTimerActivePendingTasksTimer
	ShardInfoTimerStandbyPendingTasksTimer
	ShardInfoReplicationLagHistogram
	ShardInfoTransferLagHistogram
	ShardInfoTimerLagTimer
	ShardInfoTransferDiffHistogram
	ShardInfoTimerDiffTimer
	ShardInfoTransferFailoverInProgressHistogram
	ShardInfoTimerFailoverInProgressHistogram
	ShardInfoTransferFailoverLatencyTimer
	ShardInfoTimerFailoverLatencyTimer
	SyncShardFromRemoteCounter
	SyncShardFromRemoteFailure
	MembershipChangedCounter
	NumShardsGauge
	GetEngineForShardErrorCounter
	GetEngineForShardLatency
	RemoveEngineForShardLatency
	CompleteWorkflowTaskWithStickyEnabledCounter
	CompleteWorkflowTaskWithStickyDisabledCounter
	WorkflowTaskHeartbeatTimeoutCounter
	HistoryEventNotificationQueueingLatency
	HistoryEventNotificationFanoutLatency
	HistoryEventNotificationInFlightMessageGauge
	HistoryEventNotificationFailDeliveryCount
	EmptyReplicationEventsCounter
	DuplicateReplicationEventsCounter
	StaleReplicationEventsCounter
	ReplicationEventsSizeTimer
	BufferReplicationTaskTimer
	UnbufferReplicationTaskTimer
	HistoryConflictsCounter
	CompleteTaskFailedCounter
	CacheRequests
	CacheFailures
	CacheLatency
	CacheMissCounter
	AcquireLockFailedCounter
	WorkflowContextCleared
	MutableStateSize
	ExecutionInfoSize
	ExecutionStateSize
	ActivityInfoSize
	TimerInfoSize
	ChildInfoSize
	RequestCancelInfoSize
	SignalInfoSize
	BufferedEventsSize
	ActivityInfoCount
	TimerInfoCount
	ChildInfoCount
	SignalInfoCount
	RequestCancelInfoCount
	BufferedEventsCount
	WorkflowRetryBackoffTimerCount
	WorkflowCronBackoffTimerCount
	WorkflowCleanupDeleteCount
	WorkflowCleanupArchiveCount
	WorkflowCleanupNopCount
	WorkflowCleanupDeleteHistoryInlineCount
	WorkflowSuccessCount
	WorkflowCancelCount
	WorkflowFailedCount
	WorkflowTimeoutCount
	WorkflowTerminateCount
	WorkflowContinuedAsNewCount
	ArchiverClientSendSignalCount
	ArchiverClientSendSignalFailureCount
	ArchiverClientHistoryRequestCount
	ArchiverClientHistoryInlineArchiveAttemptCount
	ArchiverClientHistoryInlineArchiveFailureCount
	ArchiverClientVisibilityRequestCount
	ArchiverClientVisibilityInlineArchiveAttemptCount
	ArchiverClientVisibilityInlineArchiveFailureCount
	LastRetrievedMessageID
	LastProcessedMessageID
	ReplicationTasksApplied
	ReplicationTasksFailed
	ReplicationTasksLag
	ReplicationTasksFetched
	ReplicationTasksReturned
	ReplicationTasksAppliedLatency
	ReplicationDLQFailed
	ReplicationDLQMaxLevelGauge
	ReplicationDLQAckLevelGauge
	GetReplicationMessagesForShardLatency
	GetDLQReplicationMessagesLatency
	EventReapplySkippedCount
	DirectQueryDispatchLatency
	DirectQueryDispatchStickyLatency
	DirectQueryDispatchNonStickyLatency
	DirectQueryDispatchStickySuccessCount
	DirectQueryDispatchNonStickySuccessCount
	DirectQueryDispatchClearStickinessLatency
	DirectQueryDispatchClearStickinessSuccessCount
	DirectQueryDispatchTimeoutBeforeNonStickyCount
	WorkflowTaskQueryLatency
	ConsistentQueryTimeoutCount
	QueryBeforeFirstWorkflowTaskCount
	QueryBufferExceededCount
	QueryRegistryInvalidStateCount
	WorkerNotSupportsConsistentQueryCount
	WorkflowTaskTimeoutOverrideCount
	WorkflowRunTimeoutOverrideCount
	ReplicationTaskCleanupCount
	ReplicationTaskCleanupFailure
	MutableStateChecksumMismatch
	MutableStateChecksumInvalidated

	ElasticsearchBulkProcessorRequests
	ElasticsearchBulkProcessorQueuedRequests
	ElasticsearchBulkProcessorRetries
	ElasticsearchBulkProcessorFailures
	ElasticsearchBulkProcessorCorruptedData
	ElasticsearchBulkProcessorDuplicateRequest

	ElasticsearchBulkProcessorRequestLatency
	ElasticsearchBulkProcessorCommitLatency
	ElasticsearchBulkProcessorWaitAddLatency
	ElasticsearchBulkProcessorWaitStartLatency

	ElasticsearchBulkProcessorBulkSize

	ElasticsearchBulkProcessorDeadlock

	NumHistoryMetrics
)

History Metrics enum

View Source 
const (
	PollSuccessPerTaskQueueCounter = iota + NumHistoryMetrics
	PollTimeoutPerTaskQueueCounter
	PollSuccessWithSyncPerTaskQueueCounter
	LeaseRequestPerTaskQueueCounter
	LeaseFailurePerTaskQueueCounter
	ConditionFailedErrorPerTaskQueueCounter
	RespondQueryTaskFailedPerTaskQueueCounter
	SyncThrottlePerTaskQueueCounter
	BufferThrottlePerTaskQueueCounter
	SyncMatchLatencyPerTaskQueue
	AsyncMatchLatencyPerTaskQueue
	ExpiredTasksPerTaskQueueCounter
	ForwardedPerTaskQueueCounter
	ForwardTaskCallsPerTaskQueue // Deprecated todo not used
	ForwardTaskErrorsPerTaskQueue
	ForwardTaskLatencyPerTaskQueue
	ForwardQueryCallsPerTaskQueue  // Deprecated todo not used
	ForwardQueryErrorsPerTaskQueue // Deprecated todo not used
	ForwardQueryLatencyPerTaskQueue
	ForwardPollCallsPerTaskQueue  // Deprecated todo not used
	ForwardPollErrorsPerTaskQueue // Deprecated todo not used
	ForwardPollLatencyPerTaskQueue
	LocalToLocalMatchPerTaskQueueCounter
	LocalToRemoteMatchPerTaskQueueCounter
	RemoteToLocalMatchPerTaskQueueCounter
	RemoteToRemoteMatchPerTaskQueueCounter
	LoadedTaskQueueGauge
	TaskQueueStartedCounter
	TaskQueueStoppedCounter

	NumMatchingMetrics
)

Matching metrics enum

View Source 
const (
	ReplicatorMessages = iota + NumMatchingMetrics
	ReplicatorFailures
	ReplicatorLatency
	ReplicatorDLQFailures
	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
	TaskQueueProcessedCount
	TaskQueueDeletedCount
	TaskQueueOutstandingCount
	ExecutionsOutstandingCount
	StartedCount
	StoppedCount
	ScanDuration
	ExecutorTasksDoneCount
	ExecutorTasksErrCount
	ExecutorTasksDeferredCount
	ExecutorTasksDroppedCount
	BatcherProcessorSuccess
	BatcherProcessorFailures
	HistoryScavengerSuccessCount
	HistoryScavengerErrorCount
	HistoryScavengerSkipCount
	NamespaceReplicationEnqueueDLQCount
	ScavengerValidationRequestsCount
	ScavengerValidationFailuresCount
	AddSearchAttributesFailuresCount

	NumWorkerMetrics
)

Worker metrics enum

View Source 
const (
	TlsCertsExpired = iota + NumWorkerMetrics
	TlsCertsExpiring

	NumServerMetrics
)

Server metrics enum

View Source 
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
)
View Source 
const (
	HistoryWorkflowExecutionCacheLatency = "history_workflow_execution_cache_latency"
)

Values used for metrics propagation

Variables

View Source 
var GoRuntimeMetrics = map[MetricName]MetricType{
	NumGoRoutinesGauge:   Gauge,
	GoMaxProcsGauge:      Gauge,
	MemoryAllocatedGauge: Gauge,
	MemoryHeapGauge:      Gauge,
	MemoryHeapIdleGauge:  Gauge,
	MemoryHeapInuseGauge: Gauge,
	MemoryStackGauge:     Gauge,
	NumGCCounter:         Counter,
	GcPauseMsTimer:       Timer,
}

GoRuntimeMetrics represent the runtime stats from go runtime

View Source 
var KVDelimiter = ","
View Source 
var KVPairsDelimiter = ";"
View Source 
var MetricDefs = map[ServiceIdx]map[int]metricDefinition{
	Common: {
		ServiceRequests:                                     NewCounterDef("service_requests"),
		ServicePendingRequests:                              NewGaugeDef("service_pending_requests"),
		ServiceFailures:                                     NewCounterDef("service_errors"),
		ServiceCriticalFailures:                             NewCounterDef("service_errors_critical"),
		ServiceLatency:                                      NewTimerDef("service_latency"),
		ServiceLatencyNoUserLatency:                         NewTimerDef("service_latency_nouserlatency"),
		ServiceLatencyUserLatency:                           NewTimerDef("service_latency_userlatency"),
		ServiceErrInvalidArgumentCounter:                    NewCounterDef("service_errors_invalid_argument"),
		ServiceErrNamespaceNotActiveCounter:                 NewCounterDef("service_errors_namespace_not_active"),
		ServiceErrResourceExhaustedCounter:                  NewCounterDef("service_errors_resource_exhausted"),
		ServiceErrNotFoundCounter:                           NewCounterDef("service_errors_entity_not_found"),
		ServiceErrExecutionAlreadyStartedCounter:            NewCounterDef("service_errors_execution_already_started"),
		ServiceErrNamespaceAlreadyExistsCounter:             NewCounterDef("service_errors_namespace_already_exists"),
		ServiceErrCancellationAlreadyRequestedCounter:       NewCounterDef("service_errors_cancellation_already_requested"),
		ServiceErrQueryFailedCounter:                        NewCounterDef("service_errors_query_failed"),
		ServiceErrContextCancelledCounter:                   NewCounterDef("service_errors_context_cancelled"),
		ServiceErrContextTimeoutCounter:                     NewCounterDef("service_errors_context_timeout"),
		ServiceErrRetryTaskCounter:                          NewCounterDef("service_errors_retry_task"),
		ServiceErrBadBinaryCounter:                          NewCounterDef("service_errors_bad_binary"),
		ServiceErrClientVersionNotSupportedCounter:          NewCounterDef("service_errors_client_version_not_supported"),
		ServiceErrIncompleteHistoryCounter:                  NewCounterDef("service_errors_incomplete_history"),
		ServiceErrNonDeterministicCounter:                   NewCounterDef("service_errors_nondeterministic"),
		ServiceErrUnauthorizedCounter:                       NewCounterDef("service_errors_unauthorized"),
		ServiceErrAuthorizeFailedCounter:                    NewCounterDef("service_errors_authorize_failed"),
		PersistenceRequests:                                 NewCounterDef("persistence_requests"),
		PersistenceFailures:                                 NewCounterDef("persistence_errors"),
		PersistenceLatency:                                  NewTimerDef("persistence_latency"),
		PersistenceErrShardExistsCounter:                    NewCounterDef("persistence_errors_shard_exists"),
		PersistenceErrShardOwnershipLostCounter:             NewCounterDef("persistence_errors_shard_ownership_lost"),
		PersistenceErrConditionFailedCounter:                NewCounterDef("persistence_errors_condition_failed"),
		PersistenceErrCurrentWorkflowConditionFailedCounter: NewCounterDef("persistence_errors_current_workflow_condition_failed"),
		PersistenceErrWorkflowConditionFailedCounter:        NewCounterDef("persistence_errors_workflow_condition_failed"),
		PersistenceErrTimeoutCounter:                        NewCounterDef("persistence_errors_timeout"),
		PersistenceErrBusyCounter:                           NewCounterDef("persistence_errors_busy"),
		PersistenceErrEntityNotExistsCounter:                NewCounterDef("persistence_errors_entity_not_exists"),
		PersistenceErrNamespaceAlreadyExistsCounter:         NewCounterDef("persistence_errors_namespace_already_exists"),
		PersistenceErrBadRequestCounter:                     NewCounterDef("persistence_errors_bad_request"),
		ClientRequests:                                      NewCounterDef("client_requests"),
		ClientFailures:                                      NewCounterDef("client_errors"),
		ClientLatency:                                       NewTimerDef("client_latency"),
		ClientRedirectionRequests:                           NewCounterDef("client_redirection_requests"),
		ClientRedirectionFailures:                           NewCounterDef("client_redirection_errors"),
		ClientRedirectionLatency:                            NewTimerDef("client_redirection_latency"),
		ServiceAuthorizationLatency:                         NewTimerDef("service_authorization_latency"),
		NamespaceCachePrepareCallbacksLatency:               NewTimerDef("namespace_cache_prepare_callbacks_latency"),
		NamespaceCacheCallbacksLatency:                      NewTimerDef("namespace_cache_callbacks_latency"),
		StateTransitionCount:                                NewDimensionlessHistogramDef("state_transition_count"),
		HistorySize:                                         NewBytesHistogramDef("history_size"),
		HistoryCount:                                        NewDimensionlessHistogramDef("history_count"),
		EventBlobSize:                                       NewBytesHistogramDef("event_blob_size"),
		SearchAttributesSize:                                NewBytesHistogramDef("search_attributes_size"),
		LockRequests:                                        NewCounterDef("lock_requests"),
		LockFailures:                                        NewCounterDef("lock_failures"),
		LockLatency:                                         NewTimerDef("lock_latency"),
		ArchivalConfigFailures:                              NewCounterDef("archivalconfig_failures"),

		VisibilityPersistenceRequests:          NewCounterDef("visibility_persistence_requests"),
		VisibilityPersistenceFailures:          NewCounterDef("visibility_persistence_errors"),
		VisibilityPersistenceLatency:           NewTimerDef("visibility_persistence_latency"),
		VisibilityPersistenceInvalidArgument:   NewCounterDef("visibility_persistence_invalid_argument"),
		VisibilityPersistenceResourceExhausted: NewCounterDef("visibility_persistence_resource_exhausted"),
		VisibilityPersistenceConditionFailed:   NewCounterDef("visibility_persistence_condition_failed"),
		VisibilityPersistenceTimeout:           NewCounterDef("visibility_persistence_timeout"),
		VisibilityPersistenceNotFound:          NewCounterDef("visibility_persistence_not_found"),
		VisibilityPersistenceInternal:          NewCounterDef("visibility_persistence_internal"),
		VisibilityPersistenceUnavailable:       NewCounterDef("visibility_persistence_unavailable"),

		SequentialTaskSubmitRequest:                 NewCounterDef("sequentialtask_submit_request"),
		SequentialTaskSubmitRequestTaskQueueExist:   NewCounterDef("sequentialtask_submit_request_taskqueue_exist"),
		SequentialTaskSubmitRequestTaskQueueMissing: NewCounterDef("sequentialtask_submit_request_taskqueue_missing"),
		SequentialTaskSubmitLatency:                 NewTimerDef("sequentialtask_submit_latency"),
		SequentialTaskQueueSize:                     NewBytesHistogramDef("sequentialtask_queue_size"),
		SequentialTaskQueueProcessingLatency:        NewTimerDef("sequentialtask_queue_processing_latency"),
		SequentialTaskTaskProcessingLatency:         NewTimerDef("sequentialtask_task_processing_latency"),
		ParallelTaskSubmitRequest:                   NewCounterDef("paralleltask_submit_request"),
		ParallelTaskSubmitLatency:                   NewTimerDef("paralleltask_submit_latency"),
		ParallelTaskTaskProcessingLatency:           NewTimerDef("paralleltask_task_processing_latency"),
		PriorityTaskSubmitRequest:                   NewCounterDef("prioritytask_submit_request"),
		PriorityTaskSubmitLatency:                   NewTimerDef("prioritytask_submit_latency"),

		HistoryArchiverArchiveNonRetryableErrorCount:              NewCounterDef("history_archiver_archive_non_retryable_error"),
		HistoryArchiverArchiveTransientErrorCount:                 NewCounterDef("history_archiver_archive_transient_error"),
		HistoryArchiverArchiveSuccessCount:                        NewCounterDef("history_archiver_archive_success"),
		HistoryArchiverHistoryMutatedCount:                        NewCounterDef("history_archiver_history_mutated"),
		HistoryArchiverTotalUploadSize:                            NewBytesHistogramDef("history_archiver_total_upload_size"),
		HistoryArchiverHistorySize:                                NewBytesHistogramDef("history_archiver_history_size"),
		HistoryArchiverBlobExistsCount:                            NewCounterDef("history_archiver_blob_exists"),
		HistoryArchiverBlobSize:                                   NewBytesHistogramDef("history_archiver_blob_size"),
		HistoryArchiverRunningDeterministicConstructionCheckCount: NewCounterDef("history_archiver_running_deterministic_construction_check"),
		HistoryArchiverDeterministicConstructionCheckFailedCount:  NewCounterDef("history_archiver_deterministic_construction_check_failed"),
		HistoryArchiverRunningBlobIntegrityCheckCount:             NewCounterDef("history_archiver_running_blob_integrity_check"),
		HistoryArchiverBlobIntegrityCheckFailedCount:              NewCounterDef("history_archiver_blob_integrity_check_failed"),
		HistoryArchiverDuplicateArchivalsCount:                    NewCounterDef("history_archiver_duplicate_archivals"),
		VisibilityArchiverArchiveNonRetryableErrorCount:           NewCounterDef("visibility_archiver_archive_non_retryable_error"),
		VisibilityArchiverArchiveTransientErrorCount:              NewCounterDef("visibility_archiver_archive_transient_error"),
		VisibilityArchiveSuccessCount:                             NewCounterDef("visibility_archiver_archive_success"),
		VersionCheckSuccessCount:                                  NewCounterDef("version_check_success"),
		VersionCheckFailedCount:                                   NewCounterDef("version_check_failed"),
		VersionCheckRequestFailedCount:                            NewCounterDef("version_check_request_failed"),
		VersionCheckLatency:                                       NewTimerDef("version_check_latency"),

		ParentClosePolicyProcessorSuccess:  NewCounterDef("parent_close_policy_processor_requests"),
		ParentClosePolicyProcessorFailures: NewCounterDef("parent_close_policy_processor_errors"),

		AddSearchAttributesWorkflowSuccessCount:  NewCounterDef("add_search_attributes_workflow_success"),
		AddSearchAttributesWorkflowFailuresCount: NewCounterDef("add_search_attributes_workflow_failure"),

		MatchingClientForwardedCounter:     NewCounterDef("forwarded"),
		MatchingClientInvalidTaskQueueName: NewCounterDef("invalid_task_queue_name"),

		NamespaceReplicationTaskAckLevelGauge: NewGaugeDef("namespace_replication_task_ack_level"),
		NamespaceReplicationDLQAckLevelGauge:  NewGaugeDef("namespace_dlq_ack_level"),
		NamespaceReplicationDLQMaxLevelGauge:  NewGaugeDef("namespace_dlq_max_level"),

		ServiceRequestsPerTaskQueue:                               NewRollupCounterDef("service_requests_per_tl", "service_requests"),
		ServiceFailuresPerTaskQueue:                               NewRollupCounterDef("service_errors_per_tl", "service_errors"),
		ServiceLatencyPerTaskQueue:                                NewRollupTimerDef("service_latency_per_tl", "service_latency"),
		ServiceErrInvalidArgumentPerTaskQueueCounter:              NewRollupCounterDef("service_errors_invalid_argument_per_tl", "service_errors_invalid_argument"),
		ServiceErrNamespaceNotActivePerTaskQueueCounter:           NewRollupCounterDef("service_errors_namespace_not_active_per_tl", "service_errors_namespace_not_active"),
		ServiceErrResourceExhaustedPerTaskQueueCounter:            NewRollupCounterDef("service_errors_resource_exhausted_per_tl", "service_errors_resource_exhausted"),
		ServiceErrNotFoundPerTaskQueueCounter:                     NewRollupCounterDef("service_errors_entity_not_found_per_tl", "service_errors_entity_not_found"),
		ServiceErrExecutionAlreadyStartedPerTaskQueueCounter:      NewRollupCounterDef("service_errors_execution_already_started_per_tl", "service_errors_execution_already_started"),
		ServiceErrNamespaceAlreadyExistsPerTaskQueueCounter:       NewRollupCounterDef("service_errors_namespace_already_exists_per_tl", "service_errors_namespace_already_exists"),
		ServiceErrCancellationAlreadyRequestedPerTaskQueueCounter: NewRollupCounterDef("service_errors_cancellation_already_requested_per_tl", "service_errors_cancellation_already_requested"),
		ServiceErrQueryFailedPerTaskQueueCounter:                  NewRollupCounterDef("service_errors_query_failed_per_tl", "service_errors_query_failed"),
		ServiceErrContextTimeoutPerTaskQueueCounter:               NewRollupCounterDef("service_errors_context_timeout_per_tl", "service_errors_context_timeout"),
		ServiceErrRetryTaskPerTaskQueueCounter:                    NewRollupCounterDef("service_errors_retry_task_per_tl", "service_errors_retry_task"),
		ServiceErrBadBinaryPerTaskQueueCounter:                    NewRollupCounterDef("service_errors_bad_binary_per_tl", "service_errors_bad_binary"),
		ServiceErrClientVersionNotSupportedPerTaskQueueCounter:    NewRollupCounterDef("service_errors_client_version_not_supported_per_tl", "service_errors_client_version_not_supported"),
		ServiceErrIncompleteHistoryPerTaskQueueCounter:            NewRollupCounterDef("service_errors_incomplete_history_per_tl", "service_errors_incomplete_history"),
		ServiceErrNonDeterministicPerTaskQueueCounter:             NewRollupCounterDef("service_errors_nondeterministic_per_tl", "service_errors_nondeterministic"),
		ServiceErrUnauthorizedPerTaskQueueCounter:                 NewRollupCounterDef("service_errors_unauthorized_per_tl", "service_errors_unauthorized"),
		ServiceErrAuthorizeFailedPerTaskQueueCounter:              NewRollupCounterDef("service_errors_authorize_failed_per_tl", "service_errors_authorize_failed"),
		ElasticsearchDocumentParseFailuresCount:                   NewCounterDef("elasticsearch_document_parse_failures_counter"),
		ElasticsearchDocumentGenerateFailuresCount:                NewCounterDef("elasticsearch_document_generate_failures_counter"),

		NoopImplementationIsUsed: NewCounterDef("noop_implementation_is_used"),
	},
	History: {
		TaskRequests: NewCounterDef("task_requests"),

		TaskLatency:       NewTimerDef("task_latency"),
		TaskUserLatency:   NewTimerDef("task_latency_userlatency"),
		TaskNoUserLatency: NewTimerDef("task_latency_nouserlatency"),

		TaskAttemptTimer:         NewDimensionlessHistogramDef("task_attempt"),
		TaskFailures:             NewCounterDef("task_errors"),
		TaskDiscarded:            NewCounterDef("task_errors_discarded"),
		TaskStandbyRetryCounter:  NewCounterDef("task_errors_standby_retry_counter"),
		TaskNotActiveCounter:     NewCounterDef("task_errors_not_active_counter"),
		TaskLimitExceededCounter: NewCounterDef("task_errors_limit_exceeded_counter"),

		TaskScheduleToStartLatency: NewTimerDef("task_schedule_to_start_latency"),

		TaskProcessingLatency:       NewTimerDef("task_latency_processing"),
		TaskNoUserProcessingLatency: NewTimerDef("task_latency_processing_nouserlatency"),

		TaskQueueLatency:       NewTimerDef("task_latency_queue"),
		TaskNoUserQueueLatency: NewTimerDef("task_latency_queue_nouserlatency"),

		TransferTaskMissingEventCounter:                   NewCounterDef("transfer_task_missing_event_counter"),
		TaskBatchCompleteCounter:                          NewCounterDef("task_batch_complete_counter"),
		TaskRedispatchQueuePendingTasksTimer:              NewTimerDef("task_redispatch_queue_pending_tasks"),
		TransferTaskThrottledCounter:                      NewCounterDef("transfer_task_throttled_counter"),
		TimerTaskThrottledCounter:                         NewCounterDef("timer_task_throttled_counter"),
		ActivityE2ELatency:                                NewTimerDef("activity_end_to_end_latency"),
		AckLevelUpdateCounter:                             NewCounterDef("ack_level_update"),
		AckLevelUpdateFailedCounter:                       NewCounterDef("ack_level_update_failed"),
		CommandTypeScheduleActivityCounter:                NewCounterDef("schedule_activity_command"),
		CommandTypeCompleteWorkflowCounter:                NewCounterDef("complete_workflow_command"),
		CommandTypeFailWorkflowCounter:                    NewCounterDef("fail_workflow_command"),
		CommandTypeCancelWorkflowCounter:                  NewCounterDef("cancel_workflow_command"),
		CommandTypeStartTimerCounter:                      NewCounterDef("start_timer_command"),
		CommandTypeCancelActivityCounter:                  NewCounterDef("cancel_activity_command"),
		CommandTypeCancelTimerCounter:                     NewCounterDef("cancel_timer_command"),
		CommandTypeRecordMarkerCounter:                    NewCounterDef("record_marker_command"),
		CommandTypeCancelExternalWorkflowCounter:          NewCounterDef("cancel_external_workflow_command"),
		CommandTypeContinueAsNewCounter:                   NewCounterDef("continue_as_new_command"),
		CommandTypeSignalExternalWorkflowCounter:          NewCounterDef("signal_external_workflow_command"),
		CommandTypeUpsertWorkflowSearchAttributesCounter:  NewCounterDef("upsert_workflow_search_attributes_command"),
		CommandTypeChildWorkflowCounter:                   NewCounterDef("child_workflow_command"),
		EmptyCompletionCommandsCounter:                    NewCounterDef("empty_completion_commands"),
		MultipleCompletionCommandsCounter:                 NewCounterDef("multiple_completion_commands"),
		FailedWorkflowTasksCounter:                        NewCounterDef("failed_workflow_tasks"),
		StaleMutableStateCounter:                          NewCounterDef("stale_mutable_state"),
		AutoResetPointsLimitExceededCounter:               NewCounterDef("auto_reset_points_exceed_limit"),
		AutoResetPointCorruptionCounter:                   NewCounterDef("auto_reset_point_corruption"),
		ConcurrencyUpdateFailureCounter:                   NewCounterDef("concurrency_update_failure"),
		ServiceErrShardOwnershipLostCounter:               NewCounterDef("service_errors_shard_ownership_lost"),
		ServiceErrTaskAlreadyStartedCounter:               NewCounterDef("service_errors_task_already_started"),
		HeartbeatTimeoutCounter:                           NewCounterDef("heartbeat_timeout"),
		ScheduleToStartTimeoutCounter:                     NewCounterDef("schedule_to_start_timeout"),
		StartToCloseTimeoutCounter:                        NewCounterDef("start_to_close_timeout"),
		ScheduleToCloseTimeoutCounter:                     NewCounterDef("schedule_to_close_timeout"),
		NewTimerNotifyCounter:                             NewCounterDef("new_timer_notifications"),
		AcquireShardsCounter:                              NewCounterDef("acquire_shards_count"),
		AcquireShardsLatency:                              NewTimerDef("acquire_shards_latency"),
		ShardContextClosedCounter:                         NewCounterDef("shard_closed_count"),
		ShardContextCreatedCounter:                        NewCounterDef("sharditem_created_count"),
		ShardContextRemovedCounter:                        NewCounterDef("sharditem_removed_count"),
		ShardContextAcquisitionLatency:                    NewTimerDef("sharditem_acquisition_latency"),
		ShardInfoReplicationPendingTasksTimer:             NewDimensionlessHistogramDef("shardinfo_replication_pending_task"),
		ShardInfoTransferActivePendingTasksTimer:          NewDimensionlessHistogramDef("shardinfo_transfer_active_pending_task"),
		ShardInfoTransferStandbyPendingTasksTimer:         NewDimensionlessHistogramDef("shardinfo_transfer_standby_pending_task"),
		ShardInfoTimerActivePendingTasksTimer:             NewDimensionlessHistogramDef("shardinfo_timer_active_pending_task"),
		ShardInfoTimerStandbyPendingTasksTimer:            NewDimensionlessHistogramDef("shardinfo_timer_standby_pending_task"),
		ShardInfoReplicationLagHistogram:                  NewDimensionlessHistogramDef("shardinfo_replication_lag"),
		ShardInfoTransferLagHistogram:                     NewDimensionlessHistogramDef("shardinfo_transfer_lag"),
		ShardInfoTimerLagTimer:                            NewTimerDef("shardinfo_timer_lag"),
		ShardInfoTransferDiffHistogram:                    NewDimensionlessHistogramDef("shardinfo_transfer_diff"),
		ShardInfoTimerDiffTimer:                           NewTimerDef("shardinfo_timer_diff"),
		ShardInfoTransferFailoverInProgressHistogram:      NewDimensionlessHistogramDef("shardinfo_transfer_failover_in_progress"),
		ShardInfoTimerFailoverInProgressHistogram:         NewDimensionlessHistogramDef("shardinfo_timer_failover_in_progress"),
		ShardInfoTransferFailoverLatencyTimer:             NewTimerDef("shardinfo_transfer_failover_latency"),
		ShardInfoTimerFailoverLatencyTimer:                NewTimerDef("shardinfo_timer_failover_latency"),
		SyncShardFromRemoteCounter:                        NewCounterDef("syncshard_remote_count"),
		SyncShardFromRemoteFailure:                        NewCounterDef("syncshard_remote_failed"),
		MembershipChangedCounter:                          NewCounterDef("membership_changed_count"),
		NumShardsGauge:                                    NewGaugeDef("numshards_gauge"),
		GetEngineForShardErrorCounter:                     NewCounterDef("get_engine_for_shard_errors"),
		GetEngineForShardLatency:                          NewTimerDef("get_engine_for_shard_latency"),
		RemoveEngineForShardLatency:                       NewTimerDef("remove_engine_for_shard_latency"),
		CompleteWorkflowTaskWithStickyEnabledCounter:      NewCounterDef("complete_workflow_task_sticky_enabled_count"),
		CompleteWorkflowTaskWithStickyDisabledCounter:     NewCounterDef("complete_workflow_task_sticky_disabled_count"),
		WorkflowTaskHeartbeatTimeoutCounter:               NewCounterDef("workflow_task_heartbeat_timeout_count"),
		HistoryEventNotificationQueueingLatency:           NewTimerDef("history_event_notification_queueing_latency"),
		HistoryEventNotificationFanoutLatency:             NewTimerDef("history_event_notification_fanout_latency"),
		HistoryEventNotificationInFlightMessageGauge:      NewGaugeDef("history_event_notification_inflight_message_gauge"),
		HistoryEventNotificationFailDeliveryCount:         NewCounterDef("history_event_notification_fail_delivery_count"),
		EmptyReplicationEventsCounter:                     NewCounterDef("empty_replication_events"),
		DuplicateReplicationEventsCounter:                 NewCounterDef("duplicate_replication_events"),
		StaleReplicationEventsCounter:                     NewCounterDef("stale_replication_events"),
		ReplicationEventsSizeTimer:                        NewTimerDef("replication_events_size"),
		BufferReplicationTaskTimer:                        NewTimerDef("buffer_replication_tasks"),
		UnbufferReplicationTaskTimer:                      NewTimerDef("unbuffer_replication_tasks"),
		HistoryConflictsCounter:                           NewCounterDef("history_conflicts"),
		CompleteTaskFailedCounter:                         NewCounterDef("complete_task_fail_count"),
		CacheRequests:                                     NewCounterDef("cache_requests"),
		CacheFailures:                                     NewCounterDef("cache_errors"),
		CacheLatency:                                      NewTimerDef("cache_latency"),
		CacheMissCounter:                                  NewCounterDef("cache_miss"),
		AcquireLockFailedCounter:                          NewCounterDef("acquire_lock_failed"),
		WorkflowContextCleared:                            NewCounterDef("workflow_context_cleared"),
		MutableStateSize:                                  NewBytesHistogramDef("mutable_state_size"),
		ExecutionInfoSize:                                 NewBytesHistogramDef("execution_info_size"),
		ExecutionStateSize:                                NewBytesHistogramDef("execution_state_size"),
		ActivityInfoSize:                                  NewBytesHistogramDef("activity_info_size"),
		TimerInfoSize:                                     NewBytesHistogramDef("timer_info_size"),
		ChildInfoSize:                                     NewBytesHistogramDef("child_info_size"),
		RequestCancelInfoSize:                             NewBytesHistogramDef("request_cancel_info_size"),
		SignalInfoSize:                                    NewBytesHistogramDef("signal_info_size"),
		BufferedEventsSize:                                NewBytesHistogramDef("buffered_events_size"),
		ActivityInfoCount:                                 NewDimensionlessHistogramDef("activity_info_count"),
		TimerInfoCount:                                    NewDimensionlessHistogramDef("timer_info_count"),
		ChildInfoCount:                                    NewDimensionlessHistogramDef("child_info_count"),
		SignalInfoCount:                                   NewDimensionlessHistogramDef("signal_info_count"),
		RequestCancelInfoCount:                            NewDimensionlessHistogramDef("request_cancel_info_count"),
		BufferedEventsCount:                               NewDimensionlessHistogramDef("buffered_events_count"),
		WorkflowRetryBackoffTimerCount:                    NewCounterDef("workflow_retry_backoff_timer"),
		WorkflowCronBackoffTimerCount:                     NewCounterDef("workflow_cron_backoff_timer"),
		WorkflowCleanupDeleteCount:                        NewCounterDef("workflow_cleanup_delete"),
		WorkflowCleanupArchiveCount:                       NewCounterDef("workflow_cleanup_archive"),
		WorkflowCleanupNopCount:                           NewCounterDef("workflow_cleanup_nop"),
		WorkflowCleanupDeleteHistoryInlineCount:           NewCounterDef("workflow_cleanup_delete_history_inline"),
		WorkflowSuccessCount:                              NewCounterDef("workflow_success"),
		WorkflowCancelCount:                               NewCounterDef("workflow_cancel"),
		WorkflowFailedCount:                               NewCounterDef("workflow_failed"),
		WorkflowTimeoutCount:                              NewCounterDef("workflow_timeout"),
		WorkflowTerminateCount:                            NewCounterDef("workflow_terminate"),
		WorkflowContinuedAsNewCount:                       NewCounterDef("workflow_continued_as_new"),
		ArchiverClientSendSignalCount:                     NewCounterDef("archiver_client_sent_signal"),
		ArchiverClientSendSignalFailureCount:              NewCounterDef("archiver_client_send_signal_error"),
		ArchiverClientHistoryRequestCount:                 NewCounterDef("archiver_client_history_request"),
		ArchiverClientHistoryInlineArchiveAttemptCount:    NewCounterDef("archiver_client_history_inline_archive_attempt"),
		ArchiverClientHistoryInlineArchiveFailureCount:    NewCounterDef("archiver_client_history_inline_archive_failure"),
		ArchiverClientVisibilityRequestCount:              NewCounterDef("archiver_client_visibility_request"),
		ArchiverClientVisibilityInlineArchiveAttemptCount: NewCounterDef("archiver_client_visibility_inline_archive_attempt"),
		ArchiverClientVisibilityInlineArchiveFailureCount: NewCounterDef("archiver_client_visibility_inline_archive_failure"),
		LastRetrievedMessageID:                            NewGaugeDef("last_retrieved_message_id"),
		LastProcessedMessageID:                            NewGaugeDef("last_processed_message_id"),
		ReplicationTasksApplied:                           NewCounterDef("replication_tasks_applied"),
		ReplicationTasksFailed:                            NewCounterDef("replication_tasks_failed"),
		ReplicationTasksLag:                               NewTimerDef("replication_tasks_lag"),
		ReplicationTasksFetched:                           NewTimerDef("replication_tasks_fetched"),
		ReplicationTasksReturned:                          NewTimerDef("replication_tasks_returned"),
		ReplicationTasksAppliedLatency:                    NewTimerDef("replication_tasks_applied_latency"),
		ReplicationDLQFailed:                              NewCounterDef("replication_dlq_enqueue_failed"),
		ReplicationDLQMaxLevelGauge:                       NewGaugeDef("replication_dlq_max_level"),
		ReplicationDLQAckLevelGauge:                       NewGaugeDef("replication_dlq_ack_level"),
		GetReplicationMessagesForShardLatency:             NewTimerDef("get_replication_messages_for_shard"),
		GetDLQReplicationMessagesLatency:                  NewTimerDef("get_dlq_replication_messages"),
		EventReapplySkippedCount:                          NewCounterDef("event_reapply_skipped_count"),
		DirectQueryDispatchLatency:                        NewTimerDef("direct_query_dispatch_latency"),
		DirectQueryDispatchStickyLatency:                  NewTimerDef("direct_query_dispatch_sticky_latency"),
		DirectQueryDispatchNonStickyLatency:               NewTimerDef("direct_query_dispatch_non_sticky_latency"),
		DirectQueryDispatchStickySuccessCount:             NewCounterDef("direct_query_dispatch_sticky_success"),
		DirectQueryDispatchNonStickySuccessCount:          NewCounterDef("direct_query_dispatch_non_sticky_success"),
		DirectQueryDispatchClearStickinessLatency:         NewTimerDef("direct_query_dispatch_clear_stickiness_latency"),
		DirectQueryDispatchClearStickinessSuccessCount:    NewCounterDef("direct_query_dispatch_clear_stickiness_success"),
		DirectQueryDispatchTimeoutBeforeNonStickyCount:    NewCounterDef("direct_query_dispatch_timeout_before_non_sticky"),
		WorkflowTaskQueryLatency:                          NewTimerDef("workflow_task_query_latency"),
		ConsistentQueryTimeoutCount:                       NewCounterDef("consistent_query_timeout"),
		QueryBeforeFirstWorkflowTaskCount:                 NewCounterDef("query_before_first_workflow_task"),
		QueryBufferExceededCount:                          NewCounterDef("query_buffer_exceeded"),
		QueryRegistryInvalidStateCount:                    NewCounterDef("query_registry_invalid_state"),
		WorkerNotSupportsConsistentQueryCount:             NewCounterDef("worker_not_supports_consistent_query"),
		WorkflowTaskTimeoutOverrideCount:                  NewCounterDef("workflow_task_timeout_overrides"),
		WorkflowRunTimeoutOverrideCount:                   NewCounterDef("workflow_run_timeout_overrides"),
		ReplicationTaskCleanupCount:                       NewCounterDef("replication_task_cleanup_count"),
		ReplicationTaskCleanupFailure:                     NewCounterDef("replication_task_cleanup_failed"),
		MutableStateChecksumMismatch:                      NewCounterDef("mutable_state_checksum_mismatch"),
		MutableStateChecksumInvalidated:                   NewCounterDef("mutable_state_checksum_invalidated"),

		ElasticsearchBulkProcessorRequests:         NewCounterDef("elasticsearch_bulk_processor_requests"),
		ElasticsearchBulkProcessorQueuedRequests:   NewDimensionlessHistogramDef("elasticsearch_bulk_processor_queued_requests"),
		ElasticsearchBulkProcessorRetries:          NewCounterDef("elasticsearch_bulk_processor_retries"),
		ElasticsearchBulkProcessorFailures:         NewCounterDef("elasticsearch_bulk_processor_errors"),
		ElasticsearchBulkProcessorCorruptedData:    NewCounterDef("elasticsearch_bulk_processor_corrupted_data"),
		ElasticsearchBulkProcessorDuplicateRequest: NewCounterDef("elasticsearch_bulk_processor_duplicate_request"),
		ElasticsearchBulkProcessorRequestLatency:   NewTimerDef("elasticsearch_bulk_processor_request_latency"),
		ElasticsearchBulkProcessorCommitLatency:    NewTimerDef("elasticsearch_bulk_processor_commit_latency"),
		ElasticsearchBulkProcessorWaitAddLatency:   NewTimerDef("elasticsearch_bulk_processor_wait_add_latency"),
		ElasticsearchBulkProcessorWaitStartLatency: NewTimerDef("elasticsearch_bulk_processor_wait_start_latency"),
		ElasticsearchBulkProcessorBulkSize:         NewDimensionlessHistogramDef("elasticsearch_bulk_processor_bulk_size"),
		ElasticsearchBulkProcessorDeadlock:         NewCounterDef("elasticsearch_bulk_processor_deadlock"),
	},
	Matching: {
		PollSuccessPerTaskQueueCounter:            NewRollupCounterDef("poll_success_per_tl", "poll_success"),
		PollTimeoutPerTaskQueueCounter:            NewRollupCounterDef("poll_timeouts_per_tl", "poll_timeouts"),
		PollSuccessWithSyncPerTaskQueueCounter:    NewRollupCounterDef("poll_success_sync_per_tl", "poll_success_sync"),
		LeaseRequestPerTaskQueueCounter:           NewRollupCounterDef("lease_requests_per_tl", "lease_requests"),
		LeaseFailurePerTaskQueueCounter:           NewRollupCounterDef("lease_failures_per_tl", "lease_failures"),
		ConditionFailedErrorPerTaskQueueCounter:   NewRollupCounterDef("condition_failed_errors_per_tl", "condition_failed_errors"),
		RespondQueryTaskFailedPerTaskQueueCounter: NewRollupCounterDef("respond_query_failed_per_tl", "respond_query_failed"),
		SyncThrottlePerTaskQueueCounter:           NewRollupCounterDef("sync_throttle_count_per_tl", "sync_throttle_count"),
		BufferThrottlePerTaskQueueCounter:         NewRollupCounterDef("buffer_throttle_count_per_tl", "buffer_throttle_count"),
		ExpiredTasksPerTaskQueueCounter:           NewRollupCounterDef("tasks_expired_per_tl", "tasks_expired"),
		ForwardedPerTaskQueueCounter:              NewCounterDef("forwarded_per_tl"),
		ForwardTaskCallsPerTaskQueue:              NewRollupCounterDef("forward_task_calls_per_tl", "forward_task_calls"),
		ForwardTaskErrorsPerTaskQueue:             NewRollupCounterDef("forward_task_errors_per_tl", "forward_task_errors"),
		ForwardQueryCallsPerTaskQueue:             NewRollupCounterDef("forward_query_calls_per_tl", "forward_query_calls"),
		ForwardQueryErrorsPerTaskQueue:            NewRollupCounterDef("forward_query_errors_per_tl", "forward_query_errors"),
		ForwardPollCallsPerTaskQueue:              NewRollupCounterDef("forward_poll_calls_per_tl", "forward_poll_calls"),
		ForwardPollErrorsPerTaskQueue:             NewRollupCounterDef("forward_poll_errors_per_tl", "forward_poll_errors"),
		SyncMatchLatencyPerTaskQueue:              NewRollupTimerDef("syncmatch_latency_per_tl", "syncmatch_latency"),
		AsyncMatchLatencyPerTaskQueue:             NewRollupTimerDef("asyncmatch_latency_per_tl", "asyncmatch_latency"),
		ForwardTaskLatencyPerTaskQueue:            NewRollupTimerDef("forward_task_latency_per_tl", "forward_task_latency"),
		ForwardQueryLatencyPerTaskQueue:           NewRollupTimerDef("forward_query_latency_per_tl", "forward_query_latency"),
		ForwardPollLatencyPerTaskQueue:            NewRollupTimerDef("forward_poll_latency_per_tl", "forward_poll_latency"),
		LocalToLocalMatchPerTaskQueueCounter:      NewRollupCounterDef("local_to_local_matches_per_tl", "local_to_local_matches"),
		LocalToRemoteMatchPerTaskQueueCounter:     NewRollupCounterDef("local_to_remote_matches_per_tl", "local_to_remote_matches"),
		RemoteToLocalMatchPerTaskQueueCounter:     NewRollupCounterDef("remote_to_local_matches_per_tl", "remote_to_local_matches"),
		RemoteToRemoteMatchPerTaskQueueCounter:    NewRollupCounterDef("remote_to_remote_matches_per_tl", "remote_to_remote_matches"),
		LoadedTaskQueueGauge:                      NewGaugeDef("loaded_task_queue_count"),
		TaskQueueStartedCounter:                   NewCounterDef("task_queue_started"),
		TaskQueueStoppedCounter:                   NewCounterDef("task_queue_stopped"),
	},
	Worker: {
		ReplicatorMessages:                            NewCounterDef("replicator_messages"),
		ReplicatorFailures:                            NewCounterDef("replicator_errors"),
		ReplicatorLatency:                             NewTimerDef("replicator_latency"),
		ReplicatorDLQFailures:                         NewCounterDef("replicator_dlq_enqueue_fails"),
		ArchiverNonRetryableErrorCount:                NewCounterDef("archiver_non_retryable_error"),
		ArchiverStartedCount:                          NewCounterDef("archiver_started"),
		ArchiverStoppedCount:                          NewCounterDef("archiver_stopped"),
		ArchiverCoroutineStartedCount:                 NewCounterDef("archiver_coroutine_started"),
		ArchiverCoroutineStoppedCount:                 NewCounterDef("archiver_coroutine_stopped"),
		ArchiverHandleHistoryRequestLatency:           NewTimerDef("archiver_handle_history_request_latency"),
		ArchiverHandleVisibilityRequestLatency:        NewTimerDef("archiver_handle_visibility_request_latency"),
		ArchiverUploadWithRetriesLatency:              NewTimerDef("archiver_upload_with_retries_latency"),
		ArchiverDeleteWithRetriesLatency:              NewTimerDef("archiver_delete_with_retries_latency"),
		ArchiverUploadFailedAllRetriesCount:           NewCounterDef("archiver_upload_failed_all_retries"),
		ArchiverUploadSuccessCount:                    NewCounterDef("archiver_upload_success"),
		ArchiverDeleteFailedAllRetriesCount:           NewCounterDef("archiver_delete_failed_all_retries"),
		ArchiverDeleteSuccessCount:                    NewCounterDef("archiver_delete_success"),
		ArchiverHandleVisibilityFailedAllRetiresCount: NewCounterDef("archiver_handle_visibility_failed_all_retries"),
		ArchiverHandleVisibilitySuccessCount:          NewCounterDef("archiver_handle_visibility_success"),
		ArchiverBacklogSizeGauge:                      NewCounterDef("archiver_backlog_size"),
		ArchiverPumpTimeoutCount:                      NewCounterDef("archiver_pump_timeout"),
		ArchiverPumpSignalThresholdCount:              NewCounterDef("archiver_pump_signal_threshold"),
		ArchiverPumpTimeoutWithoutSignalsCount:        NewCounterDef("archiver_pump_timeout_without_signals"),
		ArchiverPumpSignalChannelClosedCount:          NewCounterDef("archiver_pump_signal_channel_closed"),
		ArchiverWorkflowStartedCount:                  NewCounterDef("archiver_workflow_started"),
		ArchiverNumPumpedRequestsCount:                NewCounterDef("archiver_num_pumped_requests"),
		ArchiverNumHandledRequestsCount:               NewCounterDef("archiver_num_handled_requests"),
		ArchiverPumpedNotEqualHandledCount:            NewCounterDef("archiver_pumped_not_equal_handled"),
		ArchiverHandleAllRequestsLatency:              NewTimerDef("archiver_handle_all_requests_latency"),
		ArchiverWorkflowStoppingCount:                 NewCounterDef("archiver_workflow_stopping"),
		TaskProcessedCount:                            NewGaugeDef("task_processed"),
		TaskDeletedCount:                              NewGaugeDef("task_deleted"),
		TaskQueueProcessedCount:                       NewGaugeDef("taskqueue_processed"),
		TaskQueueDeletedCount:                         NewGaugeDef("taskqueue_deleted"),
		TaskQueueOutstandingCount:                     NewGaugeDef("taskqueue_outstanding"),
		ExecutionsOutstandingCount:                    NewGaugeDef("executions_outstanding"),
		StartedCount:                                  NewCounterDef("started"),
		StoppedCount:                                  NewCounterDef("stopped"),
		ScanDuration:                                  NewTimerDef("scan_duration"),
		ExecutorTasksDoneCount:                        NewCounterDef("executor_done"),
		ExecutorTasksErrCount:                         NewCounterDef("executor_err"),
		ExecutorTasksDeferredCount:                    NewCounterDef("executor_deferred"),
		ExecutorTasksDroppedCount:                     NewCounterDef("executor_dropped"),
		BatcherProcessorSuccess:                       NewCounterDef("batcher_processor_requests"),
		BatcherProcessorFailures:                      NewCounterDef("batcher_processor_errors"),
		HistoryScavengerSuccessCount:                  NewCounterDef("scavenger_success"),
		HistoryScavengerErrorCount:                    NewCounterDef("scavenger_errors"),
		HistoryScavengerSkipCount:                     NewCounterDef("scavenger_skips"),
		NamespaceReplicationEnqueueDLQCount:           NewCounterDef("namespace_replication_dlq_enqueue_requests"),
		ScavengerValidationRequestsCount:              NewCounterDef("scavenger_validation_requests"),
		ScavengerValidationFailuresCount:              NewCounterDef("scavenger_validation_failures"),
		AddSearchAttributesFailuresCount:              NewCounterDef("add_search_attributes_failures"),
	},
	Server: {
		TlsCertsExpired:  NewGaugeDef("certificates_expired"),
		TlsCertsExpiring: NewGaugeDef("certificates_expiring"),
	},
}

MetricDefs record the metrics for all services

View Source 
var RuntimeMetricsReporterLifetimeHooksModule = fx.Options(
	fx.Invoke(RuntimeMetricsReporterLifetimeHooks),
)
View Source 
var RuntimeMetricsReporterModule = fx.Options(
	RuntimeMetricsReporterLifetimeHooksModule,
)
View Source 
var ScopeDefs = map[ServiceIdx]map[int]scopeDefinition{

	Common: {
		UnknownScope:                                      {/* contains filtered or unexported fields */},
		PersistenceGetOrCreateShardScope:                  {/* contains filtered or unexported fields */},
		PersistenceUpdateShardScope:                       {/* contains filtered or unexported fields */},
		PersistenceCreateWorkflowExecutionScope:           {/* contains filtered or unexported fields */},
		PersistenceGetWorkflowExecutionScope:              {/* contains filtered or unexported fields */},
		PersistenceUpdateWorkflowExecutionScope:           {/* contains filtered or unexported fields */},
		PersistenceConflictResolveWorkflowExecutionScope:  {/* contains filtered or unexported fields */},
		PersistenceResetWorkflowExecutionScope:            {/* contains filtered or unexported fields */},
		PersistenceDeleteWorkflowExecutionScope:           {/* contains filtered or unexported fields */},
		PersistenceDeleteCurrentWorkflowExecutionScope:    {/* contains filtered or unexported fields */},
		PersistenceGetCurrentExecutionScope:               {/* contains filtered or unexported fields */},
		PersistenceListConcreteExecutionsScope:            {/* contains filtered or unexported fields */},
		PersistenceAddTasksScope:                          {/* contains filtered or unexported fields */},
		PersistenceGetTransferTaskScope:                   {/* contains filtered or unexported fields */},
		PersistenceGetTransferTasksScope:                  {/* contains filtered or unexported fields */},
		PersistenceCompleteTransferTaskScope:              {/* contains filtered or unexported fields */},
		PersistenceRangeCompleteTransferTaskScope:         {/* contains filtered or unexported fields */},
		PersistenceGetVisibilityTaskScope:                 {/* contains filtered or unexported fields */},
		PersistenceGetVisibilityTasksScope:                {/* contains filtered or unexported fields */},
		PersistenceCompleteVisibilityTaskScope:            {/* contains filtered or unexported fields */},
		PersistenceRangeCompleteVisibilityTaskScope:       {/* contains filtered or unexported fields */},
		PersistenceGetTieredStorageTaskScope:              {/* contains filtered or unexported fields */},
		PersistenceGetTieredStorageTasksScope:             {/* contains filtered or unexported fields */},
		PersistenceCompleteTieredStorageTaskScope:         {/* contains filtered or unexported fields */},
		PersistenceRangeCompleteTieredStorageTaskScope:    {/* contains filtered or unexported fields */},
		PersistenceGetReplicationTaskScope:                {/* contains filtered or unexported fields */},
		PersistenceGetReplicationTasksScope:               {/* contains filtered or unexported fields */},
		PersistenceCompleteReplicationTaskScope:           {/* contains filtered or unexported fields */},
		PersistenceRangeCompleteReplicationTaskScope:      {/* contains filtered or unexported fields */},
		PersistencePutReplicationTaskToDLQScope:           {/* contains filtered or unexported fields */},
		PersistenceGetReplicationTasksFromDLQScope:        {/* contains filtered or unexported fields */},
		PersistenceDeleteReplicationTaskFromDLQScope:      {/* contains filtered or unexported fields */},
		PersistenceRangeDeleteReplicationTaskFromDLQScope: {/* contains filtered or unexported fields */},
		PersistenceGetTimerTaskScope:                      {/* contains filtered or unexported fields */},
		PersistenceGetTimerTasksScope:                     {/* contains filtered or unexported fields */},
		PersistenceCompleteTimerTaskScope:                 {/* contains filtered or unexported fields */},
		PersistenceRangeCompleteTimerTaskScope:            {/* contains filtered or unexported fields */},
		PersistenceCreateTaskScope:                        {/* contains filtered or unexported fields */},
		PersistenceGetTasksScope:                          {/* contains filtered or unexported fields */},
		PersistenceCompleteTaskScope:                      {/* contains filtered or unexported fields */},
		PersistenceCompleteTasksLessThanScope:             {/* contains filtered or unexported fields */},
		PersistenceLeaseTaskQueueScope:                    {/* contains filtered or unexported fields */},
		PersistenceUpdateTaskQueueScope:                   {/* contains filtered or unexported fields */},
		PersistenceListTaskQueueScope:                     {/* contains filtered or unexported fields */},
		PersistenceDeleteTaskQueueScope:                   {/* contains filtered or unexported fields */},
		PersistenceAppendHistoryEventsScope:               {/* contains filtered or unexported fields */},
		PersistenceGetWorkflowExecutionHistoryScope:       {/* contains filtered or unexported fields */},
		PersistenceDeleteWorkflowExecutionHistoryScope:    {/* contains filtered or unexported fields */},
		PersistenceInitializeSystemNamespaceScope:         {/* contains filtered or unexported fields */},
		PersistenceCreateNamespaceScope:                   {/* contains filtered or unexported fields */},
		PersistenceGetNamespaceScope:                      {/* contains filtered or unexported fields */},
		PersistenceUpdateNamespaceScope:                   {/* contains filtered or unexported fields */},
		PersistenceDeleteNamespaceScope:                   {/* contains filtered or unexported fields */},
		PersistenceDeleteNamespaceByNameScope:             {/* contains filtered or unexported fields */},
		PersistenceListNamespaceScope:                     {/* contains filtered or unexported fields */},
		PersistenceGetMetadataScope:                       {/* contains filtered or unexported fields */},

		VisibilityPersistenceRecordWorkflowExecutionStartedScope:           {/* contains filtered or unexported fields */},
		VisibilityPersistenceRecordWorkflowExecutionClosedScope:            {/* contains filtered or unexported fields */},
		VisibilityPersistenceUpsertWorkflowExecutionScope:                  {/* contains filtered or unexported fields */},
		VisibilityPersistenceListOpenWorkflowExecutionsScope:               {/* contains filtered or unexported fields */},
		VisibilityPersistenceListClosedWorkflowExecutionsScope:             {/* contains filtered or unexported fields */},
		VisibilityPersistenceListOpenWorkflowExecutionsByTypeScope:         {/* contains filtered or unexported fields */},
		VisibilityPersistenceListClosedWorkflowExecutionsByTypeScope:       {/* contains filtered or unexported fields */},
		VisibilityPersistenceListOpenWorkflowExecutionsByWorkflowIDScope:   {/* contains filtered or unexported fields */},
		VisibilityPersistenceListClosedWorkflowExecutionsByWorkflowIDScope: {/* contains filtered or unexported fields */},
		VisibilityPersistenceListClosedWorkflowExecutionsByStatusScope:     {/* contains filtered or unexported fields */},
		VisibilityPersistenceDeleteWorkflowExecutionScope:                  {/* contains filtered or unexported fields */},
		VisibilityPersistenceListWorkflowExecutionsScope:                   {/* contains filtered or unexported fields */},
		VisibilityPersistenceScanWorkflowExecutionsScope:                   {/* contains filtered or unexported fields */},
		VisibilityPersistenceCountWorkflowExecutionsScope:                  {/* contains filtered or unexported fields */},

		PersistenceAppendHistoryNodesScope:         {/* contains filtered or unexported fields */},
		PersistenceDeleteHistoryNodesScope:         {/* contains filtered or unexported fields */},
		PersistenceReadHistoryBranchScope:          {/* contains filtered or unexported fields */},
		PersistenceForkHistoryBranchScope:          {/* contains filtered or unexported fields */},
		PersistenceDeleteHistoryBranchScope:        {/* contains filtered or unexported fields */},
		PersistenceTrimHistoryBranchScope:          {/* contains filtered or unexported fields */},
		PersistenceCompleteForkBranchScope:         {/* contains filtered or unexported fields */},
		PersistenceGetHistoryTreeScope:             {/* contains filtered or unexported fields */},
		PersistenceGetAllHistoryTreeBranchesScope:  {/* contains filtered or unexported fields */},
		PersistenceEnqueueMessageScope:             {/* contains filtered or unexported fields */},
		PersistenceEnqueueMessageToDLQScope:        {/* contains filtered or unexported fields */},
		PersistenceReadQueueMessagesScope:          {/* contains filtered or unexported fields */},
		PersistenceReadQueueMessagesFromDLQScope:   {/* contains filtered or unexported fields */},
		PersistenceDeleteQueueMessagesScope:        {/* contains filtered or unexported fields */},
		PersistenceDeleteQueueMessageFromDLQScope:  {/* contains filtered or unexported fields */},
		PersistenceRangeDeleteMessagesFromDLQScope: {/* contains filtered or unexported fields */},
		PersistenceUpdateAckLevelScope:             {/* contains filtered or unexported fields */},
		PersistenceGetAckLevelScope:                {/* contains filtered or unexported fields */},
		PersistenceUpdateDLQAckLevelScope:          {/* contains filtered or unexported fields */},
		PersistenceGetDLQAckLevelScope:             {/* contains filtered or unexported fields */},
		PersistenceNamespaceReplicationQueueScope:  {/* contains filtered or unexported fields */},
		PersistenceListClusterMetadataScope:        {/* contains filtered or unexported fields */},
		PersistenceGetClusterMetadataScope:         {/* contains filtered or unexported fields */},
		PersistenceSaveClusterMetadataScope:        {/* contains filtered or unexported fields */},
		PersistenceDeleteClusterMetadataScope:      {/* contains filtered or unexported fields */},
		PersistencePruneClusterMembershipScope:     {/* contains filtered or unexported fields */},
		PersistenceGetClusterMembersScope:          {/* contains filtered or unexported fields */},
		PersistenceUpsertClusterMembershipScope:    {/* contains filtered or unexported fields */},

		ClusterMetadataArchivalConfigScope: {/* contains filtered or unexported fields */},

		HistoryClientStartWorkflowExecutionScope:              {/* contains filtered or unexported fields */},
		HistoryClientRecordActivityTaskHeartbeatScope:         {/* contains filtered or unexported fields */},
		HistoryClientRespondWorkflowTaskCompletedScope:        {/* contains filtered or unexported fields */},
		HistoryClientRespondWorkflowTaskFailedScope:           {/* contains filtered or unexported fields */},
		HistoryClientRespondActivityTaskCompletedScope:        {/* contains filtered or unexported fields */},
		HistoryClientRespondActivityTaskFailedScope:           {/* contains filtered or unexported fields */},
		HistoryClientRespondActivityTaskCanceledScope:         {/* contains filtered or unexported fields */},
		HistoryClientGetMutableStateScope:                     {/* contains filtered or unexported fields */},
		HistoryClientPollMutableStateScope:                    {/* contains filtered or unexported fields */},
		HistoryClientResetStickyTaskQueueScope:                {/* contains filtered or unexported fields */},
		HistoryClientDescribeWorkflowExecutionScope:           {/* contains filtered or unexported fields */},
		HistoryClientRecordWorkflowTaskStartedScope:           {/* contains filtered or unexported fields */},
		HistoryClientRecordActivityTaskStartedScope:           {/* contains filtered or unexported fields */},
		HistoryClientRequestCancelWorkflowExecutionScope:      {/* contains filtered or unexported fields */},
		HistoryClientSignalWorkflowExecutionScope:             {/* contains filtered or unexported fields */},
		HistoryClientSignalWithStartWorkflowExecutionScope:    {/* contains filtered or unexported fields */},
		HistoryClientRemoveSignalMutableStateScope:            {/* contains filtered or unexported fields */},
		HistoryClientTerminateWorkflowExecutionScope:          {/* contains filtered or unexported fields */},
		HistoryClientResetWorkflowExecutionScope:              {/* contains filtered or unexported fields */},
		HistoryClientScheduleWorkflowTaskScope:                {/* contains filtered or unexported fields */},
		HistoryClientRecordChildExecutionCompletedScope:       {/* contains filtered or unexported fields */},
		HistoryClientReplicateEventsV2Scope:                   {/* contains filtered or unexported fields */},
		HistoryClientSyncShardStatusScope:                     {/* contains filtered or unexported fields */},
		HistoryClientSyncActivityScope:                        {/* contains filtered or unexported fields */},
		HistoryClientGetReplicationTasksScope:                 {/* contains filtered or unexported fields */},
		HistoryClientGetDLQReplicationTasksScope:              {/* contains filtered or unexported fields */},
		HistoryClientQueryWorkflowScope:                       {/* contains filtered or unexported fields */},
		HistoryClientReapplyEventsScope:                       {/* contains filtered or unexported fields */},
		HistoryClientGetDLQMessagesScope:                      {/* contains filtered or unexported fields */},
		HistoryClientPurgeDLQMessagesScope:                    {/* contains filtered or unexported fields */},
		HistoryClientMergeDLQMessagesScope:                    {/* contains filtered or unexported fields */},
		HistoryClientRefreshWorkflowTasksScope:                {/* contains filtered or unexported fields */},
		HistoryClientGenerateLastHistoryReplicationTasksScope: {/* contains filtered or unexported fields */},
		HistoryClientGetReplicationStatusScope:                {/* contains filtered or unexported fields */},
		MatchingClientPollWorkflowTaskQueueScope:              {/* contains filtered or unexported fields */},
		MatchingClientPollActivityTaskQueueScope:              {/* contains filtered or unexported fields */},
		MatchingClientAddActivityTaskScope:                    {/* contains filtered or unexported fields */},
		MatchingClientAddWorkflowTaskScope:                    {/* contains filtered or unexported fields */},
		MatchingClientQueryWorkflowScope:                      {/* contains filtered or unexported fields */},
		MatchingClientRespondQueryTaskCompletedScope:          {/* contains filtered or unexported fields */},
		MatchingClientCancelOutstandingPollScope:              {/* contains filtered or unexported fields */},
		MatchingClientDescribeTaskQueueScope:                  {/* contains filtered or unexported fields */},
		MatchingClientListTaskQueuePartitionsScope:            {/* contains filtered or unexported fields */},
		FrontendClientDeprecateNamespaceScope:                 {/* contains filtered or unexported fields */},
		FrontendClientDescribeNamespaceScope:                  {/* contains filtered or unexported fields */},
		FrontendClientDescribeTaskQueueScope:                  {/* contains filtered or unexported fields */},
		FrontendClientDescribeWorkflowExecutionScope:          {/* contains filtered or unexported fields */},
		FrontendClientGetWorkflowExecutionHistoryScope:        {/* contains filtered or unexported fields */},
		FrontendClientGetWorkflowExecutionRawHistoryScope:     {/* contains filtered or unexported fields */},
		FrontendClientPollForWorkflowExecutionRawHistoryScope: {/* contains filtered or unexported fields */},
		FrontendClientListArchivedWorkflowExecutionsScope:     {/* contains filtered or unexported fields */},
		FrontendClientListClosedWorkflowExecutionsScope:       {/* contains filtered or unexported fields */},
		FrontendClientListNamespacesScope:                     {/* contains filtered or unexported fields */},
		FrontendClientListOpenWorkflowExecutionsScope:         {/* contains filtered or unexported fields */},
		FrontendClientPollActivityTaskQueueScope:              {/* contains filtered or unexported fields */},
		FrontendClientPollWorkflowTaskQueueScope:              {/* contains filtered or unexported fields */},
		FrontendClientQueryWorkflowScope:                      {/* contains filtered or unexported fields */},
		FrontendClientRecordActivityTaskHeartbeatScope:        {/* contains filtered or unexported fields */},
		FrontendClientRecordActivityTaskHeartbeatByIdScope:    {/* contains filtered or unexported fields */},
		FrontendClientRegisterNamespaceScope:                  {/* contains filtered or unexported fields */},
		FrontendClientRequestCancelWorkflowExecutionScope:     {/* contains filtered or unexported fields */},
		FrontendClientResetStickyTaskQueueScope:               {/* contains filtered or unexported fields */},
		FrontendClientResetWorkflowExecutionScope:             {/* contains filtered or unexported fields */},
		FrontendClientRespondActivityTaskCanceledScope:        {/* contains filtered or unexported fields */},
		FrontendClientRespondActivityTaskCanceledByIdScope:    {/* contains filtered or unexported fields */},
		FrontendClientRespondActivityTaskCompletedScope:       {/* contains filtered or unexported fields */},
		FrontendClientRespondActivityTaskCompletedByIdScope:   {/* contains filtered or unexported fields */},
		FrontendClientRespondActivityTaskFailedScope:          {/* contains filtered or unexported fields */},
		FrontendClientRespondActivityTaskFailedByIdScope:      {/* contains filtered or unexported fields */},
		FrontendClientRespondWorkflowTaskCompletedScope:       {/* contains filtered or unexported fields */},
		FrontendClientRespondWorkflowTaskFailedScope:          {/* contains filtered or unexported fields */},
		FrontendClientRespondQueryTaskCompletedScope:          {/* contains filtered or unexported fields */},
		FrontendClientSignalWithStartWorkflowExecutionScope:   {/* contains filtered or unexported fields */},
		FrontendClientSignalWorkflowExecutionScope:            {/* contains filtered or unexported fields */},
		FrontendClientStartWorkflowExecutionScope:             {/* contains filtered or unexported fields */},
		FrontendClientTerminateWorkflowExecutionScope:         {/* contains filtered or unexported fields */},
		FrontendClientUpdateNamespaceScope:                    {/* contains filtered or unexported fields */},
		FrontendClientListWorkflowExecutionsScope:             {/* contains filtered or unexported fields */},
		FrontendClientScanWorkflowExecutionsScope:             {/* contains filtered or unexported fields */},
		FrontendClientCountWorkflowExecutionsScope:            {/* contains filtered or unexported fields */},
		FrontendClientGetSearchAttributesScope:                {/* contains filtered or unexported fields */},
		FrontendClientGetReplicationTasksScope:                {/* contains filtered or unexported fields */},
		FrontendClientGetNamespaceReplicationTasksScope:       {/* contains filtered or unexported fields */},
		FrontendClientGetDLQReplicationTasksScope:             {/* contains filtered or unexported fields */},
		FrontendClientReapplyEventsScope:                      {/* contains filtered or unexported fields */},
		FrontendClientGetClusterInfoScope:                     {/* contains filtered or unexported fields */},
		FrontendClientListTaskQueuePartitionsScope:            {/* contains filtered or unexported fields */},
		AdminClientAddSearchAttributesScope:                   {/* contains filtered or unexported fields */},
		AdminClientRemoveSearchAttributesScope:                {/* contains filtered or unexported fields */},
		AdminClientGetSearchAttributesScope:                   {/* contains filtered or unexported fields */},
		AdminClientDescribeHistoryHostScope:                   {/* contains filtered or unexported fields */},
		AdminClientDescribeWorkflowMutableStateScope:          {/* contains filtered or unexported fields */},
		AdminClientGetWorkflowExecutionRawHistoryScope:        {/* contains filtered or unexported fields */},
		AdminClientGetWorkflowExecutionRawHistoryV2Scope:      {/* contains filtered or unexported fields */},
		AdminClientDescribeClusterScope:                       {/* contains filtered or unexported fields */},
		AdminClientAddOrUpdateRemoteClusterScope:              {/* contains filtered or unexported fields */},
		AdminClientRemoveRemoteClusterScope:                   {/* contains filtered or unexported fields */},
		AdminClientRefreshWorkflowTasksScope:                  {/* contains filtered or unexported fields */},
		AdminClientResendReplicationTasksScope:                {/* contains filtered or unexported fields */},
		AdminClientGetTaskQueueTasksScope:                     {/* contains filtered or unexported fields */},
		AdminClientListClusterMembersScope:                    {/* contains filtered or unexported fields */},
		AdminClientCloseShardScope:                            {/* contains filtered or unexported fields */},
		AdminClientGetShardScope:                              {/* contains filtered or unexported fields */},
		AdminClientListTransferTasksScope:                     {/* contains filtered or unexported fields */},
		AdminClientListTimerTasksScope:                        {/* contains filtered or unexported fields */},
		AdminClientListReplicationTasksScope:                  {/* contains filtered or unexported fields */},
		AdminClientListVisibilityTasksScope:                   {/* contains filtered or unexported fields */},
		AdminClientGetDLQMessagesScope:                        {/* contains filtered or unexported fields */},
		AdminClientPurgeDLQMessagesScope:                      {/* contains filtered or unexported fields */},
		AdminClientMergeDLQMessagesScope:                      {/* contains filtered or unexported fields */},
		DCRedirectionDeprecateNamespaceScope:                  {/* contains filtered or unexported fields */},
		DCRedirectionDescribeNamespaceScope:                   {/* contains filtered or unexported fields */},
		DCRedirectionDescribeTaskQueueScope:                   {/* contains filtered or unexported fields */},
		DCRedirectionDescribeWorkflowExecutionScope:           {/* contains filtered or unexported fields */},
		DCRedirectionGetWorkflowExecutionHistoryScope:         {/* contains filtered or unexported fields */},
		DCRedirectionGetWorkflowExecutionRawHistoryScope:      {/* contains filtered or unexported fields */},
		DCRedirectionPollForWorkflowExecutionRawHistoryScope:  {/* contains filtered or unexported fields */},
		DCRedirectionListArchivedWorkflowExecutionsScope:      {/* contains filtered or unexported fields */},
		DCRedirectionListClosedWorkflowExecutionsScope:        {/* contains filtered or unexported fields */},
		DCRedirectionListNamespacesScope:                      {/* contains filtered or unexported fields */},
		DCRedirectionListOpenWorkflowExecutionsScope:          {/* contains filtered or unexported fields */},
		DCRedirectionListWorkflowExecutionsScope:              {/* contains filtered or unexported fields */},
		DCRedirectionScanWorkflowExecutionsScope:              {/* contains filtered or unexported fields */},
		DCRedirectionCountWorkflowExecutionsScope:             {/* contains filtered or unexported fields */},
		DCRedirectionGetSearchAttributesScope:                 {/* contains filtered or unexported fields */},
		DCRedirectionPollActivityTaskQueueScope:               {/* contains filtered or unexported fields */},
		DCRedirectionPollWorkflowTaskQueueScope:               {/* contains filtered or unexported fields */},
		DCRedirectionQueryWorkflowScope:                       {/* contains filtered or unexported fields */},
		DCRedirectionRecordActivityTaskHeartbeatScope:         {/* contains filtered or unexported fields */},
		DCRedirectionRecordActivityTaskHeartbeatByIdScope:     {/* contains filtered or unexported fields */},
		DCRedirectionRegisterNamespaceScope:                   {/* contains filtered or unexported fields */},
		DCRedirectionRequestCancelWorkflowExecutionScope:      {/* contains filtered or unexported fields */},
		DCRedirectionResetStickyTaskQueueScope:                {/* contains filtered or unexported fields */},
		DCRedirectionResetWorkflowExecutionScope:              {/* contains filtered or unexported fields */},
		DCRedirectionRespondActivityTaskCanceledScope:         {/* contains filtered or unexported fields */},
		DCRedirectionRespondActivityTaskCanceledByIdScope:     {/* contains filtered or unexported fields */},
		DCRedirectionRespondActivityTaskCompletedScope:        {/* contains filtered or unexported fields */},
		DCRedirectionRespondActivityTaskCompletedByIdScope:    {/* contains filtered or unexported fields */},
		DCRedirectionRespondActivityTaskFailedScope:           {/* contains filtered or unexported fields */},
		DCRedirectionRespondActivityTaskFailedByIdScope:       {/* contains filtered or unexported fields */},
		DCRedirectionRespondWorkflowTaskCompletedScope:        {/* contains filtered or unexported fields */},
		DCRedirectionRespondWorkflowTaskFailedScope:           {/* contains filtered or unexported fields */},
		DCRedirectionRespondQueryTaskCompletedScope:           {/* contains filtered or unexported fields */},
		DCRedirectionSignalWithStartWorkflowExecutionScope:    {/* contains filtered or unexported fields */},
		DCRedirectionSignalWorkflowExecutionScope:             {/* contains filtered or unexported fields */},
		DCRedirectionStartWorkflowExecutionScope:              {/* contains filtered or unexported fields */},
		DCRedirectionTerminateWorkflowExecutionScope:          {/* contains filtered or unexported fields */},
		DCRedirectionUpdateNamespaceScope:                     {/* contains filtered or unexported fields */},
		DCRedirectionListTaskQueuePartitionsScope:             {/* contains filtered or unexported fields */},

		MessagingClientPublishScope:      {/* contains filtered or unexported fields */},
		MessagingClientPublishBatchScope: {/* contains filtered or unexported fields */},

		NamespaceCacheScope:                                   {/* contains filtered or unexported fields */},
		HistoryRereplicationByTransferTaskScope:               {/* contains filtered or unexported fields */},
		HistoryRereplicationByTimerTaskScope:                  {/* contains filtered or unexported fields */},
		HistoryRereplicationByHistoryReplicationScope:         {/* contains filtered or unexported fields */},
		HistoryRereplicationByHistoryMetadataReplicationScope: {/* contains filtered or unexported fields */},
		HistoryRereplicationByActivityReplicationScope:        {/* contains filtered or unexported fields */},

		ElasticsearchBulkProcessor: {/* contains filtered or unexported fields */},
		ElasticsearchVisibility:    {/* contains filtered or unexported fields */},

		SequentialTaskProcessingScope: {/* contains filtered or unexported fields */},
		ParallelTaskProcessingScope:   {/* contains filtered or unexported fields */},
		TaskSchedulerScope:            {/* contains filtered or unexported fields */},

		HistoryArchiverScope:    {/* contains filtered or unexported fields */},
		VisibilityArchiverScope: {/* contains filtered or unexported fields */},

		BlobstoreClientUploadScope:          {/* contains filtered or unexported fields */},
		BlobstoreClientDownloadScope:        {/* contains filtered or unexported fields */},
		BlobstoreClientGetMetadataScope:     {/* contains filtered or unexported fields */},
		BlobstoreClientExistsScope:          {/* contains filtered or unexported fields */},
		BlobstoreClientDeleteScope:          {/* contains filtered or unexported fields */},
		BlobstoreClientDirectoryExistsScope: {/* contains filtered or unexported fields */},

		DynamicConfigScope:               {/* contains filtered or unexported fields */},
		TieredStorageQueueProcessorScope: {/* contains filtered or unexported fields */},
	},

	Frontend: {

		AdminRemoveTaskScope:                       {/* contains filtered or unexported fields */},
		AdminCloseShardScope:                       {/* contains filtered or unexported fields */},
		AdminGetShardScope:                         {/* contains filtered or unexported fields */},
		AdminListTransferTasksScope:                {/* contains filtered or unexported fields */},
		AdminListTimerTasksScope:                   {/* contains filtered or unexported fields */},
		AdminListReplicationTasksScope:             {/* contains filtered or unexported fields */},
		AdminListVisibilityTasksScope:              {/* contains filtered or unexported fields */},
		AdminReadDLQMessagesScope:                  {/* contains filtered or unexported fields */},
		AdminPurgeDLQMessagesScope:                 {/* contains filtered or unexported fields */},
		AdminMergeDLQMessagesScope:                 {/* contains filtered or unexported fields */},
		AdminDescribeHistoryHostScope:              {/* contains filtered or unexported fields */},
		AdminAddSearchAttributesScope:              {/* contains filtered or unexported fields */},
		AdminRemoveSearchAttributesScope:           {/* contains filtered or unexported fields */},
		AdminGetSearchAttributesScope:              {/* contains filtered or unexported fields */},
		AdminDescribeWorkflowExecutionScope:        {/* contains filtered or unexported fields */},
		AdminGetWorkflowExecutionRawHistoryScope:   {/* contains filtered or unexported fields */},
		AdminGetWorkflowExecutionRawHistoryV2Scope: {/* contains filtered or unexported fields */},
		AdminGetReplicationMessagesScope:           {/* contains filtered or unexported fields */},
		AdminListClusterMembersScope:               {/* contains filtered or unexported fields */},
		AdminGetNamespaceReplicationMessagesScope:  {/* contains filtered or unexported fields */},
		AdminGetDLQReplicationMessagesScope:        {/* contains filtered or unexported fields */},
		AdminReapplyEventsScope:                    {/* contains filtered or unexported fields */},
		AdminRefreshWorkflowTasksScope:             {/* contains filtered or unexported fields */},
		AdminResendReplicationTasksScope:           {/* contains filtered or unexported fields */},
		AdminGetTaskQueueTasksScope:                {/* contains filtered or unexported fields */},
		AdminDescribeClusterScope:                  {/* contains filtered or unexported fields */},
		AdminAddOrUpdateRemoteClusterScope:         {/* contains filtered or unexported fields */},
		AdminRemoveRemoteClusterScope:              {/* contains filtered or unexported fields */},

		FrontendStartWorkflowExecutionScope:             {/* contains filtered or unexported fields */},
		FrontendPollWorkflowTaskQueueScope:              {/* contains filtered or unexported fields */},
		FrontendPollActivityTaskQueueScope:              {/* contains filtered or unexported fields */},
		FrontendRecordActivityTaskHeartbeatScope:        {/* contains filtered or unexported fields */},
		FrontendRecordActivityTaskHeartbeatByIdScope:    {/* contains filtered or unexported fields */},
		FrontendRespondWorkflowTaskCompletedScope:       {/* contains filtered or unexported fields */},
		FrontendRespondWorkflowTaskFailedScope:          {/* contains filtered or unexported fields */},
		FrontendRespondQueryTaskCompletedScope:          {/* contains filtered or unexported fields */},
		FrontendRespondActivityTaskCompletedScope:       {/* contains filtered or unexported fields */},
		FrontendRespondActivityTaskFailedScope:          {/* contains filtered or unexported fields */},
		FrontendRespondActivityTaskCanceledScope:        {/* contains filtered or unexported fields */},
		FrontendRespondActivityTaskCompletedByIdScope:   {/* contains filtered or unexported fields */},
		FrontendRespondActivityTaskFailedByIdScope:      {/* contains filtered or unexported fields */},
		FrontendRespondActivityTaskCanceledByIdScope:    {/* contains filtered or unexported fields */},
		FrontendGetWorkflowExecutionHistoryScope:        {/* contains filtered or unexported fields */},
		FrontendPollWorkflowExecutionHistoryScope:       {/* contains filtered or unexported fields */},
		FrontendGetWorkflowExecutionRawHistoryScope:     {/* contains filtered or unexported fields */},
		FrontendPollForWorkflowExecutionRawHistoryScope: {/* contains filtered or unexported fields */},
		FrontendSignalWorkflowExecutionScope:            {/* contains filtered or unexported fields */},
		FrontendSignalWithStartWorkflowExecutionScope:   {/* contains filtered or unexported fields */},
		FrontendTerminateWorkflowExecutionScope:         {/* contains filtered or unexported fields */},
		FrontendResetWorkflowExecutionScope:             {/* contains filtered or unexported fields */},
		FrontendRequestCancelWorkflowExecutionScope:     {/* contains filtered or unexported fields */},
		FrontendListArchivedWorkflowExecutionsScope:     {/* contains filtered or unexported fields */},
		FrontendListOpenWorkflowExecutionsScope:         {/* contains filtered or unexported fields */},
		FrontendListClosedWorkflowExecutionsScope:       {/* contains filtered or unexported fields */},
		FrontendListWorkflowExecutionsScope:             {/* contains filtered or unexported fields */},
		FrontendScanWorkflowExecutionsScope:             {/* contains filtered or unexported fields */},
		FrontendCountWorkflowExecutionsScope:            {/* contains filtered or unexported fields */},
		FrontendRegisterNamespaceScope:                  {/* contains filtered or unexported fields */},
		FrontendDescribeNamespaceScope:                  {/* contains filtered or unexported fields */},
		FrontendListNamespacesScope:                     {/* contains filtered or unexported fields */},
		FrontendUpdateNamespaceScope:                    {/* contains filtered or unexported fields */},
		FrontendDeprecateNamespaceScope:                 {/* contains filtered or unexported fields */},
		FrontendQueryWorkflowScope:                      {/* contains filtered or unexported fields */},
		FrontendDescribeWorkflowExecutionScope:          {/* contains filtered or unexported fields */},
		FrontendListTaskQueuePartitionsScope:            {/* contains filtered or unexported fields */},
		FrontendDescribeTaskQueueScope:                  {/* contains filtered or unexported fields */},
		FrontendResetStickyTaskQueueScope:               {/* contains filtered or unexported fields */},
		FrontendGetSearchAttributesScope:                {/* contains filtered or unexported fields */},
		FrontendGetClusterInfoScope:                     {/* contains filtered or unexported fields */},
		VersionCheckScope:                               {/* contains filtered or unexported fields */},
		AuthorizationScope:                              {/* contains filtered or unexported fields */},
	},

	History: {
		HistoryStartWorkflowExecutionScope:              {/* contains filtered or unexported fields */},
		HistoryRecordActivityTaskHeartbeatScope:         {/* contains filtered or unexported fields */},
		HistoryRespondWorkflowTaskCompletedScope:        {/* contains filtered or unexported fields */},
		HistoryRespondWorkflowTaskFailedScope:           {/* contains filtered or unexported fields */},
		HistoryRespondActivityTaskCompletedScope:        {/* contains filtered or unexported fields */},
		HistoryRespondActivityTaskFailedScope:           {/* contains filtered or unexported fields */},
		HistoryRespondActivityTaskCanceledScope:         {/* contains filtered or unexported fields */},
		HistoryGetMutableStateScope:                     {/* contains filtered or unexported fields */},
		HistoryPollMutableStateScope:                    {/* contains filtered or unexported fields */},
		HistoryResetStickyTaskQueueScope:                {/* contains filtered or unexported fields */},
		HistoryDescribeWorkflowExecutionScope:           {/* contains filtered or unexported fields */},
		HistoryRecordWorkflowTaskStartedScope:           {/* contains filtered or unexported fields */},
		HistoryRecordActivityTaskStartedScope:           {/* contains filtered or unexported fields */},
		HistorySignalWorkflowExecutionScope:             {/* contains filtered or unexported fields */},
		HistorySignalWithStartWorkflowExecutionScope:    {/* contains filtered or unexported fields */},
		HistoryRemoveSignalMutableStateScope:            {/* contains filtered or unexported fields */},
		HistoryTerminateWorkflowExecutionScope:          {/* contains filtered or unexported fields */},
		HistoryResetWorkflowExecutionScope:              {/* contains filtered or unexported fields */},
		HistoryQueryWorkflowScope:                       {/* contains filtered or unexported fields */},
		HistoryProcessDeleteHistoryEventScope:           {/* contains filtered or unexported fields */},
		HistoryScheduleWorkflowTaskScope:                {/* contains filtered or unexported fields */},
		HistoryRecordChildExecutionCompletedScope:       {/* contains filtered or unexported fields */},
		HistoryRequestCancelWorkflowExecutionScope:      {/* contains filtered or unexported fields */},
		HistorySyncShardStatusScope:                     {/* contains filtered or unexported fields */},
		HistorySyncActivityScope:                        {/* contains filtered or unexported fields */},
		HistoryDescribeMutableStateScope:                {/* contains filtered or unexported fields */},
		HistoryGetReplicationMessagesScope:              {/* contains filtered or unexported fields */},
		HistoryGetDLQReplicationMessagesScope:           {/* contains filtered or unexported fields */},
		HistoryReadDLQMessagesScope:                     {/* contains filtered or unexported fields */},
		HistoryPurgeDLQMessagesScope:                    {/* contains filtered or unexported fields */},
		HistoryMergeDLQMessagesScope:                    {/* contains filtered or unexported fields */},
		HistoryShardControllerScope:                     {/* contains filtered or unexported fields */},
		HistoryReapplyEventsScope:                       {/* contains filtered or unexported fields */},
		HistoryRefreshWorkflowTasksScope:                {/* contains filtered or unexported fields */},
		HistoryGenerateLastHistoryReplicationTasksScope: {/* contains filtered or unexported fields */},
		HistoryGetReplicationStatusScope:                {/* contains filtered or unexported fields */},
		HistoryHistoryRemoveTaskScope:                   {/* contains filtered or unexported fields */},
		HistoryCloseShard:                               {/* contains filtered or unexported fields */},
		HistoryGetShard:                                 {/* contains filtered or unexported fields */},
		HistoryReplicateEventsV2:                        {/* contains filtered or unexported fields */},
		HistoryResetStickyTaskQueue:                     {/* contains filtered or unexported fields */},
		HistoryReapplyEvents:                            {/* contains filtered or unexported fields */},
		HistoryDescribeHistoryHost:                      {/* contains filtered or unexported fields */},
		TaskPriorityAssignerScope:                       {/* contains filtered or unexported fields */},
		TransferQueueProcessorScope:                     {/* contains filtered or unexported fields */},
		TransferActiveQueueProcessorScope:               {/* contains filtered or unexported fields */},
		TransferStandbyQueueProcessorScope:              {/* contains filtered or unexported fields */},
		TransferActiveTaskActivityScope:                 {/* contains filtered or unexported fields */},
		TransferActiveTaskWorkflowTaskScope:             {/* contains filtered or unexported fields */},
		TransferActiveTaskCloseExecutionScope:           {/* contains filtered or unexported fields */},
		TransferActiveTaskCancelExecutionScope:          {/* contains filtered or unexported fields */},
		TransferActiveTaskSignalExecutionScope:          {/* contains filtered or unexported fields */},
		TransferActiveTaskStartChildExecutionScope:      {/* contains filtered or unexported fields */},
		TransferActiveTaskResetWorkflowScope:            {/* contains filtered or unexported fields */},
		TransferStandbyTaskActivityScope:                {/* contains filtered or unexported fields */},
		TransferStandbyTaskWorkflowTaskScope:            {/* contains filtered or unexported fields */},
		TransferStandbyTaskCloseExecutionScope:          {/* contains filtered or unexported fields */},
		TransferStandbyTaskCancelExecutionScope:         {/* contains filtered or unexported fields */},
		TransferStandbyTaskSignalExecutionScope:         {/* contains filtered or unexported fields */},
		TransferStandbyTaskStartChildExecutionScope:     {/* contains filtered or unexported fields */},
		TransferStandbyTaskResetWorkflowScope:           {/* contains filtered or unexported fields */},

		VisibilityQueueProcessorScope:      {/* contains filtered or unexported fields */},
		VisibilityTaskStartExecutionScope:  {/* contains filtered or unexported fields */},
		VisibilityTaskUpsertExecutionScope: {/* contains filtered or unexported fields */},
		VisibilityTaskCloseExecutionScope:  {/* contains filtered or unexported fields */},
		VisibilityTaskDeleteExecutionScope: {/* contains filtered or unexported fields */},

		TimerQueueProcessorScope:                  {/* contains filtered or unexported fields */},
		TimerActiveQueueProcessorScope:            {/* contains filtered or unexported fields */},
		TimerStandbyQueueProcessorScope:           {/* contains filtered or unexported fields */},
		TimerActiveTaskActivityTimeoutScope:       {/* contains filtered or unexported fields */},
		TimerActiveTaskWorkflowTaskTimeoutScope:   {/* contains filtered or unexported fields */},
		TimerActiveTaskUserTimerScope:             {/* contains filtered or unexported fields */},
		TimerActiveTaskWorkflowTimeoutScope:       {/* contains filtered or unexported fields */},
		TimerActiveTaskActivityRetryTimerScope:    {/* contains filtered or unexported fields */},
		TimerActiveTaskWorkflowBackoffTimerScope:  {/* contains filtered or unexported fields */},
		TimerActiveTaskDeleteHistoryEventScope:    {/* contains filtered or unexported fields */},
		TimerStandbyTaskActivityTimeoutScope:      {/* contains filtered or unexported fields */},
		TimerStandbyTaskWorkflowTaskTimeoutScope:  {/* contains filtered or unexported fields */},
		TimerStandbyTaskUserTimerScope:            {/* contains filtered or unexported fields */},
		TimerStandbyTaskWorkflowTimeoutScope:      {/* contains filtered or unexported fields */},
		TimerStandbyTaskActivityRetryTimerScope:   {/* contains filtered or unexported fields */},
		TimerStandbyTaskWorkflowBackoffTimerScope: {/* contains filtered or unexported fields */},
		TimerStandbyTaskDeleteHistoryEventScope:   {/* contains filtered or unexported fields */},
		HistoryEventNotificationScope:             {/* contains filtered or unexported fields */},
		ReplicatorQueueProcessorScope:             {/* contains filtered or unexported fields */},
		ReplicatorTaskHistoryScope:                {/* contains filtered or unexported fields */},
		ReplicatorTaskSyncActivityScope:           {/* contains filtered or unexported fields */},
		ReplicateHistoryEventsScope:               {/* contains filtered or unexported fields */},
		ShardInfoScope:                            {/* contains filtered or unexported fields */},
		WorkflowContextScope:                      {/* contains filtered or unexported fields */},
		HistoryCacheGetOrCreateScope:              {/* contains filtered or unexported fields */},
		HistoryCacheGetOrCreateCurrentScope:       {/* contains filtered or unexported fields */},
		EventsCacheGetEventScope:                  {/* contains filtered or unexported fields */},
		EventsCachePutEventScope:                  {/* contains filtered or unexported fields */},
		EventsCacheDeleteEventScope:               {/* contains filtered or unexported fields */},
		EventsCacheGetFromStoreScope:              {/* contains filtered or unexported fields */},
		ExecutionSizeStatsScope:                   {/* contains filtered or unexported fields */},
		ExecutionCountStatsScope:                  {/* contains filtered or unexported fields */},
		SessionSizeStatsScope:                     {/* contains filtered or unexported fields */},
		SessionCountStatsScope:                    {/* contains filtered or unexported fields */},
		WorkflowCompletionStatsScope:              {/* contains filtered or unexported fields */},
		ArchiverClientScope:                       {/* contains filtered or unexported fields */},
		ReplicationTaskFetcherScope:               {/* contains filtered or unexported fields */},
		ReplicationTaskCleanupScope:               {/* contains filtered or unexported fields */},
		ReplicationDLQStatsScope:                  {/* contains filtered or unexported fields */},
		SyncShardTaskScope:                        {/* contains filtered or unexported fields */},
		SyncActivityTaskScope:                     {/* contains filtered or unexported fields */},
		HistoryMetadataReplicationTaskScope:       {/* contains filtered or unexported fields */},
		HistoryReplicationTaskScope:               {/* contains filtered or unexported fields */},
		ReplicatorScope:                           {/* contains filtered or unexported fields */},
	},

	Matching: {
		MatchingPollWorkflowTaskQueueScope:     {/* contains filtered or unexported fields */},
		MatchingPollActivityTaskQueueScope:     {/* contains filtered or unexported fields */},
		MatchingAddActivityTaskScope:           {/* contains filtered or unexported fields */},
		MatchingAddWorkflowTaskScope:           {/* contains filtered or unexported fields */},
		MatchingTaskQueueMgrScope:              {/* contains filtered or unexported fields */},
		MatchingEngineScope:                    {/* contains filtered or unexported fields */},
		MatchingQueryWorkflowScope:             {/* contains filtered or unexported fields */},
		MatchingRespondQueryTaskCompletedScope: {/* contains filtered or unexported fields */},
		MatchingCancelOutstandingPollScope:     {/* contains filtered or unexported fields */},
		MatchingDescribeTaskQueueScope:         {/* contains filtered or unexported fields */},
		MatchingListTaskQueuePartitionsScope:   {/* contains filtered or unexported fields */},
	},

	Worker: {
		ReplicatorScope:                        {/* contains filtered or unexported fields */},
		NamespaceReplicationTaskScope:          {/* contains filtered or unexported fields */},
		HistoryReplicationTaskScope:            {/* contains filtered or unexported fields */},
		HistoryMetadataReplicationTaskScope:    {/* contains filtered or unexported fields */},
		SyncShardTaskScope:                     {/* contains filtered or unexported fields */},
		SyncActivityTaskScope:                  {/* contains filtered or unexported fields */},
		ESProcessorScope:                       {/* contains filtered or unexported fields */},
		IndexProcessorScope:                    {/* contains filtered or unexported fields */},
		ArchiverDeleteHistoryActivityScope:     {/* contains filtered or unexported fields */},
		ArchiverUploadHistoryActivityScope:     {/* contains filtered or unexported fields */},
		ArchiverArchiveVisibilityActivityScope: {/* contains filtered or unexported fields */},
		ArchiverScope:                          {/* contains filtered or unexported fields */},
		ArchiverPumpScope:                      {/* contains filtered or unexported fields */},
		ArchiverArchivalWorkflowScope:          {/* contains filtered or unexported fields */},
		TaskQueueScavengerScope:                {/* contains filtered or unexported fields */},
		ExecutionsScavengerScope:               {/* contains filtered or unexported fields */},
		HistoryScavengerScope:                  {/* contains filtered or unexported fields */},
		BatcherScope:                           {/* contains filtered or unexported fields */},
		ParentClosePolicyProcessorScope:        {/* contains filtered or unexported fields */},
		AddSearchAttributesWorkflowScope:       {/* contains filtered or unexported fields */},
	},
	Server: {
		ServerTlsScope: {/* contains filtered or unexported fields */},
	},
}

ScopeDefs record the scopes for all services

View Source 
var ServiceMetrics = map[MetricName]MetricType{
	RestartCount: Counter,
}

ServiceMetrics are types for common service base metrics

View Source 
var StickyTaskQueueTag = TaskQueueTag("__sticky__")

Functions

func AddMetricsContext added in v1.12.0 

func AddMetricsContext(ctx context.Context) context.Context

func ContextCounterAdd added in v1.10.0 

func ContextCounterAdd(ctx context.Context, name string, value int64) bool

ContextCounterAdd adds value to counter within metrics context.

func ContextCounterGet added in v1.10.0 

func ContextCounterGet(ctx context.Context, name string) (int64, bool)

ContextCounterGet returns value and true if successfully retrieved value

func FrontendAPIMetricsNames added in v1.5.7 

func FrontendAPIMetricsNames() map[string]struct{}

func FrontendAPIMetricsScopes added in v1.5.7 

func FrontendAPIMetricsScopes() map[string]int

func HistoryAPIMetricsNames added in v1.5.7 

func HistoryAPIMetricsNames() map[string]struct{}

func HistoryAPIMetricsScopes added in v1.5.7 

func HistoryAPIMetricsScopes() map[string]int

func MatchingAPIMetricsNames added in v1.5.7 

func MatchingAPIMetricsNames() map[string]struct{}

func MatchingAPIMetricsScopes added in v1.5.7 

func MatchingAPIMetricsScopes() map[string]int

func NewBytesHistogramDef added in v1.14.0 

func NewBytesHistogramDef(name string) metricDefinition

func NewClientMetricsTrailerPropagatorInterceptor added in v1.10.0 

func NewClientMetricsTrailerPropagatorInterceptor(logger log.Logger) grpc.UnaryClientInterceptor

NewClientMetricsTrailerPropagatorInterceptor returns grpc client interceptor that injects metrics received in trailer into metrics context.

func NewCounterDef added in v1.14.0 

func NewCounterDef(name string) metricDefinition

func NewDimensionlessHistogramDef added in v1.14.0 

func NewDimensionlessHistogramDef(name string) metricDefinition

func NewGaugeDef added in v1.14.0 

func NewGaugeDef(name string) metricDefinition

func NewRollupCounterDef added in v1.14.0 

func NewRollupCounterDef(name string, rollupName string) metricDefinition

Rollup counter name is used to report aggregated metric excluding namespace tag.

func NewRollupTimerDef added in v1.14.0 

func NewRollupTimerDef(name string, rollupName string) metricDefinition

func NewServerMetricsContextInjectorInterceptor added in v1.10.0 

func NewServerMetricsContextInjectorInterceptor() grpc.UnaryServerInterceptor

NewServerMetricsContextInjectorInterceptor returns grpc server interceptor that adds metrics context to golang context.

func NewServerMetricsTrailerPropagatorInterceptor added in v1.10.0 

func NewServerMetricsTrailerPropagatorInterceptor(logger log.Logger) grpc.UnaryServerInterceptor

NewServerMetricsTrailerPropagatorInterceptor returns grpc server interceptor that injects metrics from context into gRPC trailer.

func NewTagFilteringScope added in v1.14.0 

func NewTagFilteringScope(config TagFilteringScopeConfig, impl internalScope) internalScope

func NewTimerDef added in v1.14.0 

func NewTimerDef(name string) metricDefinition

func NoopScope added in v0.5.7 

func NoopScope(serviceIdx ServiceIdx) internalScope

NoopScope returns a noop scope of metrics

func RuntimeMetricsReporterLifetimeHooks added in v1.14.0 

func RuntimeMetricsReporterLifetimeHooks(
	lc fx.Lifecycle,
	reporter *RuntimeMetricsReporter,
)

Types

type Client 

type Client interface {
	// IncCounter increments a counter metric
	IncCounter(scope int, counter int)
	// AddCounter adds delta to the counter metric
	AddCounter(scope int, counter int, delta int64)
	// StartTimer starts a timer for the given
	// metric name. Time will be recorded when stopwatch is stopped.
	StartTimer(scope int, timer int) Stopwatch
	// RecordTimer starts a timer for the given
	// metric name
	RecordTimer(scope int, timer int, d time.Duration)
	// RecordDistribution records and emits a distribution (wrapper on top of timer) for the given
	// metric name
	RecordDistribution(scope int, timer int, d int)
	// UpdateGauge reports Gauge type absolute value metric
	UpdateGauge(scope int, gauge int, value float64)
	// Scope returns an internal scope that can be used to add additional
	// information to metrics
	Scope(scope int, tags ...Tag) Scope
	// UserScope returns a new metrics scope that can be used to add additional
	// information to the metrics emitted by user code
	UserScope() UserScope
}

Client is the interface used to report metrics tally.

func NewClient 

func NewClient(clientConfig *ClientConfig, scope tally.Scope, serviceIdx ServiceIdx) Client

NewClient creates and returns a new instance of Client implementation reporter holds the common tags for the service serviceIdx indicates the service type in (InputhostIndex, ... StorageIndex)

type ClientConfig added in v1.14.0 

type ClientConfig struct {
	// Tags is the set of key-value pairs to be reported as part of every metric
	Tags map[string]string `yaml:"tags"`
	// IgnoreTags is a map from tag name string to tag values string list.
	// Each value present in keys will have relevant tag value replaced with "__disabled__"
	// Each value in values list will white-list tag values to be reported as usual.
	ExcludeTags map[string][]string `yaml:"excludeTags"`
	// Prefix sets the prefix to all outgoing metrics
	Prefix string `yaml:"prefix"`

	// DefaultHistogramBoundaries defines the default histogram bucket
	// boundaries.
	// Configuration of histogram boundaries for given metric unit.
	//
	// Supported values:
	// - "dimensionless"
	// - "milliseconds"
	// - "bytes"
	// - see defs.go:L62
	//
	// Tally implementation uses default buckets for timer/duration metrics.
	PerUnitHistogramBoundaries map[string][]float64 `yaml:"perUnitHistogramBoundaries"`
}

type CompositeStopwatch added in v1.14.0 

type CompositeStopwatch struct {
	// contains filtered or unexported fields
}

func NewCompositeStopwatch added in v1.14.0 

func NewCompositeStopwatch(items ...Stopwatch) *CompositeStopwatch

func (CompositeStopwatch) Stop added in v1.14.0 

func (c CompositeStopwatch) Stop()

func (CompositeStopwatch) Subtract added in v1.14.0 

func (c CompositeStopwatch) Subtract(d time.Duration)

type Config added in v1.5.7 

type Config struct {
	ClientConfig `yaml:"clientConfig,inline""`

	// M3 is the configuration for m3 metrics reporter
	M3 *m3.Configuration `yaml:"m3"`
	// Statsd is the configuration for statsd reporter
	Statsd *StatsdConfig `yaml:"statsd"`
	// Prometheus is the configuration for prometheus reporter
	Prometheus *PrometheusConfig `yaml:"prometheus"`
	// {optional} Config for Prometheus metrics reporter for SDK reported metrics.
	PrometheusSDK *PrometheusConfig `yaml:"prometheusSDK"`
}

Config contains the config items for metrics subsystem

func (*Config) InitMetricReporters added in v1.9.0 

func (c *Config) InitMetricReporters(logger log.Logger, customReporter interface{}) (Reporter, Reporter, error)

InitMetricReporters is a root function for initalizing metrics clients.

Usage pattern serverReporter, sdkReporter, err := c.InitMetricReporters(logger, customReporter) metricsClient := serverReporter.newClient(logger, serviceIdx)

customReporter Provide this argument if you want to report metrics to a custom metric platform, otherwise use nil.

returns SeverReporter, SDKReporter, error

func (*Config) NewCustomReporterScope added in v1.5.7 

func (c *Config) NewCustomReporterScope(logger log.Logger, customReporter tally.BaseStatsReporter) tally.Scope

func (*Config) NewScope added in v1.5.7 

func (c *Config) NewScope(logger log.Logger) tally.Scope

NewScope builds a new tally scope for this metrics configuration

If the underlying configuration is valid for multiple reporter types, only one of them will be used for reporting.

Current priority order is: m3 > statsd > prometheus

type ErrorClass 

type ErrorClass uint8

ErrorClass is an enum to help with classifying SLA vs. non-SLA errors (SLA = "service level agreement")

type HistogramObjective added in v1.9.0 

type HistogramObjective struct {
	Upper float64 `yaml:"upper"`
}

Deprecated. HistogramObjective is a Prometheus histogram bucket. Added for backwards compatibility.

type MetricName 

type MetricName string

MetricName is the name of the metric

func (MetricName) Empty added in v0.27.0 

func (mn MetricName) Empty() bool

Empty returns true if the metricName is an empty string

func (MetricName) String added in v0.27.0 

func (mn MetricName) String() string

String returns string representation of this metric name

type MetricType 

type MetricType int

MetricType is the type of the metric 

const (
	Counter MetricType = iota
	Timer
	Gauge
	Histogram
)

MetricTypes which are supported

type MetricUnit added in v1.14.0 

type MetricUnit string

types used/defined by the package

type MockClient added in v1.5.7 

type MockClient struct {
	// contains filtered or unexported fields
}

MockClient is a mock of Client interface.

func NewMockClient added in v1.5.7 

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance.

func (*MockClient) AddCounter added in v1.5.7 

func (m *MockClient) AddCounter(scope, counter int, delta int64)

AddCounter mocks base method.

func (*MockClient) EXPECT added in v1.5.7 

func (m *MockClient) EXPECT() *MockClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockClient) IncCounter added in v1.5.7 

func (m *MockClient) IncCounter(scope, counter int)

IncCounter mocks base method.

func (*MockClient) RecordDistribution added in v1.5.7 

func (m *MockClient) RecordDistribution(scope, timer, d int)

RecordDistribution mocks base method.

func (*MockClient) RecordTimer added in v1.5.7 

func (m *MockClient) RecordTimer(scope, timer int, d time.Duration)

RecordTimer mocks base method.

func (*MockClient) Scope added in v1.5.7 

func (m *MockClient) Scope(scope int, tags ...Tag) Scope

Scope mocks base method.

func (*MockClient) StartTimer added in v1.5.7 

func (m *MockClient) StartTimer(scope, timer int) Stopwatch

StartTimer mocks base method.

func (*MockClient) UpdateGauge added in v1.5.7 

func (m *MockClient) UpdateGauge(scope, gauge int, value float64)

UpdateGauge mocks base method.

func (*MockClient) UserScope added in v1.11.0 

func (m *MockClient) UserScope() UserScope

UserScope mocks base method.

type MockClientMockRecorder added in v1.5.7 

type MockClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) AddCounter added in v1.5.7 

func (mr *MockClientMockRecorder) AddCounter(scope, counter, delta interface{}) *gomock.Call

AddCounter indicates an expected call of AddCounter.

func (*MockClientMockRecorder) IncCounter added in v1.5.7 

func (mr *MockClientMockRecorder) IncCounter(scope, counter interface{}) *gomock.Call

IncCounter indicates an expected call of IncCounter.

func (*MockClientMockRecorder) RecordDistribution added in v1.5.7 

func (mr *MockClientMockRecorder) RecordDistribution(scope, timer, d interface{}) *gomock.Call

RecordDistribution indicates an expected call of RecordDistribution.

func (*MockClientMockRecorder) RecordTimer added in v1.5.7 

func (mr *MockClientMockRecorder) RecordTimer(scope, timer, d interface{}) *gomock.Call

RecordTimer indicates an expected call of RecordTimer.

func (*MockClientMockRecorder) Scope added in v1.5.7 

func (mr *MockClientMockRecorder) Scope(scope interface{}, tags ...interface{}) *gomock.Call

Scope indicates an expected call of Scope.

func (*MockClientMockRecorder) StartTimer added in v1.5.7 

func (mr *MockClientMockRecorder) StartTimer(scope, timer interface{}) *gomock.Call

StartTimer indicates an expected call of StartTimer.

func (*MockClientMockRecorder) UpdateGauge added in v1.5.7 

func (mr *MockClientMockRecorder) UpdateGauge(scope, gauge, value interface{}) *gomock.Call

UpdateGauge indicates an expected call of UpdateGauge.

func (*MockClientMockRecorder) UserScope added in v1.11.0 

func (mr *MockClientMockRecorder) UserScope() *gomock.Call

UserScope indicates an expected call of UserScope.

type MockReporter added in v1.9.0 

type MockReporter struct {
	// contains filtered or unexported fields
}

MockReporter is a mock of Reporter interface.

func NewMockReporter added in v1.9.0 

func NewMockReporter(ctrl *gomock.Controller) *MockReporter

NewMockReporter creates a new mock instance.

func (*MockReporter) EXPECT added in v1.9.0 

func (m *MockReporter) EXPECT() *MockReporterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockReporter) NewClient added in v1.9.0 

func (m *MockReporter) NewClient(logger log.Logger, serviceIdx ServiceIdx) (Client, error)

NewClient mocks base method.

func (*MockReporter) Stop added in v1.9.0 

func (m *MockReporter) Stop(logger log.Logger)

Stop mocks base method.

type MockReporterMockRecorder added in v1.9.0 

type MockReporterMockRecorder struct {
	// contains filtered or unexported fields
}

MockReporterMockRecorder is the mock recorder for MockReporter.

func (*MockReporterMockRecorder) NewClient added in v1.9.0 

func (mr *MockReporterMockRecorder) NewClient(logger, serviceIdx interface{}) *gomock.Call

NewClient indicates an expected call of NewClient.

func (*MockReporterMockRecorder) Stop added in v1.9.0 

func (mr *MockReporterMockRecorder) Stop(logger interface{}) *gomock.Call

Stop indicates an expected call of Stop.

type MockScope added in v1.5.7 

type MockScope struct {
	// contains filtered or unexported fields
}

MockScope is a mock of Scope interface.

func NewMockScope added in v1.5.7 

func NewMockScope(ctrl *gomock.Controller) *MockScope

NewMockScope creates a new mock instance.

func (*MockScope) AddCounter added in v1.5.7 

func (m *MockScope) AddCounter(counter int, delta int64)

AddCounter mocks base method.

func (*MockScope) EXPECT added in v1.5.7 

func (m *MockScope) EXPECT() *MockScopeMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockScope) IncCounter added in v1.5.7 

func (m *MockScope) IncCounter(counter int)

IncCounter mocks base method.

func (*MockScope) RecordDistribution added in v1.5.7 

func (m *MockScope) RecordDistribution(id, d int)

RecordDistribution mocks base method.

func (*MockScope) RecordTimer added in v1.5.7 

func (m *MockScope) RecordTimer(timer int, d time.Duration)

RecordTimer mocks base method.

func (*MockScope) StartTimer added in v1.5.7 

func (m *MockScope) StartTimer(timer int) Stopwatch

StartTimer mocks base method.

func (*MockScope) Tagged added in v1.5.7 

func (m *MockScope) Tagged(tags ...Tag) Scope

Tagged mocks base method.

func (*MockScope) UpdateGauge added in v1.5.7 

func (m *MockScope) UpdateGauge(gauge int, value float64)

UpdateGauge mocks base method.

type MockScopeMockRecorder added in v1.5.7 

type MockScopeMockRecorder struct {
	// contains filtered or unexported fields
}

MockScopeMockRecorder is the mock recorder for MockScope.

func (*MockScopeMockRecorder) AddCounter added in v1.5.7 

func (mr *MockScopeMockRecorder) AddCounter(counter, delta interface{}) *gomock.Call

AddCounter indicates an expected call of AddCounter.

func (*MockScopeMockRecorder) IncCounter added in v1.5.7 

func (mr *MockScopeMockRecorder) IncCounter(counter interface{}) *gomock.Call

IncCounter indicates an expected call of IncCounter.

func (*MockScopeMockRecorder) RecordDistribution added in v1.5.7 

func (mr *MockScopeMockRecorder) RecordDistribution(id, d interface{}) *gomock.Call

RecordDistribution indicates an expected call of RecordDistribution.

func (*MockScopeMockRecorder) RecordTimer added in v1.5.7 

func (mr *MockScopeMockRecorder) RecordTimer(timer, d interface{}) *gomock.Call

RecordTimer indicates an expected call of RecordTimer.

func (*MockScopeMockRecorder) StartTimer added in v1.5.7 

func (mr *MockScopeMockRecorder) StartTimer(timer interface{}) *gomock.Call

StartTimer indicates an expected call of StartTimer.

func (*MockScopeMockRecorder) Tagged added in v1.5.7 

func (mr *MockScopeMockRecorder) Tagged(tags ...interface{}) *gomock.Call

Tagged indicates an expected call of Tagged.

func (*MockScopeMockRecorder) UpdateGauge added in v1.5.7 

func (mr *MockScopeMockRecorder) UpdateGauge(gauge, value interface{}) *gomock.Call

UpdateGauge indicates an expected call of UpdateGauge.

type MockStopwatch added in v1.5.7 

type MockStopwatch struct {
	// contains filtered or unexported fields
}

MockStopwatch is a mock of Stopwatch interface.

func NewMockStopwatch added in v1.5.7 

func NewMockStopwatch(ctrl *gomock.Controller) *MockStopwatch

NewMockStopwatch creates a new mock instance.

func (*MockStopwatch) EXPECT added in v1.5.7 

func (m *MockStopwatch) EXPECT() *MockStopwatchMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStopwatch) Stop added in v1.5.7 

func (m *MockStopwatch) Stop()

Stop mocks base method.

func (*MockStopwatch) Subtract added in v1.10.0 

func (m *MockStopwatch) Subtract(d time.Duration)

Subtract mocks base method.

type MockStopwatchMockRecorder added in v1.5.7 

type MockStopwatchMockRecorder struct {
	// contains filtered or unexported fields
}

MockStopwatchMockRecorder is the mock recorder for MockStopwatch.

func (*MockStopwatchMockRecorder) Stop added in v1.5.7 

func (mr *MockStopwatchMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

func (*MockStopwatchMockRecorder) Subtract added in v1.10.0 

func (mr *MockStopwatchMockRecorder) Subtract(d interface{}) *gomock.Call

Subtract indicates an expected call of Subtract.

type MockUserScope added in v1.11.0 

type MockUserScope struct {
	// contains filtered or unexported fields
}

MockUserScope is a mock of UserScope interface.

func NewMockUserScope added in v1.11.0 

func NewMockUserScope(ctrl *gomock.Controller) *MockUserScope

NewMockUserScope creates a new mock instance.

func (*MockUserScope) AddCounter added in v1.11.0 

func (m *MockUserScope) AddCounter(counter string, delta int64)

AddCounter mocks base method.

func (*MockUserScope) EXPECT added in v1.11.0 

func (m *MockUserScope) EXPECT() *MockUserScopeMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockUserScope) IncCounter added in v1.11.0 

func (m *MockUserScope) IncCounter(counter string)

IncCounter mocks base method.

func (*MockUserScope) RecordDistribution added in v1.11.0 

func (m *MockUserScope) RecordDistribution(id string, d int)

RecordDistribution mocks base method.

func (*MockUserScope) RecordTimer added in v1.11.0 

func (m *MockUserScope) RecordTimer(timer string, d time.Duration)

RecordTimer mocks base method.

func (*MockUserScope) StartTimer added in v1.11.0 

func (m *MockUserScope) StartTimer(timer string) Stopwatch

StartTimer mocks base method.

func (*MockUserScope) Tagged added in v1.11.0 

func (m *MockUserScope) Tagged(tags map[string]string) UserScope

Tagged mocks base method.

func (*MockUserScope) UpdateGauge added in v1.11.0 

func (m *MockUserScope) UpdateGauge(gauge string, value float64)

UpdateGauge mocks base method.

type MockUserScopeMockRecorder added in v1.11.0 

type MockUserScopeMockRecorder struct {
	// contains filtered or unexported fields
}

MockUserScopeMockRecorder is the mock recorder for MockUserScope.

func (*MockUserScopeMockRecorder) AddCounter added in v1.11.0 

func (mr *MockUserScopeMockRecorder) AddCounter(counter, delta interface{}) *gomock.Call

AddCounter indicates an expected call of AddCounter.

func (*MockUserScopeMockRecorder) IncCounter added in v1.11.0 

func (mr *MockUserScopeMockRecorder) IncCounter(counter interface{}) *gomock.Call

IncCounter indicates an expected call of IncCounter.

func (*MockUserScopeMockRecorder) RecordDistribution added in v1.11.0 

func (mr *MockUserScopeMockRecorder) RecordDistribution(id, d interface{}) *gomock.Call

RecordDistribution indicates an expected call of RecordDistribution.

func (*MockUserScopeMockRecorder) RecordTimer added in v1.11.0 

func (mr *MockUserScopeMockRecorder) RecordTimer(timer, d interface{}) *gomock.Call

RecordTimer indicates an expected call of RecordTimer.

func (*MockUserScopeMockRecorder) StartTimer added in v1.11.0 

func (mr *MockUserScopeMockRecorder) StartTimer(timer interface{}) *gomock.Call

StartTimer indicates an expected call of StartTimer.

func (*MockUserScopeMockRecorder) Tagged added in v1.11.0 

func (mr *MockUserScopeMockRecorder) Tagged(tags interface{}) *gomock.Call

Tagged indicates an expected call of Tagged.

func (*MockUserScopeMockRecorder) UpdateGauge added in v1.11.0 

func (mr *MockUserScopeMockRecorder) UpdateGauge(gauge, value interface{}) *gomock.Call

UpdateGauge indicates an expected call of UpdateGauge.

type MockopenTelemetryStopwatchMetric added in v1.10.0 

type MockopenTelemetryStopwatchMetric struct {
	// contains filtered or unexported fields
}

MockopenTelemetryStopwatchMetric is a mock of openTelemetryStopwatchMetric interface.

func NewMockopenTelemetryStopwatchMetric added in v1.10.0 

func NewMockopenTelemetryStopwatchMetric(ctrl *gomock.Controller) *MockopenTelemetryStopwatchMetric

NewMockopenTelemetryStopwatchMetric creates a new mock instance.

func (*MockopenTelemetryStopwatchMetric) EXPECT added in v1.10.0 

func (m *MockopenTelemetryStopwatchMetric) EXPECT() *MockopenTelemetryStopwatchMetricMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockopenTelemetryStopwatchMetric) Record added in v1.10.0 

func (m *MockopenTelemetryStopwatchMetric) Record(ctx context.Context, value time.Duration)

Record mocks base method.

type MockopenTelemetryStopwatchMetricMockRecorder added in v1.10.0 

type MockopenTelemetryStopwatchMetricMockRecorder struct {
	// contains filtered or unexported fields
}

MockopenTelemetryStopwatchMetricMockRecorder is the mock recorder for MockopenTelemetryStopwatchMetric.

func (*MockopenTelemetryStopwatchMetricMockRecorder) Record added in v1.10.0 

func (mr *MockopenTelemetryStopwatchMetricMockRecorder) Record(ctx, value interface{}) *gomock.Call

Record indicates an expected call of Record.

type NoopMetricsClient added in v1.5.7 

type NoopMetricsClient struct{}

func NewNoopMetricsClient added in v1.5.7 

func NewNoopMetricsClient() *NoopMetricsClient

func (NoopMetricsClient) AddCounter added in v1.5.7 

func (m NoopMetricsClient) AddCounter(scope int, counter int, delta int64)

func (NoopMetricsClient) IncCounter added in v1.5.7 

func (m NoopMetricsClient) IncCounter(scope int, counter int)

func (NoopMetricsClient) RecordDistribution added in v1.5.7 

func (m NoopMetricsClient) RecordDistribution(scope int, timer int, d int)

func (NoopMetricsClient) RecordTimer added in v1.5.7 

func (m NoopMetricsClient) RecordTimer(scope int, timer int, d time.Duration)

func (NoopMetricsClient) Scope added in v1.5.7 

func (m NoopMetricsClient) Scope(scope int, tags ...Tag) Scope

func (NoopMetricsClient) StartTimer added in v1.5.7 

func (m NoopMetricsClient) StartTimer(scope int, timer int) Stopwatch

func (NoopMetricsClient) UpdateGauge added in v1.5.7 

func (m NoopMetricsClient) UpdateGauge(scope int, gauge int, value float64)

func (NoopMetricsClient) UserScope added in v1.11.0 

func (m NoopMetricsClient) UserScope() UserScope

type NoopMetricsScope added in v1.11.0 

type NoopMetricsScope struct{}

func NewNoopMetricsScope added in v1.11.0 

func NewNoopMetricsScope() *NoopMetricsScope

func (NoopMetricsScope) AddCounter added in v1.11.0 

func (n NoopMetricsScope) AddCounter(counter int, delta int64)

func (NoopMetricsScope) IncCounter added in v1.11.0 

func (n NoopMetricsScope) IncCounter(counter int)

func (NoopMetricsScope) RecordDistribution added in v1.11.0 

func (n NoopMetricsScope) RecordDistribution(id int, d int)

func (NoopMetricsScope) RecordTimer added in v1.11.0 

func (n NoopMetricsScope) RecordTimer(timer int, d time.Duration)

func (NoopMetricsScope) StartTimer added in v1.11.0 

func (n NoopMetricsScope) StartTimer(timer int) Stopwatch

func (NoopMetricsScope) Tagged added in v1.11.0 

func (n NoopMetricsScope) Tagged(tags ...Tag) Scope

func (NoopMetricsScope) UpdateGauge added in v1.11.0 

func (n NoopMetricsScope) UpdateGauge(gauge int, value float64)

type NoopMetricsUserScope added in v1.11.0 

type NoopMetricsUserScope struct{}

func NewNoopMetricsUserScope added in v1.11.0 

func NewNoopMetricsUserScope() *NoopMetricsUserScope

func (NoopMetricsUserScope) AddCounter added in v1.11.0 

func (n NoopMetricsUserScope) AddCounter(counter string, delta int64)

func (NoopMetricsUserScope) IncCounter added in v1.11.0 

func (n NoopMetricsUserScope) IncCounter(counter string)

func (NoopMetricsUserScope) RecordDistribution added in v1.11.0 

func (n NoopMetricsUserScope) RecordDistribution(id string, d int)

func (NoopMetricsUserScope) RecordTimer added in v1.11.0 

func (n NoopMetricsUserScope) RecordTimer(timer string, d time.Duration)

func (NoopMetricsUserScope) StartTimer added in v1.11.0 

func (n NoopMetricsUserScope) StartTimer(timer string) Stopwatch

func (NoopMetricsUserScope) Tagged added in v1.11.0 

func (n NoopMetricsUserScope) Tagged(tags map[string]string) UserScope

func (NoopMetricsUserScope) UpdateGauge added in v1.11.0 

func (n NoopMetricsUserScope) UpdateGauge(gauge string, value float64)

type NoopScopeImpl added in v1.14.0 

type NoopScopeImpl struct{}

func (NoopScopeImpl) AddCounter added in v1.14.0 

func (n NoopScopeImpl) AddCounter(counter int, delta int64)

func (NoopScopeImpl) AddCounterInternal added in v1.14.0 

func (n NoopScopeImpl) AddCounterInternal(name string, delta int64)

func (NoopScopeImpl) IncCounter added in v1.14.0 

func (n NoopScopeImpl) IncCounter(counter int)

func (NoopScopeImpl) RecordDistribution added in v1.14.0 

func (n NoopScopeImpl) RecordDistribution(id int, d int)

func (NoopScopeImpl) RecordDistributionInternal added in v1.14.0 

func (n NoopScopeImpl) RecordDistributionInternal(id string, unit MetricUnit, d int)

func (NoopScopeImpl) RecordTimer added in v1.14.0 

func (n NoopScopeImpl) RecordTimer(timer int, d time.Duration)

func (NoopScopeImpl) RecordTimerInternal added in v1.14.0 

func (n NoopScopeImpl) RecordTimerInternal(timer string, d time.Duration)

func (NoopScopeImpl) StartTimer added in v1.14.0 

func (n NoopScopeImpl) StartTimer(timer int) Stopwatch

func (NoopScopeImpl) StartTimerInternal added in v1.14.0 

func (n NoopScopeImpl) StartTimerInternal(timer string) Stopwatch

func (NoopScopeImpl) Tagged added in v1.14.0 

func (n NoopScopeImpl) Tagged(tags ...Tag) Scope

func (NoopScopeImpl) TaggedInternal added in v1.14.0 

func (n NoopScopeImpl) TaggedInternal(tags ...Tag) internalScope

func (NoopScopeImpl) UpdateGauge added in v1.14.0 

func (n NoopScopeImpl) UpdateGauge(gauge int, value float64)

type OpentelemetryListener added in v1.9.0 

type OpentelemetryListener struct {
}

type OpentelemetryReporter added in v1.9.0 

type OpentelemetryReporter struct {
	// contains filtered or unexported fields
}

OpentelemetryReporter is a base class for reporting metrics to opentelemetry.

func (*OpentelemetryReporter) GetMeter added in v1.9.0 

func (r *OpentelemetryReporter) GetMeter() metric.Meter

func (*OpentelemetryReporter) GetMeterMust added in v1.9.0 

func (r *OpentelemetryReporter) GetMeterMust() metric.MeterMust

func (*OpentelemetryReporter) NewClient added in v1.9.0 

func (r *OpentelemetryReporter) NewClient(logger log.Logger, serviceIdx ServiceIdx) (Client, error)

func (*OpentelemetryReporter) Stop added in v1.9.0 

func (r *OpentelemetryReporter) Stop(logger log.Logger)

type OtelAggregatorSelector added in v1.14.0 

type OtelAggregatorSelector struct {
	// contains filtered or unexported fields
}

OtelAggregatorSelector handles utilizing correct histogram bucket list for distinct metric unit types.

func NewOtelAggregatorSelector added in v1.14.0 

func NewOtelAggregatorSelector(
	defaultBoundaries []float64,
	perUnitBoundaries map[string][]float64,
) *OtelAggregatorSelector

Creates new instance of aggregator selector.

func (OtelAggregatorSelector) AggregatorFor added in v1.14.0 

func (s OtelAggregatorSelector) AggregatorFor(descriptor *metric.Descriptor, aggPtrs ...*emetric.Aggregator)

type OtelGaugeCache added in v1.14.0 

type OtelGaugeCache interface {
	Set(name string, tags map[string]string, value float64)
}

func NewOtelGaugeCache added in v1.14.0 

func NewOtelGaugeCache(reporter *OpentelemetryReporter) OtelGaugeCache

type PrometheusConfig added in v1.5.7 

type PrometheusConfig struct {
	// Metric framework: Tally/OpenTelemetry
	Framework string `yaml:framework`
	// Address for prometheus to serve metrics from.
	ListenAddress string `yaml:"listenAddress"`
	// DefaultHistogramBoundaries defines the default histogram bucket
	// boundaries.
	DefaultHistogramBoundaries []float64 `yaml:"defaultHistogramBoundaries"`

	// HandlerPath if specified will be used instead of using the default
	// HTTP handler path "/metrics".
	HandlerPath string `yaml:"handlerPath"`

	// Deprecated. ListenNetwork if specified will be used instead of using tcp network.
	// Supported networks: tcp, tcp4, tcp6 and unix.
	ListenNetwork string `yaml:"listenNetwork"`

	// Deprecated. TimerType is the default Prometheus type to use for Tally timers.
	TimerType string `yaml:"timerType"`

	// Deprecated. DefaultHistogramBuckets if specified will set the default histogram
	// buckets to be used by the reporter.
	DefaultHistogramBuckets []HistogramObjective `yaml:"defaultHistogramBuckets"`

	// Deprecated. DefaultSummaryObjectives if specified will set the default summary
	// objectives to be used by the reporter.
	DefaultSummaryObjectives []SummaryObjective `yaml:"defaultSummaryObjectives"`

	// Deprecated. OnError specifies what to do when an error either with listening
	// on the specified listen address or registering a metric with the
	// Prometheus. By default the registerer will panic.
	OnError string `yaml:"onError"`
}

PrometheusConfig is a new format for config for prometheus metrics.

type Reporter added in v1.9.0 

type Reporter interface {
	NewClient(logger log.Logger, serviceIdx ServiceIdx) (Client, error)
	Stop(logger log.Logger)
}

Reporter is an interface for base constructor for metrics client.

type RuntimeMetricsReporter 

type RuntimeMetricsReporter struct {
	// contains filtered or unexported fields
}

RuntimeMetricsReporter A struct containing the state of the RuntimeMetricsReporter.

func NewRuntimeMetricsReporter 

func NewRuntimeMetricsReporter(
	scope tally.Scope,
	reportInterval time.Duration,
	logger log.Logger,
	instanceID string,
) *RuntimeMetricsReporter

NewRuntimeMetricsReporter Creates a new RuntimeMetricsReporter.

func (*RuntimeMetricsReporter) Start 

func (r *RuntimeMetricsReporter) Start()

Start Starts the reporter thread that periodically emits metrics.

func (*RuntimeMetricsReporter) Stop 

func (r *RuntimeMetricsReporter) Stop()

Stop Stops reporting of runtime metrics. The reporter cannot be started again after it's been stopped.

type Scope added in v0.5.7 

type Scope interface {
	// IncCounter increments a counter metric
	IncCounter(counter int)
	// AddCounter adds delta to the counter metric
	AddCounter(counter int, delta int64)
	// StartTimer starts a timer for the given metric name.
	// Time will be recorded when stopwatch is stopped.
	StartTimer(timer int) Stopwatch
	// RecordTimer records a timer for the given metric name
	RecordTimer(timer int, d time.Duration)
	// RecordDistribution records a distribution (wrapper on top of timer) for the given
	// metric name
	RecordDistribution(id int, d int)
	// UpdateGauge reports Gauge type absolute value metric
	UpdateGauge(gauge int, value float64)
	// Tagged returns an internal scope that can be used to add additional
	// information to metrics
	Tagged(tags ...Tag) Scope
}

Scope is an interface for metric.

func GetPerTaskQueueScope added in v1.13.0 

func GetPerTaskQueueScope(
	baseScope Scope,
	namespaceName string,
	taskQueueName string,
	taskQueueKind enumspb.TaskQueueKind,
) Scope

type ServiceIdx 

type ServiceIdx int

ServiceIdx is an index that uniquely identifies the service 

const (
	Common ServiceIdx = iota
	Frontend
	History
	Matching
	Worker
	Server
	NumServices
)

Service names for all services that emit metrics.

func GetMetricsServiceIdx added in v0.27.0 

func GetMetricsServiceIdx(serviceName string, logger log.Logger) ServiceIdx

GetMetricsServiceIdx returns service id corresponding to serviceName

type StatsdConfig added in v1.5.7 

type StatsdConfig struct {
	// The host and port of the statsd server
	HostPort string `yaml:"hostPort" validate:"nonzero"`
	// The prefix to use in reporting to statsd
	Prefix string `yaml:"prefix" validate:"nonzero"`
	// FlushInterval is the maximum interval for sending packets.
	// If it is not specified, it defaults to 1 second.
	FlushInterval time.Duration `yaml:"flushInterval"`
	// FlushBytes specifies the maximum udp packet size you wish to send.
	// If FlushBytes is unspecified, it defaults  to 1432 bytes, which is
	// considered safe for local traffic.
	FlushBytes int `yaml:"flushBytes"`
}

StatsdConfig contains the config items for statsd metrics reporter

type Stopwatch added in v0.5.9 

type Stopwatch interface {
	// Stop records time elapsed from time of creation.
	Stop()
	// Subtract adds value to subtract from recorded duration.
	Subtract(d time.Duration)
}

Stopwatch is an interface tracking of elapsed time, use the Stop() method to report time elapsed since its created back to the timer or histogram.

func NewStopwatch added in v0.5.9 

func NewStopwatch(timers ...tally.Timer) Stopwatch

NewStopwatch creates a new immutable stopwatch for recording the start time to a stopwatch reporter.

func NewTestStopwatch added in v0.5.9 

func NewTestStopwatch() Stopwatch

NewTestStopwatch returns a new test stopwatch

func NopStopwatch added in v0.6.0 

func NopStopwatch() Stopwatch

NopStopwatch return a fake tally stop watch

type SummaryObjective added in v1.9.0 

type SummaryObjective struct {
	Percentile   float64 `yaml:"percentile"`
	AllowedError float64 `yaml:"allowedError"`
}

Deprecated. SummaryObjective is a Prometheus summary objective. Added for backwards compatibility.

type Tag added in v0.5.7 

type Tag interface {
	Key() string
	Value() string
}

Tag is an interface to define metrics tags

func ActivityTypeTag added in v0.27.0 

func ActivityTypeTag(value string) Tag

ActivityTypeTag returns a new activity type tag.

func AdvancedVisibilityTypeTag added in v1.12.3 

func AdvancedVisibilityTypeTag() Tag

func CommandTypeTag added in v0.27.0 

func CommandTypeTag(value string) Tag

CommandTypeTag returns a new command type tag.

func FailureTag added in v1.5.7 

func FailureTag(value string) Tag

Returns a new failure type tag

func HttpStatusTag added in v1.14.0 

func HttpStatusTag(value int) Tag

HttpStatusTag returns a new httpStatusTag.

func InstanceTag added in v0.5.9 

func InstanceTag(value string) Tag

InstanceTag returns a new instance tag

func NamespaceTag added in v0.27.0 

func NamespaceTag(value string) Tag

NamespaceTag returns a new namespace tag. For timers, this also ensures that we dual emit the metric with the all tag. If a blank namespace is provided then this converts that to an unknown namespace.

func NamespaceUnknownTag added in v0.27.0 

func NamespaceUnknownTag() Tag

NamespaceUnknownTag returns a new namespace:unknown tag-value

func QueueTypeTag added in v1.14.0 

func QueueTypeTag(value string) Tag

func ServiceRoleTag added in v1.4.0 

func ServiceRoleTag(value string) Tag

Returns a new service role tag.

func StandardVisibilityTypeTag added in v1.12.3 

func StandardVisibilityTypeTag() Tag

func StatsTypeTag added in v1.4.0 

func StatsTypeTag(value string) Tag

Returns a new stats type tag

func TargetClusterTag added in v0.6.0 

func TargetClusterTag(value string) Tag

TargetClusterTag returns a new target cluster tag.

func TaskQueueTag added in v0.27.0 

func TaskQueueTag(value string) Tag

TaskQueueTag returns a new task queue tag.

func TaskQueueUnknownTag added in v0.27.0 

func TaskQueueUnknownTag() Tag

TaskQueueUnknownTag returns a new taskqueue:unknown tag-value

func TaskTypeTag added in v1.13.0 

func TaskTypeTag(value string) Tag

func VisibilityTypeTag added in v1.12.3 

func VisibilityTypeTag(value string) Tag

func WorkflowTypeTag added in v0.27.0 

func WorkflowTypeTag(value string) Tag

WorkflowTypeTag returns a new workflow type tag.

type TagFilteringScope added in v1.14.0 

type TagFilteringScope struct {
	// contains filtered or unexported fields
}

func (*TagFilteringScope) AddCounter added in v1.14.0 

func (tfs *TagFilteringScope) AddCounter(counter int, delta int64)

func (*TagFilteringScope) AddCounterInternal added in v1.14.0 

func (tfs *TagFilteringScope) AddCounterInternal(name string, delta int64)

func (*TagFilteringScope) IncCounter added in v1.14.0 

func (tfs *TagFilteringScope) IncCounter(counter int)

func (*TagFilteringScope) RecordDistribution added in v1.14.0 

func (tfs *TagFilteringScope) RecordDistribution(id int, d int)

func (*TagFilteringScope) RecordDistributionInternal added in v1.14.0 

func (tfs *TagFilteringScope) RecordDistributionInternal(id string, unit MetricUnit, d int)

func (*TagFilteringScope) RecordTimer added in v1.14.0 

func (tfs *TagFilteringScope) RecordTimer(timer int, d time.Duration)

func (*TagFilteringScope) RecordTimerInternal added in v1.14.0 

func (tfs *TagFilteringScope) RecordTimerInternal(timer string, d time.Duration)

func (*TagFilteringScope) StartTimer added in v1.14.0 

func (tfs *TagFilteringScope) StartTimer(timer int) Stopwatch

func (*TagFilteringScope) StartTimerInternal added in v1.14.0 

func (tfs *TagFilteringScope) StartTimerInternal(timer string) Stopwatch

func (*TagFilteringScope) Tagged added in v1.14.0 

func (tfs *TagFilteringScope) Tagged(tags ...Tag) Scope

func (*TagFilteringScope) TaggedInternal added in v1.14.0 

func (tfs *TagFilteringScope) TaggedInternal(tags ...Tag) internalScope

func (*TagFilteringScope) UpdateGauge added in v1.14.0 

func (tfs *TagFilteringScope) UpdateGauge(id int, value float64)

type TagFilteringScopeConfig added in v1.14.0 

type TagFilteringScopeConfig struct {
	TagsToFilter map[string]map[string]struct{}
}

func NewTagFilteringScopeConfig added in v1.14.0 

func NewTagFilteringScopeConfig(exclusions map[string][]string) TagFilteringScopeConfig

type TallyClient added in v1.9.0 

type TallyClient struct {
	// contains filtered or unexported fields
}

TallyClient is used for reporting metrics by various Temporal services

func (*TallyClient) AddCounter added in v1.9.0 

func (m *TallyClient) AddCounter(scopeIdx int, counterIdx int, delta int64)

AddCounter adds delta to the counter and emits to the metrics backend

func (*TallyClient) IncCounter added in v1.9.0 

func (m *TallyClient) IncCounter(scopeIdx int, counterIdx int)

IncCounter increments one for a counter and emits to metrics backend

func (*TallyClient) RecordDistribution added in v1.9.0 

func (m *TallyClient) RecordDistribution(scopeIdx int, timerIdx int, d int)

RecordDistribution record and emit a distribution (wrapper on top of timer) for the given metric name

func (*TallyClient) RecordTimer added in v1.9.0 

func (m *TallyClient) RecordTimer(scopeIdx int, timerIdx int, d time.Duration)

RecordTimer record and emit a timer for the given metric name

func (*TallyClient) Scope added in v1.9.0 

func (m *TallyClient) Scope(scopeIdx int, tags ...Tag) Scope

Scope return a new internal metrics scope that can be used to add additional information to the metrics emitted

func (*TallyClient) StartTimer added in v1.9.0 

func (m *TallyClient) StartTimer(scopeIdx int, timerIdx int) Stopwatch

StartTimer starts a timer for the given metric name

func (*TallyClient) UpdateGauge added in v1.9.0 

func (m *TallyClient) UpdateGauge(scopeIdx int, gaugeIdx int, value float64)

UpdateGauge reports Gauge type metric

func (*TallyClient) UserScope added in v1.11.0 

func (m *TallyClient) UserScope() UserScope

UserScope returns a new metrics scope that can be used to add additional information to the metrics emitted by user code

type TallyReporter added in v1.9.0 

type TallyReporter struct {
	// contains filtered or unexported fields
}

TallyReporter is a base class for reporting metrics to Tally.

func (*TallyReporter) GetScope added in v1.9.0 

func (tr *TallyReporter) GetScope() tally.Scope

func (*TallyReporter) NewClient added in v1.9.0 

func (tr *TallyReporter) NewClient(logger log.Logger, serviceIdx ServiceIdx) (Client, error)

func (*TallyReporter) Stop added in v1.9.0 

func (tr *TallyReporter) Stop(logger log.Logger)

type TallyStopwatch added in v1.5.7 

type TallyStopwatch struct {
	// contains filtered or unexported fields
}

TallyStopwatch is a helper for simpler tracking of elapsed time, use the Stop() method to report time elapsed since its created back to the timer or histogram.

func (*TallyStopwatch) Stop added in v1.5.7 

func (sw *TallyStopwatch) Stop()

Stop reports time elapsed since the stopwatch start to the recorder.

func (*TallyStopwatch) Subtract added in v1.10.0 

func (sw *TallyStopwatch) Subtract(toSubstract time.Duration)

Substract records time to substract from resulting value.

type UserScope added in v1.11.0 

type UserScope interface {
	// IncCounter increments a counter metric
	IncCounter(counter string)
	// AddCounter adds delta to the counter metric
	AddCounter(counter string, delta int64)
	// StartTimer starts a timer for the given metric name.
	// Time will be recorded when stopwatch is stopped.
	StartTimer(timer string) Stopwatch
	// RecordTimer records a timer for the given metric name
	RecordTimer(timer string, d time.Duration)
	// RecordDistribution records a distribution (wrapper on top of timer) for the given
	// metric name
	RecordDistribution(id string, d int)
	// UpdateGauge reports Gauge type absolute value metric
	UpdateGauge(gauge string, value float64)
	// Tagged returns a new scope with added and/or overriden tags values that can be used
	// to provide additional information to metrics
	Tagged(tags map[string]string) UserScope
}

UserScope is an interface for reporting metrics by user code

Source Files

View all Source files

Directories

Path Synopsis
tally
statsd

Jump to

Keyboard shortcuts

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