metrics

Documentation

Overview

Package metrics is a generated GoMock package.

Index

• Constants
• Variables
• func AddMetricsContext(ctx context.Context) context.Context
• func CapturePanic(logger log.Logger, metricHandler Handler, retError *error)
• func ContextCounterAdd(ctx context.Context, name string, value int64) bool
• func ContextCounterGet(ctx context.Context, name string) (int64, bool)
• func NewBytesHistogramDef(name string, opts ...Option) metricDefinition
• func NewClientMetricsTrailerPropagatorInterceptor(logger log.Logger) grpc.UnaryClientInterceptor
• func NewCounterDef(name string, opts ...Option) metricDefinition
• func NewDimensionlessHistogramDef(name string, opts ...Option) metricDefinition
• func NewGaugeDef(name string, opts ...Option) metricDefinition
• func NewOpenTelemetryProvider(logger log.Logger, prometheusConfig *PrometheusConfig, ...) (*openTelemetryProviderImpl, error)
• func NewOtelMetricsHandler(l log.Logger, o OpenTelemetryProvider, cfg ClientConfig) (*otelMetricsHandler, error)
• func NewScope(logger log.Logger, c *Config) tally.Scope
• func NewServerMetricsContextInjectorInterceptor() grpc.UnaryServerInterceptor
• func NewServerMetricsTrailerPropagatorInterceptor(logger log.Logger) grpc.UnaryServerInterceptor
• func NewTallyMetricsHandler(cfg ClientConfig, scope tally.Scope) *tallyMetricsHandler
• func NewTimerDef(name string, opts ...Option) metricDefinition
• func RuntimeMetricsReporterLifetimeHooks(lc fx.Lifecycle, reporter *RuntimeMetricsReporter)
• type ClientConfig
• type Config
• type CounterFunc
  • func (c CounterFunc) Record(v int64, tags ...Tag)
• type CounterIface
• type GaugeFunc
  • func (c GaugeFunc) Record(v float64, tags ...Tag)
• type GaugeIface
• type Handler
  • func GetPerTaskQueueScope(handler Handler, namespaceName string, taskQueueName string, ...) Handler
  • func MetricsHandlerFromConfig(logger log.Logger, c *Config) (Handler, error)
• type HistogramFunc
  • func (c HistogramFunc) Record(v int64, tags ...Tag)
• type HistogramIface
• type HistogramObjective
• type MetricUnit
• type MockCounterIface
  • func NewMockCounterIface(ctrl *gomock.Controller) *MockCounterIface
  • func (m *MockCounterIface) EXPECT() *MockCounterIfaceMockRecorder
  • func (m *MockCounterIface) Record(arg0 int64, arg1 ...Tag)
• type MockCounterIfaceMockRecorder
  • func (mr *MockCounterIfaceMockRecorder) Record(arg0 interface{}, arg1 ...interface{}) *gomock.Call
• type MockGaugeIface
  • func NewMockGaugeIface(ctrl *gomock.Controller) *MockGaugeIface
  • func (m *MockGaugeIface) EXPECT() *MockGaugeIfaceMockRecorder
  • func (m *MockGaugeIface) Record(arg0 float64, arg1 ...Tag)
• type MockGaugeIfaceMockRecorder
  • func (mr *MockGaugeIfaceMockRecorder) Record(arg0 interface{}, arg1 ...interface{}) *gomock.Call
• type MockHandler
  • func NewMockHandler(ctrl *gomock.Controller) *MockHandler
  • func (m *MockHandler) Counter(arg0 string) CounterIface
  • func (m *MockHandler) EXPECT() *MockHandlerMockRecorder
  • func (m *MockHandler) Gauge(arg0 string) GaugeIface
  • func (m *MockHandler) Histogram(arg0 string, arg1 MetricUnit) HistogramIface
  • func (m *MockHandler) Stop(arg0 log.Logger)
  • func (m *MockHandler) Timer(arg0 string) TimerIface
  • func (m *MockHandler) WithTags(arg0 ...Tag) Handler
• type MockHandlerMockRecorder
  • func (mr *MockHandlerMockRecorder) Counter(arg0 interface{}) *gomock.Call
  • func (mr *MockHandlerMockRecorder) Gauge(arg0 interface{}) *gomock.Call
  • func (mr *MockHandlerMockRecorder) Histogram(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockHandlerMockRecorder) Stop(arg0 interface{}) *gomock.Call
  • func (mr *MockHandlerMockRecorder) Timer(arg0 interface{}) *gomock.Call
  • func (mr *MockHandlerMockRecorder) WithTags(arg0 ...interface{}) *gomock.Call
• type MockHistogramIface
  • func NewMockHistogramIface(ctrl *gomock.Controller) *MockHistogramIface
  • func (m *MockHistogramIface) EXPECT() *MockHistogramIfaceMockRecorder
  • func (m *MockHistogramIface) Record(arg0 int64, arg1 ...Tag)
• type MockHistogramIfaceMockRecorder
  • func (mr *MockHistogramIfaceMockRecorder) Record(arg0 interface{}, arg1 ...interface{}) *gomock.Call
• type MockTimerIface
  • func NewMockTimerIface(ctrl *gomock.Controller) *MockTimerIface
  • func (m *MockTimerIface) EXPECT() *MockTimerIfaceMockRecorder
  • func (m *MockTimerIface) Record(arg0 time.Duration, arg1 ...Tag)
• type MockTimerIfaceMockRecorder
  • func (mr *MockTimerIfaceMockRecorder) Record(arg0 interface{}, arg1 ...interface{}) *gomock.Call
• type OpenTelemetryProvider
• type Option
• type PrometheusConfig
• type ReasonString
• type RuntimeMetricsReporter
  • func NewRuntimeMetricsReporter(handler Handler, reportInterval time.Duration, logger log.Logger, ...) *RuntimeMetricsReporter
  • func (r *RuntimeMetricsReporter) Start()
  • func (r *RuntimeMetricsReporter) Stop()
• type SanitizeOptions
• type SanitizeRange
• type StatsdConfig
• type StatsdReporterConfig
• type SummaryObjective
• type Tag
  • func ActionType(value string) Tag
  • func ActivityTypeTag(value string) Tag
  • func AdvancedVisibilityTypeTag() Tag
  • func CacheTypeTag(value string) Tag
  • func CommandTypeTag(value string) Tag
  • func FailureTag(value string) Tag
  • func FromClusterIDTag(value int32) Tag
  • func HttpStatusTag(value int) Tag
  • func InstanceTag(value string) Tag
  • func NamespaceStateTag(value string) Tag
  • func NamespaceTag(value string) Tag
  • func NamespaceUnknownTag() Tag
  • func OperationTag(value string) Tag
  • func QueueActionTag(value string) Tag
  • func QueueReaderIDTag(readerID int64) Tag
  • func QueueTypeTag(value string) Tag
  • func ReasonTag(value ReasonString) Tag
  • func ReplicationTaskTypeTag(value enumsspb.ReplicationTaskType) Tag
  • func ResourceExhaustedCauseTag(cause enumspb.ResourceExhaustedCause) Tag
  • func ServiceErrorTypeTag(err error) Tag
  • func ServiceNameTag(value primitives.ServiceName) Tag
  • func ServiceRoleTag(value string) Tag
  • func StandardVisibilityTypeTag() Tag
  • func StringTag(key string, value string) Tag
  • func TargetClusterTag(value string) Tag
  • func TaskCategoryTag(value string) Tag
  • func TaskPriorityTag(value string) Tag
  • func TaskQueueTag(value string) Tag
  • func TaskQueueTypeTag(tqType enumspb.TaskQueueType) Tag
  • func TaskQueueUnknownTag() Tag
  • func TaskTypeTag(value string) Tag
  • func ToClusterIDTag(value int32) Tag
  • func VersionedTag(versioned bool) Tag
  • func VisibilityTypeTag(value string) Tag
  • func WorkflowTypeTag(value string) Tag
• type TimerFunc
  • func (c TimerFunc) Record(v time.Duration, tags ...Tag)
• type TimerIface
• type ValidCharacters
• type WithDescription
• type WithUnit

Constants

const (
	// FrameworkTally tally framework id
	FrameworkTally = "tally"
	// FrameworkOpentelemetry OpenTelemetry framework id
	FrameworkOpentelemetry = "opentelemetry"
)

Supported framework types

const (
	UnitNameDimensionless = "dimensionless"
	UnitNameMilliseconds  = "milliseconds"
	UnitNameBytes         = "bytes"
)

Valid unit name for PerUnitHistogramBoundaries config field

const (
	Dimensionless = "1"
	Milliseconds  = "ms"
	Bytes         = "By"
)

MetricUnit supported values Values are pulled from https://pkg.go.dev/golang.org/x/exp/event#Unit

const (
	OperationTagName     = "operation"
	ServiceRoleTagName   = "service_role"
	CacheTypeTagName     = "cache_type"
	FailureTagName       = "failure"
	TaskCategoryTagName  = "task_category"
	TaskTypeTagName      = "task_type"
	TaskPriorityTagName  = "task_priority"
	QueueReaderIDTagName = "queue_reader_id"
	QueueActionTagName   = "queue_action"
	QueueTypeTagName     = "queue_type"

	ErrorTypeTagName = "error_type"
)

Common tags for all services

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

	MutableStateCacheTypeTagValue = "mutablestate"
	EventsCacheTypeTagValue       = "events"

	InvalidHistoryURITagValue    = "invalid_history_uri"
	InvalidVisibilityURITagValue = "invalid_visibility_uri"
)

This package should hold all the metrics and tags for temporal

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

const (
	// AdminClientAddSearchAttributesScope tracks RPC calls to admin service
	AdminClientAddSearchAttributesScope = "AdminClientAddSearchAttributes"
	// AdminClientRemoveSearchAttributesScope tracks RPC calls to admin service
	AdminClientRemoveSearchAttributesScope = "AdminClientRemoveSearchAttributes"
	// AdminClientGetSearchAttributesScope tracks RPC calls to admin service
	AdminClientGetSearchAttributesScope = "AdminClientGetSearchAttributes"
	// AdminClientCloseShardScope tracks RPC calls to admin service
	AdminClientCloseShardScope = "AdminClientCloseShard"
	// AdminClientGetShardScope tracks RPC calls to admin service
	AdminClientGetShardScope = "AdminClientGetShard"
	// AdminClientListHistoryTasksScope tracks RPC calls to admin service
	AdminClientListHistoryTasksScope = "AdminClientListHistoryTasks"
	// AdminClientRemoveTaskScope tracks RPC calls to admin service
	AdminClientRemoveTaskScope = "AdminClientRemoveTask"
	// AdminClientDescribeHistoryHostScope tracks RPC calls to admin service
	AdminClientDescribeHistoryHostScope = "AdminClientDescribeHistoryHost"
	// AdminClientRebuildMutableStateScope tracks RPC calls to admin service
	AdminClientRebuildMutableStateScope = "AdminClientRebuildMutableState"
	// AdminClientDescribeMutableStateScope tracks RPC calls to admin service
	AdminClientDescribeMutableStateScope = "AdminClientDescribeMutableState"
	// AdminClientGetWorkflowExecutionRawHistoryV2Scope tracks RPC calls to admin service
	AdminClientGetWorkflowExecutionRawHistoryV2Scope = "AdminClientGetWorkflowExecutionRawHistoryV2"
	// AdminClientDescribeClusterScope tracks RPC calls to admin service
	AdminClientDescribeClusterScope = "AdminClientDescribeCluster"
	// AdminClientListClustersScope tracks RPC calls to admin service
	AdminClientListClustersScope = "AdminClientListClusters"
	// AdminClientListClusterMembersScope tracks RPC calls to admin service
	AdminClientListClusterMembersScope = "AdminClientListClusterMembers"
	// AdminClientAddOrUpdateRemoteClusterScope tracks RPC calls to admin service
	AdminClientAddOrUpdateRemoteClusterScope = "AdminClientAddOrUpdateRemoteCluster"
	// AdminClientRemoveRemoteClusterScope tracks RPC calls to admin service
	AdminClientRemoveRemoteClusterScope = "AdminClientRemoveRemoteCluster"
	// AdminClientGetReplicationMessagesScope tracks RPC calls to admin service
	AdminClientGetReplicationMessagesScope = "AdminClientGetReplicationMessages"
	// AdminClientGetNamespaceReplicationMessagesScope tracks RPC calls to admin service
	AdminClientGetNamespaceReplicationMessagesScope = "AdminClientGetNamespaceReplicationMessages"
	// AdminClientGetNamespaceScope tracks RPC calls to admin service
	AdminClientGetNamespaceScope = "AdminClientGetNamespace"
	// AdminClientGetDLQReplicationMessagesScope tracks RPC calls to admin service
	AdminClientGetDLQReplicationMessagesScope = "AdminClientGetDLQReplicationMessages"
	// AdminClientReapplyEventsScope tracks RPC calls to admin service
	AdminClientReapplyEventsScope = "AdminClientReapplyEvents"
	// AdminClientGetDLQMessagesScope tracks RPC calls to admin service
	AdminClientGetDLQMessagesScope = "AdminClientGetDLQMessages"
	// AdminClientPurgeDLQMessagesScope tracks RPC calls to admin service
	AdminClientPurgeDLQMessagesScope = "AdminClientPurgeDLQMessages"
	// AdminClientMergeDLQMessagesScope tracks RPC calls to admin service
	AdminClientMergeDLQMessagesScope = "AdminClientMergeDLQMessages"
	// AdminClientRefreshWorkflowTasksScope tracks RPC calls to admin service
	AdminClientRefreshWorkflowTasksScope = "AdminClientRefreshWorkflowTasks"
	// AdminClientResendReplicationTasksScope tracks RPC calls to admin service
	AdminClientResendReplicationTasksScope = "AdminClientResendReplicationTasks"
	// AdminClientGetTaskQueueTasksScope tracks RPC calls to admin service
	AdminClientGetTaskQueueTasksScope = "AdminClientGetTaskQueueTasks"
	// AdminClientDeleteWorkflowExecutionScope tracks RPC calls to admin service
	AdminClientDeleteWorkflowExecutionScope = "AdminClientDeleteWorkflowExecution"
	// AdminClientStreamWorkflowReplicationMessagesScope tracks RPC calls to admin service
	AdminClientStreamWorkflowReplicationMessagesScope = "AdminClientStreamWorkflowReplicationMessages"
)

Admin Client Operations

const (
	// FrontendClientDeleteWorkflowExecutionScope tracks RPC calls to frontend service
	FrontendClientDeleteWorkflowExecutionScope = "FrontendClientDeleteWorkflowExecution"
	// FrontendClientDeprecateNamespaceScope tracks RPC calls to frontend service
	FrontendClientDeprecateNamespaceScope = "FrontendClientDeprecateNamespace"
	// FrontendClientDescribeNamespaceScope tracks RPC calls to frontend service
	FrontendClientDescribeNamespaceScope = "FrontendClientDescribeNamespace"
	// FrontendClientDescribeTaskQueueScope tracks RPC calls to frontend service
	FrontendClientDescribeTaskQueueScope = "FrontendClientDescribeTaskQueue"
	// FrontendClientDescribeWorkflowExecutionScope tracks RPC calls to frontend service
	FrontendClientDescribeWorkflowExecutionScope = "FrontendClientDescribeWorkflowExecution"
	// FrontendClientGetWorkflowExecutionHistoryScope tracks RPC calls to frontend service
	FrontendClientGetWorkflowExecutionHistoryScope = "FrontendClientGetWorkflowExecutionHistory"
	// FrontendClientGetWorkflowExecutionHistoryReverseScope tracks RPC calls to frontend service
	FrontendClientGetWorkflowExecutionHistoryReverseScope = "FrontendClientGetWorkflowExecutionHistoryReverse"
	// FrontendClientGetWorkflowExecutionRawHistoryScope tracks RPC calls to frontend service
	FrontendClientGetWorkflowExecutionRawHistoryScope = "FrontendClientGetWorkflowExecutionRawHistory"
	// FrontendClientPollForWorkflowExecutionRawHistoryScope tracks RPC calls to frontend service
	FrontendClientPollForWorkflowExecutionRawHistoryScope = "FrontendClientPollForWorkflowExecutionRawHistory"
	// FrontendClientListArchivedWorkflowExecutionsScope tracks RPC calls to frontend service
	FrontendClientListArchivedWorkflowExecutionsScope = "FrontendClientListArchivedWorkflowExecutions"
	// FrontendClientListClosedWorkflowExecutionsScope tracks RPC calls to frontend service
	FrontendClientListClosedWorkflowExecutionsScope = "FrontendClientListClosedWorkflowExecutions"
	// FrontendClientListNamespacesScope tracks RPC calls to frontend service
	FrontendClientListNamespacesScope = "FrontendClientListNamespaces"
	// FrontendClientListOpenWorkflowExecutionsScope tracks RPC calls to frontend service
	FrontendClientListOpenWorkflowExecutionsScope = "FrontendClientListOpenWorkflowExecutions"
	// FrontendClientPollActivityTaskQueueScope tracks RPC calls to frontend service
	FrontendClientPollActivityTaskQueueScope = "FrontendClientPollActivityTaskQueue"
	// FrontendClientPollWorkflowExecutionUpdateScope tracks RPC calls to frontend service
	FrontendClientPollWorkflowExecutionUpdateScope = "FrontendClientPollWorkflowExecutionUpdate"
	// FrontendClientPollWorkflowTaskQueueScope tracks RPC calls to frontend service
	FrontendClientPollWorkflowTaskQueueScope = "FrontendClientPollWorkflowTaskQueue"
	// FrontendClientQueryWorkflowScope tracks RPC calls to frontend service
	FrontendClientQueryWorkflowScope = "FrontendClientQueryWorkflow"
	// FrontendClientRecordActivityTaskHeartbeatScope tracks RPC calls to frontend service
	FrontendClientRecordActivityTaskHeartbeatScope = "FrontendClientRecordActivityTaskHeartbeat"
	// FrontendClientRecordActivityTaskHeartbeatByIdScope tracks RPC calls to frontend service
	FrontendClientRecordActivityTaskHeartbeatByIdScope = "FrontendClientRecordActivityTaskHeartbeatById"
	// FrontendClientRegisterNamespaceScope tracks RPC calls to frontend service
	FrontendClientRegisterNamespaceScope = "FrontendClientRegisterNamespace"
	// FrontendClientRequestCancelWorkflowExecutionScope tracks RPC calls to frontend service
	FrontendClientRequestCancelWorkflowExecutionScope = "FrontendClientRequestCancelWorkflowExecution"
	// FrontendClientResetStickyTaskQueueScope tracks RPC calls to frontend service
	FrontendClientResetStickyTaskQueueScope = "FrontendClientResetStickyTaskQueue"
	// FrontendClientResetWorkflowExecutionScope tracks RPC calls to frontend service
	FrontendClientResetWorkflowExecutionScope = "FrontendClientResetWorkflowExecution"
	// FrontendClientRespondActivityTaskCanceledScope tracks RPC calls to frontend service
	FrontendClientRespondActivityTaskCanceledScope = "FrontendClientRespondActivityTaskCanceled"
	// FrontendClientRespondActivityTaskCanceledByIdScope tracks RPC calls to frontend service
	FrontendClientRespondActivityTaskCanceledByIdScope = "FrontendClientRespondActivityTaskCanceledById"
	// FrontendClientRespondActivityTaskCompletedScope tracks RPC calls to frontend service
	FrontendClientRespondActivityTaskCompletedScope = "FrontendClientRespondActivityTaskCompleted"
	// FrontendClientRespondActivityTaskCompletedByIdScope tracks RPC calls to frontend service
	FrontendClientRespondActivityTaskCompletedByIdScope = "FrontendClientRespondActivityTaskCompletedById"
	// FrontendClientRespondActivityTaskFailedScope tracks RPC calls to frontend service
	FrontendClientRespondActivityTaskFailedScope = "FrontendClientRespondActivityTaskFailed"
	// FrontendClientRespondActivityTaskFailedByIdScope tracks RPC calls to frontend service
	FrontendClientRespondActivityTaskFailedByIdScope = "FrontendClientRespondActivityTaskFailedById"
	// FrontendClientRespondWorkflowTaskCompletedScope tracks RPC calls to frontend service
	FrontendClientRespondWorkflowTaskCompletedScope = "FrontendClientRespondWorkflowTaskCompleted"
	// FrontendClientRespondWorkflowTaskFailedScope tracks RPC calls to frontend service
	FrontendClientRespondWorkflowTaskFailedScope = "FrontendClientRespondWorkflowTaskFailed"
	// FrontendClientRespondQueryTaskCompletedScope tracks RPC calls to frontend service
	FrontendClientRespondQueryTaskCompletedScope = "FrontendClientRespondQueryTaskCompleted"
	// FrontendClientSignalWithStartWorkflowExecutionScope tracks RPC calls to frontend service
	FrontendClientSignalWithStartWorkflowExecutionScope = "FrontendClientSignalWithStartWorkflowExecution"
	// FrontendClientSignalWorkflowExecutionScope tracks RPC calls to frontend service
	FrontendClientSignalWorkflowExecutionScope = "FrontendClientSignalWorkflowExecution"
	// FrontendClientStartWorkflowExecutionScope tracks RPC calls to frontend service
	FrontendClientStartWorkflowExecutionScope = "FrontendClientStartWorkflowExecution"
	// FrontendClientTerminateWorkflowExecutionScope tracks RPC calls to frontend service
	FrontendClientTerminateWorkflowExecutionScope = "FrontendClientTerminateWorkflowExecution"
	// FrontendClientUpdateNamespaceScope tracks RPC calls to frontend service
	FrontendClientUpdateNamespaceScope = "FrontendClientUpdateNamespace"
	// FrontendClientListWorkflowExecutionsScope tracks RPC calls to frontend service
	FrontendClientListWorkflowExecutionsScope = "FrontendClientListWorkflowExecutions"
	// FrontendClientScanWorkflowExecutionsScope tracks RPC calls to frontend service
	FrontendClientScanWorkflowExecutionsScope = "FrontendClientScanWorkflowExecutions"
	// FrontendClientCountWorkflowExecutionsScope tracks RPC calls to frontend service
	FrontendClientCountWorkflowExecutionsScope = "FrontendClientCountWorkflowExecutions"
	// FrontendClientGetSearchAttributesScope tracks RPC calls to frontend service
	FrontendClientGetSearchAttributesScope = "FrontendClientGetSearchAttributes"
	// FrontendClientGetClusterInfoScope tracks RPC calls to frontend
	FrontendClientGetClusterInfoScope = "FrontendClientGetClusterInfo"
	// FrontendClientGetSystemInfoScope tracks RPC calls to frontend
	FrontendClientGetSystemInfoScope = "FrontendClientGetSystemInfo"
	// FrontendClientListTaskQueuePartitionsScope tracks RPC calls to frontend service
	FrontendClientListTaskQueuePartitionsScope = "FrontendClientListTaskQueuePartitions"
	// FrontendClientCreateScheduleScope tracks RPC calls to frontend service
	FrontendClientCreateScheduleScope = "FrontendClientCreateSchedule"
	// FrontendClientDescribeScheduleScope tracks RPC calls to frontend service
	FrontendClientDescribeScheduleScope = "FrontendClientDescribeSchedule"
	// FrontendClientUpdateScheduleScope tracks RPC calls to frontend service
	FrontendClientUpdateScheduleScope = "FrontendClientUpdateSchedule"
	// FrontendClientPatchScheduleScope tracks RPC calls to frontend service
	FrontendClientPatchScheduleScope = "FrontendClientPatchSchedule"
	// FrontendClientListScheduleMatchingTimesScope tracks RPC calls to frontend service
	FrontendClientListScheduleMatchingTimesScope = "FrontendClientListScheduleMatchingTimes"
	// FrontendClientDeleteScheduleScope tracks RPC calls to frontend service
	FrontendClientDeleteScheduleScope = "FrontendClientDeleteSchedule"
	// FrontendClientListSchedulesScope tracks RPC calls to frontend service
	FrontendClientListSchedulesScope = "FrontendClientListSchedules"
	// FrontendClientUpdateWorkerBuildIdCompatibilityScope tracks RPC calls to frontend service
	FrontendClientUpdateWorkerBuildIdCompatibilityScope = "FrontendClientUpdateWorkerBuildIdCompatibility"
	// FrontendClientUpdateWorkflowExecutionScope tracks RPC calls to frontend service
	FrontendClientUpdateWorkflowExecutionScope = "FrontendClientUpdateWorkflowExecution"
	// FrontendClientGetWorkerBuildIdCompatibilityScope tracks RPC calls to frontend service
	FrontendClientGetWorkerBuildIdCompatibilityScope = "FrontendClientGetWorkerBuildIdCompatibility"
	// FrontendClientGetWorkerTaskReachabilityScope tracks RPC calls to frontend service
	FrontendClientGetWorkerTaskReachabilityScope = "FrontendClientGetWorkerTaskReachability"
	// FrontendClientDescribeBatchOperationScope tracks RPC calls to frontend service
	FrontendClientDescribeBatchOperationScope = "FrontendClientDescribeBatchOperation"
	// FrontendClientListBatchOperationsScope tracks RPC calls to frontend service
	FrontendClientListBatchOperationsScope = "FrontendClientListBatchOperations"
	// FrontendClientStartBatchOperationScope tracks RPC calls to frontend service
	FrontendClientStartBatchOperationScope = "FrontendClientStartBatchOperation"
	// FrontendClientStopBatchOperationScope tracks RPC calls to frontend service
	FrontendClientStopBatchOperationScope = "FrontendClientStopBatchOperation"
)

