Skip to content
This repository has been archived by the owner on Sep 23, 2023. It is now read-only.

Commit

Permalink
metrics: prevent commit metrics duplication (#1082)
Browse files Browse the repository at this point in the history
  • Loading branch information
AskAlexSharov committed Sep 6, 2023
1 parent 751f130 commit bc34066
Show file tree
Hide file tree
Showing 3 changed files with 29 additions and 27 deletions.
1 change: 1 addition & 0 deletions .golangci.yml
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@ linters:
- unused
- performance
disable:
- gosec
- exhaustive
- musttag
- contextcheck
Expand Down
52 changes: 26 additions & 26 deletions kv/kv_interface.go
Original file line number Diff line number Diff line change
Expand Up @@ -82,29 +82,29 @@ const Unlim int = -1
var (
ErrAttemptToDeleteNonDeprecatedBucket = errors.New("only buckets from dbutils.ChaindataDeprecatedTables can be deleted")

DbSize = metrics.NewCounter(`db_size`) //nolint
TxLimit = metrics.NewCounter(`tx_limit`) //nolint
TxSpill = metrics.NewCounter(`tx_spill`) //nolint
TxUnspill = metrics.NewCounter(`tx_unspill`) //nolint
TxDirty = metrics.NewCounter(`tx_dirty`) //nolint

DbCommitPreparation = metrics.GetOrCreateSummary(`db_commit_seconds{phase="preparation"}`) //nolint
DbGCWallClock = metrics.GetOrCreateSummary(`db_commit_seconds{phase="gc_wall_clock"}`) //nolint
DbGCCpuTime = metrics.GetOrCreateSummary(`db_commit_seconds{phase="gc_cpu_time"}`) //nolint
DbCommitAudit = metrics.GetOrCreateSummary(`db_commit_seconds{phase="audit"}`) //nolint
DbCommitWrite = metrics.GetOrCreateSummary(`db_commit_seconds{phase="write"}`) //nolint
DbCommitSync = metrics.GetOrCreateSummary(`db_commit_seconds{phase="sync"}`) //nolint
DbCommitEnding = metrics.GetOrCreateSummary(`db_commit_seconds{phase="ending"}`) //nolint
DbCommitTotal = metrics.GetOrCreateSummary(`db_commit_seconds{phase="total"}`) //nolint

DbPgopsNewly = metrics.NewCounter(`db_pgops{phase="newly"}`) //nolint
DbPgopsCow = metrics.NewCounter(`db_pgops{phase="cow"}`) //nolint
DbPgopsClone = metrics.NewCounter(`db_pgops{phase="clone"}`) //nolint
DbPgopsSplit = metrics.NewCounter(`db_pgops{phase="split"}`) //nolint
DbPgopsMerge = metrics.NewCounter(`db_pgops{phase="merge"}`) //nolint
DbPgopsSpill = metrics.NewCounter(`db_pgops{phase="spill"}`) //nolint
DbPgopsUnspill = metrics.NewCounter(`db_pgops{phase="unspill"}`) //nolint
DbPgopsWops = metrics.NewCounter(`db_pgops{phase="wops"}`) //nolint
DbSize = metrics.GetOrCreateCounter(`db_size`) //nolint
TxLimit = metrics.GetOrCreateCounter(`tx_limit`) //nolint
TxSpill = metrics.GetOrCreateCounter(`tx_spill`) //nolint
TxUnspill = metrics.GetOrCreateCounter(`tx_unspill`) //nolint
TxDirty = metrics.GetOrCreateCounter(`tx_dirty`) //nolint

DbCommitPreparation = metrics.GetOrCreateSummary(`db_commit_seconds{phase="preparation"}`) //nolint
//DbGCWallClock = metrics.GetOrCreateSummary(`db_commit_seconds{phase="gc_wall_clock"}`) //nolint
//DbGCCpuTime = metrics.GetOrCreateSummary(`db_commit_seconds{phase="gc_cpu_time"}`) //nolint
//DbCommitAudit = metrics.GetOrCreateSummary(`db_commit_seconds{phase="audit"}`) //nolint
DbCommitWrite = metrics.GetOrCreateSummary(`db_commit_seconds{phase="write"}`) //nolint
DbCommitSync = metrics.GetOrCreateSummary(`db_commit_seconds{phase="sync"}`) //nolint
DbCommitEnding = metrics.GetOrCreateSummary(`db_commit_seconds{phase="ending"}`) //nolint
DbCommitTotal = metrics.GetOrCreateSummary(`db_commit_seconds{phase="total"}`) //nolint

DbPgopsNewly = metrics.GetOrCreateCounter(`db_pgops{phase="newly"}`) //nolint
DbPgopsCow = metrics.GetOrCreateCounter(`db_pgops{phase="cow"}`) //nolint
DbPgopsClone = metrics.GetOrCreateCounter(`db_pgops{phase="clone"}`) //nolint
DbPgopsSplit = metrics.GetOrCreateCounter(`db_pgops{phase="split"}`) //nolint
DbPgopsMerge = metrics.GetOrCreateCounter(`db_pgops{phase="merge"}`) //nolint
DbPgopsSpill = metrics.GetOrCreateCounter(`db_pgops{phase="spill"}`) //nolint
DbPgopsUnspill = metrics.GetOrCreateCounter(`db_pgops{phase="unspill"}`) //nolint
DbPgopsWops = metrics.GetOrCreateCounter(`db_pgops{phase="wops"}`) //nolint
/*
DbPgopsPrefault = metrics.NewCounter(`db_pgops{phase="prefault"}`) //nolint
DbPgopsMinicore = metrics.NewCounter(`db_pgops{phase="minicore"}`) //nolint
Expand Down Expand Up @@ -138,9 +138,9 @@ var (
//DbGcSelfPnlMergeVolume = metrics.NewCounter(`db_gc_pnl{phase="self_merge_volume"}`) //nolint
//DbGcSelfPnlMergeCalls = metrics.NewCounter(`db_gc_pnl{phase="slef_merge_calls"}`) //nolint

GcLeafMetric = metrics.NewCounter(`db_gc_leaf`) //nolint
GcOverflowMetric = metrics.NewCounter(`db_gc_overflow`) //nolint
GcPagesMetric = metrics.NewCounter(`db_gc_pages`) //nolint
GcLeafMetric = metrics.GetOrCreateCounter(`db_gc_leaf`) //nolint
GcOverflowMetric = metrics.GetOrCreateCounter(`db_gc_overflow`) //nolint
GcPagesMetric = metrics.GetOrCreateCounter(`db_gc_pages`) //nolint

)

Expand Down
3 changes: 2 additions & 1 deletion kv/mdbx/kv_mdbx.go
Original file line number Diff line number Diff line change
Expand Up @@ -85,6 +85,7 @@ func NewMDBX(log log.Logger) MdbxOpts {
growthStep: 2 * datasize.GB,
mergeThreshold: 3 * 8192,
shrinkThreshold: -1, // default
label: kv.InMem,
}
return opts
}
Expand Down Expand Up @@ -803,7 +804,7 @@ func (tx *MdbxTx) Commit() error {

if tx.db.opts.label == kv.ChainDB {
kv.DbCommitPreparation.Update(latency.Preparation.Seconds())
kv.DbCommitAudit.Update(latency.Audit.Seconds())
//kv.DbCommitAudit.Update(latency.Audit.Seconds())
kv.DbCommitWrite.Update(latency.Write.Seconds())
kv.DbCommitSync.Update(latency.Sync.Seconds())
kv.DbCommitEnding.Update(latency.Ending.Seconds())
Expand Down

0 comments on commit bc34066

Please sign in to comment.