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
- type CounterIface
- type GaugeFunc
- type GaugeIface
- type Handler
- type HistogramFunc
- type HistogramIface
- type HistogramObjective
- type MetricUnit
- type MockCounterIface
- type MockCounterIfaceMockRecorder
- type MockGaugeIface
- type MockGaugeIfaceMockRecorder
- type 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
- type MockHistogramIfaceMockRecorder
- type MockTimerIface
- type MockTimerIfaceMockRecorder
- type OpenTelemetryProvider
- type Option
- type PrometheusConfig
- type ReasonString
- type RuntimeMetricsReporter
- 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
- 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") ServiceErrAuthorizeFailedCounter = NewCounterDef("service_errors_authorize_failed") ActionCounter = NewCounterDef("action") TlsCertsExpired = NewGaugeDef("certificates_expired") TlsCertsExpiring = NewGaugeDef("certificates_expiring") ServiceAuthorizationLatency = NewTimerDef("service_authorization_latency") EventBlobSize = NewBytesHistogramDef("event_blob_size") LockRequests = NewCounterDef("lock_requests") LockFailures = NewCounterDef("lock_failures") LockLatency = NewTimerDef("lock_latency") ClientRequests = NewCounterDef( "client_requests", WithDescription("The number of requests sent by the client to an individual service, keyed by `service_role` and `operation`."), ) ClientFailures = NewCounterDef("client_errors") ClientLatency = NewTimerDef("client_latency") ClientRedirectionRequests = NewCounterDef("client_redirection_requests") ClientRedirectionFailures = NewCounterDef("client_redirection_errors") ClientRedirectionLatency = NewTimerDef("client_redirection_latency") StateTransitionCount = NewDimensionlessHistogramDef("state_transition_count") HistorySize = NewBytesHistogramDef("history_size") HistoryCount = NewDimensionlessHistogramDef("history_count") SearchAttributesSize = NewBytesHistogramDef("search_attributes_size") MemoSize = NewBytesHistogramDef("memo_size") TooManyPendingChildWorkflows = NewCounterDef( "wf_too_many_pending_child_workflows", WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending child workflows to be exceeded. See https://t.mp/limits for more information."), ) TooManyPendingActivities = NewCounterDef( "wf_too_many_pending_activities", WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending activities to be exceeded. See https://t.mp/limits for more information."), ) TooManyPendingCancelRequests = NewCounterDef( "wf_too_many_pending_cancel_requests", WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending cancel requests to be exceeded. See https://t.mp/limits for more information."), ) TooManyPendingSignalsToExternalWorkflows = NewCounterDef( "wf_too_many_pending_external_workflow_signals", WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending signals to external workflows to be exceeded. See https://t.mp/limits for more information."), ) // Frontend AddSearchAttributesWorkflowSuccessCount = NewCounterDef("add_search_attributes_workflow_success") AddSearchAttributesWorkflowFailuresCount = NewCounterDef("add_search_attributes_workflow_failure") DeleteNamespaceWorkflowSuccessCount = NewCounterDef("delete_namespace_workflow_success") DeleteNamespaceWorkflowFailuresCount = NewCounterDef("delete_namespace_workflow_failure") VersionCheckSuccessCount = NewCounterDef("version_check_success") VersionCheckFailedCount = NewCounterDef("version_check_failed") VersionCheckRequestFailedCount = NewCounterDef("version_check_request_failed") VersionCheckLatency = NewTimerDef("version_check_latency") HTTPServiceRequests = NewCounterDef( "http_service_requests", WithDescription("The number of HTTP requests received by the service."), ) // History CacheRequests = NewCounterDef("cache_requests") CacheFailures = NewCounterDef("cache_errors") CacheLatency = NewTimerDef("cache_latency") CacheMissCounter = NewCounterDef("cache_miss") HistoryEventNotificationQueueingLatency = NewTimerDef("history_event_notification_queueing_latency") HistoryEventNotificationFanoutLatency = NewTimerDef("history_event_notification_fanout_latency") HistoryEventNotificationInFlightMessageGauge = NewGaugeDef("history_event_notification_inflight_message_gauge") HistoryEventNotificationFailDeliveryCount = NewCounterDef("history_event_notification_fail_delivery_count") // ArchivalTaskInvalidURI is emitted by the archival queue task executor when the history or visibility URI for an // archival task is not a valid URI. // We may emit this metric several times for a single task if the task is retried. ArchivalTaskInvalidURI = NewCounterDef("archival_task_invalid_uri") ArchiverClientSendSignalCount = NewCounterDef("archiver_client_sent_signal") ArchiverClientSendSignalFailureCount = NewCounterDef("archiver_client_send_signal_error") ArchiverClientHistoryRequestCount = NewCounterDef("archiver_client_history_request") ArchiverClientHistoryInlineArchiveAttemptCount = NewCounterDef("archiver_client_history_inline_archive_attempt") ArchiverClientHistoryInlineArchiveFailureCount = NewCounterDef("archiver_client_history_inline_archive_failure") ArchiverClientVisibilityRequestCount = NewCounterDef("archiver_client_visibility_request") ArchiverClientVisibilityInlineArchiveAttemptCount = NewCounterDef("archiver_client_visibility_inline_archive_attempt") ArchiverClientVisibilityInlineArchiveFailureCount = NewCounterDef("archiver_client_visibility_inline_archive_failure") ArchiverArchiveLatency = NewTimerDef("archiver_archive_latency") ArchiverArchiveTargetLatency = NewTimerDef("archiver_archive_target_latency") ShardContextClosedCounter = NewCounterDef("shard_closed_count") ShardContextCreatedCounter = NewCounterDef("sharditem_created_count") ShardContextRemovedCounter = NewCounterDef("sharditem_removed_count") ShardContextAcquisitionLatency = NewTimerDef("sharditem_acquisition_latency") ShardInfoImmediateQueueLagHistogram = NewDimensionlessHistogramDef( "shardinfo_immediate_queue_lag", WithDescription("A histogram across history shards for the difference between the smallest taskID of pending history tasks and the last generated history task ID."), ) ShardInfoScheduledQueueLagTimer = NewTimerDef( "shardinfo_scheduled_queue_lag", WithDescription("A histogram across history shards for the difference between the earliest scheduled time of pending history tasks and current time."), ) SyncShardFromRemoteCounter = NewCounterDef("syncshard_remote_count") SyncShardFromRemoteFailure = NewCounterDef("syncshard_remote_failed") TaskRequests = NewCounterDef( "task_requests", WithDescription("The number of history tasks processed."), ) TaskLoadLatency = NewTimerDef( "task_latency_load", WithDescription("Latency from history task generation to loading into memory (persistence schedule to start latency)."), ) TaskScheduleLatency = NewTimerDef( "task_latency_schedule", WithDescription("Latency from history task loading to start processing (in-memory schedule to start latency)."), ) TaskProcessingLatency = NewTimerDef( "task_latency_processing", WithDescription("Latency for processing a history task one time."), ) TaskLatency = NewTimerDef( "task_latency", WithDescription("Latency for procsssing and completing a history task. This latency is across all attempts but excludes any latencies related to workflow lock or user qutoa limit."), ) TaskQueueLatency = NewTimerDef( "task_latency_queue", WithDescription("End-to-end latency for processing and completing a history task, from task generation to completion."), ) TaskAttempt = NewDimensionlessHistogramDef( "task_attempt", WithDescription("The number of attempts took to complete a history task."), ) TaskFailures = NewCounterDef( "task_errors", WithDescription("The number of unexpected history task processing errors."), ) TaskDiscarded = NewCounterDef("task_errors_discarded") TaskSkipped = NewCounterDef("task_skipped") TaskVersionMisMatch = NewCounterDef("task_errors_version_mismatch") TasksDependencyTaskNotCompleted = NewCounterDef("task_dependency_task_not_completed") TaskStandbyRetryCounter = NewCounterDef("task_errors_standby_retry_counter") TaskWorkflowBusyCounter = NewCounterDef( "task_errors_workflow_busy", WithDescription("The number of history task processing errors caused by failing to acquire workflow lock within the configured timeout (history.cacheNonUserContextLockTimeout)."), ) TaskNotActiveCounter = NewCounterDef("task_errors_not_active_counter") TaskNamespaceHandoverCounter = NewCounterDef("task_errors_namespace_handover") TaskInternalErrorCounter = NewCounterDef("task_errors_internal") TaskThrottledCounter = NewCounterDef( "task_errors_throttled", WithDescription("The number of history task processing errors caused by resource exhausted errors, excluding workflow busy case."), ) TaskCorruptionCounter = NewCounterDef("task_errors_corruption") TaskScheduleToStartLatency = NewTimerDef("task_schedule_to_start_latency") TaskBatchCompleteCounter = NewCounterDef("task_batch_complete_counter") TaskReschedulerPendingTasks = NewDimensionlessHistogramDef("task_rescheduler_pending_tasks") PendingTasksCounter = NewDimensionlessHistogramDef( "pending_tasks", WithDescription("A histogram across history shards for the number of in-memory pending history tasks."), ) TaskSchedulerThrottled = NewCounterDef("task_scheduler_throttled") QueueScheduleLatency = NewTimerDef("queue_latency_schedule") // latency for scheduling 100 tasks in one task channel QueueReaderCountHistogram = NewDimensionlessHistogramDef("queue_reader_count") QueueSliceCountHistogram = NewDimensionlessHistogramDef("queue_slice_count") QueueActionCounter = NewCounterDef("queue_actions") QueueActionFailures = NewCounterDef("queue_action_errors") ActivityE2ELatency = NewTimerDef("activity_end_to_end_latency") AckLevelUpdateCounter = NewCounterDef("ack_level_update") AckLevelUpdateFailedCounter = NewCounterDef("ack_level_update_failed") CommandTypeScheduleActivityCounter = NewCounterDef("schedule_activity_command") CommandTypeCompleteWorkflowCounter = NewCounterDef("complete_workflow_command") CommandTypeFailWorkflowCounter = NewCounterDef("fail_workflow_command") CommandTypeCancelWorkflowCounter = NewCounterDef("cancel_workflow_command") CommandTypeStartTimerCounter = NewCounterDef("start_timer_command") CommandTypeCancelActivityCounter = NewCounterDef("cancel_activity_command") CommandTypeCancelTimerCounter = NewCounterDef("cancel_timer_command") CommandTypeRecordMarkerCounter = NewCounterDef("record_marker_command") CommandTypeCancelExternalWorkflowCounter = NewCounterDef("cancel_external_workflow_command") CommandTypeContinueAsNewCounter = NewCounterDef("continue_as_new_command") CommandTypeSignalExternalWorkflowCounter = NewCounterDef("signal_external_workflow_command") CommandTypeUpsertWorkflowSearchAttributesCounter = NewCounterDef("upsert_workflow_search_attributes_command") CommandTypeModifyWorkflowPropertiesCounter = NewCounterDef("modify_workflow_properties_command") CommandTypeChildWorkflowCounter = NewCounterDef("child_workflow_command") CommandTypeProtocolMessage = NewCounterDef("protocol_message_command") MessageTypeRequestWorkflowExecutionUpdateCounter = NewCounterDef("request_workflow_update_message") MessageTypeAcceptWorkflowExecutionUpdateCounter = NewCounterDef("accept_workflow_update_message") MessageTypeRespondWorkflowExecutionUpdateCounter = NewCounterDef("respond_workflow_update_message") MessageTypeRejectWorkflowExecutionUpdateCounter = NewCounterDef("reject_workflow_update_message") InvalidStateTransitionWorkflowExecutionUpdateCounter = NewCounterDef("invalid_state_transition_workflow_update_message") ActivityEagerExecutionCounter = NewCounterDef("activity_eager_execution") // WorkflowEagerExecutionCounter is emitted any time eager workflow start is requested. WorkflowEagerExecutionCounter = NewCounterDef("workflow_eager_execution") // WorkflowEagerExecutionDeniedCounter is emitted any time eager workflow start is requested and the serer fell back // to standard dispatch. // Timeouts and failures are not counted in this metric. // This metric has a "reason" tag attached to it to understand why eager start was denied. WorkflowEagerExecutionDeniedCounter = NewCounterDef("workflow_eager_execution_denied") EmptyCompletionCommandsCounter = NewCounterDef("empty_completion_commands") MultipleCompletionCommandsCounter = NewCounterDef("multiple_completion_commands") FailedWorkflowTasksCounter = NewCounterDef("failed_workflow_tasks") WorkflowTaskAttempt = NewDimensionlessHistogramDef("workflow_task_attempt") StaleMutableStateCounter = NewCounterDef("stale_mutable_state") AutoResetPointsLimitExceededCounter = NewCounterDef("auto_reset_points_exceed_limit") AutoResetPointCorruptionCounter = NewCounterDef("auto_reset_point_corruption") ConcurrencyUpdateFailureCounter = NewCounterDef("concurrency_update_failure") ServiceErrShardOwnershipLostCounter = NewCounterDef("service_errors_shard_ownership_lost") HeartbeatTimeoutCounter = NewCounterDef("heartbeat_timeout") ScheduleToStartTimeoutCounter = NewCounterDef("schedule_to_start_timeout") StartToCloseTimeoutCounter = NewCounterDef("start_to_close_timeout") ScheduleToCloseTimeoutCounter = NewCounterDef("schedule_to_close_timeout") NewTimerNotifyCounter = NewCounterDef("new_timer_notifications") AcquireShardsCounter = NewCounterDef("acquire_shards_count") AcquireShardsLatency = NewTimerDef("acquire_shards_latency") MembershipChangedCounter = NewCounterDef("membership_changed_count") NumShardsGauge = NewGaugeDef("numshards_gauge") GetEngineForShardErrorCounter = NewCounterDef("get_engine_for_shard_errors") GetEngineForShardLatency = NewTimerDef("get_engine_for_shard_latency") RemoveEngineForShardLatency = NewTimerDef("remove_engine_for_shard_latency") CompleteWorkflowTaskWithStickyEnabledCounter = NewCounterDef("complete_workflow_task_sticky_enabled_count") CompleteWorkflowTaskWithStickyDisabledCounter = NewCounterDef("complete_workflow_task_sticky_disabled_count") WorkflowTaskHeartbeatTimeoutCounter = NewCounterDef("workflow_task_heartbeat_timeout_count") DuplicateReplicationEventsCounter = NewCounterDef("duplicate_replication_events") AcquireLockFailedCounter = NewCounterDef("acquire_lock_failed") WorkflowContextCleared = NewCounterDef("workflow_context_cleared") MutableStateSize = NewBytesHistogramDef( "mutable_state_size", WithDescription("The size of an individual Workflow Execution's state, emitted each time a workflow execution is retrieved or updated."), ) ExecutionInfoSize = NewBytesHistogramDef("execution_info_size") ExecutionStateSize = NewBytesHistogramDef("execution_state_size") ActivityInfoSize = NewBytesHistogramDef("activity_info_size") TimerInfoSize = NewBytesHistogramDef("timer_info_size") ChildInfoSize = NewBytesHistogramDef("child_info_size") RequestCancelInfoSize = NewBytesHistogramDef("request_cancel_info_size") SignalInfoSize = NewBytesHistogramDef("signal_info_size") SignalRequestIDSize = NewBytesHistogramDef("signal_request_id_size") BufferedEventsSize = NewBytesHistogramDef("buffered_events_size") ActivityInfoCount = NewDimensionlessHistogramDef("activity_info_count") TimerInfoCount = NewDimensionlessHistogramDef("timer_info_count") ChildInfoCount = NewDimensionlessHistogramDef("child_info_count") SignalInfoCount = NewDimensionlessHistogramDef("signal_info_count") RequestCancelInfoCount = NewDimensionlessHistogramDef("request_cancel_info_count") SignalRequestIDCount = NewDimensionlessHistogramDef("signal_request_id_count") BufferedEventsCount = NewDimensionlessHistogramDef("buffered_events_count") TaskCount = NewDimensionlessHistogramDef("task_count") TotalActivityCount = NewDimensionlessHistogramDef("total_activity_count") TotalUserTimerCount = NewDimensionlessHistogramDef("total_user_timer_count") TotalChildExecutionCount = NewDimensionlessHistogramDef("total_child_execution_count") TotalRequestCancelExternalCount = NewDimensionlessHistogramDef("total_request_cancel_external_count") TotalSignalExternalCount = NewDimensionlessHistogramDef("total_signal_external_count") TotalSignalCount = NewDimensionlessHistogramDef("total_signal_count") WorkflowRetryBackoffTimerCount = NewCounterDef("workflow_retry_backoff_timer") WorkflowCronBackoffTimerCount = NewCounterDef("workflow_cron_backoff_timer") WorkflowDelayedStartBackoffTimerCount = NewCounterDef("workflow_delayed_start_backoff_timer") WorkflowCleanupDeleteCount = NewCounterDef("workflow_cleanup_delete") WorkflowCleanupArchiveCount = NewCounterDef("workflow_cleanup_archive") WorkflowCleanupNopCount = NewCounterDef("workflow_cleanup_nop") WorkflowCleanupDeleteHistoryInlineCount = NewCounterDef("workflow_cleanup_delete_history_inline") WorkflowSuccessCount = NewCounterDef("workflow_success") WorkflowCancelCount = NewCounterDef("workflow_cancel") WorkflowFailedCount = NewCounterDef("workflow_failed") WorkflowTimeoutCount = NewCounterDef("workflow_timeout") WorkflowTerminateCount = NewCounterDef("workflow_terminate") WorkflowContinuedAsNewCount = NewCounterDef("workflow_continued_as_new") ReplicationTasksSend = NewCounterDef("replication_tasks_send") ReplicationTasksRecv = NewCounterDef("replication_tasks_recv") ReplicationTasksRecvBacklog = NewDimensionlessHistogramDef("replication_tasks_recv_backlog") ReplicationTasksSkipped = NewCounterDef("replication_tasks_skipped") ReplicationTasksApplied = NewCounterDef("replication_tasks_applied") ReplicationTasksFailed = NewCounterDef("replication_tasks_failed") // ReplicationTasksLag is a heuristic for how far behind the remote DC is for a given cluster. It measures the // difference between task IDs so its unit should be "tasks". ReplicationTasksLag = NewDimensionlessHistogramDef("replication_tasks_lag") // ReplicationTasksFetched records the number of tasks fetched by the poller. ReplicationTasksFetched = NewDimensionlessHistogramDef("replication_tasks_fetched") ReplicationLatency = NewTimerDef("replication_latency") ReplicationDLQFailed = NewCounterDef("replication_dlq_enqueue_failed") ReplicationDLQMaxLevelGauge = NewGaugeDef("replication_dlq_max_level") ReplicationDLQAckLevelGauge = NewGaugeDef("replication_dlq_ack_level") ReplicationNonEmptyDLQCount = NewCounterDef("replication_dlq_non_empty") ReplicationOutlierNamespace = NewCounterDef("replication_outlier_namespace") EventReapplySkippedCount = NewCounterDef("event_reapply_skipped_count") DirectQueryDispatchLatency = NewTimerDef("direct_query_dispatch_latency") DirectQueryDispatchStickyLatency = NewTimerDef("direct_query_dispatch_sticky_latency") DirectQueryDispatchNonStickyLatency = NewTimerDef("direct_query_dispatch_non_sticky_latency") DirectQueryDispatchStickySuccessCount = NewCounterDef("direct_query_dispatch_sticky_success") DirectQueryDispatchNonStickySuccessCount = NewCounterDef("direct_query_dispatch_non_sticky_success") DirectQueryDispatchClearStickinessLatency = NewTimerDef("direct_query_dispatch_clear_stickiness_latency") DirectQueryDispatchClearStickinessSuccessCount = NewCounterDef("direct_query_dispatch_clear_stickiness_success") DirectQueryDispatchTimeoutBeforeNonStickyCount = NewCounterDef("direct_query_dispatch_timeout_before_non_sticky") WorkflowTaskQueryLatency = NewTimerDef("workflow_task_query_latency") ConsistentQueryTimeoutCount = NewCounterDef("consistent_query_timeout") QueryBufferExceededCount = NewCounterDef("query_buffer_exceeded") QueryRegistryInvalidStateCount = NewCounterDef("query_registry_invalid_state") WorkflowTaskTimeoutOverrideCount = NewCounterDef("workflow_task_timeout_overrides") WorkflowRunTimeoutOverrideCount = NewCounterDef("workflow_run_timeout_overrides") ReplicationTaskCleanupCount = NewCounterDef("replication_task_cleanup_count") ReplicationTaskCleanupFailure = NewCounterDef("replication_task_cleanup_failed") MutableStateDirty = NewCounterDef("mutable_state_dirty") MutableStateChecksumMismatch = NewCounterDef("mutable_state_checksum_mismatch") MutableStateChecksumInvalidated = NewCounterDef("mutable_state_checksum_invalidated") ClusterMetadataLockLatency = NewTimerDef("cluster_metadata_lock_latency") ClusterMetadataCallbackLockLatency = NewTimerDef("cluster_metadata_callback_lock_latency") ShardControllerLockLatency = NewTimerDef("shard_controller_lock_latency") ShardLockLatency = NewTimerDef("shard_lock_latency") NamespaceRegistryLockLatency = NewTimerDef("namespace_registry_lock_latency") ClosedWorkflowBufferEventCount = NewCounterDef("closed_workflow_buffer_event_counter") InorderBufferedEventsCounter = NewCounterDef("inordered_buffered_events") ShardLingerSuccess = NewTimerDef("shard_linger_success") ShardLingerTimeouts = NewCounterDef("shard_linger_timeouts") DynamicRateLimiterMultiplier = NewGaugeDef("dynamic_rate_limit_multiplier") // Matching MatchingClientForwardedCounter = NewCounterDef("forwarded") MatchingClientInvalidTaskQueueName = NewCounterDef("invalid_task_queue_name") SyncMatchLatencyPerTaskQueue = NewTimerDef("syncmatch_latency") AsyncMatchLatencyPerTaskQueue = NewTimerDef("asyncmatch_latency") PollSuccessPerTaskQueueCounter = NewCounterDef("poll_success") PollTimeoutPerTaskQueueCounter = NewCounterDef("poll_timeouts") PollSuccessWithSyncPerTaskQueueCounter = NewCounterDef("poll_success_sync") LeaseRequestPerTaskQueueCounter = NewCounterDef("lease_requests") LeaseFailurePerTaskQueueCounter = NewCounterDef("lease_failures") ConditionFailedErrorPerTaskQueueCounter = NewCounterDef("condition_failed_errors") RespondQueryTaskFailedPerTaskQueueCounter = NewCounterDef("respond_query_failed") SyncThrottlePerTaskQueueCounter = NewCounterDef("sync_throttle_count") BufferThrottlePerTaskQueueCounter = NewCounterDef("buffer_throttle_count") ExpiredTasksPerTaskQueueCounter = NewCounterDef("tasks_expired") ForwardedPerTaskQueueCounter = NewCounterDef("forwarded_per_tl") ForwardTaskErrorsPerTaskQueue = NewCounterDef("forward_task_errors") LocalToLocalMatchPerTaskQueueCounter = NewCounterDef("local_to_local_matches") LocalToRemoteMatchPerTaskQueueCounter = NewCounterDef("local_to_remote_matches") RemoteToLocalMatchPerTaskQueueCounter = NewCounterDef("remote_to_local_matches") RemoteToRemoteMatchPerTaskQueueCounter = NewCounterDef("remote_to_remote_matches") LoadedTaskQueueGauge = NewGaugeDef("loaded_task_queue_count") TaskQueueStartedCounter = NewCounterDef("task_queue_started") TaskQueueStoppedCounter = NewCounterDef("task_queue_stopped") TaskWriteThrottlePerTaskQueueCounter = NewCounterDef("task_write_throttle_count") TaskWriteLatencyPerTaskQueue = NewTimerDef("task_write_latency") TaskLagPerTaskQueueGauge = NewGaugeDef("task_lag_per_tl") NoRecentPollerTasksPerTaskQueueCounter = NewCounterDef("no_poller_tasks") UnknownBuildPollsCounter = NewCounterDef("unknown_build_polls") UnknownBuildTasksCounter = NewCounterDef("unknown_build_tasks") // Worker ExecutorTasksDoneCount = NewCounterDef("executor_done") ExecutorTasksErrCount = NewCounterDef("executor_err") ExecutorTasksDeferredCount = NewCounterDef("executor_deferred") ExecutorTasksDroppedCount = NewCounterDef("executor_dropped") StartedCount = NewCounterDef("started") StoppedCount = NewCounterDef("stopped") TaskProcessedCount = NewGaugeDef("task_processed") TaskDeletedCount = NewGaugeDef("task_deleted") TaskQueueProcessedCount = NewGaugeDef("taskqueue_processed") TaskQueueDeletedCount = NewGaugeDef("taskqueue_deleted") TaskQueueOutstandingCount = NewGaugeDef("taskqueue_outstanding") HistoryArchiverArchiveNonRetryableErrorCount = NewCounterDef("history_archiver_archive_non_retryable_error") HistoryArchiverArchiveTransientErrorCount = NewCounterDef("history_archiver_archive_transient_error") HistoryArchiverArchiveSuccessCount = NewCounterDef("history_archiver_archive_success") HistoryArchiverTotalUploadSize = NewBytesHistogramDef("history_archiver_total_upload_size") HistoryArchiverHistorySize = NewBytesHistogramDef("history_archiver_history_size") HistoryArchiverDuplicateArchivalsCount = NewCounterDef("history_archiver_duplicate_archivals") HistoryArchiverBlobExistsCount = NewCounterDef("history_archiver_blob_exists") HistoryArchiverBlobSize = NewBytesHistogramDef("history_archiver_blob_size") HistoryWorkflowExecutionCacheLatency = NewTimerDef("history_workflow_execution_cache_latency") VisibilityArchiverArchiveNonRetryableErrorCount = NewCounterDef("visibility_archiver_archive_non_retryable_error") VisibilityArchiverArchiveTransientErrorCount = NewCounterDef("visibility_archiver_archive_transient_error") VisibilityArchiveSuccessCount = NewCounterDef("visibility_archiver_archive_success") HistoryScavengerSuccessCount = NewCounterDef("scavenger_success") HistoryScavengerErrorCount = NewCounterDef("scavenger_errors") HistoryScavengerSkipCount = NewCounterDef("scavenger_skips") ExecutionsOutstandingCount = NewGaugeDef("executions_outstanding") ArchiverNonRetryableErrorCount = NewCounterDef("archiver_non_retryable_error") ArchiverStartedCount = NewCounterDef("archiver_started") ArchiverStoppedCount = NewCounterDef("archiver_stopped") ArchiverCoroutineStartedCount = NewCounterDef("archiver_coroutine_started") ArchiverCoroutineStoppedCount = NewCounterDef("archiver_coroutine_stopped") ArchiverHandleHistoryRequestLatency = NewTimerDef("archiver_handle_history_request_latency") ArchiverHandleVisibilityRequestLatency = NewTimerDef("archiver_handle_visibility_request_latency") ArchiverUploadWithRetriesLatency = NewTimerDef("archiver_upload_with_retries_latency") ArchiverDeleteWithRetriesLatency = NewTimerDef("archiver_delete_with_retries_latency") ArchiverUploadFailedAllRetriesCount = NewCounterDef("archiver_upload_failed_all_retries") ArchiverUploadSuccessCount = NewCounterDef("archiver_upload_success") ArchiverDeleteFailedAllRetriesCount = NewCounterDef("archiver_delete_failed_all_retries") ArchiverDeleteSuccessCount = NewCounterDef("archiver_delete_success") ArchiverHandleVisibilityFailedAllRetiresCount = NewCounterDef("archiver_handle_visibility_failed_all_retries") ArchiverHandleVisibilitySuccessCount = NewCounterDef("archiver_handle_visibility_success") ArchiverBacklogSizeGauge = NewGaugeDef("archiver_backlog_size") ArchiverPumpTimeoutCount = NewCounterDef("archiver_pump_timeout") ArchiverPumpSignalThresholdCount = NewCounterDef("archiver_pump_signal_threshold") ArchiverPumpTimeoutWithoutSignalsCount = NewCounterDef("archiver_pump_timeout_without_signals") ArchiverPumpSignalChannelClosedCount = NewCounterDef("archiver_pump_signal_channel_closed") ArchiverWorkflowStartedCount = NewCounterDef("archiver_workflow_started") ArchiverNumPumpedRequestsCount = NewCounterDef("archiver_num_pumped_requests") ArchiverNumHandledRequestsCount = NewCounterDef("archiver_num_handled_requests") ArchiverPumpedNotEqualHandledCount = NewCounterDef("archiver_pumped_not_equal_handled") ArchiverHandleAllRequestsLatency = NewTimerDef("archiver_handle_all_requests_latency") ArchiverWorkflowStoppingCount = NewCounterDef("archiver_workflow_stopping") ScavengerValidationRequestsCount = NewCounterDef("scavenger_validation_requests") ScavengerValidationFailuresCount = NewCounterDef("scavenger_validation_failures") ScavengerValidationSkipsCount = NewCounterDef("scavenger_validation_skips") AddSearchAttributesFailuresCount = NewCounterDef("add_search_attributes_failures") DeleteNamespaceSuccessCount = NewCounterDef("delete_namespace_success") RenameNamespaceSuccessCount = NewCounterDef("rename_namespace_success") DeleteExecutionsSuccessCount = NewCounterDef("delete_executions_success") DeleteNamespaceFailuresCount = NewCounterDef("delete_namespace_failures") UpdateNamespaceFailuresCount = NewCounterDef("update_namespace_failures") RenameNamespaceFailuresCount = NewCounterDef("rename_namespace_failures") ReadNamespaceFailuresCount = NewCounterDef("read_namespace_failures") ListExecutionsFailuresCount = NewCounterDef("list_executions_failures") CountExecutionsFailuresCount = NewCounterDef("count_executions_failures") DeleteExecutionFailuresCount = NewCounterDef("delete_execution_failures") DeleteExecutionNotFoundCount = NewCounterDef("delete_execution_not_found") RateLimiterFailuresCount = NewCounterDef("rate_limiter_failures") BatcherProcessorSuccess = NewCounterDef( "batcher_processor_requests", WithDescription("The number of individual workflow execution tasks successfully processed by the batch request processor"), ) BatcherProcessorFailures = NewCounterDef("batcher_processor_errors") BatcherOperationFailures = NewCounterDef("batcher_operation_errors") ElasticsearchBulkProcessorRequests = NewCounterDef("elasticsearch_bulk_processor_requests") ElasticsearchBulkProcessorQueuedRequests = NewDimensionlessHistogramDef("elasticsearch_bulk_processor_queued_requests") ElasticsearchBulkProcessorFailures = NewCounterDef("elasticsearch_bulk_processor_errors") ElasticsearchBulkProcessorCorruptedData = NewCounterDef("elasticsearch_bulk_processor_corrupted_data") ElasticsearchBulkProcessorDuplicateRequest = NewCounterDef("elasticsearch_bulk_processor_duplicate_request") ElasticsearchBulkProcessorRequestLatency = NewTimerDef("elasticsearch_bulk_processor_request_latency") ElasticsearchBulkProcessorCommitLatency = NewTimerDef("elasticsearch_bulk_processor_commit_latency") ElasticsearchBulkProcessorWaitAddLatency = NewTimerDef("elasticsearch_bulk_processor_wait_add_latency") ElasticsearchBulkProcessorWaitStartLatency = NewTimerDef("elasticsearch_bulk_processor_wait_start_latency") ElasticsearchBulkProcessorBulkSize = NewDimensionlessHistogramDef("elasticsearch_bulk_processor_bulk_size") ElasticsearchBulkProcessorBulkResquestTookLatency = NewTimerDef("elasticsearch_bulk_processor_bulk_request_took_latency") ElasticsearchDocumentParseFailuresCount = NewCounterDef("elasticsearch_document_parse_failures_counter") ElasticsearchDocumentGenerateFailuresCount = NewCounterDef("elasticsearch_document_generate_failures_counter") ElasticsearchCustomOrderByClauseCount = NewCounterDef("elasticsearch_custom_order_by_clause_counter") CatchUpReadyShardCountGauge = NewGaugeDef("catchup_ready_shard_count") HandoverReadyShardCountGauge = NewGaugeDef("handover_ready_shard_count") ReplicatorMessages = NewCounterDef("replicator_messages") ReplicatorFailures = NewCounterDef("replicator_errors") ReplicatorLatency = NewTimerDef("replicator_latency") ReplicatorDLQFailures = NewCounterDef("replicator_dlq_enqueue_fails") NamespaceReplicationEnqueueDLQCount = NewCounterDef("namespace_replication_dlq_enqueue_requests") ParentClosePolicyProcessorSuccess = NewCounterDef("parent_close_policy_processor_requests") ParentClosePolicyProcessorFailures = NewCounterDef("parent_close_policy_processor_errors") ScheduleMissedCatchupWindow = NewCounterDef( "schedule_missed_catchup_window", WithDescription("The number of times a schedule missed an action due to the configured catchup window"), ) ScheduleRateLimited = NewCounterDef( "schedule_rate_limited", WithDescription("The number of times a schedule action was delayed by more than 1s due to rate limiting"), ) ScheduleBufferOverruns = NewCounterDef( "schedule_buffer_overruns", WithDescription("The number of schedule actions that were dropped due to the action buffer being full"), ) ScheduleActionSuccess = NewCounterDef( "schedule_action_success", WithDescription("The number of schedule actions that were successfully taken by a schedule"), ) ScheduleActionErrors = NewCounterDef( "schedule_action_errors", WithDescription("The number of schedule actions that failed to start"), ) ScheduleCancelWorkflowErrors = NewCounterDef( "schedule_cancel_workflow_errors", WithDescription("The number of times a schedule got an error trying to cancel a previous run"), ) ScheduleTerminateWorkflowErrors = NewCounterDef( "schedule_terminate_workflow_errors", WithDescription("The number of times a schedule got an error trying to terminate a previous run"), ) // Force replication EncounterZombieWorkflowCount = NewCounterDef("encounter_zombie_workflow_count") EncounterNotFoundWorkflowCount = NewCounterDef("encounter_not_found_workflow_count") EncounterPassRetentionWorkflowCount = NewCounterDef("encounter_pass_retention_workflow_count") GenerateReplicationTasksLatency = NewTimerDef("generate_replication_tasks_latency") VerifyReplicationTaskSuccess = NewCounterDef("verify_replication_task_success") VerifyReplicationTaskNotFound = NewCounterDef("verify_replication_task_not_found") VerifyReplicationTaskFailed = NewCounterDef("verify_replication_task_failed") VerifyReplicationTasksLatency = NewTimerDef("verify_replication_tasks_latency") VerifyDescribeMutableStateLatency = NewTimerDef("verify_describe_mutable_state_latency") // Replication NamespaceReplicationTaskAckLevelGauge = NewGaugeDef("namespace_replication_task_ack_level") NamespaceReplicationDLQAckLevelGauge = NewGaugeDef("namespace_dlq_ack_level") NamespaceReplicationDLQMaxLevelGauge = NewGaugeDef("namespace_dlq_max_level") // Persistence PersistenceRequests = NewCounterDef( "persistence_requests", WithDescription("Persistence requests, keyed by `operation`"), ) PersistenceFailures = NewCounterDef("persistence_errors") PersistenceErrorWithType = NewCounterDef( "persistence_error_with_type", WithDescription("Persistence errors, keyed by `error_type`"), ) PersistenceLatency = NewTimerDef( "persistence_latency", WithDescription("Persistence latency, keyed by `operation`"), ) PersistenceShardRPS = NewDimensionlessHistogramDef("persistence_shard_rps") PersistenceErrResourceExhaustedCounter = NewCounterDef("persistence_errors_resource_exhausted") VisibilityPersistenceRequests = NewCounterDef("visibility_persistence_requests") VisibilityPersistenceErrorWithType = NewCounterDef("visibility_persistence_error_with_type") VisibilityPersistenceFailures = NewCounterDef("visibility_persistence_errors") VisibilityPersistenceResourceExhausted = NewCounterDef("visibility_persistence_resource_exhausted") VisibilityPersistenceLatency = NewTimerDef("visibility_persistence_latency") )
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 ¶ added in v1.12.0
func CapturePanic ¶ added in v1.22.0
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 ¶ added in v1.10.0
ContextCounterAdd adds value to counter within metrics context.
func ContextCounterGet ¶ added in v1.10.0
ContextCounterGet returns value and true if successfully retrieved value
func NewBytesHistogramDef ¶ added in v1.14.0
func NewClientMetricsTrailerPropagatorInterceptor ¶ added in v1.10.0
func NewClientMetricsTrailerPropagatorInterceptor(logger log.Logger) grpc.UnaryClientInterceptor
NewClientMetricsTrailerPropagatorInterceptor returns grpc client interceptor that injects metrics received in trailer into metrics context.
func NewCounterDef ¶ added in v1.14.0
func NewDimensionlessHistogramDef ¶ added in v1.14.0
func NewGaugeDef ¶ added in v1.14.0
func NewOpenTelemetryProvider ¶ added in v1.17.0
func NewOpenTelemetryProvider( logger log.Logger, prometheusConfig *PrometheusConfig, clientConfig *ClientConfig, ) (*openTelemetryProviderImpl, error)
func NewOtelMetricsHandler ¶ added in v1.17.0
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 ¶ added in v1.16.0
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 ¶ added in v1.10.0
func NewServerMetricsContextInjectorInterceptor() grpc.UnaryServerInterceptor
NewServerMetricsContextInjectorInterceptor returns grpc server interceptor that adds metrics context to golang context.
func NewServerMetricsTrailerPropagatorInterceptor ¶ added in v1.10.0
func NewServerMetricsTrailerPropagatorInterceptor(logger log.Logger) grpc.UnaryServerInterceptor
NewServerMetricsTrailerPropagatorInterceptor returns grpc server interceptor that injects metrics from context into gRPC trailer.
func NewTallyMetricsHandler ¶ added in v1.17.0
func NewTallyMetricsHandler(cfg ClientConfig, scope tally.Scope) *tallyMetricsHandler
func NewTimerDef ¶ added in v1.14.0
func RuntimeMetricsReporterLifetimeHooks ¶ added in v1.14.0
func RuntimeMetricsReporterLifetimeHooks( lc fx.Lifecycle, reporter *RuntimeMetricsReporter, )
Types ¶
type ClientConfig ¶ added in v1.14.0
type ClientConfig struct { // Tags is the set of key-value pairs to be reported as part of every metric Tags map[string]string `yaml:"tags"` // 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 ¶ added in v1.5.7
type Config struct { ClientConfig `yaml:"clientConfig,inline"` // M3 is the configuration for m3 metrics reporter M3 *m3.Configuration `yaml:"m3"` // Statsd is the configuration for statsd reporter Statsd *StatsdConfig `yaml:"statsd"` // Prometheus is the configuration for prometheus reporter Prometheus *PrometheusConfig `yaml:"prometheus"` }
Config contains the config items for metrics subsystem
type CounterFunc ¶ added in v1.20.0
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 ¶ added in v1.20.0
func (c CounterFunc) Record(v int64, tags ...Tag)
type CounterIface ¶ added in v1.20.0
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 ¶ added in v1.20.0
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
type GaugeIface ¶ added in v1.20.0
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 ¶ added in v1.20.0
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 ¶ added in v1.13.0
type HistogramFunc ¶ added in v1.20.0
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 ¶ added in v1.20.0
func (c HistogramFunc) Record(v int64, tags ...Tag)
type HistogramIface ¶ added in v1.20.0
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 ¶ added in v1.9.0
type HistogramObjective struct {
Upper float64 `yaml:"upper"`
}
Deprecated. HistogramObjective is a Prometheus histogram bucket. Added for backwards compatibility.
type MockCounterIface ¶ added in v1.20.0
type MockCounterIface struct {
// contains filtered or unexported fields
}
MockCounterIface is a mock of CounterIface interface.
func NewMockCounterIface ¶ added in v1.20.0
func NewMockCounterIface(ctrl *gomock.Controller) *MockCounterIface
NewMockCounterIface creates a new mock instance.
func (*MockCounterIface) EXPECT ¶ added in v1.20.0
func (m *MockCounterIface) EXPECT() *MockCounterIfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockCounterIface) Record ¶ added in v1.20.0
func (m *MockCounterIface) Record(arg0 int64, arg1 ...Tag)
Record mocks base method.
type MockCounterIfaceMockRecorder ¶ added in v1.20.0
type MockCounterIfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockCounterIfaceMockRecorder is the mock recorder for MockCounterIface.
func (*MockCounterIfaceMockRecorder) Record ¶ added in v1.20.0
func (mr *MockCounterIfaceMockRecorder) Record(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Record indicates an expected call of Record.
type MockGaugeIface ¶ added in v1.20.0
type MockGaugeIface struct {
// contains filtered or unexported fields
}
MockGaugeIface is a mock of GaugeIface interface.
func NewMockGaugeIface ¶ added in v1.20.0
func NewMockGaugeIface(ctrl *gomock.Controller) *MockGaugeIface
NewMockGaugeIface creates a new mock instance.
func (*MockGaugeIface) EXPECT ¶ added in v1.20.0
func (m *MockGaugeIface) EXPECT() *MockGaugeIfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockGaugeIface) Record ¶ added in v1.20.0
func (m *MockGaugeIface) Record(arg0 float64, arg1 ...Tag)
Record mocks base method.
type MockGaugeIfaceMockRecorder ¶ added in v1.20.0
type MockGaugeIfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockGaugeIfaceMockRecorder is the mock recorder for MockGaugeIface.
func (*MockGaugeIfaceMockRecorder) Record ¶ added in v1.20.0
func (mr *MockGaugeIfaceMockRecorder) Record(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Record indicates an expected call of Record.
type MockHandler ¶ added in v1.20.0
type MockHandler struct {
// contains filtered or unexported fields
}
MockHandler is a mock of Handler interface.
func NewMockHandler ¶ added in v1.20.0
func NewMockHandler(ctrl *gomock.Controller) *MockHandler
NewMockHandler creates a new mock instance.
func (*MockHandler) Counter ¶ added in v1.20.0
func (m *MockHandler) Counter(arg0 string) CounterIface
Counter mocks base method.
func (*MockHandler) EXPECT ¶ added in v1.20.0
func (m *MockHandler) EXPECT() *MockHandlerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockHandler) Gauge ¶ added in v1.20.0
func (m *MockHandler) Gauge(arg0 string) GaugeIface
Gauge mocks base method.
func (*MockHandler) Histogram ¶ added in v1.20.0
func (m *MockHandler) Histogram(arg0 string, arg1 MetricUnit) HistogramIface
Histogram mocks base method.
func (*MockHandler) Stop ¶ added in v1.20.0
func (m *MockHandler) Stop(arg0 log.Logger)
Stop mocks base method.
func (*MockHandler) Timer ¶ added in v1.20.0
func (m *MockHandler) Timer(arg0 string) TimerIface
Timer mocks base method.
func (*MockHandler) WithTags ¶ added in v1.20.0
func (m *MockHandler) WithTags(arg0 ...Tag) Handler
WithTags mocks base method.
type MockHandlerMockRecorder ¶ added in v1.20.0
type MockHandlerMockRecorder struct {
// contains filtered or unexported fields
}
MockHandlerMockRecorder is the mock recorder for MockHandler.
func (*MockHandlerMockRecorder) Counter ¶ added in v1.20.0
func (mr *MockHandlerMockRecorder) Counter(arg0 interface{}) *gomock.Call
Counter indicates an expected call of Counter.
func (*MockHandlerMockRecorder) Gauge ¶ added in v1.20.0
func (mr *MockHandlerMockRecorder) Gauge(arg0 interface{}) *gomock.Call
Gauge indicates an expected call of Gauge.
func (*MockHandlerMockRecorder) Histogram ¶ added in v1.20.0
func (mr *MockHandlerMockRecorder) Histogram(arg0, arg1 interface{}) *gomock.Call
Histogram indicates an expected call of Histogram.
func (*MockHandlerMockRecorder) Stop ¶ added in v1.20.0
func (mr *MockHandlerMockRecorder) Stop(arg0 interface{}) *gomock.Call
Stop indicates an expected call of Stop.
func (*MockHandlerMockRecorder) Timer ¶ added in v1.20.0
func (mr *MockHandlerMockRecorder) Timer(arg0 interface{}) *gomock.Call
Timer indicates an expected call of Timer.
func (*MockHandlerMockRecorder) WithTags ¶ added in v1.20.0
func (mr *MockHandlerMockRecorder) WithTags(arg0 ...interface{}) *gomock.Call
WithTags indicates an expected call of WithTags.
type MockHistogramIface ¶ added in v1.20.0
type MockHistogramIface struct {
// contains filtered or unexported fields
}
MockHistogramIface is a mock of HistogramIface interface.
func NewMockHistogramIface ¶ added in v1.20.0
func NewMockHistogramIface(ctrl *gomock.Controller) *MockHistogramIface
NewMockHistogramIface creates a new mock instance.
func (*MockHistogramIface) EXPECT ¶ added in v1.20.0
func (m *MockHistogramIface) EXPECT() *MockHistogramIfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockHistogramIface) Record ¶ added in v1.20.0
func (m *MockHistogramIface) Record(arg0 int64, arg1 ...Tag)
Record mocks base method.
type MockHistogramIfaceMockRecorder ¶ added in v1.20.0
type MockHistogramIfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockHistogramIfaceMockRecorder is the mock recorder for MockHistogramIface.
func (*MockHistogramIfaceMockRecorder) Record ¶ added in v1.20.0
func (mr *MockHistogramIfaceMockRecorder) Record(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Record indicates an expected call of Record.
type MockTimerIface ¶ added in v1.20.0
type MockTimerIface struct {
// contains filtered or unexported fields
}
MockTimerIface is a mock of TimerIface interface.
func NewMockTimerIface ¶ added in v1.20.0
func NewMockTimerIface(ctrl *gomock.Controller) *MockTimerIface
NewMockTimerIface creates a new mock instance.
func (*MockTimerIface) EXPECT ¶ added in v1.20.0
func (m *MockTimerIface) EXPECT() *MockTimerIfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockTimerIfaceMockRecorder ¶ added in v1.20.0
type MockTimerIfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockTimerIfaceMockRecorder is the mock recorder for MockTimerIface.
func (*MockTimerIfaceMockRecorder) Record ¶ added in v1.20.0
func (mr *MockTimerIfaceMockRecorder) Record(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Record indicates an expected call of Record.
type OpenTelemetryProvider ¶ added in v1.17.0
type Option ¶ added in v1.22.0
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 ¶ added in v1.5.7
type PrometheusConfig struct { // Metric framework: Tally/OpenTelemetry Framework string `yaml:"framework"` // Address for prometheus to serve metrics from. ListenAddress string `yaml:"listenAddress"` // 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 ¶ added in v1.20.0
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 ¶ added in v1.17.2
type SanitizeOptions struct { NameCharacters *ValidCharacters `yaml:"nameChars"` KeyCharacters *ValidCharacters `yaml:"keyChars"` ValueCharacters *ValidCharacters `yaml:"valueChars"` ReplacementCharacter string `yaml:"replacementChar"` }
type SanitizeRange ¶ added in v1.17.2
type StatsdConfig ¶ added in v1.5.7
type StatsdConfig struct { // The host and port of the statsd server HostPort string `yaml:"hostPort" validate:"nonzero"` // The prefix to use in reporting to statsd Prefix string `yaml:"prefix" validate:"nonzero"` // FlushInterval is the maximum interval for sending packets. // If it is not specified, it defaults to 1 second. FlushInterval time.Duration `yaml:"flushInterval"` // FlushBytes specifies the maximum udp packet size you wish to send. // If FlushBytes is unspecified, it defaults to 1432 bytes, which is // considered safe for local traffic. FlushBytes int `yaml:"flushBytes"` // 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 ¶ added in v1.17.0
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 ¶ added in v1.9.0
type SummaryObjective struct { Percentile float64 `yaml:"percentile"` AllowedError float64 `yaml:"allowedError"` }
Deprecated. SummaryObjective is a Prometheus summary objective. Added for backwards compatibility.
type Tag ¶ added in v0.5.7
Tag is an interface to define metrics tags
func ActionType ¶ added in v1.17.0
func ActivityTypeTag ¶ added in v0.27.0
ActivityTypeTag returns a new activity type tag.
func AdvancedVisibilityTypeTag ¶ added in v1.12.3
func AdvancedVisibilityTypeTag() Tag
func CacheTypeTag ¶ added in v1.19.0
func CommandTypeTag ¶ added in v0.27.0
CommandTypeTag returns a new command type tag.
func FromClusterIDTag ¶ added in v1.21.0
FromClusterIDTag returns a new from cluster tag.
func HttpStatusTag ¶ added in v1.14.0
HttpStatusTag returns a new httpStatusTag.
func InstanceTag ¶ added in v0.5.9
InstanceTag returns a new instance tag
func NamespaceStateTag ¶ added in v1.20.0
NamespaceStateTag returns a new namespace state tag.
func NamespaceTag ¶ added in v0.27.0
NamespaceTag returns a new namespace tag. For timers, this also ensures that we dual emit the metric with the all tag. If a blank namespace is provided then this converts that to an unknown namespace.
func NamespaceUnknownTag ¶ added in v0.27.0
func NamespaceUnknownTag() Tag
NamespaceUnknownTag returns a new namespace:unknown tag-value
func OperationTag ¶ added in v1.17.0
func QueueActionTag ¶ added in v1.21.0
func QueueReaderIDTag ¶ added in v1.18.0
func QueueTypeTag ¶ added in v1.14.0
func ReasonTag ¶ added in v1.20.0
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 ¶ added in v1.21.0
func ReplicationTaskTypeTag(value enumsspb.ReplicationTaskType) Tag
ReplicationTaskTypeTag returns a new replication task type tag.
func ResourceExhaustedCauseTag ¶ added in v1.15.0
func ResourceExhaustedCauseTag(cause enumspb.ResourceExhaustedCause) Tag
func ServiceErrorTypeTag ¶ added in v1.15.0
func ServiceNameTag ¶ added in v1.19.0
func ServiceNameTag(value primitives.ServiceName) Tag
func ServiceRoleTag ¶ added in v1.4.0
Returns a new service role tag.
func StandardVisibilityTypeTag ¶ added in v1.12.3
func StandardVisibilityTypeTag() Tag
func TargetClusterTag ¶ added in v0.6.0
TargetClusterTag returns a new target cluster tag.
func TaskCategoryTag ¶ added in v1.17.0
func TaskPriorityTag ¶ added in v1.17.0
func TaskQueueTag ¶ added in v0.27.0
TaskQueueTag returns a new task queue tag.
func TaskQueueTypeTag ¶ added in v1.16.0
func TaskQueueTypeTag(tqType enumspb.TaskQueueType) Tag
func TaskQueueUnknownTag ¶ added in v0.27.0
func TaskQueueUnknownTag() Tag
TaskQueueUnknownTag returns a new taskqueue:unknown tag-value
func TaskTypeTag ¶ added in v1.13.0
func ToClusterIDTag ¶ added in v1.21.0
ToClusterIDTag returns a new to cluster tag.
func VersionedTag ¶ added in v1.22.0
VersionedTag represents whether a loaded task queue manager represents a specific version set.
func VisibilityTypeTag ¶ added in v1.12.3
func WorkflowTypeTag ¶ added in v0.27.0
WorkflowTypeTag returns a new workflow type tag.
type TimerFunc ¶ added in v1.20.0
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
type TimerIface ¶ added in v1.20.0
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 ¶ added in v1.17.2
type ValidCharacters struct { Ranges []SanitizeRange `yaml:"ranges"` SafeCharacters string `yaml:"safeChars"` }
type WithDescription ¶ added in v1.22.0
type WithDescription string
WithDescription sets the description, or "help text", of a metric. See ServiceRequests for an example.
type WithUnit ¶ added in v1.22.0
type WithUnit MetricUnit
WithUnit sets the unit of a metric. See NewBytesHistogramDef for an example.