Frontend Client Operations

const (
	// HistoryClientStartWorkflowExecutionScope tracks RPC calls to history service
	HistoryClientStartWorkflowExecutionScope = "HistoryClientStartWorkflowExecution"
	// HistoryClientRecordActivityTaskHeartbeatScope tracks RPC calls to history service
	HistoryClientRecordActivityTaskHeartbeatScope = "HistoryClientRecordActivityTaskHeartbeat"
	// HistoryClientRespondWorkflowTaskCompletedScope tracks RPC calls to history service
	HistoryClientRespondWorkflowTaskCompletedScope = "HistoryClientRespondWorkflowTaskCompleted"
	// HistoryClientRespondWorkflowTaskFailedScope tracks RPC calls to history service
	HistoryClientRespondWorkflowTaskFailedScope = "HistoryClientRespondWorkflowTaskFailed"
	// HistoryClientRespondActivityTaskCompletedScope tracks RPC calls to history service
	HistoryClientRespondActivityTaskCompletedScope = "HistoryClientRespondActivityTaskCompleted"
	// HistoryClientRespondActivityTaskFailedScope tracks RPC calls to history service
	HistoryClientRespondActivityTaskFailedScope = "HistoryClientRespondActivityTaskFailed"
	// HistoryClientRespondActivityTaskCanceledScope tracks RPC calls to history service
	HistoryClientRespondActivityTaskCanceledScope = "HistoryClientRespondActivityTaskCanceled"
	// HistoryClientGetMutableStateScope tracks RPC calls to history service
	HistoryClientGetMutableStateScope = "HistoryClientGetMutableState"
	// HistoryClientPollMutableStateScope tracks RPC calls to history service
	HistoryClientPollMutableStateScope = "HistoryClientPollMutableState"
	// HistoryClientResetStickyTaskQueueScope tracks RPC calls to history service
	HistoryClientResetStickyTaskQueueScope = "HistoryClientResetStickyTaskQueue"
	// HistoryClientDescribeWorkflowExecutionScope tracks RPC calls to history service
	HistoryClientDescribeWorkflowExecutionScope = "HistoryClientDescribeWorkflowExecution"
	// HistoryClientRecordWorkflowTaskStartedScope tracks RPC calls to history service
	HistoryClientRecordWorkflowTaskStartedScope = "HistoryClientRecordWorkflowTaskStarted"
	// HistoryClientRecordActivityTaskStartedScope tracks RPC calls to history service
	HistoryClientRecordActivityTaskStartedScope = "HistoryClientRecordActivityTaskStarted"
	// HistoryClientRequestCancelWorkflowExecutionScope tracks RPC calls to history service
	HistoryClientRequestCancelWorkflowExecutionScope = "HistoryClientRequestCancelWorkflowExecution"
	// HistoryClientSignalWorkflowExecutionScope tracks RPC calls to history service
	HistoryClientSignalWorkflowExecutionScope = "HistoryClientSignalWorkflowExecution"
	// HistoryClientSignalWithStartWorkflowExecutionScope tracks RPC calls to history service
	HistoryClientSignalWithStartWorkflowExecutionScope = "HistoryClientSignalWithStartWorkflowExecution"
	// HistoryClientRemoveSignalMutableStateScope tracks RPC calls to history service
	HistoryClientRemoveSignalMutableStateScope = "HistoryClientRemoveSignalMutableState"
	// HistoryClientTerminateWorkflowExecutionScope tracks RPC calls to history service
	HistoryClientTerminateWorkflowExecutionScope = "HistoryClientTerminateWorkflowExecution"
	// HistoryClientUpdateWorkflowExecutionScope tracks RPC calls to history service
	HistoryClientUpdateWorkflowExecutionScope = "HistoryClientUpdateWorkflowExecution"
	// HistoryClientPollWorkflowExecutionUpdateScope tracks RPC calls to history service
	HistoryClientPollWorkflowExecutionUpdateScope = "HistoryClientPollPollWorkflowExecutionUpdate"
	// HistoryClientDeleteWorkflowExecutionScope tracks RPC calls to history service
	HistoryClientDeleteWorkflowExecutionScope = "HistoryClientDeleteWorkflowExecution"
	// HistoryClientResetWorkflowExecutionScope tracks RPC calls to history service
	HistoryClientResetWorkflowExecutionScope = "HistoryClientResetWorkflowExecution"
	// HistoryClientScheduleWorkflowTaskScope tracks RPC calls to history service
	HistoryClientScheduleWorkflowTaskScope = "HistoryClientScheduleWorkflowTask"
	// HistoryClientVerifyFirstWorkflowTaskScheduled tracks RPC calls to history service
	HistoryClientVerifyFirstWorkflowTaskScheduled
	// HistoryClientRecordChildExecutionCompletedScope tracks RPC calls to history service
	HistoryClientRecordChildExecutionCompletedScope = "HistoryClientRecordChildExecutionCompleted"
	// HistoryClientVerifyChildExecutionCompletionRecordedScope tracks RPC calls to history service
	HistoryClientVerifyChildExecutionCompletionRecordedScope = "HistoryClientVerifyChildExecutionCompletionRecorded"
	// HistoryClientReplicateEventsV2Scope tracks RPC calls to history service
	HistoryClientReplicateEventsV2Scope = "HistoryClientReplicateEventsV2"
	// HistoryClientReplicateWorkflowStateScope tracks RPC calls to history service
	HistoryClientReplicateWorkflowStateScope = "HistoryClientReplicateWorkflowState"
	// HistoryClientSyncShardStatusScope tracks RPC calls to history service
	HistoryClientSyncShardStatusScope = "HistoryClientSyncShardStatus"
	// HistoryClientSyncActivityScope tracks RPC calls to history service
	HistoryClientSyncActivityScope = "HistoryClientSyncActivity"
	// HistoryClientGetReplicationTasksScope tracks RPC calls to history service
	HistoryClientGetReplicationTasksScope = "HistoryClientGetReplicationTasks"
	// HistoryClientGetDLQReplicationTasksScope tracks RPC calls to history service
	HistoryClientGetDLQReplicationTasksScope = "HistoryClientGetDLQReplicationTasks"
	// HistoryClientQueryWorkflowScope tracks RPC calls to history service
	HistoryClientQueryWorkflowScope = "HistoryClientQueryWorkflow"
	// HistoryClientReapplyEventsScope tracks RPC calls to history service
	HistoryClientReapplyEventsScope = "HistoryClientReapplyEvents"
	// HistoryClientGetDLQMessagesScope tracks RPC calls to history service
	HistoryClientGetDLQMessagesScope = "HistoryClientGetDLQMessages"
	// HistoryClientPurgeDLQMessagesScope tracks RPC calls to history service
	HistoryClientPurgeDLQMessagesScope = "HistoryClientPurgeDLQMessages"
	// HistoryClientMergeDLQMessagesScope tracks RPC calls to history service
	HistoryClientMergeDLQMessagesScope = "HistoryClientMergeDLQMessages"
	// HistoryClientRefreshWorkflowTasksScope tracks RPC calls to history service
	HistoryClientRefreshWorkflowTasksScope = "HistoryClientRefreshWorkflowTasks"
	// HistoryClientGenerateLastHistoryReplicationTasksScope tracks RPC calls to history service
	HistoryClientGenerateLastHistoryReplicationTasksScope = "HistoryClientGenerateLastHistoryReplicationTasks"
	// HistoryClientGetReplicationStatusScope tracks RPC calls to history service
	HistoryClientGetReplicationStatusScope = "HistoryClientGetReplicationStatus"
	// HistoryClientDeleteWorkflowVisibilityRecordScope tracks RPC calls to history service
	HistoryClientDeleteWorkflowVisibilityRecordScope = "HistoryClientDeleteWorkflowVisibilityRecord"
	// HistoryClientCloseShardScope tracks RPC calls to history service
	HistoryClientCloseShardScope = "HistoryClientCloseShard"
	// HistoryClientDescribeMutableStateScope tracks RPC calls to history service
	HistoryClientDescribeMutableStateScope = "HistoryClientDescribeMutableState"
	// HistoryClientGetDLQReplicationMessagesScope tracks RPC calls to history service
	HistoryClientGetDLQReplicationMessagesScope = "HistoryClientGetDLQReplicationMessages"
	// HistoryClientGetShardScope tracks RPC calls to history service
	HistoryClientGetShardScope = "HistoryClientGetShard"
	// HistoryClientIsActivityTaskValidScope tracks RPC calls to history service
	HistoryClientIsActivityTaskValidScope = "HistoryClientIsActivityTaskValid"
	// HistoryClientIsWorkflowTaskValidScope tracks RPC calls to history service
	HistoryClientIsWorkflowTaskValidScope = "HistoryClientIsWorkflowTaskValid"
	// HistoryClientRebuildMutableStateScope tracks RPC calls to history service
	HistoryClientRebuildMutableStateScope = "HistoryClientRebuildMutableState"
	// HistoryClientRemoveTaskScope tracks RPC calls to history service
	HistoryClientRemoveTaskScope = "HistoryClientRemoveTask"
	// HistoryClientVerifyFirstWorkflowTaskScheduledScope tracks RPC calls to history service
	HistoryClientVerifyFirstWorkflowTaskScheduledScope = "HistoryClientVerifyFirstWorkflowTaskScheduled"
	// HistoryClientDescribeHistoryHostScope tracks RPC calls to history service
	HistoryClientDescribeHistoryHostScope = "HistoryClientDescribeHistoryHost"
	// HistoryClientGetReplicationMessagesScope tracks RPC calls to history service
	HistoryClientGetReplicationMessagesScope = "HistoryClientGetReplicationMessages"
	// HistoryClientStreamWorkflowReplicationMessagesScope tracks RPC calls to history service
	HistoryClientStreamWorkflowReplicationMessagesScope = "HistoryClientStreamWorkflowReplicationMessages"
)

History Client Operations

const (
	// MatchingClientPollWorkflowTaskQueueScope tracks RPC calls to matching service
	MatchingClientPollWorkflowTaskQueueScope = "MatchingClientPollWorkflowTaskQueue"
	// MatchingClientPollActivityTaskQueueScope tracks RPC calls to matching service
	MatchingClientPollActivityTaskQueueScope = "MatchingClientPollActivityTaskQueue"
	// MatchingClientAddActivityTaskScope tracks RPC calls to matching service
	MatchingClientAddActivityTaskScope = "MatchingClientAddActivityTask"
	// MatchingClientAddWorkflowTaskScope tracks RPC calls to matching service
	MatchingClientAddWorkflowTaskScope = "MatchingClientAddWorkflowTask"
	// MatchingClientQueryWorkflowScope tracks RPC calls to matching service
	MatchingClientQueryWorkflowScope = "MatchingClientQueryWorkflow"
	// MatchingClientRespondQueryTaskCompletedScope tracks RPC calls to matching service
	MatchingClientRespondQueryTaskCompletedScope = "MatchingClientRespondQueryTaskCompleted"
	// MatchingClientCancelOutstandingPollScope tracks RPC calls to matching service
	MatchingClientCancelOutstandingPollScope = "MatchingClientCancelOutstandingPoll"
	// MatchingClientDescribeTaskQueueScope tracks RPC calls to matching service
	MatchingClientDescribeTaskQueueScope = "MatchingClientDescribeTaskQueue"
	// MatchingClientGetBuildIdTaskQueueMappingScope tracks RPC calls to matching service
	MatchingClientGetBuildIdTaskQueueMappingScope = "MatchingClientGetBuildIdTaskQueueMapping"
	// MatchingClientListTaskQueuePartitionsScope tracks RPC calls to matching service
	MatchingClientListTaskQueuePartitionsScope = "MatchingClientListTaskQueuePartitions"
	// MatchingClientUpdateWorkerBuildIdCompatibilityScope tracks RPC calls to matching service
	MatchingClientUpdateWorkerBuildIdCompatibilityScope = "MatchingClientUpdateWorkerBuildIdCompatibility"
	// MatchingClientGetWorkerBuildIdCompatibilityScope tracks RPC calls to matching service
	MatchingClientGetWorkerBuildIdCompatibilityScope = "MatchingClientGetWorkerBuildIdCompatibility"
	// MatchingClientGetTaskQueueUserDataScope tracks RPC calls to matching service
	MatchingClientGetTaskQueueUserDataScope = "MatchingClientGetTaskQueueUserData"
	// MatchingClientApplyTaskQueueUserDataReplicationEventScope tracks RPC calls to matching service
	MatchingClientApplyTaskQueueUserDataReplicationEventScope = "MatchingClientApplyTaskQueueUserDataReplicationEvent"
	// MatchingClientForceUnloadTaskQueueScope tracks RPC calls to matching service
	MatchingClientForceUnloadTaskQueueScope = "MatchingClientForceUnloadTaskQueue"
	// MatchingClientUpdateTaskQueueUserDataScope tracks RPC calls to matching service
	MatchingClientUpdateTaskQueueUserDataScope = "MatchingClientUpdateTaskQueueUserData"
	// MatchingClientReplicateTaskQueueUserDataScope tracks RPC calls to matching service
	MatchingClientReplicateTaskQueueUserDataScope = "MatchingClientReplicateTaskQueueUserData"
)

Matching Client Operations

const (
	// TaskQueueScavengerScope is scope used by all metrics emitted by worker.taskqueue.Scavenger module
	TaskQueueScavengerScope = "TaskQueueScavenger"
	// ExecutionsScavengerScope is scope used by all metrics emitted by worker.executions.Scavenger module
	ExecutionsScavengerScope = "ExecutionsScavenger"
)

Worker

