Documentation
¶
Overview ¶
Package metrics is a generated GoMock package.
Index ¶
- Constants
- Variables
- func AddMetricsContext(ctx context.Context) context.Context
- func ContextCounterAdd(ctx context.Context, name string, value int64) bool
- func ContextCounterGet(ctx context.Context, name string) (int64, bool)
- func NewBytesHistogramDef(name string) metricDefinition
- func NewClientMetricsTrailerPropagatorInterceptor(logger log.Logger) grpc.UnaryClientInterceptor
- func NewCounterDef(name string) metricDefinition
- func NewDimensionlessHistogramDef(name string) metricDefinition
- func NewGaugeDef(name string) metricDefinition
- func NewOpenTelemetryProvider(logger log.Logger, prometheusConfig *PrometheusConfig, ...) (*openTelemetryProviderImpl, error)
- func NewOtelMetricsHandler(l log.Logger, o OpenTelemetryProvider, cfg ClientConfig) *otelMetricsHandler
- 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 NewTimeHistogramDef(name string) metricDefinition
- func NewTimerDef(name string) 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 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 VisibilityTypeTag(value string) Tag
- func WorkflowTypeTag(value string) Tag
- type TimerFunc
- type TimerIface
- type ValidCharacters
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://pkgo.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"
// 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"
// AdminDescribeHistoryHostScope is the metric scope for admin.AdminDescribeHistoryHost
AdminDescribeHistoryHostScope = "AdminDescribeHistoryHost"
// AdminAddSearchAttributesScope is the metric scope for admin.AdminAddSearchAttributes
AdminAddSearchAttributesScope = "AdminAddSearchAttributes"
// AdminRemoveSearchAttributesScope is the metric scope for admin.AdminRemoveSearchAttributes
AdminRemoveSearchAttributesScope = "AdminRemoveSearchAttributes"
// AdminGetSearchAttributesScope is the metric scope for admin.AdminGetSearchAttributes
AdminGetSearchAttributesScope = "AdminGetSearchAttributes"
// AdminRebuildMutableStateScope is the metric scope for admin.AdminRebuildMutableState
AdminRebuildMutableStateScope = "AdminRebuildMutableState"
// AdminDescribeMutableStateScope is the metric scope for admin.AdminDescribeMutableState
AdminDescribeMutableStateScope = "AdminDescribeMutableState"
// AdminGetWorkflowExecutionRawHistoryV2Scope is the metric scope for admin.GetWorkflowExecutionRawHistoryScope
AdminGetWorkflowExecutionRawHistoryV2Scope = "AdminGetWorkflowExecutionRawHistoryV2"
// AdminGetReplicationMessagesScope is the metric scope for admin.GetReplicationMessages
AdminGetReplicationMessagesScope = "AdminGetReplicationMessages"
// AdminGetNamespaceReplicationMessagesScope is the metric scope for admin.GetNamespaceReplicationMessages
AdminGetNamespaceReplicationMessagesScope = "AdminGetNamespaceReplicationMessages"
// AdminGetDLQReplicationMessagesScope is the metric scope for admin.GetDLQReplicationMessages
AdminGetDLQReplicationMessagesScope = "AdminGetDLQReplicationMessages"
// AdminReapplyEventsScope is the metric scope for admin.ReapplyEvents
AdminReapplyEventsScope = "AdminReapplyEvents"
// AdminRefreshWorkflowTasksScope is the metric scope for admin.RefreshWorkflowTasks
AdminRefreshWorkflowTasksScope = "AdminRefreshWorkflowTasks"
// AdminResendReplicationTasksScope is the metric scope for admin.ResendReplicationTasks
AdminResendReplicationTasksScope = "AdminResendReplicationTasks"
// AdminGetTaskQueueTasksScope is the metric scope for admin.GetTaskQueueTasks
AdminGetTaskQueueTasksScope = "AdminGetTaskQueueTasks"
// AdminRemoveTaskScope is the metric scope for admin.AdminRemoveTask
AdminRemoveTaskScope = "AdminRemoveTask"
// AdminCloseShardScope is the metric scope for admin.AdminCloseShard
AdminCloseShardScope = "AdminCloseShard"
// AdminGetShardScope is the metric scope for admin.AdminGetShard
AdminGetShardScope = "AdminGetShard"
// AdminListHistoryTasksScope is the metric scope for admin.ListHistoryTasks
AdminListHistoryTasksScope = "AdminListHistoryTasks"
// AdminGetDLQMessagesScope is the metric scope for admin.AdminGetDLQMessages
AdminGetDLQMessagesScope = "AdminGetDLQMessages"
// AdminPurgeDLQMessagesScope is the metric scope for admin.AdminPurgeDLQMessages
AdminPurgeDLQMessagesScope = "AdminPurgeDLQMessages"
// AdminMergeDLQMessagesScope is the metric scope for admin.AdminMergeDLQMessages
AdminMergeDLQMessagesScope = "AdminMergeDLQMessages"
// AdminListClusterMembersScope is the metric scope for admin.AdminListClusterMembers
AdminListClusterMembersScope = "AdminListClusterMembers"
// AdminDescribeClusterScope is the metric scope for admin.AdminDescribeCluster
AdminDescribeClusterScope = "AdminDescribeCluster"
// AdminListClustersScope is the metric scope for admin.AdminListClusters
AdminListClustersScope = "AdminListClusters"
// AdminAddOrUpdateRemoteClusterScope is the metric scope for admin.AdminAddOrUpdateRemoteCluster
AdminAddOrUpdateRemoteClusterScope = "AdminAddOrUpdateRemoteCluster"
// AdminRemoveRemoteClusterScope is the metric scope for admin.AdminRemoveRemoteCluster
AdminRemoveRemoteClusterScope = "AdminRemoveRemoteCluster"
// AdminDeleteWorkflowExecutionScope is the metric scope for admin.AdminDeleteWorkflowExecution
AdminDeleteWorkflowExecutionScope = "AdminDeleteWorkflowExecution"
// AdminStreamWorkflowReplicationMessagesScope is the metric scope for admin.AdminStreamReplicationMessages
AdminStreamWorkflowReplicationMessagesScope = "AdminStreamWorkflowReplicationMessages"
// OperatorAddSearchAttributesScope is the metric scope for operator.AddSearchAttributes
OperatorAddSearchAttributesScope
// OperatorRemoveSearchAttributesScope is the metric scope for operator.RemoveSearchAttributes
OperatorRemoveSearchAttributesScope = "OperatorRemoveSearchAttributes"
// OperatorListSearchAttributesScope is the metric scope for operator.ListSearchAttributes
OperatorListSearchAttributesScope = "OperatorListSearchAttributes"
OperatorDeleteNamespaceScope = "OperatorDeleteNamespace"
// OperatorAddOrUpdateRemoteClusterScope is the metric scope for operator.AddOrUpdateRemoteCluster
OperatorAddOrUpdateRemoteClusterScope = "OperatorAddOrUpdateRemoteCluster"
// OperatorRemoveRemoteClusterScope is the metric scope for operator.RemoveRemoteCluster
OperatorRemoveRemoteClusterScope = "OperatorRemoveRemoteCluster"
// OperatorListClustersScope is the metric scope for operator.OperatorListClusters
OperatorListClustersScope = "OperatorListClusters"
// OperatorDeleteWorkflowExecutionScope is the metric scope for operator.DeleteWorkflowExecution
OperatorDeleteWorkflowExecutionScope = "OperatorDeleteWorkflowExecution"
)
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"
// 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 (
// FrontendStartWorkflowExecutionScope is the metric scope for frontend.StartWorkflowExecution
FrontendStartWorkflowExecutionScope = "StartWorkflowExecution"
// FrontendPollWorkflowTaskQueueScope is the metric scope for frontend.PollWorkflowTaskQueue
FrontendPollWorkflowTaskQueueScope = "PollWorkflowTaskQueue"
// FrontendPollActivityTaskQueueScope is the metric scope for frontend.PollActivityTaskQueue
FrontendPollActivityTaskQueueScope = "PollActivityTaskQueue"
// FrontendRecordActivityTaskHeartbeatScope is the metric scope for frontend.RecordActivityTaskHeartbeat
FrontendRecordActivityTaskHeartbeatScope = "RecordActivityTaskHeartbeat"
// FrontendRecordActivityTaskHeartbeatByIdScope is the metric scope for frontend.RecordActivityTaskHeartbeatById
FrontendRecordActivityTaskHeartbeatByIdScope = "RecordActivityTaskHeartbeatById"
// FrontendRespondWorkflowTaskCompletedScope is the metric scope for frontend.RespondWorkflowTaskCompleted
FrontendRespondWorkflowTaskCompletedScope = "RespondWorkflowTaskCompleted"
// 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"
// FrontendSignalWorkflowExecutionScope is the metric scope for frontend.SignalWorkflowExecution
FrontendSignalWorkflowExecutionScope = "SignalWorkflowExecution"
// FrontendSignalWithStartWorkflowExecutionScope is the metric scope for frontend.SignalWithStartWorkflowExecution
FrontendSignalWithStartWorkflowExecutionScope = "SignalWithStartWorkflowExecution"
// 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"
// FrontendQueryWorkflowScope is the metric scope for frontend.QueryWorkflow
FrontendQueryWorkflowScope = "QueryWorkflow"
// 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"
// FrontendResetWorkflowExecutionScope is the metric scope for frontend.ResetWorkflowExecution
FrontendResetWorkflowExecutionScope = "ResetWorkflowExecution"
// 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")
ServicePendingRequests = NewGaugeDef("service_pending_requests")
ServiceFailures = NewCounterDef("service_errors")
ServiceErrorWithType = NewCounterDef("service_error_with_type")
ServiceCriticalFailures = NewCounterDef("service_errors_critical")
ServiceLatency = NewTimerDef("service_latency")
ServiceLatencyNoUserLatency = NewTimerDef("service_latency_nouserlatency")
ServiceLatencyUserLatency = NewTimerDef("service_latency_userlatency")
ServiceErrInvalidArgumentCounter = NewCounterDef("service_errors_invalid_argument")
ServiceErrNamespaceNotActiveCounter = NewCounterDef("service_errors_namespace_not_active")
ServiceErrResourceExhaustedCounter = NewCounterDef("service_errors_resource_exhausted")
ServiceErrNotFoundCounter = NewCounterDef("service_errors_entity_not_found")
ServiceErrExecutionAlreadyStartedCounter = NewCounterDef("service_errors_execution_already_started")
ServiceErrNamespaceAlreadyExistsCounter = NewCounterDef("service_errors_namespace_already_exists")
ServiceErrCancellationAlreadyRequestedCounter = NewCounterDef("service_errors_cancellation_already_requested")
ServiceErrQueryFailedCounter = NewCounterDef("service_errors_query_failed")
ServiceErrContextCancelledCounter = NewCounterDef("service_errors_context_cancelled")
ServiceErrContextTimeoutCounter = NewCounterDef("service_errors_context_timeout")
ServiceErrRetryTaskCounter = NewCounterDef("service_errors_retry_task")
ServiceErrBadBinaryCounter = NewCounterDef("service_errors_bad_binary")
ServiceErrClientVersionNotSupportedCounter = NewCounterDef("service_errors_client_version_not_supported")
ServiceErrIncompleteHistoryCounter = NewCounterDef("service_errors_incomplete_history")
ServiceErrNonDeterministicCounter = NewCounterDef("service_errors_nondeterministic")
ServiceErrUnauthorizedCounter = NewCounterDef("service_errors_unauthorized")
ServiceErrAuthorizeFailedCounter = NewCounterDef("service_errors_authorize_failed")
ActionCounter = NewCounterDef("action")
TlsCertsExpired = NewGaugeDef("certificates_expired")
TlsCertsExpiring = NewGaugeDef("certificates_expiring")
ServiceAuthorizationLatency = NewTimerDef("service_authorization_latency")
EventBlobSize = NewBytesHistogramDef("event_blob_size")
NamespaceCachePrepareCallbacksLatency = NewTimerDef("namespace_cache_prepare_callbacks_latency")
NamespaceCacheCallbacksLatency = NewTimerDef("namespace_cache_callbacks_latency")
LockRequests = NewCounterDef("lock_requests")
LockFailures = NewCounterDef("lock_failures")
LockLatency = NewTimerDef("lock_latency")
ClientRequests = NewCounterDef("client_requests")
ClientFailures = NewCounterDef("client_errors")
ClientLatency = NewTimerDef("client_latency")
ClientRedirectionRequests = NewCounterDef("client_redirection_requests")
ClientRedirectionFailures = NewCounterDef("client_redirection_errors")
ClientRedirectionLatency = NewTimerDef("client_redirection_latency")
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")
TooManyPendingActivities = NewCounterDef("wf_too_many_pending_activities")
TooManyPendingCancelRequests = NewCounterDef("wf_too_many_pending_cancel_requests")
TooManyPendingSignalsToExternalWorkflows = NewCounterDef("wf_too_many_pending_external_workflow_signals")
// 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")
// 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")
ShardInfoReplicationPendingTasksTimer = NewDimensionlessHistogramDef("shardinfo_replication_pending_task")
ShardInfoTransferActivePendingTasksTimer = NewDimensionlessHistogramDef("shardinfo_transfer_active_pending_task")
ShardInfoTransferStandbyPendingTasksTimer = NewDimensionlessHistogramDef("shardinfo_transfer_standby_pending_task")
ShardInfoTimerActivePendingTasksTimer = NewDimensionlessHistogramDef("shardinfo_timer_active_pending_task")
ShardInfoTimerStandbyPendingTasksTimer = NewDimensionlessHistogramDef("shardinfo_timer_standby_pending_task")
ShardInfoVisibilityPendingTasksTimer = NewDimensionlessHistogramDef("shardinfo_visibility_pending_task")
ShardInfoReplicationLagHistogram = NewDimensionlessHistogramDef("shardinfo_replication_lag")
ShardInfoTransferLagHistogram = NewDimensionlessHistogramDef("shardinfo_transfer_lag")
ShardInfoTimerLagTimer = NewTimerDef("shardinfo_timer_lag")
ShardInfoVisibilityLagHistogram = NewDimensionlessHistogramDef("shardinfo_visibility_lag")
ShardInfoImmediateQueueLagHistogram = NewDimensionlessHistogramDef("shardinfo_immediate_queue_lag")
ShardInfoScheduledQueueLagTimer = NewTimerDef("shardinfo_scheduled_queue_lag")
SyncShardFromRemoteCounter = NewCounterDef("syncshard_remote_count")
SyncShardFromRemoteFailure = NewCounterDef("syncshard_remote_failed")
TaskRequests = NewCounterDef("task_requests")
TaskLoadLatency = NewTimerDef("task_latency_load") // latency from task generation to task loading (persistence scheduleToStart)
TaskScheduleLatency = NewTimerDef("task_latency_schedule") // latency from task submission to in-memory queue to processing (in-memory scheduleToStart)
TaskProcessingLatency = NewTimerDef("task_latency_processing") // latency for processing task one time
TaskLatency = NewTimerDef("task_latency") // task in-memory latency across multiple attempts
TaskQueueLatency = NewTimerDef("task_latency_queue") // task e2e latency
TaskAttempt = NewDimensionlessHistogramDef("task_attempt")
TaskFailures = NewCounterDef("task_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")
TaskNotActiveCounter = NewCounterDef("task_errors_not_active_counter")
TaskLimitExceededCounter = NewCounterDef("task_errors_limit_exceeded_counter")
TaskNamespaceHandoverCounter = NewCounterDef("task_errors_namespace_handover")
TaskThrottledCounter = NewCounterDef("task_errors_throttled")
TaskCorruptionCounter = NewCounterDef("task_errors_corruption")
TaskScheduleToStartLatency = NewTimerDef("task_schedule_to_start_latency")
TransferTaskMissingEventCounter = NewCounterDef("transfer_task_missing_event_counter")
TaskBatchCompleteCounter = NewCounterDef("task_batch_complete_counter")
TaskReschedulerPendingTasks = NewDimensionlessHistogramDef("task_rescheduler_pending_tasks")
PendingTasksCounter = NewDimensionlessHistogramDef("pending_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")
ServiceErrTaskAlreadyStartedCounter = NewCounterDef("service_errors_task_already_started")
HeartbeatTimeoutCounter = NewCounterDef("heartbeat_timeout")
ScheduleToStartTimeoutCounter = NewCounterDef("schedule_to_start_timeout")
StartToCloseTimeoutCounter = NewCounterDef("start_to_close_timeout")
ScheduleToCloseTimeoutCounter = NewCounterDef("schedule_to_close_timeout")
NewTimerNotifyCounter = NewCounterDef("new_timer_notifications")
AcquireShardsCounter = NewCounterDef("acquire_shards_count")
AcquireShardsLatency = NewTimerDef("acquire_shards_latency")
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")
EmptyReplicationEventsCounter = NewCounterDef("empty_replication_events")
DuplicateReplicationEventsCounter = NewCounterDef("duplicate_replication_events")
StaleReplicationEventsCounter = NewCounterDef("stale_replication_events")
ReplicationEventsSizeTimer = NewTimerDef("replication_events_size")
BufferReplicationTaskTimer = NewTimerDef("buffer_replication_tasks")
UnbufferReplicationTaskTimer = NewTimerDef("unbuffer_replication_tasks")
HistoryConflictsCounter = NewCounterDef("history_conflicts")
CompleteTaskFailedCounter = NewCounterDef("complete_task_fail_count")
AcquireLockFailedCounter = NewCounterDef("acquire_lock_failed")
WorkflowContextCleared = NewCounterDef("workflow_context_cleared")
MutableStateSize = NewBytesHistogramDef("mutable_state_size")
ExecutionInfoSize = NewBytesHistogramDef("execution_info_size")
ExecutionStateSize = NewBytesHistogramDef("execution_state_size")
ActivityInfoSize = NewBytesHistogramDef("activity_info_size")
TimerInfoSize = NewBytesHistogramDef("timer_info_size")
ChildInfoSize = NewBytesHistogramDef("child_info_size")
RequestCancelInfoSize = NewBytesHistogramDef("request_cancel_info_size")
SignalInfoSize = NewBytesHistogramDef("signal_info_size")
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")
LastRetrievedMessageID = NewGaugeDef("last_retrieved_message_id")
LastProcessedMessageID = NewGaugeDef("last_processed_message_id")
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".
// It currently has units of "ms", which is incorrect. See https://github.com/temporalio/temporal/issues/4483.
ReplicationTasksLag = NewTimeHistogramDef("replication_tasks_lag")
// ReplicationTasksFetched records the number of tasks fetched by the poller.
// It has the same unit issue as ReplicationTasksLag.
ReplicationTasksFetched = NewTimeHistogramDef("replication_tasks_fetched")
// ReplicationTasksReturned is the same as ReplicationTasksFetched.
ReplicationTasksReturned = NewTimeHistogramDef("replication_tasks_returned")
ReplicationLatency = NewTimerDef("replication_latency")
ReplicationTasksAppliedLatency = NewTimerDef("replication_tasks_applied_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")
GetReplicationMessagesForShardLatency = NewTimerDef("get_replication_messages_for_shard")
GetDLQReplicationMessagesLatency = NewTimerDef("get_dlq_replication_messages")
EventReapplySkippedCount = NewCounterDef("event_reapply_skipped_count")
DirectQueryDispatchLatency = NewTimerDef("direct_query_dispatch_latency")
DirectQueryDispatchStickyLatency = NewTimerDef("direct_query_dispatch_sticky_latency")
DirectQueryDispatchNonStickyLatency = NewTimerDef("direct_query_dispatch_non_sticky_latency")
DirectQueryDispatchStickySuccessCount = NewCounterDef("direct_query_dispatch_sticky_success")
DirectQueryDispatchNonStickySuccessCount = NewCounterDef("direct_query_dispatch_non_sticky_success")
DirectQueryDispatchClearStickinessLatency = NewTimerDef("direct_query_dispatch_clear_stickiness_latency")
DirectQueryDispatchClearStickinessSuccessCount = NewCounterDef("direct_query_dispatch_clear_stickiness_success")
DirectQueryDispatchTimeoutBeforeNonStickyCount = NewCounterDef("direct_query_dispatch_timeout_before_non_sticky")
WorkflowTaskQueryLatency = NewTimerDef("workflow_task_query_latency")
ConsistentQueryTimeoutCount = NewCounterDef("consistent_query_timeout")
QueryBeforeFirstWorkflowTaskCount = NewCounterDef("query_before_first_workflow_task")
QueryBufferExceededCount = NewCounterDef("query_buffer_exceeded")
QueryRegistryInvalidStateCount = NewCounterDef("query_registry_invalid_state")
WorkerNotSupportsConsistentQueryCount = NewCounterDef("worker_not_supports_consistent_query")
WorkflowTaskTimeoutOverrideCount = NewCounterDef("workflow_task_timeout_overrides")
WorkflowRunTimeoutOverrideCount = NewCounterDef("workflow_run_timeout_overrides")
ReplicationTaskCleanupCount = NewCounterDef("replication_task_cleanup_count")
ReplicationTaskCleanupFailure = NewCounterDef("replication_task_cleanup_failed")
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")
// 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")
ForwardTaskCallsPerTaskQueue = NewCounterDef("forward_task_calls")
ForwardTaskErrorsPerTaskQueue = NewCounterDef("forward_task_errors")
ForwardQueryCallsPerTaskQueue = NewCounterDef("forward_query_calls")
ForwardQueryErrorsPerTaskQueue = NewCounterDef("forward_query_errors")
ForwardPollCallsPerTaskQueue = NewCounterDef("forward_poll_calls")
ForwardPollErrorsPerTaskQueue = NewCounterDef("forward_poll_errors")
ForwardTaskLatencyPerTaskQueue = NewTimerDef("forward_task_latency")
ForwardQueryLatencyPerTaskQueue = NewTimerDef("forward_query_latency")
ForwardPollLatencyPerTaskQueue = NewTimerDef("forward_poll_latency")
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")
// Worker
ExecutorTasksDoneCount = NewCounterDef("executor_done")
ExecutorTasksErrCount = NewCounterDef("executor_err")
ExecutorTasksDeferredCount = NewCounterDef("executor_deferred")
ExecutorTasksDroppedCount = NewCounterDef("executor_dropped")
StartedCount = NewCounterDef("started")
StoppedCount = NewCounterDef("stopped")
ScanDuration = NewTimerDef("scan_duration")
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")
HistoryArchiverHistoryMutatedCount = NewCounterDef("history_archiver_history_mutated")
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")
HistoryArchiverRunningDeterministicConstructionCheckCount = NewCounterDef("history_archiver_running_deterministic_construction_check")
HistoryArchiverDeterministicConstructionCheckFailedCount = NewCounterDef("history_archiver_deterministic_construction_check_failed")
HistoryArchiverRunningBlobIntegrityCheckCount = NewCounterDef("history_archiver_running_blob_integrity_check")
HistoryArchiverBlobIntegrityCheckFailedCount = NewCounterDef("history_archiver_blob_integrity_check_failed")
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")
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")
ScheduleRateLimited = NewCounterDef("schedule_rate_limited")
ScheduleBufferOverruns = NewCounterDef("schedule_buffer_overruns")
ScheduleActionSuccess = NewCounterDef("schedule_action_success")
ScheduleActionErrors = NewCounterDef("schedule_action_errors")
ScheduleCancelWorkflowErrors = NewCounterDef("schedule_cancel_workflow_errors")
ScheduleTerminateWorkflowErrors = NewCounterDef("schedule_terminate_workflow_errors")
// Force replication
EncounterZombieWorkflowCount = NewCounterDef("encounter_zombie_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")
PersistenceFailures = NewCounterDef("persistence_errors")
PersistenceErrorWithType = NewCounterDef("persistence_error_with_type")
PersistenceLatency = NewTimerDef("persistence_latency")
PersistenceShardRPS = NewDimensionlessHistogramDef("persistence_shard_rps")
PersistenceErrShardExistsCounter = NewCounterDef("persistence_errors_shard_exists")
PersistenceErrShardOwnershipLostCounter = NewCounterDef("persistence_errors_shard_ownership_lost")
PersistenceErrConditionFailedCounter = NewCounterDef("persistence_errors_condition_failed")
PersistenceErrCurrentWorkflowConditionFailedCounter = NewCounterDef("persistence_errors_current_workflow_condition_failed")
PersistenceErrWorkflowConditionFailedCounter = NewCounterDef("persistence_errors_workflow_condition_failed")
PersistenceErrTimeoutCounter = NewCounterDef("persistence_errors_timeout")
PersistenceErrBusyCounter = NewCounterDef("persistence_errors_busy")
PersistenceErrEntityNotExistsCounter = NewCounterDef("persistence_errors_entity_not_exists")
PersistenceErrNamespaceAlreadyExistsCounter = NewCounterDef("persistence_errors_namespace_already_exists")
PersistenceErrBadRequestCounter = NewCounterDef("persistence_errors_bad_request")
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 AddMetricsContext(ctx context.Context) context.Context
func ContextCounterAdd ¶ added in v1.10.0
func ContextCounterAdd(ctx context.Context, name string, value int64) bool
ContextCounterAdd adds value to counter within metrics context.
func ContextCounterGet ¶ added in v1.10.0
func ContextCounterGet(ctx context.Context, name string) (int64, bool)
ContextCounterGet returns value and true if successfully retrieved value
func NewBytesHistogramDef ¶ added in v1.14.0
func NewBytesHistogramDef(name string) metricDefinition
func NewClientMetricsTrailerPropagatorInterceptor ¶ added in v1.10.0
func NewClientMetricsTrailerPropagatorInterceptor(logger log.Logger) grpc.UnaryClientInterceptor
NewClientMetricsTrailerPropagatorInterceptor returns grpc client interceptor that injects metrics received in trailer into metrics context.
func NewCounterDef ¶ added in v1.14.0
func NewCounterDef(name string) metricDefinition
func NewDimensionlessHistogramDef ¶ added in v1.14.0
func NewDimensionlessHistogramDef(name string) metricDefinition
func NewGaugeDef ¶ added in v1.14.0
func NewGaugeDef(name string) metricDefinition
func 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
func NewScope ¶ added in v1.16.0
func NewScope(logger log.Logger, c *Config) tally.Scope
NewScope builds a new tally scope for this metrics configuration
If the underlying configuration is valid for multiple reporter types, only one of them will be used for reporting.
Current priority order is: statsd > prometheus
func NewServerMetricsContextInjectorInterceptor ¶ 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 NewTimeHistogramDef ¶ added in v1.21.0
func NewTimeHistogramDef(name string) metricDefinition
func NewTimerDef ¶ added in v1.14.0
func NewTimerDef(name string) metricDefinition
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
type CounterFunc func(int64, ...Tag)
Mostly cribbed from https://github.com/temporalio/sdk-go/blob/master/internal/common/metrics/handler.go and adapted to depend on golang.org/x/exp/event
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
type GaugeFunc func(float64, ...Tag)
Mostly cribbed from https://github.com/temporalio/sdk-go/blob/master/internal/common/metrics/handler.go and adapted to depend on golang.org/x/exp/event
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
func GetPerTaskQueueScope(
handler Handler,
namespaceName string,
taskQueueName string,
taskQueueKind enumspb.TaskQueueKind,
) Handler
func MetricsHandlerFromConfig ¶ added in v1.17.0
func MetricsHandlerFromConfig(logger log.Logger, c *Config) Handler
MetricsHandlerFromConfig is used at startup to construct a MetricsHandler
type HistogramFunc ¶ added in v1.20.0
type HistogramFunc func(int64, ...Tag)
Mostly cribbed from https://github.com/temporalio/sdk-go/blob/master/internal/common/metrics/handler.go and adapted to depend on golang.org/x/exp/event
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.
type MockCounterIfaceMockRecorder ¶ added in v1.20.0
type MockCounterIfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockCounterIfaceMockRecorder is the mock recorder for MockCounterIface.
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.
type MockGaugeIfaceMockRecorder ¶ added in v1.20.0
type MockGaugeIfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockGaugeIfaceMockRecorder is the mock recorder for MockGaugeIface.
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.
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.
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.
type MockHistogramIfaceMockRecorder ¶ added in v1.20.0
type MockHistogramIfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockHistogramIfaceMockRecorder is the mock recorder for MockHistogramIface.
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.
type MockTimerIfaceMockRecorder ¶ added in v1.20.0
type MockTimerIfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockTimerIfaceMockRecorder is the mock recorder for MockTimerIface.
type OpenTelemetryProvider ¶ added in v1.17.0
type OpenTelemetryProvider interface {
Stop(logger log.Logger)
GetMeter() metric.Meter
}
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.
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 SanitizeRange struct {
StartRange string `yaml:"startRange"`
EndRange string `yaml:"endRange"`
}
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
type Tag interface {
Key() string
Value() string
}
Tag is an interface to define metrics tags
func ActionType ¶ added in v1.17.0
func ActionType(value string) Tag
func ActivityTypeTag ¶ added in v0.27.0
func ActivityTypeTag(value string) Tag
ActivityTypeTag returns a new activity type tag.
func AdvancedVisibilityTypeTag ¶ added in v1.12.3
func AdvancedVisibilityTypeTag() Tag
func CacheTypeTag ¶ added in v1.19.0
func CacheTypeTag(value string) Tag
func CommandTypeTag ¶ added in v0.27.0
func CommandTypeTag(value string) Tag
CommandTypeTag returns a new command type tag.
func FromClusterIDTag ¶ added in v1.21.0
func FromClusterIDTag(value int32) Tag
FromClusterIDTag returns a new from cluster tag.
func HttpStatusTag ¶ added in v1.14.0
func HttpStatusTag(value int) Tag
HttpStatusTag returns a new httpStatusTag.
func InstanceTag ¶ added in v0.5.9
func InstanceTag(value string) Tag
InstanceTag returns a new instance tag
func NamespaceStateTag ¶ added in v1.20.0
func NamespaceStateTag(value string) Tag
NamespaceStateTag returns a new namespace state tag.
func NamespaceTag ¶ added in v0.27.0
func NamespaceTag(value string) Tag
NamespaceTag returns a new namespace tag. For timers, this also ensures that we dual emit the metric with the all tag. If a blank namespace is provided then this converts that to an unknown namespace.
func NamespaceUnknownTag ¶ added in v0.27.0
func NamespaceUnknownTag() Tag
NamespaceUnknownTag returns a new namespace:unknown tag-value
func OperationTag ¶ added in v1.17.0
func OperationTag(value string) Tag
func QueueActionTag ¶ added in v1.21.0
func QueueActionTag(value string) Tag
func QueueReaderIDTag ¶ added in v1.18.0
func QueueReaderIDTag(readerID int64) Tag
func QueueTypeTag ¶ added in v1.14.0
func QueueTypeTag(value string) Tag
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 ServiceErrorTypeTag(err error) Tag
func ServiceNameTag ¶ added in v1.19.0
func ServiceNameTag(value primitives.ServiceName) Tag
func ServiceRoleTag ¶ added in v1.4.0
func ServiceRoleTag(value string) Tag
Returns a new service role tag.
func StandardVisibilityTypeTag ¶ added in v1.12.3
func StandardVisibilityTypeTag() Tag
func TargetClusterTag ¶ added in v0.6.0
func TargetClusterTag(value string) Tag
TargetClusterTag returns a new target cluster tag.
func TaskCategoryTag ¶ added in v1.17.0
func TaskCategoryTag(value string) Tag
func TaskPriorityTag ¶ added in v1.17.0
func TaskPriorityTag(value string) Tag
func TaskQueueTag ¶ added in v0.27.0
func TaskQueueTag(value string) Tag
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 TaskTypeTag(value string) Tag
func ToClusterIDTag ¶ added in v1.21.0
func ToClusterIDTag(value int32) Tag
ToClusterIDTag returns a new to cluster tag.
func VisibilityTypeTag ¶ added in v1.12.3
func VisibilityTypeTag(value string) Tag
func WorkflowTypeTag ¶ added in v0.27.0
func WorkflowTypeTag(value string) Tag
WorkflowTypeTag returns a new workflow type tag.
type TimerFunc ¶ added in v1.20.0
type TimerFunc func(time.Duration, ...Tag)
Mostly cribbed from https://github.com/temporalio/sdk-go/blob/master/internal/common/metrics/handler.go and adapted to depend on golang.org/x/exp/event
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"`
}