metrics

Documentation

Index

• Constants
• Variables
• func InitMetricsVars()
• func InitPhaseDurationObserverMap()

Constants

const (
	PhaseBuildLocking       = "build:locking"
	PhaseOpenLocking        = "open:locking"
	PhaseNextLocking        = "next:locking"
	PhaseLockLocking        = "lock:locking"
	PhaseBuildFinal         = "build:final"
	PhaseOpenFinal          = "open:final"
	PhaseNextFinal          = "next:final"
	PhaseLockFinal          = "lock:final"
	PhaseCommitPrewrite     = "commit:prewrite"
	PhaseCommitCommit       = "commit:commit"
	PhaseCommitWaitCommitTS = "commit:wait:commit-ts"
	PhaseCommitWaitLatestTS = "commit:wait:latest-ts"
	PhaseCommitWaitLatch    = "commit:wait:local-latch"
	PhaseCommitWaitBinlog   = "commit:wait:prewrite-binlog"
	PhaseWriteResponse      = "write-response"
)

phases

Variables

var (
	TotalQueryProcHistogramGeneral  prometheus.Observer
	TotalCopProcHistogramGeneral    prometheus.Observer
	TotalCopWaitHistogramGeneral    prometheus.Observer
	CopMVCCRatioHistogramGeneral    prometheus.Observer
	TotalQueryProcHistogramInternal prometheus.Observer
	TotalCopProcHistogramInternal   prometheus.Observer
	TotalCopWaitHistogramInternal   prometheus.Observer

	SelectForUpdateFirstAttemptDuration prometheus.Observer
	SelectForUpdateRetryDuration        prometheus.Observer
	DmlFirstAttemptDuration             prometheus.Observer
	DmlRetryDuration                    prometheus.Observer

	// FairLockingTxnUsedCount counts transactions where at least one statement has fair locking enabled.
	FairLockingTxnUsedCount prometheus.Counter
	// FairLockingStmtUsedCount counts statements that have fair locking enabled.
	FairLockingStmtUsedCount prometheus.Counter
	// FairLockingTxnEffectiveCount counts transactions where at least one statement has fair locking enabled,
	// and it takes effect (which is determined according to whether lock-with-conflict has occurred during execution).
	FairLockingTxnEffectiveCount prometheus.Counter
	// FairLockingStmtEffectiveCount counts statements where at least one statement has fair locking enabled,
	// and it takes effect (which is determined according to whether lock-with-conflict has occurred during execution).
	FairLockingStmtEffectiveCount prometheus.Counter

	ExecutorCounterMergeJoinExec            prometheus.Counter
	ExecutorCountHashJoinExec               prometheus.Counter
	ExecutorCounterHashAggExec              prometheus.Counter
	ExecutorStreamAggExec                   prometheus.Counter
	ExecutorCounterSortExec                 prometheus.Counter
	ExecutorCounterTopNExec                 prometheus.Counter
	ExecutorCounterNestedLoopApplyExec      prometheus.Counter
	ExecutorCounterIndexLookUpJoin          prometheus.Counter
	ExecutorCounterIndexLookUpExecutor      prometheus.Counter
	ExecutorCounterIndexMergeReaderExecutor prometheus.Counter

	SessionExecuteRunDurationInternal prometheus.Observer
	SessionExecuteRunDurationGeneral  prometheus.Observer
	TotalTiFlashQuerySuccCounter      prometheus.Counter

	// pre-define observers for non-internal queries
	ExecBuildLocking       prometheus.Observer
	ExecOpenLocking        prometheus.Observer
	ExecNextLocking        prometheus.Observer
	ExecLockLocking        prometheus.Observer
	ExecBuildFinal         prometheus.Observer
	ExecOpenFinal          prometheus.Observer
	ExecNextFinal          prometheus.Observer
	ExecLockFinal          prometheus.Observer
	ExecCommitPrewrite     prometheus.Observer
	ExecCommitCommit       prometheus.Observer
	ExecCommitWaitCommitTS prometheus.Observer
	ExecCommitWaitLatestTS prometheus.Observer
	ExecCommitWaitLatch    prometheus.Observer
	ExecCommitWaitBinlog   prometheus.Observer
	ExecWriteResponse      prometheus.Observer
	ExecUnknown            prometheus.Observer

	// pre-define observers for internal queries
	ExecBuildLockingInternal       prometheus.Observer
	ExecOpenLockingInternal        prometheus.Observer
	ExecNextLockingInternal        prometheus.Observer
	ExecLockLockingInternal        prometheus.Observer
	ExecBuildFinalInternal         prometheus.Observer
	ExecOpenFinalInternal          prometheus.Observer
	ExecNextFinalInternal          prometheus.Observer
	ExecLockFinalInternal          prometheus.Observer
	ExecCommitPrewriteInternal     prometheus.Observer
	ExecCommitCommitInternal       prometheus.Observer
	ExecCommitWaitCommitTSInternal prometheus.Observer
	ExecCommitWaitLatestTSInternal prometheus.Observer
	ExecCommitWaitLatchInternal    prometheus.Observer
	ExecCommitWaitBinlogInternal   prometheus.Observer
	ExecWriteResponseInternal      prometheus.Observer
	ExecUnknownInternal            prometheus.Observer

	TransactionDurationPessimisticRollbackInternal prometheus.Observer
	TransactionDurationPessimisticRollbackGeneral  prometheus.Observer
	TransactionDurationOptimisticRollbackInternal  prometheus.Observer
	TransactionDurationOptimisticRollbackGeneral   prometheus.Observer

	PhaseDurationObserverMap         map[string]prometheus.Observer
	PhaseDurationObserverMapInternal map[string]prometheus.Observer

	MppCoordinatorStatsTotalRegisteredNumber prometheus.Gauge
	MppCoordinatorStatsActiveNumber          prometheus.Gauge
	MppCoordinatorStatsOverTimeNumber        prometheus.Gauge
	MppCoordinatorStatsReportNotReceived     prometheus.Gauge

	MppCoordinatorLatencyRcvReport prometheus.Observer
)

executor metrics vars

Functions

func InitMetricsVars

func InitMetricsVars()

InitMetricsVars init executor metrics vars.

func InitPhaseDurationObserverMap

func InitPhaseDurationObserverMap()

InitPhaseDurationObserverMap init observer map