const (
	// PersistenceAppendHistoryNodesScope tracks AppendHistoryNodes calls made by service to persistence layer
	PersistenceAppendHistoryNodesScope = "AppendHistoryNodes"
	// PersistenceAppendRawHistoryNodesScope tracks AppendRawHistoryNodes calls made by service to persistence layer
	PersistenceAppendRawHistoryNodesScope = "AppendRawHistoryNodes"
	// PersistenceDeleteHistoryNodesScope tracks DeleteHistoryNodes calls made by service to persistence layer
	PersistenceDeleteHistoryNodesScope = "DeleteHistoryNodes"
	// PersistenceReadHistoryBranchScope tracks ReadHistoryBranch calls made by service to persistence layer
	PersistenceReadHistoryBranchScope = "ReadHistoryBranch"
	// PersistenceReadHistoryBranchReverseScope tracks ReadHistoryBranchReverse calls made by service to persistence layer
	PersistenceReadHistoryBranchReverseScope = "ReadHistoryBranchReverse"
	// PersistenceReadRawHistoryBranchScope tracks ReadRawHistoryBranch calls made by service to persistence layer
	PersistenceReadRawHistoryBranchScope = "ReadRawHistoryBranch"
	// PersistenceForkHistoryBranchScope tracks ForkHistoryBranch calls made by service to persistence layer
	PersistenceForkHistoryBranchScope = "ForkHistoryBranch"
	// PersistenceDeleteHistoryBranchScope tracks DeleteHistoryBranch calls made by service to persistence layer
	PersistenceDeleteHistoryBranchScope = "DeleteHistoryBranch"
	// PersistenceTrimHistoryBranchScope tracks TrimHistoryBranch calls made by service to persistence layer
	PersistenceTrimHistoryBranchScope = "TrimHistoryBranch"
	// PersistenceCompleteForkBranchScope tracks CompleteForkBranch calls made by service to persistence layer
	PersistenceCompleteForkBranchScope = "CompleteForkBranch"
	// PersistenceGetHistoryTreeScope tracks GetHistoryTree calls made by service to persistence layer
	PersistenceGetHistoryTreeScope = "GetHistoryTree"
	// PersistenceGetAllHistoryTreeBranchesScope tracks GetHistoryTree calls made by service to persistence layer
	PersistenceGetAllHistoryTreeBranchesScope = "GetAllHistoryTreeBranches"
	// PersistenceNamespaceReplicationQueueScope is the metrics scope for namespace replication queue
	PersistenceNamespaceReplicationQueueScope = "NamespaceReplicationQueue"
	// PersistenceEnqueueMessageScope tracks Enqueue calls made by service to persistence layer
	PersistenceEnqueueMessageScope = "EnqueueMessage"
	// PersistenceEnqueueMessageToDLQScope tracks Enqueue DLQ calls made by service to persistence layer
	PersistenceEnqueueMessageToDLQScope = "EnqueueMessageToDLQ"
	// PersistenceReadQueueMessagesScope tracks ReadMessages calls made by service to persistence layer
	PersistenceReadQueueMessagesScope = "ReadQueueMessages"
	// PersistenceReadMessagesFromDLQScope tracks ReadMessagesFromDLQ calls made by service to persistence layer
	PersistenceReadMessagesFromDLQScope = "ReadMessagesFromDLQ"
	// PersistenceDeleteMessagesBeforeScope tracks DeleteMessagesBefore calls made by service to persistence layer
	PersistenceDeleteMessagesBeforeScope = "DeleteMessagesBefore"
	// PersistenceDeleteMessageFromDLQScope tracks DeleteMessageFromDLQ calls made by service to persistence layer
	PersistenceDeleteMessageFromDLQScope = "DeleteMessageFromDLQ"
	// PersistenceRangeDeleteMessagesFromDLQScope tracks RangeDeleteMessagesFromDLQ calls made by service to persistence layer
	PersistenceRangeDeleteMessagesFromDLQScope = "RangeDeleteMessagesFromDLQ"
	// PersistenceUpdateAckLevelScope tracks UpdateAckLevel calls made by service to persistence layer
	PersistenceUpdateAckLevelScope = "UpdateAckLevel"
	// PersistenceGetAckLevelScope tracks GetAckLevel calls made by service to persistence layer
	PersistenceGetAckLevelScope = "GetAckLevel"
	// PersistenceUpdateDLQAckLevelScope tracks UpdateDLQAckLevel calls made by service to persistence layer
	PersistenceUpdateDLQAckLevelScope = "UpdateDLQAckLevel"
	// PersistenceGetDLQAckLevelScope tracks GetDLQAckLevel calls made by service to persistence layer
	PersistenceGetDLQAckLevelScope = "GetDLQAckLevel"
	// PersistenceListClusterMetadataScope tracks ListClusterMetadata calls made by service to persistence layer
	PersistenceListClusterMetadataScope = "ListClusterMetadata"
	// PersistenceGetClusterMetadataScope tracks GetClusterMetadata calls made by service to persistence layer
	PersistenceGetClusterMetadataScope = "GetClusterMetadata"
	// PersistenceGetCurrentClusterMetadataScope tracks GetCurrentClusterMetadata calls made by service to persistence layer
	PersistenceGetCurrentClusterMetadataScope = "GetCurrentClusterMetadata"
	// PersistenceSaveClusterMetadataScope tracks SaveClusterMetadata calls made by service to persistence layer
	PersistenceSaveClusterMetadataScope = "SaveClusterMetadata"
	// PersistenceDeleteClusterMetadataScope tracks DeleteClusterMetadata calls made by service to persistence layer
	PersistenceDeleteClusterMetadataScope = "DeleteClusterMetadata"
	// PersistenceUpsertClusterMembershipScope tracks UpsertClusterMembership calls made by service to persistence layer
	PersistenceUpsertClusterMembershipScope = "UpsertClusterMembership"
	// PersistencePruneClusterMembershipScope tracks PruneClusterMembership calls made by service to persistence layer
	PersistencePruneClusterMembershipScope = "PruneClusterMembership"
	// PersistenceGetClusterMembersScope tracks GetClusterMembers calls made by service to persistence layer
	PersistenceGetClusterMembersScope = "GetClusterMembers"
	// PersistenceGetOrCreateShardScope tracks GetOrCreateShard calls made by service to persistence layer
	PersistenceGetOrCreateShardScope = "GetOrCreateShard"
	// PersistenceUpdateShardScope tracks UpdateShard calls made by service to persistence layer
	PersistenceUpdateShardScope = "UpdateShard"
	// PersistenceAssertShardOwnershipScope tracks UpdateShard calls made by service to persistence layer
	PersistenceAssertShardOwnershipScope = "AssertShardOwnership"
	// PersistenceCreateWorkflowExecutionScope tracks CreateWorkflowExecution calls made by service to persistence layer
	PersistenceCreateWorkflowExecutionScope = "CreateWorkflowExecution"
	// PersistenceGetWorkflowExecutionScope tracks GetWorkflowExecution calls made by service to persistence layer
	PersistenceGetWorkflowExecutionScope = "GetWorkflowExecution"
	// PersistenceSetWorkflowExecutionScope tracks SetWorkflowExecution calls made by service to persistence layer
	PersistenceSetWorkflowExecutionScope = "SetWorkflowExecution"
	// PersistenceUpdateWorkflowExecutionScope tracks UpdateWorkflowExecution calls made by service to persistence layer
	PersistenceUpdateWorkflowExecutionScope = "UpdateWorkflowExecution"
	// PersistenceConflictResolveWorkflowExecutionScope tracks ConflictResolveWorkflowExecution calls made by service to persistence layer
	PersistenceConflictResolveWorkflowExecutionScope = "ConflictResolveWorkflowExecution"
	// PersistenceResetWorkflowExecutionScope tracks ResetWorkflowExecution calls made by service to persistence layer
	PersistenceResetWorkflowExecutionScope = "ResetWorkflowExecution"
	// PersistenceDeleteWorkflowExecutionScope tracks DeleteWorkflowExecution calls made by service to persistence layer
	PersistenceDeleteWorkflowExecutionScope = "DeleteWorkflowExecution"
	// PersistenceDeleteCurrentWorkflowExecutionScope tracks DeleteCurrentWorkflowExecution calls made by service to persistence layer
	PersistenceDeleteCurrentWorkflowExecutionScope = "DeleteCurrentWorkflowExecution"
	// PersistenceGetCurrentExecutionScope tracks GetCurrentExecution calls made by service to persistence layer
	PersistenceGetCurrentExecutionScope = "GetCurrentExecution"
	// PersistenceListConcreteExecutionsScope tracks ListConcreteExecutions calls made by service to persistence layer
	PersistenceListConcreteExecutionsScope = "ListConcreteExecutions"
	// PersistenceAddTasksScope tracks AddTasks calls made by service to persistence layer
	PersistenceAddTasksScope = "AddTasks"
	// PersistenceGetTransferTasksScope tracks GetTransferTasks calls made by service to persistence layer
	PersistenceGetTransferTasksScope = "GetTransferTasks"
	// PersistenceCompleteTransferTaskScope tracks CompleteTransferTasks calls made by service to persistence layer
	PersistenceCompleteTransferTaskScope = "CompleteTransferTask"
	// PersistenceRangeCompleteTransferTasksScope tracks CompleteTransferTasks calls made by service to persistence layer
	PersistenceRangeCompleteTransferTasksScope = "RangeCompleteTransferTasks"
	// PersistenceGetVisibilityTasksScope tracks GetVisibilityTasks calls made by service to persistence layer
	PersistenceGetVisibilityTasksScope = "GetVisibilityTasks"
	// PersistenceCompleteVisibilityTaskScope tracks CompleteVisibilityTasks calls made by service to persistence layer
	PersistenceCompleteVisibilityTaskScope = "CompleteVisibilityTask"
	// PersistenceRangeCompleteVisibilityTasksScope tracks CompleteVisibilityTasks calls made by service to persistence layer
	PersistenceRangeCompleteVisibilityTasksScope = "RangeCompleteVisibilityTasks"
	// PersistenceGetReplicationTaskScope tracks GetReplicationTask calls made by service to persistence layer
	PersistenceGetArchivalTasksScope = "GetArchivalTasks"
	// PersistenceCompleteArchivalTaskScope tracks CompleteArchivalTasks calls made by service to persistence layer
	PersistenceCompleteArchivalTaskScope = "CompleteArchivalTask"
	// PersistenceRangeCompleteArchivalTasksScope tracks CompleteArchivalTasks calls made by service to persistence layer
	PersistenceRangeCompleteArchivalTasksScope = "RangeCompleteArchivalTasks"
	// PersistenceGetReplicationTasksScope tracks GetReplicationTasks calls made by service to persistence layer
	PersistenceGetReplicationTasksScope = "GetReplicationTasks"
	// PersistenceCompleteReplicationTaskScope tracks CompleteReplicationTasks calls made by service to persistence layer
	PersistenceCompleteReplicationTaskScope = "CompleteReplicationTask"
	// PersistenceRangeCompleteReplicationTasksScope tracks RangeCompleteReplicationTasks calls made by service to persistence layer
	PersistenceRangeCompleteReplicationTasksScope = "RangeCompleteReplicationTasks"
	// PersistencePutReplicationTaskToDLQScope tracks PersistencePutReplicationTaskToDLQScope calls made by service to persistence layer
	PersistencePutReplicationTaskToDLQScope = "PutReplicationTaskToDLQ"
	// PersistenceGetReplicationTasksFromDLQScope tracks PersistenceGetReplicationTasksFromDLQScope calls made by service to persistence layer
	PersistenceGetReplicationTasksFromDLQScope = "GetReplicationTasksFromDLQ"
	// PersistenceDeleteReplicationTaskFromDLQScope tracks PersistenceDeleteReplicationTaskFromDLQScope calls made by service to persistence layer
	PersistenceDeleteReplicationTaskFromDLQScope = "DeleteReplicationTaskFromDLQ"
	// PersistenceRangeDeleteReplicationTaskFromDLQScope tracks PersistenceRangeDeleteReplicationTaskFromDLQScope calls made by service to persistence layer
	PersistenceRangeDeleteReplicationTaskFromDLQScope = "RangeDeleteReplicationTaskFromDLQ"
	// PersistenceGetTimerTasksScope tracks GetTimerTasks calls made by service to persistence layer
	PersistenceGetTimerTasksScope = "GetTimerTasks"
	// PersistenceCompleteTimerTaskScope tracks CompleteTimerTasks calls made by service to persistence layer
	PersistenceCompleteTimerTaskScope = "CompleteTimerTask"
	// PersistenceRangeCompleteTimerTasksScope tracks CompleteTimerTasks calls made by service to persistence layer
	PersistenceRangeCompleteTimerTasksScope = "RangeCompleteTimerTasks"
	// PersistenceCreateTasksScope tracks CreateTasks calls made by service to persistence layer
	PersistenceCreateTasksScope = "CreateTasks"
	// PersistenceGetTasksScope tracks GetTasks calls made by service to persistence layer
	PersistenceGetTasksScope = "GetTasks"
	// PersistenceCompleteTaskScope tracks CompleteTask calls made by service to persistence layer
	PersistenceCompleteTaskScope = "CompleteTask"
	// PersistenceCompleteTasksLessThanScope is the metric scope for persistence.TaskManager.PersistenceCompleteTasksLessThan API
	PersistenceCompleteTasksLessThanScope = "CompleteTasksLessThan"
	// PersistenceCreateTaskQueueScope tracks PersistenceCreateTaskQueueScope calls made by service to persistence layer
	PersistenceCreateTaskQueueScope = "CreateTaskQueue"
	// PersistenceUpdateTaskQueueScope tracks PersistenceUpdateTaskQueueScope calls made by service to persistence layer
	PersistenceUpdateTaskQueueScope = "UpdateTaskQueue"
	// PersistenceGetTaskQueueScope tracks PersistenceGetTaskQueueScope calls made by service to persistence layer
	PersistenceGetTaskQueueScope = "GetTaskQueue"
	// PersistenceListTaskQueueScope is the metric scope for persistence.TaskManager.ListTaskQueue API
	PersistenceListTaskQueueScope = "ListTaskQueue"
	// PersistenceDeleteTaskQueueScope is the metric scope for persistence.TaskManager.DeleteTaskQueue API
	PersistenceDeleteTaskQueueScope = "DeleteTaskQueue"
	// PersistenceGetTaskQueueUserDataScope is the metric scope for persistence.TaskManager.GetTaskQueueUserData API
	PersistenceGetTaskQueueUserDataScope = "GetTaskQueueUserData"
	// PersistenceUpdateTaskQueueUserDataScope is the metric scope for persistence.TaskManager.UpdateTaskQueueUserData API
	PersistenceUpdateTaskQueueUserDataScope = "UpdateTaskQueueUserData"
	// PersistenceListTaskQueueUserDataEntriesScope is the metric scope for persistence.TaskManager.ListTaskQueueUserDataEntries API
	PersistenceListTaskQueueUserDataEntriesScope = "ListTaskQueueUserDataEntries"
	// PersistenceGetTaskQueuesByBuildIdScope is the metric scope for persistence.TaskManager.GetTaskQueuesByBuildId API
	PersistenceGetTaskQueuesByBuildIdScope = "GetTaskQueuesByBuildId"
	// PersistenceCountTaskQueuesByBuildIdScope is the metric scope for persistence.TaskManager.CountTaskQueuesByBuildId API
	PersistenceCountTaskQueuesByBuildIdScope = "CountTaskQueuesByBuildId"
	// PersistenceAppendHistoryEventsScope tracks AppendHistoryEvents calls made by service to persistence layer
	PersistenceAppendHistoryEventsScope = "AppendHistoryEvents"
	// PersistenceGetWorkflowExecutionHistoryScope tracks GetWorkflowExecutionHistory calls made by service to persistence layer
	PersistenceGetWorkflowExecutionHistoryScope = "GetWorkflowExecutionHistory"
	// PersistenceDeleteWorkflowExecutionHistoryScope tracks DeleteWorkflowExecutionHistory calls made by service to persistence layer
	PersistenceDeleteWorkflowExecutionHistoryScope = "DeleteWorkflowExecutionHistory"
	// PersistenceInitializeSystemNamespaceScope tracks InitializeSystemNamespaceScope calls made by service to persistence layer
	PersistenceInitializeSystemNamespaceScope = "InitializeSystemNamespace"
	// PersistenceCreateNamespaceScope tracks CreateNamespace calls made by service to persistence layer
	PersistenceCreateNamespaceScope = "CreateNamespace"
	// PersistenceGetNamespaceScope tracks GetNamespace calls made by service to persistence layer
	PersistenceGetNamespaceScope = "GetNamespace"
	// PersistenceUpdateNamespaceScope tracks UpdateNamespace calls made by service to persistence layer
	PersistenceUpdateNamespaceScope = "UpdateNamespace"
	// PersistenceDeleteNamespaceScope tracks DeleteNamespace calls made by service to persistence layer
	PersistenceDeleteNamespaceScope = "DeleteNamespace"
	// PersistenceRenameNamespaceScope tracks RenameNamespace calls made by service to persistence layer
	PersistenceRenameNamespaceScope = "RenameNamespace"
	// PersistenceDeleteNamespaceByNameScope tracks DeleteNamespaceByName calls made by service to persistence layer
	PersistenceDeleteNamespaceByNameScope = "DeleteNamespaceByName"
	// PersistenceListNamespacesScope tracks ListNamespaces calls made by service to persistence layer
	PersistenceListNamespacesScope = "ListNamespaces"
	// PersistenceGetMetadataScope tracks DeleteNamespaceByName calls made by service to persistence layer
	PersistenceGetMetadataScope = "GetMetadata"

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

const (
	ServerTlsScope = "ServerTls"
	// AuthorizationScope is the scope used by all metric emitted by authorization code
	AuthorizationScope = "Authorization"
	// NamespaceCacheScope tracks namespace cache callbacks
	NamespaceCacheScope = "NamespaceCache"
)

Common

const (
	// AdminGetWorkflowExecutionRawHistoryV2Scope is the metric scope for admin.GetWorkflowExecutionRawHistoryScope
	AdminGetWorkflowExecutionRawHistoryV2Scope = "AdminGetWorkflowExecutionRawHistoryV2"

	// OperatorAddSearchAttributesScope is the metric scope for operator.AddSearchAttributes
	OperatorAddSearchAttributesScope = "OperatorAddSearchAttributes"
	// OperatorDeleteNamespaceScope is the metric scope for operator.OperatorDeleteNamespace
	OperatorDeleteNamespaceScope = "OperatorDeleteNamespace"

	// FrontendPollWorkflowTaskQueueScope is the metric scope for frontend.PollWorkflowTaskQueue
	FrontendPollWorkflowTaskQueueScope = "PollWorkflowTaskQueue"
	// FrontendRespondWorkflowTaskFailedScope is the metric scope for frontend.RespondWorkflowTaskFailed
	FrontendRespondWorkflowTaskFailedScope = "RespondWorkflowTaskFailed"
	// FrontendRespondQueryTaskCompletedScope is the metric scope for frontend.RespondQueryTaskCompleted
	FrontendRespondQueryTaskCompletedScope = "RespondQueryTaskCompleted"
	// FrontendRespondActivityTaskCompletedScope is the metric scope for frontend.RespondActivityTaskCompleted
	FrontendRespondActivityTaskCompletedScope = "RespondActivityTaskCompleted"
	// FrontendRespondActivityTaskFailedScope is the metric scope for frontend.RespondActivityTaskFailed
	FrontendRespondActivityTaskFailedScope = "RespondActivityTaskFailed"
	// FrontendRespondActivityTaskCanceledScope is the metric scope for frontend.RespondActivityTaskCanceled
	FrontendRespondActivityTaskCanceledScope = "RespondActivityTaskCanceled"
	// FrontendRespondActivityTaskCompletedByIdScope is the metric scope for frontend.RespondActivityTaskCompletedById
	FrontendRespondActivityTaskCompletedByIdScope = "RespondActivityTaskCompletedById"
	// FrontendRespondActivityTaskFailedByIdScope is the metric scope for frontend.RespondActivityTaskFailedById
	FrontendRespondActivityTaskFailedByIdScope = "RespondActivityTaskFailedById"
	// FrontendRespondActivityTaskCanceledByIdScope is the metric scope for frontend.RespondActivityTaskCanceledById
	FrontendRespondActivityTaskCanceledByIdScope = "RespondActivityTaskCanceledById"
	// FrontendGetWorkflowExecutionHistoryScope is the metric scope for non-long-poll frontend.GetWorkflowExecutionHistory
	FrontendGetWorkflowExecutionHistoryScope = "GetWorkflowExecutionHistory"
	// FrontendGetWorkflowExecutionHistoryReverseScope is the metric for frontend.GetWorkflowExecutionHistoryReverse
	FrontendGetWorkflowExecutionHistoryReverseScope = "GetWorkflowExecutionHistoryReverse"
	// FrontendPollWorkflowExecutionHistoryScope is the metric scope for long poll case of frontend.GetWorkflowExecutionHistory
	FrontendPollWorkflowExecutionHistoryScope = "PollWorkflowExecutionHistory"
	// FrontendGetWorkflowExecutionRawHistoryScope is the metric scope for frontend.GetWorkflowExecutionRawHistory
	FrontendGetWorkflowExecutionRawHistoryScope = "GetWorkflowExecutionRawHistory"
	// FrontendPollForWorkflowExecutionRawHistoryScope is the metric scope for frontend.GetWorkflowExecutionRawHistory
	FrontendPollForWorkflowExecutionRawHistoryScope = "PollForWorkflowExecutionRawHistory"
	// FrontendTerminateWorkflowExecutionScope is the metric scope for frontend.TerminateWorkflowExecution
	FrontendTerminateWorkflowExecutionScope = "TerminateWorkflowExecution"
	// FrontendDeleteWorkflowExecutionScope is the metric scope for frontend.DeleteWorkflowExecution
	FrontendDeleteWorkflowExecutionScope = "DeleteWorkflowExecution"
	// FrontendRequestCancelWorkflowExecutionScope is the metric scope for frontend.RequestCancelWorkflowExecution
	FrontendRequestCancelWorkflowExecutionScope = "RequestCancelWorkflowExecution"
	// FrontendListArchivedWorkflowExecutionsScope is the metric scope for frontend.ListArchivedWorkflowExecutions
	FrontendListArchivedWorkflowExecutionsScope = "ListArchivedWorkflowExecutions"
	// FrontendListOpenWorkflowExecutionsScope is the metric scope for frontend.ListOpenWorkflowExecutions
	FrontendListOpenWorkflowExecutionsScope = "ListOpenWorkflowExecutions"
	// FrontendListClosedWorkflowExecutionsScope is the metric scope for frontend.ListClosedWorkflowExecutions
	FrontendListClosedWorkflowExecutionsScope = "ListClosedWorkflowExecutions"
	// FrontendListWorkflowExecutionsScope is the metric scope for frontend.ListWorkflowExecutions
	FrontendListWorkflowExecutionsScope = "ListWorkflowExecutions"
	// FrontendScanWorkflowExecutionsScope is the metric scope for frontend.ListWorkflowExecutions
	FrontendScanWorkflowExecutionsScope = "ScanWorkflowExecutions"
	// FrontendCountWorkflowExecutionsScope is the metric scope for frontend.CountWorkflowExecutions
	FrontendCountWorkflowExecutionsScope = "CountWorkflowExecutions"
	// FrontendRegisterNamespaceScope is the metric scope for frontend.RegisterNamespace
	FrontendRegisterNamespaceScope = "RegisterNamespace"
	// FrontendDescribeNamespaceScope is the metric scope for frontend.DescribeNamespace
	FrontendDescribeNamespaceScope = "DescribeNamespace"
	// FrontendUpdateNamespaceScope is the metric scope for frontend.DescribeNamespace
	FrontendUpdateNamespaceScope = "UpdateNamespace"
	// FrontendDeprecateNamespaceScope is the metric scope for frontend.DeprecateNamespace
	FrontendDeprecateNamespaceScope = "DeprecateNamespace"
	// FrontendDescribeWorkflowExecutionScope is the metric scope for frontend.DescribeWorkflowExecution
	FrontendDescribeWorkflowExecutionScope = "DescribeWorkflowExecution"
	// FrontendDescribeTaskQueueScope is the metric scope for frontend.DescribeTaskQueue
	FrontendDescribeTaskQueueScope = "DescribeTaskQueue"
	// FrontendListTaskQueuePartitionsScope is the metric scope for frontend.ResetStickyTaskQueue
	FrontendListTaskQueuePartitionsScope = "ListTaskQueuePartitions"
	// FrontendResetStickyTaskQueueScope is the metric scope for frontend.ResetStickyTaskQueue
	FrontendResetStickyTaskQueueScope = "ResetStickyTaskQueue"
	// FrontendListNamespacesScope is the metric scope for frontend.ListNamespace
	FrontendListNamespacesScope = "ListNamespaces"
	// FrontendGetSearchAttributesScope is the metric scope for frontend.GetSearchAttributes
	FrontendGetSearchAttributesScope = "GetSearchAttributes"
	// FrontendGetClusterInfoScope is the metric scope for frontend.GetClusterInfo
	FrontendGetClusterInfoScope = "GetClusterInfo"
	// FrontendGetSystemInfoScope is the metric scope for frontend.GetSystemInfo
	FrontendGetSystemInfoScope = "GetSystemInfo"
	// FrontendCreateScheduleScope is the metric scope for frontend.CreateScheduleScope = "CreateScheduleScope is the metric scope for frontend.CreateSchedule"
	FrontendCreateScheduleScope = "CreateSchedule"
	// FrontendDescribeScheduleScope is the metric scope for frontend.DescribeScheduleScope = "DescribeScheduleScope is the metric scope for frontend.DescribeSchedule"
	FrontendDescribeScheduleScope = "DescribeSchedule"
	// FrontendUpdateScheduleScope is the metric scope for frontend.UpdateScheduleScope = "UpdateScheduleScope is the metric scope for frontend.UpdateSchedule"
	FrontendUpdateScheduleScope = "UpdateSchedule"
	// FrontendPatchScheduleScope is the metric scope for frontend.PatchScheduleScope = "PatchScheduleScope is the metric scope for frontend.PatchSchedule"
	FrontendPatchScheduleScope = "PatchSchedule"
	// FrontendListScheduleMatchingTimesScope is the metric scope for frontend.ListScheduleMatchingTimesScope = "ListScheduleMatchingTimesScope is the metric scope for frontend.ListScheduleMatchingTimes"
	FrontendListScheduleMatchingTimesScope = "ListScheduleMatchingTimes"
	// FrontendDeleteScheduleScope is the metric scope for frontend.DeleteScheduleScope = "DeleteScheduleScope is the metric scope for frontend.DeleteSchedule"
	FrontendDeleteScheduleScope = "DeleteSchedule"
	// FrontendListSchedulesScope is the metric scope for frontend.ListSchedulesScope = "ListSchedulesScope is the metric scope for frontend.ListSchedules"
	FrontendListSchedulesScope = "ListSchedules"
	// FrontendUpdateWorkerBuildIdCompatibilityScope is the metric scope for frontend.UpdateWorkerBuildIdCompatibilityScope = "UpdateWorkerBuildIdCompatibilityScope is the metric scope for frontend.UpdateWorkerBuildIdCompatibility"
	FrontendUpdateWorkerBuildIdCompatibilityScope = "UpdateWorkerBuildIdCompatibility"
	// FrontendGetWorkerBuildIdCompatibilityScope is the metric scope for frontend.GetWorkerBuildIdCompatibilityScope = "GetWorkerBuildIdCompatibilityScope is the metric scope for frontend.GetWorkerBuildIdCompatibility"
	FrontendGetWorkerBuildIdCompatibilityScope = "GetWorkerBuildIdCompatibility"
	// FrontendUpdateWorkflowExecutionScope is the metric scope for frontend.UpdateWorkflowExecution
	FrontendUpdateWorkflowExecutionScope = "UpdateWorkflowExecution"
	// FrontendDescribeBatchOperationScope is the metric scope for frontend.DescribeBatchOperation
	FrontendDescribeBatchOperationScope = "DescribeBatchOperation"
	// FrontendListBatchOperationsScope is the metric scope for frontend.ListBatchOperations
	FrontendListBatchOperationsScope = "ListBatchOperations"
	// FrontendStartBatchOperationScope is the metric scope for frontend.StartBatchOperation
	FrontendStartBatchOperationScope = "StartBatchOperation"
	// FrontendStopBatchOperationScope is the metric scope for frontend.StopBatchOperation
	FrontendStopBatchOperationScope = "StopBatchOperation"
	// VersionCheckScope is scope used by version checker
	VersionCheckScope = "VersionCheck"
)

Frontend Scope

const (
	// HistoryStartWorkflowExecutionScope tracks StartWorkflowExecution API calls received by service
	HistoryStartWorkflowExecutionScope = "StartWorkflowExecution"
	// HistoryRecordActivityTaskHeartbeatScope tracks RecordActivityTaskHeartbeat API calls received by service
	HistoryRecordActivityTaskHeartbeatScope = "RecordActivityTaskHeartbeat"
	// HistoryRespondWorkflowTaskCompletedScope tracks RespondWorkflowTaskCompleted API calls received by service
	HistoryRespondWorkflowTaskCompletedScope = "RespondWorkflowTaskCompleted"
	// HistoryRespondWorkflowTaskFailedScope tracks RespondWorkflowTaskFailed API calls received by service
	HistoryRespondWorkflowTaskFailedScope = "RespondWorkflowTaskFailed"
	// HistoryRespondActivityTaskCompletedScope tracks RespondActivityTaskCompleted API calls received by service
	HistoryRespondActivityTaskCompletedScope = "RespondActivityTaskCompleted"
	// HistoryRespondActivityTaskFailedScope tracks RespondActivityTaskFailed API calls received by service
	HistoryRespondActivityTaskFailedScope = "RespondActivityTaskFailed"
	// HistoryRespondActivityTaskCanceledScope tracks RespondActivityTaskCanceled API calls received by service
	HistoryRespondActivityTaskCanceledScope = "RespondActivityTaskCanceled"
	// HistoryGetMutableStateScope tracks GetMutableStateScope API calls received by service
	HistoryGetMutableStateScope = "GetMutableState"
	// HistoryPollMutableStateScope tracks PollMutableStateScope API calls received by service
	HistoryPollMutableStateScope = "PollMutableState"
	// HistoryResetStickyTaskQueueScope tracks ResetStickyTaskQueueScope API calls received by service
	HistoryResetStickyTaskQueueScope = "ResetStickyTaskQueue"
	// HistoryDescribeWorkflowExecutionScope tracks DescribeWorkflowExecution API calls received by service
	HistoryDescribeWorkflowExecutionScope = "DescribeWorkflowExecution"
	// HistoryRecordWorkflowTaskStartedScope tracks RecordWorkflowTaskStarted API calls received by service
	HistoryRecordWorkflowTaskStartedScope = "RecordWorkflowTaskStarted"
	// HistoryRecordActivityTaskStartedScope tracks RecordActivityTaskStarted API calls received by service
	HistoryRecordActivityTaskStartedScope = "RecordActivityTaskStarted"
	// HistorySignalWorkflowExecutionScope tracks SignalWorkflowExecution API calls received by service
	HistorySignalWorkflowExecutionScope = "SignalWorkflowExecution"
	// HistorySignalWithStartWorkflowExecutionScope tracks SignalWithStartWorkflowExecution API calls received by service
	HistorySignalWithStartWorkflowExecutionScope = "SignalWithStartWorkflowExecution"
	// HistoryRemoveSignalMutableStateScope tracks RemoveSignalMutableState API calls received by service
	HistoryRemoveSignalMutableStateScope = "RemoveSignalMutableState"
	// HistoryTerminateWorkflowExecutionScope tracks TerminateWorkflowExecution API calls received by service
	HistoryTerminateWorkflowExecutionScope = "TerminateWorkflowExecution"
	// HistoryScheduleWorkflowTaskScope tracks ScheduleWorkflowTask API calls received by service
	HistoryScheduleWorkflowTaskScope = "ScheduleWorkflowTask"
	// HistoryVerifyFirstWorkflowTaskScheduled tracks VerifyFirstWorkflowTaskScheduled API calls received by service
	HistoryVerifyFirstWorkflowTaskScheduledScope = "VerifyFirstWorkflowTaskScheduled"
	// HistoryRecordChildExecutionCompletedScope tracks RecordChildExecutionCompleted API calls received by service
	HistoryRecordChildExecutionCompletedScope = "RecordChildExecutionCompleted"
	// HistoryVerifyChildExecutionCompletionRecordedScope tracks VerifyChildExecutionCompletionRecorded API calls received by service
	HistoryVerifyChildExecutionCompletionRecordedScope = "VerifyChildExecutionCompletionRecorded"
	// HistoryRequestCancelWorkflowExecutionScope tracks RequestCancelWorkflowExecution API calls received by service
	HistoryRequestCancelWorkflowExecutionScope = "RequestCancelWorkflowExecution"
	// HistorySyncShardStatusScope tracks HistorySyncShardStatus API calls received by service
	HistorySyncShardStatusScope = "SyncShardStatus"
	// HistorySyncActivityScope tracks HistoryActivity API calls received by service
	HistorySyncActivityScope = "SyncActivity"
	// HistoryRebuildMutableStateScope tracks RebuildMutable API calls received by service
	HistoryRebuildMutableStateScope = "RebuildMutableState"
	// HistoryDescribeMutableStateScope tracks DescribeMutableState API calls received by service
	HistoryDescribeMutableStateScope = "DescribeMutableState"
	// HistoryGetReplicationMessagesScope tracks GetReplicationMessages API calls received by service
	HistoryGetReplicationMessagesScope = "GetReplicationMessages"
	// HistoryGetDLQReplicationMessagesScope tracks GetReplicationMessages API calls received by service
	HistoryGetDLQReplicationMessagesScope = "GetDLQReplicationMessages"
	// HistoryReadDLQMessagesScope tracks GetDLQMessages API calls received by service
	HistoryReadDLQMessagesScope = "ReadDLQMessages"
	// HistoryPurgeDLQMessagesScope tracks PurgeDLQMessages API calls received by service
	HistoryPurgeDLQMessagesScope = "PurgeDLQMessages"
	// HistoryMergeDLQMessagesScope tracks MergeDLQMessages API calls received by service
	HistoryMergeDLQMessagesScope = "MergeDLQMessages"
	// HistoryShardControllerScope is the scope used by shard controller
	HistoryShardControllerScope = "ShardController"
	// HistoryReapplyEventsScope is the scope used by event reapplication
	HistoryReapplyEventsScope = "ReapplyEvents"
	// HistoryRefreshWorkflowTasksScope is the scope used by refresh workflow tasks API
	HistoryRefreshWorkflowTasksScope = "RefreshWorkflowTasks"
	// HistoryGenerateLastHistoryReplicationTasksScope is the scope used by generate last replication tasks API
	HistoryGenerateLastHistoryReplicationTasksScope = "GenerateLastHistoryReplicationTasks"
	// HistoryGetReplicationStatusScope is the scope used by GetReplicationStatus API
	HistoryGetReplicationStatusScope = "GetReplicationStatus"
	// HistoryHistoryRemoveTaskScope is the scope used by remove task API
	HistoryHistoryRemoveTaskScope = "HistoryRemoveTask"
	// HistoryCloseShard is the scope used by close shard API
	HistoryCloseShardScope = "CloseShard"
	// HistoryGetShard is the scope used by get shard API
	HistoryGetShardScope = "GetShard"
	// HistoryReplicateEventsV2 is the scope used by replicate events API
	HistoryReplicateEventsV2Scope = "ReplicateEventsV2"
	// HistoryDescribeHistoryHost is the scope used by describe history host API
	HistoryDescribeHistoryHostScope = "DescribeHistoryHost"
	// HistoryDeleteWorkflowVisibilityRecordScope is the scope used by delete workflow visibility record API
	HistoryDeleteWorkflowVisibilityRecordScope = "DeleteWorkflowVisibilityRecord"
	// HistoryUpdateWorkflowExecutionScope is the scope used by update workflow execution API
	HistoryUpdateWorkflowExecutionScope = "UpdateWorkflowExecution"
	// HistoryResetWorkflowExecutionScope tracks ResetWorkflowExecution API calls received by service
	HistoryResetWorkflowExecutionScope = "ResetWorkflowExecution"
	// HistoryQueryWorkflowScope tracks QueryWorkflow API calls received by service
	HistoryQueryWorkflowScope = "QueryWorkflow"
	// HistoryProcessDeleteHistoryEventScope tracks ProcessDeleteHistoryEvent processing calls
	HistoryProcessDeleteHistoryEventScope = "ProcessDeleteHistoryEvent"
	// HistoryDeleteWorkflowExecutionScope tracks DeleteWorkflowExecutions API calls
	HistoryDeleteWorkflowExecutionScope = "DeleteWorkflowExecution"
	// HistoryCacheGetOrCreateScope is the scope used by history cache
	HistoryCacheGetOrCreateScope = "HistoryCacheGetOrCreate"
	// HistoryCacheGetOrCreateCurrentScope is the scope used by history cache
	HistoryCacheGetOrCreateCurrentScope = "CacheGetOrCreateCurrent"
	// TaskPriorityAssignerScope is the scope used by all metric emitted by task priority assigner
	TaskPriorityAssignerScope = "TaskPriorityAssigner"
	// TransferQueueProcessorScope is the scope used by all metric emitted by transfer queue processor
	TransferQueueProcessorScope = "TransferQueueProcessor"
	// TransferActiveQueueProcessorScope is the scope used by all metric emitted by transfer queue processor
	TransferActiveQueueProcessorScope = "TransferActiveQueueProcessor"
	// TransferStandbyQueueProcessorScope is the scope used by all metric emitted by transfer queue processor
	TransferStandbyQueueProcessorScope = "TransferStandbyQueueProcessor"
	// TransferActiveTaskActivityScope is the scope used for activity task processing by transfer queue processor
	TransferActiveTaskActivityScope = "TransferActiveTaskActivity"
	// TransferActiveTaskWorkflowTaskScope is the scope used for workflow task processing by transfer queue processor
	TransferActiveTaskWorkflowTaskScope = "TransferActiveTaskWorkflowTask"
	// TransferActiveTaskCloseExecutionScope is the scope used for close execution task processing by transfer queue processor
	TransferActiveTaskCloseExecutionScope = "TransferActiveTaskCloseExecution"
	// TransferActiveTaskCancelExecutionScope is the scope used for cancel execution task processing by transfer queue processor
	TransferActiveTaskCancelExecutionScope = "TransferActiveTaskCancelExecution"
	// TransferActiveTaskSignalExecutionScope is the scope used for signal execution task processing by transfer queue processor
	TransferActiveTaskSignalExecutionScope = "TransferActiveTaskSignalExecution"
	// TransferActiveTaskStartChildExecutionScope is the scope used for start child execution task processing by transfer queue processor
	TransferActiveTaskStartChildExecutionScope = "TransferActiveTaskStartChildExecution"
	// TransferActiveTaskResetWorkflowScope is the scope used for record workflow started task processing by transfer queue processor
	TransferActiveTaskResetWorkflowScope = "TransferActiveTaskResetWorkflow"
	// TransferStandbyTaskResetWorkflowScope is the scope used for record workflow started task processing by transfer queue processor
	TransferStandbyTaskResetWorkflowScope = "TransferStandbyTaskResetWorkflow"
	// TransferStandbyTaskActivityScope is the scope used for activity task processing by transfer queue processor
	TransferStandbyTaskActivityScope = "TransferStandbyTaskActivity"
	// TransferStandbyTaskWorkflowTaskScope is the scope used for workflow task processing by transfer queue processor
	TransferStandbyTaskWorkflowTaskScope = "TransferStandbyTaskWorkflowTask"
	// TransferStandbyTaskCloseExecutionScope is the scope used for close execution task processing by transfer queue processor
	TransferStandbyTaskCloseExecutionScope = "TransferStandbyTaskCloseExecution"
	// TransferStandbyTaskCancelExecutionScope is the scope used for cancel execution task processing by transfer queue processor
	TransferStandbyTaskCancelExecutionScope = "TransferStandbyTaskCancelExecution"
	// TransferStandbyTaskSignalExecutionScope is the scope used for signal execution task processing by transfer queue processor
	TransferStandbyTaskSignalExecutionScope = "TransferStandbyTaskSignalExecution"
	// TransferStandbyTaskStartChildExecutionScope is the scope used for start child execution task processing by transfer queue processor
	TransferStandbyTaskStartChildExecutionScope = "TransferStandbyTaskStartChildExecution"

	// VisibilityQueueProcessorScope is the scope used by all metric emitted by visibility queue processor
	VisibilityQueueProcessorScope = "VisibilityQueueProcessor"
	// VisibilityTaskStartExecutionScope is the scope used for start execution processing by visibility queue processor
	VisibilityTaskStartExecutionScope = "VisibilityTaskStartExecution"
	// VisibilityTaskUpsertExecutionScope is the scope used for upsert execution processing by visibility queue processor
	VisibilityTaskUpsertExecutionScope = "VisibilityTaskUpsertExecution"
	// VisibilityTaskCloseExecutionScope is the scope used for close execution attributes processing by visibility queue processor
	VisibilityTaskCloseExecutionScope = "VisibilityTaskCloseExecution"
	// VisibilityTaskDeleteExecutionScope is the scope used for delete by visibility queue processor
	VisibilityTaskDeleteExecutionScope = "VisibilityTaskDeleteExecution"

	// TimerQueueProcessorScope is the scope used by all metric emitted by timer queue processor
	TimerQueueProcessorScope = "TimerQueueProcessor"
	// TimerActiveQueueProcessorScope is the scope used by all metric emitted by timer queue processor
	TimerActiveQueueProcessorScope = "TimerActiveQueueProcessor"
	// TimerStandbyQueueProcessorScope is the scope used by all metric emitted by timer queue processor
	TimerStandbyQueueProcessorScope = "TimerStandbyQueueProcessor"
	// TimerActiveTaskActivityTimeoutScope is the scope used by metric emitted by timer queue processor for processing activity timeouts
	TimerActiveTaskActivityTimeoutScope = "TimerActiveTaskActivityTimeout"
	// TimerActiveTaskWorkflowTaskTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow task timeouts
	TimerActiveTaskWorkflowTaskTimeoutScope = "TimerActiveTaskWorkflowTaskTimeout"
	// TimerActiveTaskUserTimerScope is the scope used by metric emitted by timer queue processor for processing user timers
	TimerActiveTaskUserTimerScope = "TimerActiveTaskUserTimer"
	// TimerActiveTaskWorkflowTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow timeouts.
	TimerActiveTaskWorkflowTimeoutScope = "TimerActiveTaskWorkflowTimeout"
	// TimerActiveTaskActivityRetryTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
	TimerActiveTaskActivityRetryTimerScope = "TimerActiveTaskActivityRetryTimer"
	// TimerActiveTaskWorkflowBackoffTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
	TimerActiveTaskWorkflowBackoffTimerScope = "TimerActiveTaskWorkflowBackoffTimer"
	// TimerActiveTaskDeleteHistoryEventScope is the scope used by metric emitted by timer queue processor for processing history event cleanup
	TimerActiveTaskDeleteHistoryEventScope = "TimerActiveTaskDeleteHistoryEvent"
	// TimerStandbyTaskActivityTimeoutScope is the scope used by metric emitted by timer queue processor for processing activity timeouts
	TimerStandbyTaskActivityTimeoutScope = "TimerStandbyTaskActivityTimeout"
	// TimerStandbyTaskWorkflowTaskTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow task timeouts
	TimerStandbyTaskWorkflowTaskTimeoutScope = "TimerStandbyTaskWorkflowTaskTimeout"
	// TimerStandbyTaskUserTimerScope is the scope used by metric emitted by timer queue processor for processing user timers
	TimerStandbyTaskUserTimerScope = "TimerStandbyTaskUserTimer"
	// TimerStandbyTaskWorkflowTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow timeouts.
	TimerStandbyTaskWorkflowTimeoutScope = "TimerStandbyTaskWorkflowTimeout"
	// TimerStandbyTaskActivityRetryTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
	TimerStandbyTaskActivityRetryTimerScope = "TimerStandbyTaskActivityRetryTimer"
	// TimerStandbyTaskDeleteHistoryEventScope is the scope used by metric emitted by timer queue processor for processing history event cleanup
	TimerStandbyTaskDeleteHistoryEventScope = "TimerStandbyTaskDeleteHistoryEvent"
	// TimerStandbyTaskWorkflowBackoffTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
	TimerStandbyTaskWorkflowBackoffTimerScope = "TimerStandbyTaskWorkflowBackoffTimer"

	// ReplicatorQueueProcessorScope is the scope used by all metric emitted by replicator queue processor
	ReplicatorQueueProcessorScope = "ReplicatorQueueProcessor"
	// ReplicatorTaskHistoryScope is the scope used for history task processing by replicator queue processor
	ReplicatorTaskHistoryScope = "ReplicatorTaskHistory"
	// ReplicatorTaskSyncActivityScope is the scope used for sync activity by replicator queue processor
	ReplicatorTaskSyncActivityScope = "ReplicatorTaskSyncActivity"
	// ReplicateHistoryEventsScope is the scope used by historyReplicator API for applying events
	ReplicateHistoryEventsScope = "ReplicateHistoryEvents"
	// HistoryRereplicationByTransferTaskScope tracks history replication calls made by transfer task
	HistoryRereplicationByTransferTaskScope = "HistoryRereplicationByTransferTask"
	// HistoryRereplicationByTimerTaskScope tracks history replication calls made by timer task
	HistoryRereplicationByTimerTaskScope = "HistoryRereplicationByTimerTask"
	// HistoryRereplicationByHistoryReplicationScope tracks history replication calls made by history replication
	HistoryRereplicationByHistoryReplicationScope = "HistoryRereplicationByHistoryReplication"
	// HistoryRereplicationByHistoryMetadataReplicationScope tracks history replication calls made by history replication
	HistoryRereplicationByHistoryMetadataReplicationScope = "HistoryRereplicationByHistoryMetadataReplication"
	// HistoryRereplicationByActivityReplicationScope tracks history replication calls made by activity replication
	HistoryRereplicationByActivityReplicationScope = "HistoryRereplicationByActivityReplication"

	// ShardInfoScope is the scope used when updating shard info
	ShardInfoScope = "ShardInfo"
	// WorkflowContextScope is the scope used by WorkflowContext component
	WorkflowContextScope = "WorkflowContext"
	// ExecutionStatsScope is the scope used for emiting workflow execution related stats
	ExecutionStatsScope = "ExecutionStats"
	// SessionStatsScope is the scope used for emiting session update related stats
	SessionStatsScope = "SessionStats"
	// WorkflowCompletionStatsScope tracks workflow completion updates
	WorkflowCompletionStatsScope = "CompletionStats"
	// ReplicationTaskFetcherScope is scope used by all metrics emitted by ReplicationTaskFetcher
	ReplicationTaskFetcherScope = "ReplicationTaskFetcher"
	// ReplicationTaskCleanupScope is scope used by all metrics emitted by ReplicationTaskProcessor cleanup
	ReplicationTaskCleanupScope = "ReplicationTaskCleanup"
	// ReplicationDLQStatsScope is scope used by all metrics emitted related to replication DLQ
	ReplicationDLQStatsScope = "ReplicationDLQStats"
	// EventsCacheGetEventScope is the scope used by events cache
	EventsCacheGetEventScope = "EventsCacheGetEvent"
	// EventsCachePutEventScope is the scope used by events cache
	EventsCachePutEventScope = "EventsCachePutEvent"
	// EventsCacheDeleteEventScope is the scope used by events cache
	EventsCacheDeleteEventScope = "EventsCacheDeleteEvent"
	// EventsCacheGetFromStoreScope is the scope used by events cache
	EventsCacheGetFromStoreScope = "EventsCacheGetFromStore"
	// HistoryEventNotificationScope is the scope used by shard history event notification
	HistoryEventNotificationScope = "HistoryEventNotification"
	// ArchiverClientScope is scope used by all metrics emitted by archiver.Client
	ArchiverClientScope = "ArchiverClient"
	// DeadlockDetectorScope is a scope for deadlock detector
	DeadlockDetectorScope = "DeadlockDetector"
	// OperationTimerQueueProcessorScope is a scope for timer queue base processor
	OperationTimerQueueProcessorScope = "TimerQueueProcessor"
	// OperationTimerActiveQueueProcessorScope is a scope for timer queue active processor
	OperationTimerActiveQueueProcessorScope = "TimerActiveQueueProcessor"
	// OperationTimerStandbyQueueProcessorScope is a scope for timer queue standby processor
	OperationTimerStandbyQueueProcessorScope = "TimerStandbyQueueProcessor"
	// OperationTransferQueueProcessorScope is a scope for transfer queue base processor
	OperationTransferQueueProcessorScope = "TransferQueueProcessor"
	// OperationTransferActiveQueueProcessorScope is a scope for transfer queue active processor
	OperationTransferActiveQueueProcessorScope = "TransferActiveQueueProcessor"
	// OperationTransferStandbyQueueProcessorScope is a scope for transfer queue standby processor
	OperationTransferStandbyQueueProcessorScope = "TransferStandbyQueueProcessor"
	// OperationVisibilityQueueProcessorScope is a scope for visibility queue processor
	OperationVisibilityQueueProcessorScope = "VisibilityQueueProcessor"
	// OperationArchivalQueueProcessorScope is a scope for archival queue processor
	OperationArchivalQueueProcessorScope = "ArchivalQueueProcessor"
	// OperationMemoryScheduledQueueProcessorScope is a scope for memory scheduled queue processor.
	OperationMemoryScheduledQueueProcessorScope = "MemoryScheduledQueueProcessor"
)

History Scope

const (
	// MatchingPollWorkflowTaskQueueScope tracks PollWorkflowTaskQueue API calls received by service
	MatchingPollWorkflowTaskQueueScope = "PollWorkflowTaskQueue"
	// MatchingPollActivityTaskQueueScope tracks PollActivityTaskQueue API calls received by service
	MatchingPollActivityTaskQueueScope = "PollActivityTaskQueue"
	// MatchingAddActivityTaskScope tracks AddActivityTask API calls received by service
	MatchingAddActivityTaskScope = "AddActivityTask"
	// MatchingAddWorkflowTaskScope tracks AddWorkflowTask API calls received by service
	MatchingAddWorkflowTaskScope = "AddWorkflowTask"
	// MatchingTaskQueueMgrScope is the metrics scope for matching.TaskQueueManager component
	MatchingTaskQueueMgrScope = "TaskQueueMgr"
	// MatchingEngineScope is the metrics scope for matchingEngine component
	MatchingEngineScope = "MatchingEngine"
	// MatchingQueryWorkflowScope tracks AddWorkflowTask API calls received by service
	MatchingQueryWorkflowScope = "QueryWorkflow"
	// MatchingRespondQueryTaskCompletedScope tracks AddWorkflowTask API calls received by service
	MatchingRespondQueryTaskCompletedScope = "RespondQueryTaskCompleted"
	// MatchingCancelOutstandingPollScope tracks CancelOutstandingPoll API calls received by service
	MatchingCancelOutstandingPollScope = "CancelOutstandingPoll"
	// MatchingDescribeTaskQueueScope tracks DescribeTaskQueue API calls received by service
	MatchingDescribeTaskQueueScope = "DescribeTaskQueue"
	// MatchingListTaskQueuePartitionsScope tracks ListTaskQueuePartitions API calls received by service
	MatchingListTaskQueuePartitionsScope = "ListTaskQueuePartitions"
	// MatchingUpdateWorkerBuildIdCompatibilityScope tracks UpdateWorkerBuildIdCompatibility API calls received by service
	MatchingUpdateWorkerBuildIdCompatibilityScope = "UpdateWorkerBuildIdCompatibility"
	// MatchingGetWorkerBuildIdCompatibilityScope tracks GetWorkerBuildIdCompatibility API calls received by service
	MatchingGetWorkerBuildIdCompatibilityScope = "GetWorkerBuildIdCompatibility"
	// MatchingGetTaskQueueUserDataScope tracks GetTaskQueueUserData API calls received by service
	MatchingGetTaskQueueUserDataScope = "GetTaskQueueUserData"
	// MatchingApplyTaskQueueUserDataReplicationEventScope tracks ApplyTaskQueueUserDataReplicationEvent API calls received by service
	MatchingApplyTaskQueueUserDataReplicationEventScope = "MatchingApplyTaskQueueUserDataReplicationEvent"
)

Matching Scope

const (
	// HistoryArchiverScope is used by history archivers
	HistoryArchiverScope = "HistoryArchiver"
	// VisibilityArchiverScope is used by visibility archivers
	VisibilityArchiverScope = "VisibilityArchiver"
	// HistoryScavengerScope is scope used by all metrics emitted by worker.history.Scavenger module
	HistoryScavengerScope = "HistoryScavenger"
	// ArchiverDeleteHistoryActivityScope is scope used by all metrics emitted by archiver.DeleteHistoryActivity
	ArchiverDeleteHistoryActivityScope = "ArchiverDeleteHistoryActivity"
	// ArchiverUploadHistoryActivityScope is scope used by all metrics emitted by archiver.UploadHistoryActivity
	ArchiverUploadHistoryActivityScope = "ArchiverUploadHistoryActivity"
	// ArchiverArchiveVisibilityActivityScope is scope used by all metrics emitted by archiver.ArchiveVisibilityActivity
	ArchiverArchiveVisibilityActivityScope = "ArchiverArchiveVisibilityActivity"
	// ArchiverScope is scope used by all metrics emitted by archiver.Archiver
	ArchiverScope = "Archiver"
	// ArchiverPumpScope is scope used by all metrics emitted by archiver.Pump
	ArchiverPumpScope = "ArchiverPump"
	// ArchiverArchivalWorkflowScope is scope used by all metrics emitted by archiver.ArchivalWorkflow
	ArchiverArchivalWorkflowScope = "ArchiverArchivalWorkflow"
	// AddSearchAttributesWorkflowScope is scope used by all metrics emitted by worker.AddSearchAttributesWorkflowScope module
	AddSearchAttributesWorkflowScope = "AddSearchAttributesWorkflow"
	// BatcherScope is scope used by all metrics emitted by worker.Batcher module
	BatcherScope = "Batcher"
	// ElasticsearchBulkProcessor is scope used by all metric emitted by Elasticsearch bulk processor
	ElasticsearchBulkProcessor = "ElasticsearchBulkProcessor"
	// ElasticsearchVisibility is scope used by all Elasticsearch visibility metrics
	ElasticsearchVisibility = "ElasticsearchVisibility"
	// MigrationWorkflowScope is scope used by metrics emitted by migration related workflows
	MigrationWorkflowScope = "MigrationWorkflow"
	// ReplicatorScope is the scope used by all metric emitted by replicator
	ReplicatorScope = "Replicator"
	// NamespaceReplicationTaskScope is the scope used by namespace task replication processing
	NamespaceReplicationTaskScope = "NamespaceReplicationTask"
	// HistoryReplicationTaskScope is the scope used by history task replication processing
	HistoryReplicationTaskScope = "HistoryReplicationTask"
	// HistoryMetadataReplicationTaskScope is the scope used by history metadata task replication processing
	HistoryMetadataReplicationTaskScope = "HistoryMetadataReplicationTask"
	// SyncShardTaskScope is the scope used by sync shrad information processing
	SyncShardTaskScope = "SyncShardTask"
	// SyncActivityTaskScope is the scope used by sync activity
	SyncActivityTaskScope = "SyncActivityTask"
	// SyncWorkflowStateTaskScope is the scope used by closed workflow task replication processing
	SyncWorkflowStateTaskScope = "SyncWorkflowStateTask"
	// SyncWatermarkScope is the scope used by closed workflow task replication processing
	SyncWatermarkScope = "SyncWatermark"
	// NoopTaskScope is the scope used by noop task
	NoopTaskScope = "NoopTask"
	// UnknownTaskScope is the scope used by unknown task
	UnknownTaskScope = "UnknownTask"
	// ParentClosePolicyProcessorScope is scope used by all metrics emitted by worker.ParentClosePolicyProcessor
	ParentClosePolicyProcessorScope = "ParentClosePolicyProcessor"
	DeleteNamespaceWorkflowScope    = "DeleteNamespaceWorkflow"
	ReclaimResourcesWorkflowScope   = "ReclaimResourcesWorkflow"
	DeleteExecutionsWorkflowScope   = "DeleteExecutionsWorkflow"
)

Worker Scope

const (
	TaskTypeTransferActiveTaskActivity             = "TransferActiveTaskActivity"
	TaskTypeTransferActiveTaskWorkflowTask         = "TransferActiveTaskWorkflowTask"
	TaskTypeTransferActiveTaskCloseExecution       = "TransferActiveTaskCloseExecution"
	TaskTypeTransferActiveTaskCancelExecution      = "TransferActiveTaskCancelExecution"
	TaskTypeTransferActiveTaskSignalExecution      = "TransferActiveTaskSignalExecution"
	TaskTypeTransferActiveTaskStartChildExecution  = "TransferActiveTaskStartChildExecution"
	TaskTypeTransferActiveTaskResetWorkflow        = "TransferActiveTaskResetWorkflow"
	TaskTypeTransferActiveTaskDeleteExecution      = "TransferActiveTaskDeleteExecution"
	TaskTypeTransferStandbyTaskActivity            = "TransferStandbyTaskActivity"
	TaskTypeTransferStandbyTaskWorkflowTask        = "TransferStandbyTaskWorkflowTask"
	TaskTypeTransferStandbyTaskCloseExecution      = "TransferStandbyTaskCloseExecution"
	TaskTypeTransferStandbyTaskCancelExecution     = "TransferStandbyTaskCancelExecution"
	TaskTypeTransferStandbyTaskSignalExecution     = "TransferStandbyTaskSignalExecution"
	TaskTypeTransferStandbyTaskStartChildExecution = "TransferStandbyTaskStartChildExecution"
	TaskTypeTransferStandbyTaskResetWorkflow       = "TransferStandbyTaskResetWorkflow"
	TaskTypeTransferStandbyTaskDeleteExecution     = "TransferStandbyTaskDeleteExecution"
	TaskTypeVisibilityTaskStartExecution           = "VisibilityTaskStartExecution"
	TaskTypeVisibilityTaskUpsertExecution          = "VisibilityTaskUpsertExecution"
	TaskTypeVisibilityTaskCloseExecution           = "VisibilityTaskCloseExecution"
	TaskTypeVisibilityTaskDeleteExecution          = "VisibilityTaskDeleteExecution"
	TaskTypeArchivalTaskArchiveExecution           = "ArchivalTaskArchiveExecution"
	TaskTypeTimerActiveTaskActivityTimeout         = "TimerActiveTaskActivityTimeout"
	TaskTypeTimerActiveTaskWorkflowTaskTimeout     = "TimerActiveTaskWorkflowTaskTimeout"
	TaskTypeTimerActiveTaskUserTimer               = "TimerActiveTaskUserTimer"
	TaskTypeTimerActiveTaskWorkflowTimeout         = "TimerActiveTaskWorkflowTimeout"
	TaskTypeTimerActiveTaskActivityRetryTimer      = "TimerActiveTaskActivityRetryTimer"
	TaskTypeTimerActiveTaskWorkflowBackoffTimer    = "TimerActiveTaskWorkflowBackoffTimer"
	TaskTypeTimerActiveTaskDeleteHistoryEvent      = "TimerActiveTaskDeleteHistoryEvent"
	TaskTypeTimerStandbyTaskActivityTimeout        = "TimerStandbyTaskActivityTimeout"
	TaskTypeTimerStandbyTaskWorkflowTaskTimeout    = "TimerStandbyTaskWorkflowTaskTimeout"
	TaskTypeTimerStandbyTaskUserTimer              = "TimerStandbyTaskUserTimer"
	TaskTypeTimerStandbyTaskWorkflowTimeout        = "TimerStandbyTaskWorkflowTimeout"
	TaskTypeTimerStandbyTaskActivityRetryTimer     = "TimerStandbyTaskActivityRetryTimer"
	TaskTypeTimerStandbyTaskWorkflowBackoffTimer   = "TimerStandbyTaskWorkflowBackoffTimer"
	TaskTypeTimerStandbyTaskDeleteHistoryEvent     = "TimerStandbyTaskDeleteHistoryEvent"
	TaskTypeMemoryScheduledTaskWorkflowTaskTimeout = "MemoryScheduledTaskWorkflowTaskTimeout"
)

History task type

const (
	ScheduleActionTypeTag       = "schedule_action"
	ScheduleActionStartWorkflow = "start_workflow"
)

Schedule action types

Variables

var (
	ServiceRequests = NewCounterDef(
		"service_requests",
		WithDescription("The number of RPC requests received by the service."),
	)
	ServicePendingRequests                   = NewGaugeDef("service_pending_requests")
	ServiceFailures                          = NewCounterDef("service_errors")
	ServicePanic                             = NewCounterDef("service_panics")
	ServiceErrorWithType                     = NewCounterDef("service_error_with_type")
	ServiceLatency                           = NewTimerDef("service_latency")
	ServiceLatencyNoUserLatency              = NewTimerDef("service_latency_nouserlatency")
	ServiceLatencyUserLatency                = NewTimerDef("service_latency_userlatency")
	ServiceErrInvalidArgumentCounter         = NewCounterDef("service_errors_invalid_argument")
	ServiceErrNamespaceNotActiveCounter      = NewCounterDef("service_errors_namespace_not_active")
	ServiceErrResourceExhaustedCounter       = NewCounterDef("service_errors_resource_exhausted")
	ServiceErrNotFoundCounter                = NewCounterDef("service_errors_entity_not_found")
	ServiceErrExecutionAlreadyStartedCounter = NewCounterDef("service_errors_execution_already_started")
	ServiceErrContextTimeoutCounter          = NewCounterDef("service_errors_context_timeout")
	ServiceErrRetryTaskCounter               = NewCounterDef("service_errors_retry_task")
	ServiceErrIncompleteHistoryCounter       = NewCounterDef("service_errors_incomplete_history")
	ServiceErrNonDeterministicCounter        = NewCounterDef("service_errors_nondeterministic")
	ServiceErrUnauthorizedCounter            = NewCounterDef("service_errors_unauthorized")
	ServiceErrAuthorizeFailedCounter         = NewCounterDef("service_errors_authorize_failed")
	ActionCounter                            = NewCounterDef("action")
	TlsCertsExpired                          = NewGaugeDef("certificates_expired")
	TlsCertsExpiring                         = NewGaugeDef("certificates_expiring")
	ServiceAuthorizationLatency              = NewTimerDef("service_authorization_latency")
	EventBlobSize                            = NewBytesHistogramDef("event_blob_size")
	LockRequests                             = NewCounterDef("lock_requests")
	LockFailures                             = NewCounterDef("lock_failures")
	LockLatency                              = NewTimerDef("lock_latency")
	ClientRequests                           = NewCounterDef(
		"client_requests",
		WithDescription("The number of requests sent by the client to an individual service, keyed by `service_role` and `operation`."),
	)
	ClientFailures               = NewCounterDef("client_errors")
	ClientLatency                = NewTimerDef("client_latency")
	ClientRedirectionRequests    = NewCounterDef("client_redirection_requests")
	ClientRedirectionFailures    = NewCounterDef("client_redirection_errors")
	ClientRedirectionLatency     = NewTimerDef("client_redirection_latency")
	StateTransitionCount         = NewDimensionlessHistogramDef("state_transition_count")
	HistorySize                  = NewBytesHistogramDef("history_size")
	HistoryCount                 = NewDimensionlessHistogramDef("history_count")
	SearchAttributesSize         = NewBytesHistogramDef("search_attributes_size")
	MemoSize                     = NewBytesHistogramDef("memo_size")
	TooManyPendingChildWorkflows = NewCounterDef(
		"wf_too_many_pending_child_workflows",
		WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending child workflows to be exceeded. See https://t.mp/limits for more information."),
	)
	TooManyPendingActivities = NewCounterDef(
		"wf_too_many_pending_activities",
		WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending activities to be exceeded. See https://t.mp/limits for more information."),
	)
	TooManyPendingCancelRequests = NewCounterDef(
		"wf_too_many_pending_cancel_requests",
		WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending cancel requests to be exceeded. See https://t.mp/limits for more information."),
	)
	TooManyPendingSignalsToExternalWorkflows = NewCounterDef(
		"wf_too_many_pending_external_workflow_signals",
		WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending signals to external workflows to be exceeded. See https://t.mp/limits for more information."),
	)

	// Frontend
	AddSearchAttributesWorkflowSuccessCount  = NewCounterDef("add_search_attributes_workflow_success")
	AddSearchAttributesWorkflowFailuresCount = NewCounterDef("add_search_attributes_workflow_failure")
	DeleteNamespaceWorkflowSuccessCount      = NewCounterDef("delete_namespace_workflow_success")
	DeleteNamespaceWorkflowFailuresCount     = NewCounterDef("delete_namespace_workflow_failure")
	VersionCheckSuccessCount                 = NewCounterDef("version_check_success")
	VersionCheckFailedCount                  = NewCounterDef("version_check_failed")
	VersionCheckRequestFailedCount           = NewCounterDef("version_check_request_failed")
	VersionCheckLatency                      = NewTimerDef("version_check_latency")
	HTTPServiceRequests                      = NewCounterDef(
		"http_service_requests",
		WithDescription("The number of HTTP requests received by the service."),
	)

	// History
	CacheRequests                                = NewCounterDef("cache_requests")
	CacheFailures                                = NewCounterDef("cache_errors")
	CacheLatency                                 = NewTimerDef("cache_latency")
	CacheMissCounter                             = NewCounterDef("cache_miss")
	HistoryEventNotificationQueueingLatency      = NewTimerDef("history_event_notification_queueing_latency")
	HistoryEventNotificationFanoutLatency        = NewTimerDef("history_event_notification_fanout_latency")
	HistoryEventNotificationInFlightMessageGauge = NewGaugeDef("history_event_notification_inflight_message_gauge")
	HistoryEventNotificationFailDeliveryCount    = NewCounterDef("history_event_notification_fail_delivery_count")
	// ArchivalTaskInvalidURI is emitted by the archival queue task executor when the history or visibility URI for an
	// archival task is not a valid URI.
	// We may emit this metric several times for a single task if the task is retried.
	ArchivalTaskInvalidURI                            = NewCounterDef("archival_task_invalid_uri")
	ArchiverClientSendSignalCount                     = NewCounterDef("archiver_client_sent_signal")
	ArchiverClientSendSignalFailureCount              = NewCounterDef("archiver_client_send_signal_error")
	ArchiverClientHistoryRequestCount                 = NewCounterDef("archiver_client_history_request")
	ArchiverClientHistoryInlineArchiveAttemptCount    = NewCounterDef("archiver_client_history_inline_archive_attempt")
	ArchiverClientHistoryInlineArchiveFailureCount    = NewCounterDef("archiver_client_history_inline_archive_failure")
	ArchiverClientVisibilityRequestCount              = NewCounterDef("archiver_client_visibility_request")
	ArchiverClientVisibilityInlineArchiveAttemptCount = NewCounterDef("archiver_client_visibility_inline_archive_attempt")
	ArchiverClientVisibilityInlineArchiveFailureCount = NewCounterDef("archiver_client_visibility_inline_archive_failure")
	ArchiverArchiveLatency                            = NewTimerDef("archiver_archive_latency")
	ArchiverArchiveTargetLatency                      = NewTimerDef("archiver_archive_target_latency")
	ShardContextClosedCounter                         = NewCounterDef("shard_closed_count")
	ShardContextCreatedCounter                        = NewCounterDef("sharditem_created_count")
	ShardContextRemovedCounter                        = NewCounterDef("sharditem_removed_count")
	ShardContextAcquisitionLatency                    = NewTimerDef("sharditem_acquisition_latency")
	ShardInfoImmediateQueueLagHistogram               = NewDimensionlessHistogramDef(
		"shardinfo_immediate_queue_lag",
		WithDescription("A histogram across history shards for the difference between the smallest taskID of pending history tasks and the last generated history task ID."),
	)
	ShardInfoScheduledQueueLagTimer = NewTimerDef(
		"shardinfo_scheduled_queue_lag",
		WithDescription("A histogram across history shards for the difference between the earliest scheduled time of pending history tasks and current time."),
	)
	SyncShardFromRemoteCounter = NewCounterDef("syncshard_remote_count")
	SyncShardFromRemoteFailure = NewCounterDef("syncshard_remote_failed")
	TaskRequests               = NewCounterDef(
		"task_requests",
		WithDescription("The number of history tasks processed."),
	)
	TaskLoadLatency = NewTimerDef(
		"task_latency_load",
		WithDescription("Latency from history task generation to loading into memory (persistence schedule to start latency)."),
	)
	TaskScheduleLatency = NewTimerDef(
		"task_latency_schedule",
		WithDescription("Latency from history task loading to start processing (in-memory schedule to start latency)."),
	)
	TaskProcessingLatency = NewTimerDef(
		"task_latency_processing",
		WithDescription("Latency for processing a history task one time."),
	)
	TaskLatency = NewTimerDef(
		"task_latency",
		WithDescription("Latency for procsssing and completing a history task. This latency is across all attempts but excludes any latencies related to workflow lock or user qutoa limit."),
	)
	TaskQueueLatency = NewTimerDef(
		"task_latency_queue",
		WithDescription("End-to-end latency for processing and completing a history task, from task generation to completion."),
	)
	TaskAttempt = NewDimensionlessHistogramDef(
		"task_attempt",
		WithDescription("The number of attempts took to complete a history task."),
	)
	TaskFailures = NewCounterDef(
		"task_errors",
		WithDescription("The number of unexpected history task processing errors."),
	)
	TaskDiscarded                   = NewCounterDef("task_errors_discarded")
	TaskSkipped                     = NewCounterDef("task_skipped")
	TaskVersionMisMatch             = NewCounterDef("task_errors_version_mismatch")
	TasksDependencyTaskNotCompleted = NewCounterDef("task_dependency_task_not_completed")
	TaskStandbyRetryCounter         = NewCounterDef("task_errors_standby_retry_counter")
	TaskWorkflowBusyCounter         = NewCounterDef(
		"task_errors_workflow_busy",
		WithDescription("The number of history task processing errors caused by failing to acquire workflow lock within the configured timeout (history.cacheNonUserContextLockTimeout)."),
	)
	TaskNotActiveCounter         = NewCounterDef("task_errors_not_active_counter")
	TaskNamespaceHandoverCounter = NewCounterDef("task_errors_namespace_handover")
	TaskThrottledCounter         = NewCounterDef(
		"task_errors_throttled",
		WithDescription("The number of history task processing errors caused by resource exhausted errors, excluding workflow busy case."),
	)
	TaskCorruptionCounter       = NewCounterDef("task_errors_corruption")
	TaskScheduleToStartLatency  = NewTimerDef("task_schedule_to_start_latency")
	TaskBatchCompleteCounter    = NewCounterDef("task_batch_complete_counter")
	TaskReschedulerPendingTasks = NewDimensionlessHistogramDef("task_rescheduler_pending_tasks")
	PendingTasksCounter         = NewDimensionlessHistogramDef(
		"pending_tasks",
		WithDescription("A histogram across history shards for the number of in-memory pending history tasks."),
	)
	TaskSchedulerThrottled                               = NewCounterDef("task_scheduler_throttled")
	QueueScheduleLatency                                 = NewTimerDef("queue_latency_schedule") // latency for scheduling 100 tasks in one task channel
	QueueReaderCountHistogram                            = NewDimensionlessHistogramDef("queue_reader_count")
	QueueSliceCountHistogram                             = NewDimensionlessHistogramDef("queue_slice_count")
	QueueActionCounter                                   = NewCounterDef("queue_actions")
	QueueActionFailures                                  = NewCounterDef("queue_action_errors")
	ActivityE2ELatency                                   = NewTimerDef("activity_end_to_end_latency")
	AckLevelUpdateCounter                                = NewCounterDef("ack_level_update")
	AckLevelUpdateFailedCounter                          = NewCounterDef("ack_level_update_failed")
	CommandTypeScheduleActivityCounter                   = NewCounterDef("schedule_activity_command")
	CommandTypeCompleteWorkflowCounter                   = NewCounterDef("complete_workflow_command")
	CommandTypeFailWorkflowCounter                       = NewCounterDef("fail_workflow_command")
	CommandTypeCancelWorkflowCounter                     = NewCounterDef("cancel_workflow_command")
	CommandTypeStartTimerCounter                         = NewCounterDef("start_timer_command")
	CommandTypeCancelActivityCounter                     = NewCounterDef("cancel_activity_command")
	CommandTypeCancelTimerCounter                        = NewCounterDef("cancel_timer_command")
	CommandTypeRecordMarkerCounter                       = NewCounterDef("record_marker_command")
	CommandTypeCancelExternalWorkflowCounter             = NewCounterDef("cancel_external_workflow_command")
	CommandTypeContinueAsNewCounter                      = NewCounterDef("continue_as_new_command")
	CommandTypeSignalExternalWorkflowCounter             = NewCounterDef("signal_external_workflow_command")
	CommandTypeUpsertWorkflowSearchAttributesCounter     = NewCounterDef("upsert_workflow_search_attributes_command")
	CommandTypeModifyWorkflowPropertiesCounter           = NewCounterDef("modify_workflow_properties_command")
	CommandTypeChildWorkflowCounter                      = NewCounterDef("child_workflow_command")
	CommandTypeProtocolMessage                           = NewCounterDef("protocol_message_command")
	MessageTypeRequestWorkflowExecutionUpdateCounter     = NewCounterDef("request_workflow_update_message")
	MessageTypeAcceptWorkflowExecutionUpdateCounter      = NewCounterDef("accept_workflow_update_message")
	MessageTypeRespondWorkflowExecutionUpdateCounter     = NewCounterDef("respond_workflow_update_message")
	MessageTypeRejectWorkflowExecutionUpdateCounter      = NewCounterDef("reject_workflow_update_message")
	InvalidStateTransitionWorkflowExecutionUpdateCounter = NewCounterDef("invalid_state_transition_workflow_update_message")

	ActivityEagerExecutionCounter = NewCounterDef("activity_eager_execution")
	// WorkflowEagerExecutionCounter is emitted any time eager workflow start is requested.
	WorkflowEagerExecutionCounter = NewCounterDef("workflow_eager_execution")
	// WorkflowEagerExecutionDeniedCounter is emitted any time eager workflow start is requested and the serer fell back
	// to standard dispatch.
	// Timeouts and failures are not counted in this metric.
	// This metric has a "reason" tag attached to it to understand why eager start was denied.
	WorkflowEagerExecutionDeniedCounter           = NewCounterDef("workflow_eager_execution_denied")
	EmptyCompletionCommandsCounter                = NewCounterDef("empty_completion_commands")
	MultipleCompletionCommandsCounter             = NewCounterDef("multiple_completion_commands")
	FailedWorkflowTasksCounter                    = NewCounterDef("failed_workflow_tasks")
	WorkflowTaskAttempt                           = NewDimensionlessHistogramDef("workflow_task_attempt")
	StaleMutableStateCounter                      = NewCounterDef("stale_mutable_state")
	AutoResetPointsLimitExceededCounter           = NewCounterDef("auto_reset_points_exceed_limit")
	AutoResetPointCorruptionCounter               = NewCounterDef("auto_reset_point_corruption")
	ConcurrencyUpdateFailureCounter               = NewCounterDef("concurrency_update_failure")
	ServiceErrShardOwnershipLostCounter           = NewCounterDef("service_errors_shard_ownership_lost")
	HeartbeatTimeoutCounter                       = NewCounterDef("heartbeat_timeout")
	ScheduleToStartTimeoutCounter                 = NewCounterDef("schedule_to_start_timeout")
	StartToCloseTimeoutCounter                    = NewCounterDef("start_to_close_timeout")
	ScheduleToCloseTimeoutCounter                 = NewCounterDef("schedule_to_close_timeout")
	NewTimerNotifyCounter                         = NewCounterDef("new_timer_notifications")
	AcquireShardsCounter                          = NewCounterDef("acquire_shards_count")
	AcquireShardsLatency                          = NewTimerDef("acquire_shards_latency")
	MembershipChangedCounter                      = NewCounterDef("membership_changed_count")
	NumShardsGauge                                = NewGaugeDef("numshards_gauge")
	GetEngineForShardErrorCounter                 = NewCounterDef("get_engine_for_shard_errors")
	GetEngineForShardLatency                      = NewTimerDef("get_engine_for_shard_latency")
	RemoveEngineForShardLatency                   = NewTimerDef("remove_engine_for_shard_latency")
	CompleteWorkflowTaskWithStickyEnabledCounter  = NewCounterDef("complete_workflow_task_sticky_enabled_count")
	CompleteWorkflowTaskWithStickyDisabledCounter = NewCounterDef("complete_workflow_task_sticky_disabled_count")
	WorkflowTaskHeartbeatTimeoutCounter           = NewCounterDef("workflow_task_heartbeat_timeout_count")
	DuplicateReplicationEventsCounter             = NewCounterDef("duplicate_replication_events")
	AcquireLockFailedCounter                      = NewCounterDef("acquire_lock_failed")
	WorkflowContextCleared                        = NewCounterDef("workflow_context_cleared")
	MutableStateSize                              = NewBytesHistogramDef(
		"mutable_state_size",
		WithDescription("The size of an individual Workflow Execution's state, emitted each time a workflow execution is retrieved or updated."),
	)
	ExecutionInfoSize                       = NewBytesHistogramDef("execution_info_size")
	ExecutionStateSize                      = NewBytesHistogramDef("execution_state_size")
	ActivityInfoSize                        = NewBytesHistogramDef("activity_info_size")
	TimerInfoSize                           = NewBytesHistogramDef("timer_info_size")
	ChildInfoSize                           = NewBytesHistogramDef("child_info_size")
	RequestCancelInfoSize                   = NewBytesHistogramDef("request_cancel_info_size")
	SignalInfoSize                          = NewBytesHistogramDef("signal_info_size")
	SignalRequestIDSize                     = NewBytesHistogramDef("signal_request_id_size")
	BufferedEventsSize                      = NewBytesHistogramDef("buffered_events_size")
	ActivityInfoCount                       = NewDimensionlessHistogramDef("activity_info_count")
	TimerInfoCount                          = NewDimensionlessHistogramDef("timer_info_count")
	ChildInfoCount                          = NewDimensionlessHistogramDef("child_info_count")
	SignalInfoCount                         = NewDimensionlessHistogramDef("signal_info_count")
	RequestCancelInfoCount                  = NewDimensionlessHistogramDef("request_cancel_info_count")
	SignalRequestIDCount                    = NewDimensionlessHistogramDef("signal_request_id_count")
	BufferedEventsCount                     = NewDimensionlessHistogramDef("buffered_events_count")
	TaskCount                               = NewDimensionlessHistogramDef("task_count")
	TotalActivityCount                      = NewDimensionlessHistogramDef("total_activity_count")
	TotalUserTimerCount                     = NewDimensionlessHistogramDef("total_user_timer_count")
	TotalChildExecutionCount                = NewDimensionlessHistogramDef("total_child_execution_count")
	TotalRequestCancelExternalCount         = NewDimensionlessHistogramDef("total_request_cancel_external_count")
	TotalSignalExternalCount                = NewDimensionlessHistogramDef("total_signal_external_count")
	TotalSignalCount                        = NewDimensionlessHistogramDef("total_signal_count")
	WorkflowRetryBackoffTimerCount          = NewCounterDef("workflow_retry_backoff_timer")
	WorkflowCronBackoffTimerCount           = NewCounterDef("workflow_cron_backoff_timer")
	WorkflowDelayedStartBackoffTimerCount   = NewCounterDef("workflow_delayed_start_backoff_timer")
	WorkflowCleanupDeleteCount              = NewCounterDef("workflow_cleanup_delete")
	WorkflowCleanupArchiveCount             = NewCounterDef("workflow_cleanup_archive")
	WorkflowCleanupNopCount                 = NewCounterDef("workflow_cleanup_nop")
	WorkflowCleanupDeleteHistoryInlineCount = NewCounterDef("workflow_cleanup_delete_history_inline")
	WorkflowSuccessCount                    = NewCounterDef("workflow_success")
	WorkflowCancelCount                     = NewCounterDef("workflow_cancel")
	WorkflowFailedCount                     = NewCounterDef("workflow_failed")
	WorkflowTimeoutCount                    = NewCounterDef("workflow_timeout")
	WorkflowTerminateCount                  = NewCounterDef("workflow_terminate")
	WorkflowContinuedAsNewCount             = NewCounterDef("workflow_continued_as_new")
	ReplicationTasksSend                    = NewCounterDef("replication_tasks_send")
	ReplicationTasksRecv                    = NewCounterDef("replication_tasks_recv")
	ReplicationTasksRecvBacklog             = NewDimensionlessHistogramDef("replication_tasks_recv_backlog")
	ReplicationTasksSkipped                 = NewCounterDef("replication_tasks_skipped")
	ReplicationTasksApplied                 = NewCounterDef("replication_tasks_applied")
	ReplicationTasksFailed                  = NewCounterDef("replication_tasks_failed")
	// ReplicationTasksLag is a heuristic for how far behind the remote DC is for a given cluster. It measures the
	// difference between task IDs so its unit should be "tasks".
	ReplicationTasksLag = NewDimensionlessHistogramDef("replication_tasks_lag")
	// ReplicationTasksFetched records the number of tasks fetched by the poller.
	ReplicationTasksFetched                        = NewDimensionlessHistogramDef("replication_tasks_fetched")
	ReplicationLatency                             = NewTimerDef("replication_latency")
	ReplicationDLQFailed                           = NewCounterDef("replication_dlq_enqueue_failed")
	ReplicationDLQMaxLevelGauge                    = NewGaugeDef("replication_dlq_max_level")
	ReplicationDLQAckLevelGauge                    = NewGaugeDef("replication_dlq_ack_level")
	ReplicationNonEmptyDLQCount                    = NewCounterDef("replication_dlq_non_empty")
	ReplicationOutlierNamespace                    = NewCounterDef("replication_outlier_namespace")
	EventReapplySkippedCount                       = NewCounterDef("event_reapply_skipped_count")
	DirectQueryDispatchLatency                     = NewTimerDef("direct_query_dispatch_latency")
	DirectQueryDispatchStickyLatency               = NewTimerDef("direct_query_dispatch_sticky_latency")
	DirectQueryDispatchNonStickyLatency            = NewTimerDef("direct_query_dispatch_non_sticky_latency")
	DirectQueryDispatchStickySuccessCount          = NewCounterDef("direct_query_dispatch_sticky_success")
	DirectQueryDispatchNonStickySuccessCount       = NewCounterDef("direct_query_dispatch_non_sticky_success")
	DirectQueryDispatchClearStickinessLatency      = NewTimerDef("direct_query_dispatch_clear_stickiness_latency")
	DirectQueryDispatchClearStickinessSuccessCount = NewCounterDef("direct_query_dispatch_clear_stickiness_success")
	DirectQueryDispatchTimeoutBeforeNonStickyCount = NewCounterDef("direct_query_dispatch_timeout_before_non_sticky")
	WorkflowTaskQueryLatency                       = NewTimerDef("workflow_task_query_latency")
	ConsistentQueryTimeoutCount                    = NewCounterDef("consistent_query_timeout")
	QueryBufferExceededCount                       = NewCounterDef("query_buffer_exceeded")
	QueryRegistryInvalidStateCount                 = NewCounterDef("query_registry_invalid_state")
	WorkflowTaskTimeoutOverrideCount               = NewCounterDef("workflow_task_timeout_overrides")
	WorkflowRunTimeoutOverrideCount                = NewCounterDef("workflow_run_timeout_overrides")
	ReplicationTaskCleanupCount                    = NewCounterDef("replication_task_cleanup_count")
	ReplicationTaskCleanupFailure                  = NewCounterDef("replication_task_cleanup_failed")
	MutableStateDirty                              = NewCounterDef("mutable_state_dirty")
	MutableStateChecksumMismatch                   = NewCounterDef("mutable_state_checksum_mismatch")
	MutableStateChecksumInvalidated                = NewCounterDef("mutable_state_checksum_invalidated")
	ClusterMetadataLockLatency                     = NewTimerDef("cluster_metadata_lock_latency")
	ClusterMetadataCallbackLockLatency             = NewTimerDef("cluster_metadata_callback_lock_latency")
	ShardControllerLockLatency                     = NewTimerDef("shard_controller_lock_latency")
	ShardLockLatency                               = NewTimerDef("shard_lock_latency")
	NamespaceRegistryLockLatency                   = NewTimerDef("namespace_registry_lock_latency")
	ClosedWorkflowBufferEventCount                 = NewCounterDef("closed_workflow_buffer_event_counter")
	InorderBufferedEventsCounter                   = NewCounterDef("inordered_buffered_events")
	ShardLingerSuccess                             = NewTimerDef("shard_linger_success")
	ShardLingerTimeouts                            = NewCounterDef("shard_linger_timeouts")
	DynamicRateLimiterMultiplier                   = NewGaugeDef("dynamic_rate_limit_multiplier")

	// Matching
	MatchingClientForwardedCounter            = NewCounterDef("forwarded")
	MatchingClientInvalidTaskQueueName        = NewCounterDef("invalid_task_queue_name")
	SyncMatchLatencyPerTaskQueue              = NewTimerDef("syncmatch_latency")
	AsyncMatchLatencyPerTaskQueue             = NewTimerDef("asyncmatch_latency")
	PollSuccessPerTaskQueueCounter            = NewCounterDef("poll_success")
	PollTimeoutPerTaskQueueCounter            = NewCounterDef("poll_timeouts")
	PollSuccessWithSyncPerTaskQueueCounter    = NewCounterDef("poll_success_sync")
	LeaseRequestPerTaskQueueCounter           = NewCounterDef("lease_requests")
	LeaseFailurePerTaskQueueCounter           = NewCounterDef("lease_failures")
	ConditionFailedErrorPerTaskQueueCounter   = NewCounterDef("condition_failed_errors")
	RespondQueryTaskFailedPerTaskQueueCounter = NewCounterDef("respond_query_failed")
	SyncThrottlePerTaskQueueCounter           = NewCounterDef("sync_throttle_count")
	BufferThrottlePerTaskQueueCounter         = NewCounterDef("buffer_throttle_count")
	ExpiredTasksPerTaskQueueCounter           = NewCounterDef("tasks_expired")
	ForwardedPerTaskQueueCounter              = NewCounterDef("forwarded_per_tl")
	ForwardTaskErrorsPerTaskQueue             = NewCounterDef("forward_task_errors")
	LocalToLocalMatchPerTaskQueueCounter      = NewCounterDef("local_to_local_matches")
	LocalToRemoteMatchPerTaskQueueCounter     = NewCounterDef("local_to_remote_matches")
	RemoteToLocalMatchPerTaskQueueCounter     = NewCounterDef("remote_to_local_matches")
	RemoteToRemoteMatchPerTaskQueueCounter    = NewCounterDef("remote_to_remote_matches")
	LoadedTaskQueueGauge                      = NewGaugeDef("loaded_task_queue_count")
	TaskQueueStartedCounter                   = NewCounterDef("task_queue_started")
	TaskQueueStoppedCounter                   = NewCounterDef("task_queue_stopped")
	TaskWriteThrottlePerTaskQueueCounter      = NewCounterDef("task_write_throttle_count")
	TaskWriteLatencyPerTaskQueue              = NewTimerDef("task_write_latency")
	TaskLagPerTaskQueueGauge                  = NewGaugeDef("task_lag_per_tl")
	NoRecentPollerTasksPerTaskQueueCounter    = NewCounterDef("no_poller_tasks")
	UnknownBuildPollsCounter                  = NewCounterDef("unknown_build_polls")
	UnknownBuildTasksCounter                  = NewCounterDef("unknown_build_tasks")

	// Worker
	ExecutorTasksDoneCount                          = NewCounterDef("executor_done")
	ExecutorTasksErrCount                           = NewCounterDef("executor_err")
	ExecutorTasksDeferredCount                      = NewCounterDef("executor_deferred")
	ExecutorTasksDroppedCount                       = NewCounterDef("executor_dropped")
	StartedCount                                    = NewCounterDef("started")
	StoppedCount                                    = NewCounterDef("stopped")
	TaskProcessedCount                              = NewGaugeDef("task_processed")
	TaskDeletedCount                                = NewGaugeDef("task_deleted")
	TaskQueueProcessedCount                         = NewGaugeDef("taskqueue_processed")
	TaskQueueDeletedCount                           = NewGaugeDef("taskqueue_deleted")
	TaskQueueOutstandingCount                       = NewGaugeDef("taskqueue_outstanding")
	HistoryArchiverArchiveNonRetryableErrorCount    = NewCounterDef("history_archiver_archive_non_retryable_error")
	HistoryArchiverArchiveTransientErrorCount       = NewCounterDef("history_archiver_archive_transient_error")
	HistoryArchiverArchiveSuccessCount              = NewCounterDef("history_archiver_archive_success")
	HistoryArchiverTotalUploadSize                  = NewBytesHistogramDef("history_archiver_total_upload_size")
	HistoryArchiverHistorySize                      = NewBytesHistogramDef("history_archiver_history_size")
	HistoryArchiverDuplicateArchivalsCount          = NewCounterDef("history_archiver_duplicate_archivals")
	HistoryArchiverBlobExistsCount                  = NewCounterDef("history_archiver_blob_exists")
	HistoryArchiverBlobSize                         = NewBytesHistogramDef("history_archiver_blob_size")
	HistoryWorkflowExecutionCacheLatency            = NewTimerDef("history_workflow_execution_cache_latency")
	VisibilityArchiverArchiveNonRetryableErrorCount = NewCounterDef("visibility_archiver_archive_non_retryable_error")
	VisibilityArchiverArchiveTransientErrorCount    = NewCounterDef("visibility_archiver_archive_transient_error")
	VisibilityArchiveSuccessCount                   = NewCounterDef("visibility_archiver_archive_success")
	HistoryScavengerSuccessCount                    = NewCounterDef("scavenger_success")
	HistoryScavengerErrorCount                      = NewCounterDef("scavenger_errors")
	HistoryScavengerSkipCount                       = NewCounterDef("scavenger_skips")
	ExecutionsOutstandingCount                      = NewGaugeDef("executions_outstanding")
	ArchiverNonRetryableErrorCount                  = NewCounterDef("archiver_non_retryable_error")
	ArchiverStartedCount                            = NewCounterDef("archiver_started")
	ArchiverStoppedCount                            = NewCounterDef("archiver_stopped")
	ArchiverCoroutineStartedCount                   = NewCounterDef("archiver_coroutine_started")
	ArchiverCoroutineStoppedCount                   = NewCounterDef("archiver_coroutine_stopped")
	ArchiverHandleHistoryRequestLatency             = NewTimerDef("archiver_handle_history_request_latency")
	ArchiverHandleVisibilityRequestLatency          = NewTimerDef("archiver_handle_visibility_request_latency")
	ArchiverUploadWithRetriesLatency                = NewTimerDef("archiver_upload_with_retries_latency")
	ArchiverDeleteWithRetriesLatency                = NewTimerDef("archiver_delete_with_retries_latency")
	ArchiverUploadFailedAllRetriesCount             = NewCounterDef("archiver_upload_failed_all_retries")
	ArchiverUploadSuccessCount                      = NewCounterDef("archiver_upload_success")
	ArchiverDeleteFailedAllRetriesCount             = NewCounterDef("archiver_delete_failed_all_retries")
	ArchiverDeleteSuccessCount                      = NewCounterDef("archiver_delete_success")
	ArchiverHandleVisibilityFailedAllRetiresCount   = NewCounterDef("archiver_handle_visibility_failed_all_retries")
	ArchiverHandleVisibilitySuccessCount            = NewCounterDef("archiver_handle_visibility_success")
	ArchiverBacklogSizeGauge                        = NewGaugeDef("archiver_backlog_size")
	ArchiverPumpTimeoutCount                        = NewCounterDef("archiver_pump_timeout")
	ArchiverPumpSignalThresholdCount                = NewCounterDef("archiver_pump_signal_threshold")
	ArchiverPumpTimeoutWithoutSignalsCount          = NewCounterDef("archiver_pump_timeout_without_signals")
	ArchiverPumpSignalChannelClosedCount            = NewCounterDef("archiver_pump_signal_channel_closed")
	ArchiverWorkflowStartedCount                    = NewCounterDef("archiver_workflow_started")
	ArchiverNumPumpedRequestsCount                  = NewCounterDef("archiver_num_pumped_requests")
	ArchiverNumHandledRequestsCount                 = NewCounterDef("archiver_num_handled_requests")
	ArchiverPumpedNotEqualHandledCount              = NewCounterDef("archiver_pumped_not_equal_handled")
	ArchiverHandleAllRequestsLatency                = NewTimerDef("archiver_handle_all_requests_latency")
	ArchiverWorkflowStoppingCount                   = NewCounterDef("archiver_workflow_stopping")
	ScavengerValidationRequestsCount                = NewCounterDef("scavenger_validation_requests")
	ScavengerValidationFailuresCount                = NewCounterDef("scavenger_validation_failures")
	ScavengerValidationSkipsCount                   = NewCounterDef("scavenger_validation_skips")
	AddSearchAttributesFailuresCount                = NewCounterDef("add_search_attributes_failures")
	DeleteNamespaceSuccessCount                     = NewCounterDef("delete_namespace_success")
	RenameNamespaceSuccessCount                     = NewCounterDef("rename_namespace_success")
	DeleteExecutionsSuccessCount                    = NewCounterDef("delete_executions_success")
	DeleteNamespaceFailuresCount                    = NewCounterDef("delete_namespace_failures")
	UpdateNamespaceFailuresCount                    = NewCounterDef("update_namespace_failures")
	RenameNamespaceFailuresCount                    = NewCounterDef("rename_namespace_failures")
	ReadNamespaceFailuresCount                      = NewCounterDef("read_namespace_failures")
	ListExecutionsFailuresCount                     = NewCounterDef("list_executions_failures")
	CountExecutionsFailuresCount                    = NewCounterDef("count_executions_failures")
	DeleteExecutionFailuresCount                    = NewCounterDef("delete_execution_failures")
	DeleteExecutionNotFoundCount                    = NewCounterDef("delete_execution_not_found")
	RateLimiterFailuresCount                        = NewCounterDef("rate_limiter_failures")
	BatcherProcessorSuccess                         = NewCounterDef(
		"batcher_processor_requests",
		WithDescription("The number of individual workflow execution tasks successfully processed by the batch request processor"),
	)
	BatcherProcessorFailures                          = NewCounterDef("batcher_processor_errors")
	BatcherOperationFailures                          = NewCounterDef("batcher_operation_errors")
	ElasticsearchBulkProcessorRequests                = NewCounterDef("elasticsearch_bulk_processor_requests")
	ElasticsearchBulkProcessorQueuedRequests          = NewDimensionlessHistogramDef("elasticsearch_bulk_processor_queued_requests")
	ElasticsearchBulkProcessorFailures                = NewCounterDef("elasticsearch_bulk_processor_errors")
	ElasticsearchBulkProcessorCorruptedData           = NewCounterDef("elasticsearch_bulk_processor_corrupted_data")
	ElasticsearchBulkProcessorDuplicateRequest        = NewCounterDef("elasticsearch_bulk_processor_duplicate_request")
	ElasticsearchBulkProcessorRequestLatency          = NewTimerDef("elasticsearch_bulk_processor_request_latency")
	ElasticsearchBulkProcessorCommitLatency           = NewTimerDef("elasticsearch_bulk_processor_commit_latency")
	ElasticsearchBulkProcessorWaitAddLatency          = NewTimerDef("elasticsearch_bulk_processor_wait_add_latency")
	ElasticsearchBulkProcessorWaitStartLatency        = NewTimerDef("elasticsearch_bulk_processor_wait_start_latency")
	ElasticsearchBulkProcessorBulkSize                = NewDimensionlessHistogramDef("elasticsearch_bulk_processor_bulk_size")
	ElasticsearchBulkProcessorBulkResquestTookLatency = NewTimerDef("elasticsearch_bulk_processor_bulk_request_took_latency")
	ElasticsearchDocumentParseFailuresCount           = NewCounterDef("elasticsearch_document_parse_failures_counter")
	ElasticsearchDocumentGenerateFailuresCount        = NewCounterDef("elasticsearch_document_generate_failures_counter")
	ElasticsearchCustomOrderByClauseCount             = NewCounterDef("elasticsearch_custom_order_by_clause_counter")
	CatchUpReadyShardCountGauge                       = NewGaugeDef("catchup_ready_shard_count")
	HandoverReadyShardCountGauge                      = NewGaugeDef("handover_ready_shard_count")
	ReplicatorMessages                                = NewCounterDef("replicator_messages")
	ReplicatorFailures                                = NewCounterDef("replicator_errors")
	ReplicatorLatency                                 = NewTimerDef("replicator_latency")
	ReplicatorDLQFailures                             = NewCounterDef("replicator_dlq_enqueue_fails")
	NamespaceReplicationEnqueueDLQCount               = NewCounterDef("namespace_replication_dlq_enqueue_requests")
	ParentClosePolicyProcessorSuccess                 = NewCounterDef("parent_close_policy_processor_requests")
	ParentClosePolicyProcessorFailures                = NewCounterDef("parent_close_policy_processor_errors")
	ScheduleMissedCatchupWindow                       = NewCounterDef(
		"schedule_missed_catchup_window",
		WithDescription("The number of times a schedule missed an action due to the configured catchup window"),
	)
	ScheduleRateLimited = NewCounterDef(
		"schedule_rate_limited",
		WithDescription("The number of times a schedule action was delayed by more than 1s due to rate limiting"),
	)
	ScheduleBufferOverruns = NewCounterDef(
		"schedule_buffer_overruns",
		WithDescription("The number of schedule actions that were dropped due to the action buffer being full"),
	)
	ScheduleActionSuccess = NewCounterDef(
		"schedule_action_success",
		WithDescription("The number of schedule actions that were successfully taken by a schedule"),
	)
	ScheduleActionErrors = NewCounterDef(
		"schedule_action_errors",
		WithDescription("The number of schedule actions that failed to start"),
	)
	ScheduleCancelWorkflowErrors = NewCounterDef(
		"schedule_cancel_workflow_errors",
		WithDescription("The number of times a schedule got an error trying to cancel a previous run"),
	)
	ScheduleTerminateWorkflowErrors = NewCounterDef(
		"schedule_terminate_workflow_errors",
		WithDescription("The number of times a schedule got an error trying to terminate a previous run"),
	)

	// Force replication
	EncounterZombieWorkflowCount        = NewCounterDef("encounter_zombie_workflow_count")
	EncounterNotFoundWorkflowCount      = NewCounterDef("encounter_not_found_workflow_count")
	EncounterPassRetentionWorkflowCount = NewCounterDef("encounter_pass_retention_workflow_count")
	GenerateReplicationTasksLatency     = NewTimerDef("generate_replication_tasks_latency")
	VerifyReplicationTaskSuccess        = NewCounterDef("verify_replication_task_success")
	VerifyReplicationTaskNotFound       = NewCounterDef("verify_replication_task_not_found")
	VerifyReplicationTaskFailed         = NewCounterDef("verify_replication_task_failed")
	VerifyReplicationTasksLatency       = NewTimerDef("verify_replication_tasks_latency")
	VerifyDescribeMutableStateLatency   = NewTimerDef("verify_describe_mutable_state_latency")

	// Replication
	NamespaceReplicationTaskAckLevelGauge = NewGaugeDef("namespace_replication_task_ack_level")
	NamespaceReplicationDLQAckLevelGauge  = NewGaugeDef("namespace_dlq_ack_level")
	NamespaceReplicationDLQMaxLevelGauge  = NewGaugeDef("namespace_dlq_max_level")

	// Persistence
	PersistenceRequests = NewCounterDef(
		"persistence_requests",
		WithDescription("Persistence requests, keyed by `operation`"),
	)
	PersistenceFailures      = NewCounterDef("persistence_errors")
	PersistenceErrorWithType = NewCounterDef(
		"persistence_error_with_type",
		WithDescription("Persistence errors, keyed by `error_type`"),
	)
	PersistenceLatency = NewTimerDef(
		"persistence_latency",
		WithDescription("Persistence latency, keyed by `operation`"),
	)
	PersistenceShardRPS                    = NewDimensionlessHistogramDef("persistence_shard_rps")
	PersistenceErrResourceExhaustedCounter = NewCounterDef("persistence_errors_resource_exhausted")
	VisibilityPersistenceRequests          = NewCounterDef("visibility_persistence_requests")
	VisibilityPersistenceErrorWithType     = NewCounterDef("visibility_persistence_error_with_type")
	VisibilityPersistenceFailures          = NewCounterDef("visibility_persistence_errors")
	VisibilityPersistenceResourceExhausted = NewCounterDef("visibility_persistence_resource_exhausted")
	VisibilityPersistenceLatency           = NewTimerDef("visibility_persistence_latency")
)

var NoopCounterMetricFunc = CounterFunc(func(i int64, t ...Tag) {})

var NoopGaugeMetricFunc = GaugeFunc(func(f float64, t ...Tag) {})

var NoopHistogramMetricFunc = HistogramFunc(func(i int64, t ...Tag) {})

var NoopTimerMetricFunc = TimerFunc(func(d time.Duration, t ...Tag) {})

var RuntimeMetricsReporterLifetimeHooksModule = fx.Options(
	fx.Invoke(RuntimeMetricsReporterLifetimeHooks),
)

var RuntimeMetricsReporterModule = fx.Options(
	RuntimeMetricsReporterLifetimeHooksModule,
)

var StickyTaskQueueTag = TaskQueueTag("__sticky__")

Functions

func AddMetricsContext

func AddMetricsContext(ctx context.Context) context.Context

func CapturePanic

func CapturePanic(logger log.Logger, metricHandler Handler, retError *error)

CapturePanic is used to capture panic, it will emit the service panic metric, log the panic and also return the error through pointer. If the panic value is not error then a default error is returned We have to use pointer is because in golang: "recover return nil if was not called directly by a deferred function." And we have to set the returned error otherwise our handler will return nil as error which is incorrect

func ContextCounterAdd

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

ContextCounterAdd adds value to counter within metrics context.

func ContextCounterGet

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

ContextCounterGet returns value and true if successfully retrieved value

func NewBytesHistogramDef

func NewBytesHistogramDef(name string, opts ...Option) metricDefinition

func NewClientMetricsTrailerPropagatorInterceptor

func NewClientMetricsTrailerPropagatorInterceptor(logger log.Logger) grpc.UnaryClientInterceptor

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

func NewCounterDef

func NewCounterDef(name string, opts ...Option) metricDefinition

func NewDimensionlessHistogramDef

func NewDimensionlessHistogramDef(name string, opts ...Option) metricDefinition

func NewGaugeDef

func NewGaugeDef(name string, opts ...Option) metricDefinition

func NewOpenTelemetryProvider

func NewOpenTelemetryProvider(
	logger log.Logger,
	prometheusConfig *PrometheusConfig,
	clientConfig *ClientConfig,
) (*openTelemetryProviderImpl, error)

func NewOtelMetricsHandler

func NewOtelMetricsHandler(
	l log.Logger,
	o OpenTelemetryProvider,
	cfg ClientConfig,
) (*otelMetricsHandler, error)

NewOtelMetricsHandler returns a new Handler that uses the provided OpenTelemetry metric.Meter to record metrics. This OTel handler supports metric descriptions for metrics registered with the New*Def functions. However, those functions must be called before this constructor. Otherwise, the descriptions will be empty. This is because the OTel metric descriptions are generated from the globalRegistry. You may also record metrics that are not registered via the New*Def functions. In that case, the metric description will be the OTel default (the metric name itself).

func NewScope

func NewScope(logger log.Logger, c *Config) 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: statsd > prometheus

func NewServerMetricsContextInjectorInterceptor

func NewServerMetricsContextInjectorInterceptor() grpc.UnaryServerInterceptor

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

func NewServerMetricsTrailerPropagatorInterceptor

func NewServerMetricsTrailerPropagatorInterceptor(logger log.Logger) grpc.UnaryServerInterceptor

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

func NewTallyMetricsHandler

func NewTallyMetricsHandler(cfg ClientConfig, scope tally.Scope) *tallyMetricsHandler

func NewTimerDef

func NewTimerDef(name string, opts ...Option) metricDefinition

func RuntimeMetricsReporterLifetimeHooks

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

Types

type ClientConfig

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"`
	// ExcludeTags is a map from tag name string to tag values string list.
	// Each value present in keys will have relevant tag value replaced with "_tag_excluded_"
	// 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"
	PerUnitHistogramBoundaries map[string][]float64 `yaml:"perUnitHistogramBoundaries"`
}

