metric: add metric for pessimistic lock keys (#20383) (#20513)

Signed-off-by: ti-srebot <[email protected]>
pingcap · Oct 21, 2020 · 9c6c698 · 9c6c698
1 parent 0b0fbf1
commit 9c6c698
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/metrics/session.go b/metrics/session.go
@@ -142,4 +142,5 @@ const (
 	LblAddress     = "address"
 	LblBatchGet    = "batch_get"
 	LblGet         = "get"
+	LblLockKeys    = "lock_keys"
 )
diff --git a/store/tikv/txn.go b/store/tikv/txn.go
@@ -45,6 +45,7 @@ var (
 	tikvTxnCmdHistogramWithRollback = metrics.TiKVTxnCmdHistogram.WithLabelValues(metrics.LblRollback)
 	tikvTxnCmdHistogramWithBatchGet = metrics.TiKVTxnCmdHistogram.WithLabelValues(metrics.LblBatchGet)
 	tikvTxnCmdHistogramWithGet      = metrics.TiKVTxnCmdHistogram.WithLabelValues(metrics.LblGet)
+	tikvTxnCmdHistogramWithLockKeys = metrics.TiKVTxnCmdHistogram.WithLabelValues(metrics.LblLockKeys)
 )
 
 // SchemaAmender is used by pessimistic transactions to amend commit mutations for schema change during 2pc.
@@ -369,6 +370,7 @@ func (txn *tikvTxn) LockKeys(ctx context.Context, lockCtx *kv.LockCtx, keysInput
 	keys := make([][]byte, 0, len(keysInput))
 	startTime := time.Now()
 	defer func() {
+		tikvTxnCmdHistogramWithLockKeys.Observe(time.Since(startTime).Seconds())
 		if err == nil {
 			if lockCtx.PessimisticLockWaited != nil {
 				if atomic.LoadInt32(lockCtx.PessimisticLockWaited) > 0 {