waku-org/nwaku
1
0
Fork 0
mirror of https://github.com/waku-org/nwaku.git synced 2025-02-05 03:25:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(store): follow good practices in store insert and query metrics (#1150)

Browse Source
This commit is contained in:
Lorenzo Delgado 2022-09-14 14:40:11 +02:00 committed by GitHub
parent f7b4e8f57d
commit 89069aa34f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
waku/v2/protocol/waku_store/protocol.nim
View File

@ -31,8 +31,8 @@ declarePublicGauge waku_store_messages, "number of historical messages", ["type"
declarePublicGauge waku_store_peers, "number of store peers" declarePublicGauge waku_store_peers, "number of store peers"
declarePublicGauge waku_store_errors, "number of store protocol errors", ["type"] declarePublicGauge waku_store_errors, "number of store protocol errors", ["type"]
declarePublicGauge waku_store_queries, "number of store queries received" declarePublicGauge waku_store_queries, "number of store queries received"
declarePublicHistogram waku_store_insert_time, "time spent storing a message (ms)" declarePublicHistogram waku_store_insert_duration_seconds, "message insertion duration"
declarePublicHistogram waku_store_query_time, "time spent processing a history query (ms)" declarePublicHistogram waku_store_query_duration_seconds, "history query duration"
logScope: logScope:
topics = "wakustore" topics = "wakustore"
@ -120,8 +120,8 @@ proc findMessages(w: WakuStore, query: HistoryQuery): HistoryResponse {.gcsafe.}
ascendingOrder = qAscendingOrder ascendingOrder = qAscendingOrder
) )
let queryTime = getTime().toUnixFloat() - queryStartTime let queryDuration = getTime().toUnixFloat() - queryStartTime
waku_store_query_time.observe(getMillisecondTime(queryTime)) waku_store_query_duration_seconds.observe(queryDuration)
# Build response # Build response
@ -268,8 +268,8 @@ proc handleMessage*(w: WakuStore, pubsubTopic: string, msg: WakuMessage) {.async
waku_store_errors.inc(labelValues = [insertFailure]) waku_store_errors.inc(labelValues = [insertFailure])
return return
let insertTime = getTime().toUnixFloat() - insertStartTime let insertDuration = getTime().toUnixFloat() - insertStartTime
waku_store_insert_time.observe(getMillisecondTime(insertTime)) waku_store_insert_duration_seconds.observe(insertDuration)
# TODO: Remove after converting the query method into a non-callback method # TODO: Remove after converting the query method into a non-callback method