type Config

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"`
}

Config contains the config items for metrics subsystem

type CounterFunc

type CounterFunc func(int64, ...Tag)

Mostly cribbed from https://github.com/temporalio/sdk-go/blob/master/internal/common/metrics/handler.go and adapted to depend on golang.org/x/exp/event

func (CounterFunc) Record

func (c CounterFunc) Record(v int64, tags ...Tag)

type CounterIface

type CounterIface interface {
	// Record increments the counter value.
	// Tags provided are merged with the source MetricsHandler
	Record(int64, ...Tag)
}

CounterIface is an ever-increasing counter.

type GaugeFunc

type GaugeFunc func(float64, ...Tag)

Mostly cribbed from https://github.com/temporalio/sdk-go/blob/master/internal/common/metrics/handler.go and adapted to depend on golang.org/x/exp/event

func (GaugeFunc) Record

func (c GaugeFunc) Record(v float64, tags ...Tag)

type GaugeIface

type GaugeIface interface {
	// Record updates the gauge value.
	// Tags provided are merged with the source MetricsHandler
	Record(float64, ...Tag)
}

GaugeIface can be set to any float and repesents a latest value instrument.

type Handler

type Handler interface {
	// WithTags creates a new MetricProvder with provided []Tag
	// Tags are merged with registered Tags from the source MetricsHandler
	WithTags(...Tag) Handler

	// Counter obtains a counter for the given name.
	Counter(string) CounterIface

	// Gauge obtains a gauge for the given name.
	Gauge(string) GaugeIface

	// Timer obtains a timer for the given name.
	Timer(string) TimerIface

	// Histogram obtains a histogram for the given name.
	Histogram(string, MetricUnit) HistogramIface

	Stop(log.Logger)
}

