Documentation
¶
Index ¶
- Constants
- Variables
- type Client
- type ClientImpl
- func (m *ClientImpl) AddCounter(scopeIdx int, counterIdx int, delta int64)
- func (m *ClientImpl) IncCounter(scopeIdx int, counterIdx int)
- func (m *ClientImpl) RecordTimer(scopeIdx int, timerIdx int, d time.Duration)
- func (m *ClientImpl) StartTimer(scopeIdx int, timerIdx int) tally.Stopwatch
- func (m *ClientImpl) Tagged(tags map[string]string) Client
- func (m *ClientImpl) UpdateGauge(scopeIdx int, gaugeIdx int, value float64)
- type ErrorClass
- type MetricName
- type MetricType
- type RuntimeMetricsReporter
- type ServiceIdx
Constants ¶
const (
Common = iota
Frontend
History
Matching
Worker
NumServices
)
Service names for all services that emit metrics.
const (
HostnameTagName = "hostname"
OperationTagName = "operation"
// ShardTagName is temporary until we can get all metric data removed for the service
ShardTagName = "shard"
)
Common tags for all services
const (
UnknownDirectoryTagValue = "Unknown"
AllShardsTagValue = "ALL"
NoneShardsTagValue = "NONE"
)
This package should hold all the metrics and tags for cadence
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 (
// PersistenceCreateShardScope tracks CreateShard calls made by service to persistence layer
PersistenceCreateShardScope = iota
// PersistenceGetShardScope tracks GetShard calls made by service to persistence layer
PersistenceGetShardScope
// PersistenceUpdateShardScope tracks UpdateShard calls made by service to persistence layer
PersistenceUpdateShardScope
// PersistenceCreateWorkflowExecutionScope tracks CreateWorkflowExecution calls made by service to persistence layer
PersistenceCreateWorkflowExecutionScope
// PersistenceGetWorkflowExecutionScope tracks GetWorkflowExecution calls made by service to persistence layer
PersistenceGetWorkflowExecutionScope
// PersistenceUpdateWorkflowExecutionScope tracks UpdateWorkflowExecution calls made by service to persistence layer
PersistenceUpdateWorkflowExecutionScope
// PersistenceResetMutableStateScope tracks ResetMutableState calls made by service to persistence layer
PersistenceResetMutableStateScope
// PersistenceDeleteWorkflowExecutionScope tracks DeleteWorkflowExecution calls made by service to persistence layer
PersistenceDeleteWorkflowExecutionScope
// PersistenceGetCurrentExecutionScope tracks GetCurrentExecution calls made by service to persistence layer
PersistenceGetCurrentExecutionScope
// PersistenceGetTransferTasksScope tracks GetTransferTasks calls made by service to persistence layer
PersistenceGetTransferTasksScope
// PersistenceGetReplicationTasksScope tracks GetReplicationTasks calls made by service to persistence layer
PersistenceGetReplicationTasksScope
// PersistenceCompleteTransferTaskScope tracks CompleteTransferTasks calls made by service to persistence layer
PersistenceCompleteTransferTaskScope
// PersistenceCompleteReplicationTaskScope tracks CompleteReplicationTasks calls made by service to persistence layer
PersistenceCompleteReplicationTaskScope
// PersistenceGetTimerIndexTasksScope tracks GetTimerIndexTasks calls made by service to persistence layer
PersistenceGetTimerIndexTasksScope
// PersistenceCompleteTimerTaskScope tracks CompleteTimerTasks calls made by service to persistence layer
PersistenceCompleteTimerTaskScope
// PersistenceCreateTaskScope tracks CreateTask calls made by service to persistence layer
PersistenceCreateTaskScope
// PersistenceGetTasksScope tracks GetTasks calls made by service to persistence layer
PersistenceGetTasksScope
// PersistenceCompleteTaskScope tracks CompleteTask calls made by service to persistence layer
PersistenceCompleteTaskScope
// PersistenceLeaseTaskListScope tracks LeaseTaskList calls made by service to persistence layer
PersistenceLeaseTaskListScope
// PersistenceUpdateTaskListScope tracks PersistenceUpdateTaskListScope calls made by service to persistence layer
PersistenceUpdateTaskListScope
// PersistenceAppendHistoryEventsScope tracks AppendHistoryEvents calls made by service to persistence layer
PersistenceAppendHistoryEventsScope
// PersistenceGetWorkflowExecutionHistoryScope tracks GetWorkflowExecutionHistory calls made by service to persistence layer
PersistenceGetWorkflowExecutionHistoryScope
// PersistenceDeleteWorkflowExecutionHistoryScope tracks DeleteWorkflowExecutionHistory calls made by service to persistence layer
PersistenceDeleteWorkflowExecutionHistoryScope
// PersistenceCreateDomainScope tracks CreateDomain calls made by service to persistence layer
PersistenceCreateDomainScope
// PersistenceGetDomainScope tracks GetDomain calls made by service to persistence layer
PersistenceGetDomainScope
// PersistenceUpdateDomainScope tracks UpdateDomain calls made by service to persistence layer
PersistenceUpdateDomainScope
// PersistenceDeleteDomainScope tracks DeleteDomain calls made by service to persistence layer
PersistenceDeleteDomainScope
// PersistenceDeleteDomainByNameScope tracks DeleteDomainByName calls made by service to persistence layer
PersistenceDeleteDomainByNameScope
// PersistenceListDomainScope tracks DeleteDomainByName calls made by service to persistence layer
PersistenceListDomainScope
// PersistenceGetMetadataScope tracks DeleteDomainByName calls made by service to persistence layer
PersistenceGetMetadataScope
// PersistenceRecordWorkflowExecutionStartedScope tracks RecordWorkflowExecutionStarted calls made by service to persistence layer
PersistenceRecordWorkflowExecutionStartedScope
// PersistenceRecordWorkflowExecutionClosedScope tracks RecordWorkflowExecutionClosed calls made by service to persistence layer
PersistenceRecordWorkflowExecutionClosedScope
// PersistenceListOpenWorkflowExecutionsScope tracks ListOpenWorkflowExecutions calls made by service to persistence layer
PersistenceListOpenWorkflowExecutionsScope
// PersistenceListClosedWorkflowExecutionsScope tracks ListClosedWorkflowExecutions calls made by service to persistence layer
PersistenceListClosedWorkflowExecutionsScope
// PersistenceListOpenWorkflowExecutionsByTypeScope tracks ListOpenWorkflowExecutionsByType calls made by service to persistence layer
PersistenceListOpenWorkflowExecutionsByTypeScope
// PersistenceListClosedWorkflowExecutionsByTypeScope tracks ListClosedWorkflowExecutionsByType calls made by service to persistence layer
PersistenceListClosedWorkflowExecutionsByTypeScope
// PersistenceListOpenWorkflowExecutionsByWorkflowIDScope tracks ListOpenWorkflowExecutionsByWorkflowID calls made by service to persistence layer
PersistenceListOpenWorkflowExecutionsByWorkflowIDScope
// PersistenceListClosedWorkflowExecutionsByWorkflowIDScope tracks ListClosedWorkflowExecutionsByWorkflowID calls made by service to persistence layer
PersistenceListClosedWorkflowExecutionsByWorkflowIDScope
// PersistenceListClosedWorkflowExecutionsByStatusScope tracks ListClosedWorkflowExecutionsByStatus calls made by service to persistence layer
PersistenceListClosedWorkflowExecutionsByStatusScope
// PersistenceGetClosedWorkflowExecutionScope tracks GetClosedWorkflowExecution calls made by service to persistence layer
PersistenceGetClosedWorkflowExecutionScope
// HistoryClientStartWorkflowExecutionScope tracks RPC calls to history service
HistoryClientStartWorkflowExecutionScope
// HistoryClientRecordActivityTaskHeartbeatScope tracks RPC calls to history service
HistoryClientRecordActivityTaskHeartbeatScope
// HistoryClientRespondDecisionTaskCompletedScope tracks RPC calls to history service
HistoryClientRespondDecisionTaskCompletedScope
// HistoryClientRespondDecisionTaskFailedScope tracks RPC calls to history service
HistoryClientRespondDecisionTaskFailedScope
// HistoryClientRespondActivityTaskCompletedScope tracks RPC calls to history service
HistoryClientRespondActivityTaskCompletedScope
// HistoryClientRespondActivityTaskFailedScope tracks RPC calls to history service
HistoryClientRespondActivityTaskFailedScope
// HistoryClientRespondActivityTaskCanceledScope tracks RPC calls to history service
HistoryClientRespondActivityTaskCanceledScope
// HistoryClientGetMutableStateScope tracks RPC calls to history service
HistoryClientGetMutableStateScope
// HistoryClientResetStickyTaskListScope tracks RPC calls to history service
HistoryClientResetStickyTaskListScope
// HistoryClientDescribeWorkflowExecutionScope tracks RPC calls to history service
HistoryClientDescribeWorkflowExecutionScope
// HistoryClientRecordDecisionTaskStartedScope tracks RPC calls to history service
HistoryClientRecordDecisionTaskStartedScope
// HistoryClientRecordActivityTaskStartedScope tracks RPC calls to history service
HistoryClientRecordActivityTaskStartedScope
// HistoryClientRequestCancelWorkflowExecutionScope tracks RPC calls to history service
HistoryClientRequestCancelWorkflowExecutionScope
// HistoryClientSignalWorkflowExecutionScope tracks RPC calls to history service
HistoryClientSignalWorkflowExecutionScope
// HistoryClientSignalWithStartWorkflowExecutionScope tracks RPC calls to history service
HistoryClientSignalWithStartWorkflowExecutionScope
// HistoryClientRemoveSignalMutableStateScope tracks RPC calls to history service
HistoryClientRemoveSignalMutableStateScope
// HistoryClientTerminateWorkflowExecutionScope tracks RPC calls to history service
HistoryClientTerminateWorkflowExecutionScope
// HistoryClientScheduleDecisionTaskScope tracks RPC calls to history service
HistoryClientScheduleDecisionTaskScope
// HistoryClientRecordChildExecutionCompletedScope tracks RPC calls to history service
HistoryClientRecordChildExecutionCompletedScope
// HistoryClientReplicateEventsScope tracks RPC calls to history service
HistoryClientReplicateEventsScope
// HistoryClientSyncShardStatusScope tracks RPC calls to history service
HistoryClientSyncShardStatusScope
// MatchingClientPollForDecisionTaskScope tracks RPC calls to matching service
MatchingClientPollForDecisionTaskScope
// MatchingClientPollForActivityTaskScope tracks RPC calls to matching service
MatchingClientPollForActivityTaskScope
// MatchingClientAddActivityTaskScope tracks RPC calls to matching service
MatchingClientAddActivityTaskScope
// MatchingClientAddDecisionTaskScope tracks RPC calls to matching service
MatchingClientAddDecisionTaskScope
// MatchingClientQueryWorkflowScope tracks RPC calls to matching service
MatchingClientQueryWorkflowScope
// MatchingClientRespondQueryTaskCompletedScope tracks RPC calls to matching service
MatchingClientRespondQueryTaskCompletedScope
// MatchingClientCancelOutstandingPollScope tracks RPC calls to matching service
MatchingClientCancelOutstandingPollScope
// MatchingClientDescribeTaskListScope tracks RPC calls to matching service
MatchingClientDescribeTaskListScope
// DomainCacheScope tracks domain cache callbacks
DomainCacheScope
NumCommonScopes
)
Scopes enum
const (
// FrontendStartWorkflowExecutionScope is the metric scope for frontend.StartWorkflowExecution
FrontendStartWorkflowExecutionScope = iota + NumCommonScopes
// PollForDecisionTaskScope is the metric scope for frontend.PollForDecisionTask
FrontendPollForDecisionTaskScope
// FrontendPollForActivityTaskScope is the metric scope for frontend.PollForActivityTask
FrontendPollForActivityTaskScope
// FrontendRecordActivityTaskHeartbeatScope is the metric scope for frontend.RecordActivityTaskHeartbeat
FrontendRecordActivityTaskHeartbeatScope
// FrontendRecordActivityTaskHeartbeatByIDScope is the metric scope for frontend.RespondDecisionTaskCompleted
FrontendRecordActivityTaskHeartbeatByIDScope
// FrontendRespondDecisionTaskCompletedScope is the metric scope for frontend.RespondDecisionTaskCompleted
FrontendRespondDecisionTaskCompletedScope
// FrontendRespondDecisionTaskFailedScope is the metric scope for frontend.RespondDecisionTaskFailed
FrontendRespondDecisionTaskFailedScope
// FrontendRespondQueryTaskCompletedScope is the metric scope for frontend.RespondQueryTaskCompleted
FrontendRespondQueryTaskCompletedScope
// FrontendRespondActivityTaskCompletedScope is the metric scope for frontend.RespondActivityTaskCompleted
FrontendRespondActivityTaskCompletedScope
// FrontendRespondActivityTaskFailedScope is the metric scope for frontend.RespondActivityTaskFailed
FrontendRespondActivityTaskFailedScope
// FrontendRespondActivityTaskCanceledScope is the metric scope for frontend.RespondActivityTaskCanceled
FrontendRespondActivityTaskCanceledScope
// FrontendRespondActivityTaskCompletedScope is the metric scope for frontend.RespondActivityTaskCompletedByID
FrontendRespondActivityTaskCompletedByIDScope
// FrontendRespondActivityTaskFailedScope is the metric scope for frontend.RespondActivityTaskFailedByID
FrontendRespondActivityTaskFailedByIDScope
// FrontendRespondActivityTaskCanceledScope is the metric scope for frontend.RespondActivityTaskCanceledByID
FrontendRespondActivityTaskCanceledByIDScope
// FrontendGetWorkflowExecutionHistoryScope is the metric scope for frontend.GetWorkflowExecutionHistory
FrontendGetWorkflowExecutionHistoryScope
// FrontendSignalWorkflowExecutionScope is the metric scope for frontend.SignalWorkflowExecution
FrontendSignalWorkflowExecutionScope
// FrontendSignalWithStartWorkflowExecutionScope is the metric scope for frontend.SignalWithStartWorkflowExecution
FrontendSignalWithStartWorkflowExecutionScope
// FrontendTerminateWorkflowExecutionScope is the metric scope for frontend.TerminateWorkflowExecution
FrontendTerminateWorkflowExecutionScope
// FrontendRequestCancelWorkflowExecutionScope is the metric scope for frontend.RequestCancelWorkflowExecution
FrontendRequestCancelWorkflowExecutionScope
// FrontendListOpenWorkflowExecutionsScope is the metric scope for frontend.ListOpenWorkflowExecutions
FrontendListOpenWorkflowExecutionsScope
// FrontendListClosedWorkflowExecutionsScope is the metric scope for frontend.ListClosedWorkflowExecutions
FrontendListClosedWorkflowExecutionsScope
// FrontendRegisterDomainScope is the metric scope for frontend.RegisterDomain
FrontendRegisterDomainScope
// FrontendDescribeDomainScope is the metric scope for frontend.DescribeDomain
FrontendDescribeDomainScope
// FrontendUpdateDomainScope is the metric scope for frontend.DescribeDomain
FrontendUpdateDomainScope
// FrontendDeprecateDomainScope is the metric scope for frontend.DeprecateDomain
FrontendDeprecateDomainScope
// FrontendQueryWorkflowScope is the metric scope for frontend.QueryWorkflow
FrontendQueryWorkflowScope
// FrontendDescribeWorkflowExecutionScope is the metric scope for frontend.DescribeWorkflowExecution
FrontendDescribeWorkflowExecutionScope
// FrontendDescribeTaskListScope is the metric scope for frontend.DescribeTaskList
FrontendDescribeTaskListScope
// FrontendResetStickyTaskListScope is the metric scope for frontend.ResetStickyTaskList
FrontendResetStickyTaskListScope
// FrontendListDomainsScope is the metric scope for frontend.ListDomain
FrontendListDomainsScope
NumFrontendScopes
)
-- Operation scopes for Frontend service --
const (
// HistoryStartWorkflowExecutionScope tracks StartWorkflowExecution API calls received by service
HistoryStartWorkflowExecutionScope = iota + NumCommonScopes
// HistoryRecordActivityTaskHeartbeatScope tracks RecordActivityTaskHeartbeat API calls received by service
HistoryRecordActivityTaskHeartbeatScope
// HistoryRespondDecisionTaskCompletedScope tracks RespondDecisionTaskCompleted API calls received by service
HistoryRespondDecisionTaskCompletedScope
// HistoryRespondDecisionTaskFailedScope tracks RespondDecisionTaskFailed API calls received by service
HistoryRespondDecisionTaskFailedScope
// HistoryRespondActivityTaskCompletedScope tracks RespondActivityTaskCompleted API calls received by service
HistoryRespondActivityTaskCompletedScope
// HistoryRespondActivityTaskFailedScope tracks RespondActivityTaskFailed API calls received by service
HistoryRespondActivityTaskFailedScope
// HistoryRespondActivityTaskCanceledScope tracks RespondActivityTaskCanceled API calls received by service
HistoryRespondActivityTaskCanceledScope
// HistoryGetMutableStateScope tracks GetMutableStateScope API calls received by service
HistoryGetMutableStateScope
// HistoryResetStickyTaskListScope tracks ResetStickyTaskListScope API calls received by service
HistoryResetStickyTaskListScope
// HistoryDescribeWorkflowExecutionScope tracks DescribeWorkflowExecution API calls received by service
HistoryDescribeWorkflowExecutionScope
// HistoryRecordDecisionTaskStartedScope tracks RecordDecisionTaskStarted API calls received by service
HistoryRecordDecisionTaskStartedScope
// HistoryRecordActivityTaskStartedScope tracks RecordActivityTaskStarted API calls received by service
HistoryRecordActivityTaskStartedScope
// HistorySignalWorkflowExecutionScope tracks SignalWorkflowExecution API calls received by service
HistorySignalWorkflowExecutionScope
// HistorySignalWithStartWorkflowExecutionScope tracks SignalWithStartWorkflowExecution API calls received by service
HistorySignalWithStartWorkflowExecutionScope
// HistoryRemoveSignalMutableStateScope tracks RemoveSignalMutableState API calls received by service
HistoryRemoveSignalMutableStateScope
// HistoryTerminateWorkflowExecutionScope tracks TerminateWorkflowExecution API calls received by service
HistoryTerminateWorkflowExecutionScope
// HistoryScheduleDecisionTaskScope tracks ScheduleDecisionTask API calls received by service
HistoryScheduleDecisionTaskScope
// HistoryRecordChildExecutionCompletedScope tracks CompleteChildExecution API calls received by service
HistoryRecordChildExecutionCompletedScope
// HistoryRequestCancelWorkflowExecutionScope tracks RequestCancelWorkflowExecution API calls received by service
HistoryRequestCancelWorkflowExecutionScope
// HistoryReplicateEventsScope tracks ReplicateEvents API calls received by service
HistoryReplicateEventsScope
// HistorySyncShardStatusScope tracks ReplicateEvents API calls received by service
HistorySyncShardStatusScope
// HistoryShardControllerScope is the scope used by shard controller
HistoryShardControllerScope
// TransferQueueProcessorScope is the scope used by all metric emitted by transfer queue processor
TransferQueueProcessorScope
// TransferActiveQueueProcessorScope is the scope used by all metric emitted by transfer queue processor
TransferActiveQueueProcessorScope
// TransferStandbyQueueProcessorScope is the scope used by all metric emitted by transfer queue processor
TransferStandbyQueueProcessorScope
// TransferActiveTaskActivityScope is the scope used for activity task processing by transfer queue processor
TransferActiveTaskActivityScope
// TransferActiveTaskDecisionScope is the scope used for decision task processing by transfer queue processor
TransferActiveTaskDecisionScope
// TransferActiveTaskCloseExecutionScope is the scope used for close execution task processing by transfer queue processor
TransferActiveTaskCloseExecutionScope
// TransferActiveTaskCancelExecutionScope is the scope used for cancel execution task processing by transfer queue processor
TransferActiveTaskCancelExecutionScope
// TransferActiveTaskSignalExecutionScope is the scope used for signal execution task processing by transfer queue processor
TransferActiveTaskSignalExecutionScope
// TransferActiveTaskStartChildExecutionScope is the scope used for start child execution task processing by transfer queue processor
TransferActiveTaskStartChildExecutionScope
// TransferStandbyTaskActivityScope is the scope used for activity task processing by transfer queue processor
TransferStandbyTaskActivityScope
// TransferStandbyTaskDecisionScope is the scope used for decision task processing by transfer queue processor
TransferStandbyTaskDecisionScope
// TransferStandbyTaskCloseExecutionScope is the scope used for close execution task processing by transfer queue processor
TransferStandbyTaskCloseExecutionScope
// TransferStandbyTaskCancelExecutionScope is the scope used for cancel execution task processing by transfer queue processor
TransferStandbyTaskCancelExecutionScope
// TransferStandbyTaskSignalExecutionScope is the scope used for signal execution task processing by transfer queue processor
TransferStandbyTaskSignalExecutionScope
// TransferStandbyTaskStartChildExecutionScope is the scope used for start child execution task processing by transfer queue processor
TransferStandbyTaskStartChildExecutionScope
// TimerQueueProcessorScope is the scope used by all metric emitted by timer queue processor
TimerQueueProcessorScope
// TimerActiveQueueProcessorScope is the scope used by all metric emitted by timer queue processor
TimerActiveQueueProcessorScope
// TimerQueueProcessorScope is the scope used by all metric emitted by timer queue processor
TimerStandbyQueueProcessorScope
// TimerActiveTaskActivityTimeoutScope is the scope used by metric emitted by timer queue processor for processing activity timeouts
TimerActiveTaskActivityTimeoutScope
// TimerActiveTaskDecisionTimeoutScope is the scope used by metric emitted by timer queue processor for processing decision timeouts
TimerActiveTaskDecisionTimeoutScope
// TimerActiveTaskUserTimerScope is the scope used by metric emitted by timer queue processor for processing user timers
TimerActiveTaskUserTimerScope
// TimerActiveTaskWorkflowTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow timeouts.
TimerActiveTaskWorkflowTimeoutScope
// TimerActiveTaskRetryTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
TimerActiveTaskRetryTimerScope
// TimerActiveTaskDeleteHistoryEvent is the scope used by metric emitted by timer queue processor for processing history event cleanup
TimerActiveTaskDeleteHistoryEvent
// TimerStandbyTaskActivityTimeoutScope is the scope used by metric emitted by timer queue processor for processing activity timeouts
TimerStandbyTaskActivityTimeoutScope
// TimerStandbyTaskDecisionTimeoutScope is the scope used by metric emitted by timer queue processor for processing decision timeouts
TimerStandbyTaskDecisionTimeoutScope
// TimerStandbyTaskUserTimerScope is the scope used by metric emitted by timer queue processor for processing user timers
TimerStandbyTaskUserTimerScope
// TimerStandbyTaskWorkflowTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow timeouts.
TimerStandbyTaskWorkflowTimeoutScope
// TimerStandbyTaskRetryTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
TimerStandbyTaskRetryTimerScope
// TimerStandbyTaskDeleteHistoryEvent is the scope used by metric emitted by timer queue processor for processing history event cleanup
TimerStandbyTaskDeleteHistoryEvent
// HistoryEventNotificationScope is the scope used by shard history event nitification
HistoryEventNotificationScope
// ReplicatorQueueProcessorScope is the scope used by all metric emitted by replicator queue processor
ReplicatorQueueProcessorScope
// ReplicatorTaskHistoryScope is the scope used for history task processing by replicator queue processor
ReplicatorTaskHistoryScope
// ReplicateHistoryEventsScope is the scope used by historyReplicator API for applying events
ReplicateHistoryEventsScope
// ShardInfoScope is the scope used when updating shard info
ShardInfoScope
NumHistoryScopes
)
-- Operation scopes for History service --
const (
// PollForDecisionTaskScope tracks PollForDecisionTask API calls received by service
MatchingPollForDecisionTaskScope = iota + NumCommonScopes
// PollForActivityTaskScope tracks PollForActivityTask API calls received by service
MatchingPollForActivityTaskScope
// MatchingAddActivityTaskScope tracks AddActivityTask API calls received by service
MatchingAddActivityTaskScope
// MatchingAddDecisionTaskScope tracks AddDecisionTask API calls received by service
MatchingAddDecisionTaskScope
// MatchingTaskListMgrScope is the metrics scope for matching.TaskListManager component
MatchingTaskListMgrScope
// MatchingQueryWorkflowScope tracks AddDecisionTask API calls received by service
MatchingQueryWorkflowScope
// MatchingRespondQueryTaskCompletedScope tracks AddDecisionTask API calls received by service
MatchingRespondQueryTaskCompletedScope
// MatchingCancelOutstandingPollScope tracks CancelOutstandingPoll API calls received by service
MatchingCancelOutstandingPollScope
// MatchingDescribeTaskListScope tracks DescribeTaskList API calls received by service
MatchingDescribeTaskListScope
NumMatchingScopes
)
-- Operation scopes for Matching service --
const (
// ReplicationScope is the scope used by all metric emitted by replicator
ReplicatorScope = iota + NumCommonScopes
// DomainReplicationTaskScope is the scope used by domain task replication processing
DomainReplicationTaskScope
// HistoryReplicationTaskScope is the scope used by history task replication processing
HistoryReplicationTaskScope
// SyncShardTaskScope is the scope used by sync shrad information processing
SyncShardTaskScope
NumWorkerScopes
)
-- Operation scopes for Worker service --
const (
CadenceRequests = iota
CadenceFailures
CadenceCriticalFailures
CadenceLatency
CadenceErrBadRequestCounter
CadenceErrDomainNotActiveCounter
CadenceErrServiceBusyCounter
CadenceErrEntityNotExistsCounter
CadenceErrExecutionAlreadyStartedCounter
CadenceErrDomainAlreadyExistsCounter
CadenceErrCancellationAlreadyRequestedCounter
CadenceErrQueryFailedCounter
CadenceErrLimitExceededCounter
CadenceErrContextTimeoutCounter
CadenceErrRetryTaskCounter
PersistenceRequests
PersistenceFailures
PersistenceLatency
PersistenceErrShardExistsCounter
PersistenceErrShardOwnershipLostCounter
PersistenceErrConditionFailedCounter
PersistenceErrTimeoutCounter
PersistenceErrBusyCounter
HistoryClientFailures
MatchingClientFailures
DomainCacheTotalCallbacksLatency
DomainCacheBeforeCallbackLatency
DomainCacheAfterCallbackLatency
NumCommonMetrics // Needs to be last on this list for iota numbering
)
Common Metrics enum
const (
TaskRequests = iota + NumCommonMetrics
TaskFailures
TaskLatency
AckLevelUpdateCounter
AckLevelUpdateFailedCounter
DecisionTypeScheduleActivityCounter
DecisionTypeCompleteWorkflowCounter
DecisionTypeFailWorkflowCounter
DecisionTypeCancelWorkflowCounter
DecisionTypeStartTimerCounter
DecisionTypeCancelActivityCounter
DecisionTypeCancelTimerCounter
DecisionTypeRecordMarkerCounter
DecisionTypeCancelExternalWorkflowCounter
DecisionTypeChildWorkflowCounter
DecisionTypeContinueAsNewCounter
DecisionTypeSignalExternalWorkflowCounter
MultipleCompletionDecisionsCounter
FailedDecisionsCounter
StaleMutableStateCounter
ConcurrencyUpdateFailureCounter
CadenceErrEventAlreadyStartedCounter
CadenceErrShardOwnershipLostCounter
HeartbeatTimeoutCounter
ScheduleToStartTimeoutCounter
StartToCloseTimeoutCounter
ScheduleToCloseTimeoutCounter
NewTimerCounter
NewTimerNotifyCounter
AcquireShardsCounter
AcquireShardsLatency
ShardClosedCounter
ShardItemCreatedCounter
ShardItemRemovedCounter
ShardInfoTransferDiffTimer
ShardInfoTimerDiffTimer
MembershipChangedCounter
NumShardsGauge
GetEngineForShardErrorCounter
GetEngineForShardLatency
RemoveEngineForShardLatency
CompleteDecisionWithStickyEnabledCounter
CompleteDecisionWithStickyDisabledCounter
HistoryEventNotificationQueueingLatency
HistoryEventNotificationFanoutLatency
HistoryEventNotificationInFlightMessageGauge
HistoryEventNotificationFailDeliveryCount
EmptyReplicationEventsCounter
DuplicateReplicationEventsCounter
StaleReplicationEventsCounter
ReplicationEventsSizeTimer
BufferReplicationTaskTimer
UnbufferReplicationTaskTimer
HistoryConflictsCounter
HistoryTaskStandbyRetryCounter
HistoryTaskNotActiveCounter
HistoryTaskBatchCompleteCounter
)
History Metrics enum
const (
PollSuccessCounter = iota + NumCommonMetrics
PollTimeoutCounter
PollSuccessWithSyncCounter
LeaseRequestCounter
LeaseFailureCounter
ConditionFailedErrorCounter
RespondQueryTaskFailedCounter
SyncThrottleCounter
BufferThrottleCounter
)
Matching metrics enum
const (
ReplicatorMessages = iota + NumCommonMetrics
ReplicatorFailures
ReplicatorLatency
)
Worker metrics enum
const (
// NoError indicates that there is no error (error should be nil)
NoError = ErrorClass(iota)
// UserError indicates that this is NOT an SLA-reportable error
UserError
// InternalError indicates that this is an SLA-reportable error
InternalError
)
Variables ¶
var GoRuntimeMetrics = map[MetricName]MetricType{
NumGoRoutinesGauge: Gauge,
GoMaxProcsGauge: Gauge,
MemoryAllocatedGauge: Gauge,
MemoryHeapGauge: Gauge,
MemoryHeapIdleGauge: Gauge,
MemoryHeapInuseGauge: Gauge,
MemoryStackGauge: Gauge,
NumGCCounter: Counter,
GcPauseMsTimer: Timer,
}
GoRuntimeMetrics represent the runtime stats from go runtime
var MetricDefs = map[ServiceIdx]map[int]metricDefinition{
Common: {
CadenceRequests: {/* contains filtered or unexported fields */},
CadenceFailures: {/* contains filtered or unexported fields */},
CadenceCriticalFailures: {/* contains filtered or unexported fields */},
CadenceLatency: {/* contains filtered or unexported fields */},
CadenceErrBadRequestCounter: {/* contains filtered or unexported fields */},
CadenceErrDomainNotActiveCounter: {/* contains filtered or unexported fields */},
CadenceErrServiceBusyCounter: {/* contains filtered or unexported fields */},
CadenceErrEntityNotExistsCounter: {/* contains filtered or unexported fields */},
CadenceErrExecutionAlreadyStartedCounter: {/* contains filtered or unexported fields */},
CadenceErrDomainAlreadyExistsCounter: {/* contains filtered or unexported fields */},
CadenceErrCancellationAlreadyRequestedCounter: {/* contains filtered or unexported fields */},
CadenceErrQueryFailedCounter: {/* contains filtered or unexported fields */},
CadenceErrLimitExceededCounter: {/* contains filtered or unexported fields */},
CadenceErrContextTimeoutCounter: {/* contains filtered or unexported fields */},
CadenceErrRetryTaskCounter: {/* contains filtered or unexported fields */},
PersistenceRequests: {/* contains filtered or unexported fields */},
PersistenceFailures: {/* contains filtered or unexported fields */},
PersistenceLatency: {/* contains filtered or unexported fields */},
PersistenceErrShardExistsCounter: {/* contains filtered or unexported fields */},
PersistenceErrShardOwnershipLostCounter: {/* contains filtered or unexported fields */},
PersistenceErrConditionFailedCounter: {/* contains filtered or unexported fields */},
PersistenceErrTimeoutCounter: {/* contains filtered or unexported fields */},
PersistenceErrBusyCounter: {/* contains filtered or unexported fields */},
HistoryClientFailures: {/* contains filtered or unexported fields */},
MatchingClientFailures: {/* contains filtered or unexported fields */},
DomainCacheTotalCallbacksLatency: {/* contains filtered or unexported fields */},
DomainCacheBeforeCallbackLatency: {/* contains filtered or unexported fields */},
DomainCacheAfterCallbackLatency: {/* contains filtered or unexported fields */},
},
Frontend: {},
History: {
TaskRequests: {/* contains filtered or unexported fields */},
TaskFailures: {/* contains filtered or unexported fields */},
TaskLatency: {/* contains filtered or unexported fields */},
AckLevelUpdateCounter: {/* contains filtered or unexported fields */},
AckLevelUpdateFailedCounter: {/* contains filtered or unexported fields */},
DecisionTypeScheduleActivityCounter: {/* contains filtered or unexported fields */},
DecisionTypeCompleteWorkflowCounter: {/* contains filtered or unexported fields */},
DecisionTypeFailWorkflowCounter: {/* contains filtered or unexported fields */},
DecisionTypeCancelWorkflowCounter: {/* contains filtered or unexported fields */},
DecisionTypeStartTimerCounter: {/* contains filtered or unexported fields */},
DecisionTypeCancelActivityCounter: {/* contains filtered or unexported fields */},
DecisionTypeCancelTimerCounter: {/* contains filtered or unexported fields */},
DecisionTypeRecordMarkerCounter: {/* contains filtered or unexported fields */},
DecisionTypeCancelExternalWorkflowCounter: {/* contains filtered or unexported fields */},
DecisionTypeContinueAsNewCounter: {/* contains filtered or unexported fields */},
DecisionTypeChildWorkflowCounter: {/* contains filtered or unexported fields */},
MultipleCompletionDecisionsCounter: {/* contains filtered or unexported fields */},
FailedDecisionsCounter: {/* contains filtered or unexported fields */},
StaleMutableStateCounter: {/* contains filtered or unexported fields */},
ConcurrencyUpdateFailureCounter: {/* contains filtered or unexported fields */},
CadenceErrShardOwnershipLostCounter: {/* contains filtered or unexported fields */},
CadenceErrEventAlreadyStartedCounter: {/* contains filtered or unexported fields */},
HeartbeatTimeoutCounter: {/* contains filtered or unexported fields */},
ScheduleToStartTimeoutCounter: {/* contains filtered or unexported fields */},
StartToCloseTimeoutCounter: {/* contains filtered or unexported fields */},
ScheduleToCloseTimeoutCounter: {/* contains filtered or unexported fields */},
NewTimerCounter: {/* contains filtered or unexported fields */},
NewTimerNotifyCounter: {/* contains filtered or unexported fields */},
AcquireShardsCounter: {/* contains filtered or unexported fields */},
AcquireShardsLatency: {/* contains filtered or unexported fields */},
ShardClosedCounter: {/* contains filtered or unexported fields */},
ShardItemCreatedCounter: {/* contains filtered or unexported fields */},
ShardItemRemovedCounter: {/* contains filtered or unexported fields */},
ShardInfoTransferDiffTimer: {/* contains filtered or unexported fields */},
ShardInfoTimerDiffTimer: {/* contains filtered or unexported fields */},
MembershipChangedCounter: {/* contains filtered or unexported fields */},
NumShardsGauge: {/* contains filtered or unexported fields */},
GetEngineForShardErrorCounter: {/* contains filtered or unexported fields */},
GetEngineForShardLatency: {/* contains filtered or unexported fields */},
RemoveEngineForShardLatency: {/* contains filtered or unexported fields */},
CompleteDecisionWithStickyEnabledCounter: {/* contains filtered or unexported fields */},
CompleteDecisionWithStickyDisabledCounter: {/* contains filtered or unexported fields */},
HistoryEventNotificationQueueingLatency: {/* contains filtered or unexported fields */},
HistoryEventNotificationFanoutLatency: {/* contains filtered or unexported fields */},
HistoryEventNotificationInFlightMessageGauge: {/* contains filtered or unexported fields */},
HistoryEventNotificationFailDeliveryCount: {/* contains filtered or unexported fields */},
EmptyReplicationEventsCounter: {/* contains filtered or unexported fields */},
DuplicateReplicationEventsCounter: {/* contains filtered or unexported fields */},
StaleReplicationEventsCounter: {/* contains filtered or unexported fields */},
ReplicationEventsSizeTimer: {/* contains filtered or unexported fields */},
BufferReplicationTaskTimer: {/* contains filtered or unexported fields */},
UnbufferReplicationTaskTimer: {/* contains filtered or unexported fields */},
HistoryConflictsCounter: {/* contains filtered or unexported fields */},
HistoryTaskStandbyRetryCounter: {/* contains filtered or unexported fields */},
HistoryTaskNotActiveCounter: {/* contains filtered or unexported fields */},
HistoryTaskBatchCompleteCounter: {/* contains filtered or unexported fields */},
},
Matching: {
PollSuccessCounter: {/* contains filtered or unexported fields */},
PollTimeoutCounter: {/* contains filtered or unexported fields */},
PollSuccessWithSyncCounter: {/* contains filtered or unexported fields */},
LeaseRequestCounter: {/* contains filtered or unexported fields */},
LeaseFailureCounter: {/* contains filtered or unexported fields */},
ConditionFailedErrorCounter: {/* contains filtered or unexported fields */},
RespondQueryTaskFailedCounter: {/* contains filtered or unexported fields */},
SyncThrottleCounter: {/* contains filtered or unexported fields */},
BufferThrottleCounter: {/* contains filtered or unexported fields */},
},
Worker: {
ReplicatorMessages: {/* contains filtered or unexported fields */},
ReplicatorFailures: {/* contains filtered or unexported fields */},
ReplicatorLatency: {/* contains filtered or unexported fields */},
},
}
MetricDefs record the metrics for all services
var ScopeDefs = map[ServiceIdx]map[int]scopeDefinition{
Common: {
PersistenceCreateShardScope: {/* contains filtered or unexported fields */},
PersistenceGetShardScope: {/* contains filtered or unexported fields */},
PersistenceUpdateShardScope: {/* contains filtered or unexported fields */},
PersistenceCreateWorkflowExecutionScope: {/* contains filtered or unexported fields */},
PersistenceGetWorkflowExecutionScope: {/* contains filtered or unexported fields */},
PersistenceUpdateWorkflowExecutionScope: {/* contains filtered or unexported fields */},
PersistenceResetMutableStateScope: {/* contains filtered or unexported fields */},
PersistenceDeleteWorkflowExecutionScope: {/* contains filtered or unexported fields */},
PersistenceGetCurrentExecutionScope: {/* contains filtered or unexported fields */},
PersistenceGetTransferTasksScope: {/* contains filtered or unexported fields */},
PersistenceGetReplicationTasksScope: {/* contains filtered or unexported fields */},
PersistenceCompleteTransferTaskScope: {/* contains filtered or unexported fields */},
PersistenceCompleteReplicationTaskScope: {/* contains filtered or unexported fields */},
PersistenceGetTimerIndexTasksScope: {/* contains filtered or unexported fields */},
PersistenceCompleteTimerTaskScope: {/* contains filtered or unexported fields */},
PersistenceCreateTaskScope: {/* contains filtered or unexported fields */},
PersistenceGetTasksScope: {/* contains filtered or unexported fields */},
PersistenceCompleteTaskScope: {/* contains filtered or unexported fields */},
PersistenceLeaseTaskListScope: {/* contains filtered or unexported fields */},
PersistenceUpdateTaskListScope: {/* contains filtered or unexported fields */},
PersistenceAppendHistoryEventsScope: {/* contains filtered or unexported fields */},
PersistenceGetWorkflowExecutionHistoryScope: {/* contains filtered or unexported fields */},
PersistenceDeleteWorkflowExecutionHistoryScope: {/* contains filtered or unexported fields */},
PersistenceCreateDomainScope: {/* contains filtered or unexported fields */},
PersistenceGetDomainScope: {/* contains filtered or unexported fields */},
PersistenceUpdateDomainScope: {/* contains filtered or unexported fields */},
PersistenceDeleteDomainScope: {/* contains filtered or unexported fields */},
PersistenceDeleteDomainByNameScope: {/* contains filtered or unexported fields */},
PersistenceListDomainScope: {/* contains filtered or unexported fields */},
PersistenceGetMetadataScope: {/* contains filtered or unexported fields */},
PersistenceRecordWorkflowExecutionStartedScope: {/* contains filtered or unexported fields */},
PersistenceRecordWorkflowExecutionClosedScope: {/* contains filtered or unexported fields */},
PersistenceListOpenWorkflowExecutionsScope: {/* contains filtered or unexported fields */},
PersistenceListClosedWorkflowExecutionsScope: {/* contains filtered or unexported fields */},
PersistenceListOpenWorkflowExecutionsByTypeScope: {/* contains filtered or unexported fields */},
PersistenceListClosedWorkflowExecutionsByTypeScope: {/* contains filtered or unexported fields */},
PersistenceListOpenWorkflowExecutionsByWorkflowIDScope: {/* contains filtered or unexported fields */},
PersistenceListClosedWorkflowExecutionsByWorkflowIDScope: {/* contains filtered or unexported fields */},
PersistenceListClosedWorkflowExecutionsByStatusScope: {/* contains filtered or unexported fields */},
PersistenceGetClosedWorkflowExecutionScope: {/* contains filtered or unexported fields */},
HistoryClientStartWorkflowExecutionScope: {/* contains filtered or unexported fields */},
HistoryClientRecordActivityTaskHeartbeatScope: {/* contains filtered or unexported fields */},
HistoryClientRespondDecisionTaskCompletedScope: {/* contains filtered or unexported fields */},
HistoryClientRespondDecisionTaskFailedScope: {/* contains filtered or unexported fields */},
HistoryClientRespondActivityTaskCompletedScope: {/* contains filtered or unexported fields */},
HistoryClientRespondActivityTaskFailedScope: {/* contains filtered or unexported fields */},
HistoryClientRespondActivityTaskCanceledScope: {/* contains filtered or unexported fields */},
HistoryClientGetMutableStateScope: {/* contains filtered or unexported fields */},
HistoryClientResetStickyTaskListScope: {/* contains filtered or unexported fields */},
HistoryClientDescribeWorkflowExecutionScope: {/* contains filtered or unexported fields */},
HistoryClientRecordDecisionTaskStartedScope: {/* contains filtered or unexported fields */},
HistoryClientRecordActivityTaskStartedScope: {/* contains filtered or unexported fields */},
HistoryClientRequestCancelWorkflowExecutionScope: {/* contains filtered or unexported fields */},
HistoryClientSignalWorkflowExecutionScope: {/* contains filtered or unexported fields */},
HistoryClientSignalWithStartWorkflowExecutionScope: {/* contains filtered or unexported fields */},
HistoryClientRemoveSignalMutableStateScope: {/* contains filtered or unexported fields */},
HistoryClientTerminateWorkflowExecutionScope: {/* contains filtered or unexported fields */},
HistoryClientScheduleDecisionTaskScope: {/* contains filtered or unexported fields */},
HistoryClientRecordChildExecutionCompletedScope: {/* contains filtered or unexported fields */},
HistoryClientReplicateEventsScope: {/* contains filtered or unexported fields */},
HistoryClientSyncShardStatusScope: {/* contains filtered or unexported fields */},
MatchingClientPollForDecisionTaskScope: {/* contains filtered or unexported fields */},
MatchingClientPollForActivityTaskScope: {/* contains filtered or unexported fields */},
MatchingClientAddActivityTaskScope: {/* contains filtered or unexported fields */},
MatchingClientAddDecisionTaskScope: {/* contains filtered or unexported fields */},
MatchingClientQueryWorkflowScope: {/* contains filtered or unexported fields */},
MatchingClientRespondQueryTaskCompletedScope: {/* contains filtered or unexported fields */},
MatchingClientCancelOutstandingPollScope: {/* contains filtered or unexported fields */},
MatchingClientDescribeTaskListScope: {/* contains filtered or unexported fields */},
DomainCacheScope: {/* contains filtered or unexported fields */},
},
Frontend: {
FrontendStartWorkflowExecutionScope: {/* contains filtered or unexported fields */},
FrontendPollForDecisionTaskScope: {/* contains filtered or unexported fields */},
FrontendPollForActivityTaskScope: {/* contains filtered or unexported fields */},
FrontendRecordActivityTaskHeartbeatScope: {/* contains filtered or unexported fields */},
FrontendRecordActivityTaskHeartbeatByIDScope: {/* contains filtered or unexported fields */},
FrontendRespondDecisionTaskCompletedScope: {/* contains filtered or unexported fields */},
FrontendRespondDecisionTaskFailedScope: {/* contains filtered or unexported fields */},
FrontendRespondQueryTaskCompletedScope: {/* contains filtered or unexported fields */},
FrontendRespondActivityTaskCompletedScope: {/* contains filtered or unexported fields */},
FrontendRespondActivityTaskFailedScope: {/* contains filtered or unexported fields */},
FrontendRespondActivityTaskCanceledScope: {/* contains filtered or unexported fields */},
FrontendRespondActivityTaskCompletedByIDScope: {/* contains filtered or unexported fields */},
FrontendRespondActivityTaskFailedByIDScope: {/* contains filtered or unexported fields */},
FrontendRespondActivityTaskCanceledByIDScope: {/* contains filtered or unexported fields */},
FrontendGetWorkflowExecutionHistoryScope: {/* contains filtered or unexported fields */},
FrontendSignalWorkflowExecutionScope: {/* contains filtered or unexported fields */},
FrontendSignalWithStartWorkflowExecutionScope: {/* contains filtered or unexported fields */},
FrontendTerminateWorkflowExecutionScope: {/* contains filtered or unexported fields */},
FrontendRequestCancelWorkflowExecutionScope: {/* contains filtered or unexported fields */},
FrontendListOpenWorkflowExecutionsScope: {/* contains filtered or unexported fields */},
FrontendListClosedWorkflowExecutionsScope: {/* contains filtered or unexported fields */},
FrontendRegisterDomainScope: {/* contains filtered or unexported fields */},
FrontendDescribeDomainScope: {/* contains filtered or unexported fields */},
FrontendListDomainsScope: {/* contains filtered or unexported fields */},
FrontendUpdateDomainScope: {/* contains filtered or unexported fields */},
FrontendDeprecateDomainScope: {/* contains filtered or unexported fields */},
FrontendQueryWorkflowScope: {/* contains filtered or unexported fields */},
FrontendDescribeWorkflowExecutionScope: {/* contains filtered or unexported fields */},
FrontendDescribeTaskListScope: {/* contains filtered or unexported fields */},
},
History: {
HistoryStartWorkflowExecutionScope: {/* contains filtered or unexported fields */},
HistoryRecordActivityTaskHeartbeatScope: {/* contains filtered or unexported fields */},
HistoryRespondDecisionTaskCompletedScope: {/* contains filtered or unexported fields */},
HistoryRespondDecisionTaskFailedScope: {/* contains filtered or unexported fields */},
HistoryRespondActivityTaskCompletedScope: {/* contains filtered or unexported fields */},
HistoryRespondActivityTaskFailedScope: {/* contains filtered or unexported fields */},
HistoryRespondActivityTaskCanceledScope: {/* contains filtered or unexported fields */},
HistoryGetMutableStateScope: {/* contains filtered or unexported fields */},
HistoryResetStickyTaskListScope: {/* contains filtered or unexported fields */},
HistoryDescribeWorkflowExecutionScope: {/* contains filtered or unexported fields */},
HistoryRecordDecisionTaskStartedScope: {/* contains filtered or unexported fields */},
HistoryRecordActivityTaskStartedScope: {/* contains filtered or unexported fields */},
HistorySignalWorkflowExecutionScope: {/* contains filtered or unexported fields */},
HistorySignalWithStartWorkflowExecutionScope: {/* contains filtered or unexported fields */},
HistoryRemoveSignalMutableStateScope: {/* contains filtered or unexported fields */},
HistoryTerminateWorkflowExecutionScope: {/* contains filtered or unexported fields */},
HistoryScheduleDecisionTaskScope: {/* contains filtered or unexported fields */},
HistoryRecordChildExecutionCompletedScope: {/* contains filtered or unexported fields */},
HistoryRequestCancelWorkflowExecutionScope: {/* contains filtered or unexported fields */},
HistoryReplicateEventsScope: {/* contains filtered or unexported fields */},
HistorySyncShardStatusScope: {/* contains filtered or unexported fields */},
HistoryShardControllerScope: {/* contains filtered or unexported fields */},
TransferQueueProcessorScope: {/* contains filtered or unexported fields */},
TransferActiveQueueProcessorScope: {/* contains filtered or unexported fields */},
TransferStandbyQueueProcessorScope: {/* contains filtered or unexported fields */},
TransferActiveTaskActivityScope: {/* contains filtered or unexported fields */},
TransferActiveTaskDecisionScope: {/* contains filtered or unexported fields */},
TransferActiveTaskCloseExecutionScope: {/* contains filtered or unexported fields */},
TransferActiveTaskCancelExecutionScope: {/* contains filtered or unexported fields */},
TransferActiveTaskSignalExecutionScope: {/* contains filtered or unexported fields */},
TransferActiveTaskStartChildExecutionScope: {/* contains filtered or unexported fields */},
TransferStandbyTaskActivityScope: {/* contains filtered or unexported fields */},
TransferStandbyTaskDecisionScope: {/* contains filtered or unexported fields */},
TransferStandbyTaskCloseExecutionScope: {/* contains filtered or unexported fields */},
TransferStandbyTaskCancelExecutionScope: {/* contains filtered or unexported fields */},
TransferStandbyTaskSignalExecutionScope: {/* contains filtered or unexported fields */},
TransferStandbyTaskStartChildExecutionScope: {/* contains filtered or unexported fields */},
TimerQueueProcessorScope: {/* contains filtered or unexported fields */},
TimerActiveQueueProcessorScope: {/* contains filtered or unexported fields */},
TimerStandbyQueueProcessorScope: {/* contains filtered or unexported fields */},
TimerActiveTaskActivityTimeoutScope: {/* contains filtered or unexported fields */},
TimerActiveTaskDecisionTimeoutScope: {/* contains filtered or unexported fields */},
TimerActiveTaskUserTimerScope: {/* contains filtered or unexported fields */},
TimerActiveTaskWorkflowTimeoutScope: {/* contains filtered or unexported fields */},
TimerActiveTaskRetryTimerScope: {/* contains filtered or unexported fields */},
TimerActiveTaskDeleteHistoryEvent: {/* contains filtered or unexported fields */},
TimerStandbyTaskActivityTimeoutScope: {/* contains filtered or unexported fields */},
TimerStandbyTaskDecisionTimeoutScope: {/* contains filtered or unexported fields */},
TimerStandbyTaskUserTimerScope: {/* contains filtered or unexported fields */},
TimerStandbyTaskWorkflowTimeoutScope: {/* contains filtered or unexported fields */},
TimerStandbyTaskRetryTimerScope: {/* contains filtered or unexported fields */},
TimerStandbyTaskDeleteHistoryEvent: {/* contains filtered or unexported fields */},
HistoryEventNotificationScope: {/* contains filtered or unexported fields */},
ReplicatorQueueProcessorScope: {/* contains filtered or unexported fields */},
ReplicatorTaskHistoryScope: {/* contains filtered or unexported fields */},
ReplicateHistoryEventsScope: {/* contains filtered or unexported fields */},
ShardInfoScope: {/* contains filtered or unexported fields */},
},
Matching: {
MatchingPollForDecisionTaskScope: {/* contains filtered or unexported fields */},
MatchingPollForActivityTaskScope: {/* contains filtered or unexported fields */},
MatchingAddActivityTaskScope: {/* contains filtered or unexported fields */},
MatchingAddDecisionTaskScope: {/* contains filtered or unexported fields */},
MatchingTaskListMgrScope: {/* contains filtered or unexported fields */},
MatchingQueryWorkflowScope: {/* contains filtered or unexported fields */},
MatchingRespondQueryTaskCompletedScope: {/* contains filtered or unexported fields */},
MatchingCancelOutstandingPollScope: {/* contains filtered or unexported fields */},
MatchingDescribeTaskListScope: {/* contains filtered or unexported fields */},
},
Worker: {
ReplicatorScope: {/* contains filtered or unexported fields */},
DomainReplicationTaskScope: {/* contains filtered or unexported fields */},
HistoryReplicationTaskScope: {/* contains filtered or unexported fields */},
SyncShardTaskScope: {/* contains filtered or unexported fields */},
},
}
ScopeDefs record the scopes for all services
var ServiceMetrics = map[MetricName]MetricType{
RestartCount: Counter,
}
ServiceMetrics are types for common service base metrics
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface {
// IncCounter increments a counter metric
IncCounter(scope int, counter int)
// AddCounter adds delta to the counter metric
AddCounter(scope int, counter int, delta int64)
// StartTimer starts a timer for the given
// metric name. Time will be recorded when stopwatch is stopped.
StartTimer(scope int, timer int) tally.Stopwatch
// RecordTimer starts a timer for the given
// metric name
RecordTimer(scope int, timer int, d time.Duration)
// UpdateGauge reports Gauge type absolute value metric
UpdateGauge(scope int, gauge int, value float64)
// Tagged returns a client that adds the given tags to all metrics
Tagged(tags map[string]string) Client
}
Client is the interface used to report metrics tally.
type ClientImpl ¶
type ClientImpl struct {
// contains filtered or unexported fields
}
ClientImpl is used for reporting metrics by various Cadence services
func (*ClientImpl) AddCounter ¶
func (m *ClientImpl) AddCounter(scopeIdx int, counterIdx int, delta int64)
AddCounter adds delta to the counter and emits to the metrics backend
func (*ClientImpl) IncCounter ¶
func (m *ClientImpl) IncCounter(scopeIdx int, counterIdx int)
IncCounter increments one for a counter and emits to metrics backend
func (*ClientImpl) RecordTimer ¶
func (m *ClientImpl) RecordTimer(scopeIdx int, timerIdx int, d time.Duration)
RecordTimer record and emit a timer for the given metric name
func (*ClientImpl) StartTimer ¶
func (m *ClientImpl) StartTimer(scopeIdx int, timerIdx int) tally.Stopwatch
StartTimer starts a timer for the given metric name
func (*ClientImpl) Tagged ¶
func (m *ClientImpl) Tagged(tags map[string]string) Client
Tagged returns a client that adds the given tags to all metrics
func (*ClientImpl) UpdateGauge ¶
func (m *ClientImpl) UpdateGauge(scopeIdx int, gaugeIdx int, value float64)
UpdateGauge reports Gauge type metric
type ErrorClass ¶
type ErrorClass uint8
ErrorClass is an enum to help with classifying SLA vs. non-SLA errors (SLA = "service level agreement")
type MetricType ¶
type MetricType int
MetricType is the type of the metric
const (
Counter MetricType = iota
Timer
Gauge
)
MetricTypes which are supported
type RuntimeMetricsReporter ¶
type RuntimeMetricsReporter struct {
// contains filtered or unexported fields
}
RuntimeMetricsReporter A struct containing the state of the RuntimeMetricsReporter.
func NewRuntimeMetricsReporter ¶
func NewRuntimeMetricsReporter(scope tally.Scope, reportInterval time.Duration, logger bark.Logger) *RuntimeMetricsReporter
NewRuntimeMetricsReporter Creates a new RuntimeMetricsReporter.