Handler is a wrapper around a metrics client

var (
	NoopMetricsHandler Handler = newNoopMetricsHandler()
)

func GetPerTaskQueueScope

func GetPerTaskQueueScope(
	handler Handler,
	namespaceName string,
	taskQueueName string,
	taskQueueKind enumspb.TaskQueueKind,
) Handler

func MetricsHandlerFromConfig

func MetricsHandlerFromConfig(logger log.Logger, c *Config) (Handler, error)

MetricsHandlerFromConfig is used at startup to construct a MetricsHandler

type HistogramFunc

type HistogramFunc func(int64, ...Tag)

Mostly cribbed from https://github.com/temporalio/sdk-go/blob/master/internal/common/metrics/handler.go and adapted to depend on golang.org/x/exp/event

func (HistogramFunc) Record

func (c HistogramFunc) Record(v int64, tags ...Tag)

type HistogramIface

type HistogramIface interface {
	// Record adds a value to the distribution
	// Tags provided are merged with the source MetricsHandler
	Record(int64, ...Tag)
}

HistogramIface records a distribution of values.

type HistogramObjective

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

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

type MetricUnit

type MetricUnit string

types used/defined by the package

type MockCounterIface

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

MockCounterIface is a mock of CounterIface interface.

func NewMockCounterIface

func NewMockCounterIface(ctrl *gomock.Controller) *MockCounterIface

NewMockCounterIface creates a new mock instance.

func (*MockCounterIface) EXPECT

func (m *MockCounterIface) EXPECT() *MockCounterIfaceMockRecorder

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

func (*MockCounterIface) Record

func (m *MockCounterIface) Record(arg0 int64, arg1 ...Tag)

Record mocks base method.

type MockCounterIfaceMockRecorder

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

MockCounterIfaceMockRecorder is the mock recorder for MockCounterIface.

func (*MockCounterIfaceMockRecorder) Record

func (mr *MockCounterIfaceMockRecorder) Record(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Record indicates an expected call of Record.

type MockGaugeIface

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

MockGaugeIface is a mock of GaugeIface interface.

func NewMockGaugeIface

func NewMockGaugeIface(ctrl *gomock.Controller) *MockGaugeIface

NewMockGaugeIface creates a new mock instance.

func (*MockGaugeIface) EXPECT

func (m *MockGaugeIface) EXPECT() *MockGaugeIfaceMockRecorder

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

func (*MockGaugeIface) Record

func (m *MockGaugeIface) Record(arg0 float64, arg1 ...Tag)

Record mocks base method.

type MockGaugeIfaceMockRecorder

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

MockGaugeIfaceMockRecorder is the mock recorder for MockGaugeIface.

func (*MockGaugeIfaceMockRecorder) Record

func (mr *MockGaugeIfaceMockRecorder) Record(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Record indicates an expected call of Record.

type MockHandler

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

MockHandler is a mock of Handler interface.

func NewMockHandler

func NewMockHandler(ctrl *gomock.Controller) *MockHandler

NewMockHandler creates a new mock instance.

func (*MockHandler) Counter

func (m *MockHandler) Counter(arg0 string) CounterIface

Counter mocks base method.

func (*MockHandler) EXPECT

func (m *MockHandler) EXPECT() *MockHandlerMockRecorder

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

func (*MockHandler) Gauge

func (m *MockHandler) Gauge(arg0 string) GaugeIface

Gauge mocks base method.

func (*MockHandler) Histogram

func (m *MockHandler) Histogram(arg0 string, arg1 MetricUnit) HistogramIface

Histogram mocks base method.

func (*MockHandler) Stop

func (m *MockHandler) Stop(arg0 log.Logger)

Stop mocks base method.

func (*MockHandler) Timer

func (m *MockHandler) Timer(arg0 string) TimerIface

Timer mocks base method.

func (*MockHandler) WithTags

func (m *MockHandler) WithTags(arg0 ...Tag) Handler

WithTags mocks base method.

type MockHandlerMockRecorder

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

MockHandlerMockRecorder is the mock recorder for MockHandler.

func (*MockHandlerMockRecorder) Counter

func (mr *MockHandlerMockRecorder) Counter(arg0 interface{}) *gomock.Call

Counter indicates an expected call of Counter.

func (*MockHandlerMockRecorder) Gauge

func (mr *MockHandlerMockRecorder) Gauge(arg0 interface{}) *gomock.Call

Gauge indicates an expected call of Gauge.

func (*MockHandlerMockRecorder) Histogram

func (mr *MockHandlerMockRecorder) Histogram(arg0, arg1 interface{}) *gomock.Call

Histogram indicates an expected call of Histogram.

func (*MockHandlerMockRecorder) Stop

func (mr *MockHandlerMockRecorder) Stop(arg0 interface{}) *gomock.Call

Stop indicates an expected call of Stop.

func (*MockHandlerMockRecorder) Timer

func (mr *MockHandlerMockRecorder) Timer(arg0 interface{}) *gomock.Call

Timer indicates an expected call of Timer.

func (*MockHandlerMockRecorder) WithTags

func (mr *MockHandlerMockRecorder) WithTags(arg0 ...interface{}) *gomock.Call

WithTags indicates an expected call of WithTags.

type MockHistogramIface

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

MockHistogramIface is a mock of HistogramIface interface.

func NewMockHistogramIface

func NewMockHistogramIface(ctrl *gomock.Controller) *MockHistogramIface

NewMockHistogramIface creates a new mock instance.

func (*MockHistogramIface) EXPECT

func (m *MockHistogramIface) EXPECT() *MockHistogramIfaceMockRecorder

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

func (*MockHistogramIface) Record

func (m *MockHistogramIface) Record(arg0 int64, arg1 ...Tag)

Record mocks base method.

type MockHistogramIfaceMockRecorder

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

MockHistogramIfaceMockRecorder is the mock recorder for MockHistogramIface.

func (*MockHistogramIfaceMockRecorder) Record

func (mr *MockHistogramIfaceMockRecorder) Record(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Record indicates an expected call of Record.

type MockTimerIface

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

MockTimerIface is a mock of TimerIface interface.

func NewMockTimerIface

func NewMockTimerIface(ctrl *gomock.Controller) *MockTimerIface

NewMockTimerIface creates a new mock instance.

func (*MockTimerIface) EXPECT

func (m *MockTimerIface) EXPECT() *MockTimerIfaceMockRecorder

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

func (*MockTimerIface) Record

func (m *MockTimerIface) Record(arg0 time.Duration, arg1 ...Tag)

Record mocks base method.

type MockTimerIfaceMockRecorder

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

MockTimerIfaceMockRecorder is the mock recorder for MockTimerIface.

func (*MockTimerIfaceMockRecorder) Record

func (mr *MockTimerIfaceMockRecorder) Record(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Record indicates an expected call of Record.

type OpenTelemetryProvider

type OpenTelemetryProvider interface {
	Stop(logger log.Logger)
	GetMeter() metric.Meter
}

type Option

type Option interface {
	// contains filtered or unexported methods
}

Option is used to configure a metric definition. Note that options are currently only supported when using the Prometheus reporter with the OpenTelemetry framework.

type PrometheusConfig

type PrometheusConfig struct {
	// Metric framework: Tally/OpenTelemetry
	Framework string `yaml:"framework"`
	// Address for prometheus to serve metrics from.
	ListenAddress string `yaml:"listenAddress"`

	// 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 is always histogram.
	TimerType string `yaml:"timerType"`

	// Deprecated. Please use PerUnitHistogramBoundaries in ClientConfig.
	// DefaultHistogramBoundaries defines the default histogram bucket boundaries for tally timer metrics.
	DefaultHistogramBoundaries []float64 `yaml:"defaultHistogramBoundaries"`

	// Deprecated. Please use PerUnitHistogramBoundaries in ClientConfig.
	// DefaultHistogramBuckets if specified will set the default histogram
	// buckets to be used by the reporter for tally timer metrics.
	// The unit for value specified is Second.
	// If specified, will override DefaultSummaryObjectives and PerUnitHistogramBoundaries["milliseconds"].
	DefaultHistogramBuckets []HistogramObjective `yaml:"defaultHistogramBuckets"`

	// Deprecated. DefaultSummaryObjectives if specified will set the default summary
	// objectives to be used by the reporter.
	// The unit for value specified is Second.
	// If specified, will override PerUnitHistogramBoundaries["milliseconds"].
	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"`

	// Deprecated. SanitizeOptions is an optional field that enables a user to
	// specify which characters are valid and/or should be replaced before metrics
	// are emitted.
	SanitizeOptions *SanitizeOptions `yaml:"sanitizeOptions"`
}

PrometheusConfig is a new format for config for prometheus metrics.

type ReasonString

type ReasonString string

ReasonString is just a string but the special type is defined here to remind callers of ReasonTag to limit the cardinality of possible reasons.

type RuntimeMetricsReporter

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

RuntimeMetricsReporter A struct containing the state of the RuntimeMetricsReporter.

func NewRuntimeMetricsReporter

func NewRuntimeMetricsReporter(
	handler Handler,
	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 SanitizeOptions

type SanitizeOptions struct {
	NameCharacters       *ValidCharacters `yaml:"nameChars"`
	KeyCharacters        *ValidCharacters `yaml:"keyChars"`
	ValueCharacters      *ValidCharacters `yaml:"valueChars"`
	ReplacementCharacter string           `yaml:"replacementChar"`
}

type SanitizeRange

type SanitizeRange struct {
	StartRange string `yaml:"startRange"`
	EndRange   string `yaml:"endRange"`
}

type StatsdConfig

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"`
	// Reporter allows additional configuration of the stats reporter, e.g. with custom tagging options.
	Reporter StatsdReporterConfig `yaml:"reporter"`
}

StatsdConfig contains the config items for statsd metrics reporter

type StatsdReporterConfig

type StatsdReporterConfig struct {
	// TagSeparator allows tags to be appended with a separator. If not specified tag keys and values
	// are embedded to the stat name directly.
	TagSeparator string `yaml:"tagSeparator"`
}

type SummaryObjective

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

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

type Tag

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

Tag is an interface to define metrics tags

func ActionType

func ActionType(value string) Tag

func ActivityTypeTag

func ActivityTypeTag(value string) Tag

ActivityTypeTag returns a new activity type tag.

func AdvancedVisibilityTypeTag

func AdvancedVisibilityTypeTag() Tag

func CacheTypeTag

func CacheTypeTag(value string) Tag

func CommandTypeTag

func CommandTypeTag(value string) Tag

CommandTypeTag returns a new command type tag.

func FailureTag

func FailureTag(value string) Tag

Returns a new failure type tag

func FromClusterIDTag

func FromClusterIDTag(value int32) Tag

FromClusterIDTag returns a new from cluster tag.

func HttpStatusTag

func HttpStatusTag(value int) Tag

HttpStatusTag returns a new httpStatusTag.

func InstanceTag

func InstanceTag(value string) Tag

InstanceTag returns a new instance tag

func NamespaceStateTag

func NamespaceStateTag(value string) Tag

NamespaceStateTag returns a new namespace state tag.

func NamespaceTag

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

func NamespaceUnknownTag() Tag

NamespaceUnknownTag returns a new namespace:unknown tag-value

func OperationTag

func OperationTag(value string) Tag

func QueueActionTag

func QueueActionTag(value string) Tag

func QueueReaderIDTag

func QueueReaderIDTag(readerID int64) Tag

func QueueTypeTag

func QueueTypeTag(value string) Tag

func ReasonTag

func ReasonTag(value ReasonString) Tag

ReasonTag is a generic tag can be used anywhere a reason is needed. Make sure that the value is of limited cardinality.

func ReplicationTaskTypeTag

func ReplicationTaskTypeTag(value enumsspb.ReplicationTaskType) Tag

ReplicationTaskTypeTag returns a new replication task type tag.

func ResourceExhaustedCauseTag

func ResourceExhaustedCauseTag(cause enumspb.ResourceExhaustedCause) Tag

func ServiceErrorTypeTag

func ServiceErrorTypeTag(err error) Tag

func ServiceNameTag

func ServiceNameTag(value primitives.ServiceName) Tag

func ServiceRoleTag

func ServiceRoleTag(value string) Tag

Returns a new service role tag.

func StandardVisibilityTypeTag

func StandardVisibilityTypeTag() Tag

func StringTag

func StringTag(key string, value string) Tag

func TargetClusterTag

func TargetClusterTag(value string) Tag

TargetClusterTag returns a new target cluster tag.

func TaskCategoryTag

func TaskCategoryTag(value string) Tag

func TaskPriorityTag

func TaskPriorityTag(value string) Tag

func TaskQueueTag

func TaskQueueTag(value string) Tag

TaskQueueTag returns a new task queue tag.

func TaskQueueTypeTag

func TaskQueueTypeTag(tqType enumspb.TaskQueueType) Tag

func TaskQueueUnknownTag

func TaskQueueUnknownTag() Tag

TaskQueueUnknownTag returns a new taskqueue:unknown tag-value

func TaskTypeTag

func TaskTypeTag(value string) Tag

func ToClusterIDTag

func ToClusterIDTag(value int32) Tag

ToClusterIDTag returns a new to cluster tag.

func VersionedTag

func VersionedTag(versioned bool) Tag

VersionedTag represents whether a loaded task queue manager represents a specific version set.

func VisibilityTypeTag

func VisibilityTypeTag(value string) Tag

func WorkflowTypeTag

func WorkflowTypeTag(value string) Tag

WorkflowTypeTag returns a new workflow type tag.

type TimerFunc

type TimerFunc func(time.Duration, ...Tag)

Mostly cribbed from https://github.com/temporalio/sdk-go/blob/master/internal/common/metrics/handler.go and adapted to depend on golang.org/x/exp/event

func (TimerFunc) Record

func (c TimerFunc) Record(v time.Duration, tags ...Tag)

type TimerIface

type TimerIface interface {
	// Record sets the timer value.
	// Tags provided are merged with the source MetricsHandler
	Record(time.Duration, ...Tag)
}

TimerIface records time durations.

type ValidCharacters

type ValidCharacters struct {
	Ranges         []SanitizeRange `yaml:"ranges"`
	SafeCharacters string          `yaml:"safeChars"`
}

type WithDescription

type WithDescription string

WithDescription sets the description, or "help text", of a metric. See ServiceRequests for an example.

type WithUnit

type WithUnit MetricUnit

WithUnit sets the unit of a metric. See NewBytesHistogramDef for an example.