logos-messaging/logos-messaging-nim
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-nim.git synced 2026-01-05 23:43:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: non-relay protocols cross performance measurement metrics (#3299)

Browse Source 
* Introducing new non-relay protocol request handling time metric
This commit is contained in:
NagyZoltanPeter 2025-03-31 13:27:51 +02:00 committed by GitHub
parent fca3b034c2
commit 36ee2aa9bf
3 changed files with 21 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
waku/common/rate_limit/request_limiter.nim
View File

@ -22,6 +22,8 @@ import
libp2p/stream/connection, libp2p/stream/connection,
libp2p/utility libp2p/utility
import std/times except TimeInterval, Duration, seconds, minutes
import ./[single_token_limiter, service_metrics, timed_map] import ./[single_token_limiter, service_metrics, timed_map]
export token_bucket, setting, service_metrics export token_bucket, setting, service_metrics
@ -76,8 +78,15 @@ template checkUsageLimit*(
bodyWithinLimit, bodyRejected: untyped, bodyWithinLimit, bodyRejected: untyped,
) = ) =
if t.checkUsage(proto, conn): if t.checkUsage(proto, conn):
let requestStartTime = getTime().toUnixFloat()
waku_service_requests.inc(labelValues = [proto, "served"]) waku_service_requests.inc(labelValues = [proto, "served"])
bodyWithinLimit bodyWithinLimit
let requestDurationSec = getTime().toUnixFloat() - requestStartTime
waku_service_request_handling_duration_seconds.observe(
requestDurationSec, labelValues = [proto]
)
else: else:
waku_service_requests.inc(labelValues = [proto, "rejected"]) waku_service_requests.inc(labelValues = [proto, "rejected"])
bodyRejected bodyRejected

3
waku/common/rate_limit/service_metrics.nim
View File

@ -17,3 +17,6 @@ proc setServiceLimitMetric*(service: string, limit: Option[RateLimitSetting]) =
waku_service_requests_limit.set( waku_service_requests_limit.set(
limit.get().calculateLimitPerSecond(), labelValues = [service] limit.get().calculateLimitPerSecond(), labelValues = [service]
) )
declarePublicHistogram waku_service_request_handling_duration_seconds,
"duration of non-relay service handling", ["service"]

9
waku/common/rate_limit/single_token_limiter.nim
View File

@ -4,6 +4,8 @@
import std/[options], chronos/timer, libp2p/stream/connection, libp2p/utility import std/[options], chronos/timer, libp2p/stream/connection, libp2p/utility
import std/times except TimeInterval, Duration
import ./[token_bucket, setting, service_metrics] import ./[token_bucket, setting, service_metrics]
export token_bucket, setting, service_metrics export token_bucket, setting, service_metrics
@ -43,8 +45,15 @@ template checkUsageLimit*(
bodyWithinLimit, bodyRejected: untyped, bodyWithinLimit, bodyRejected: untyped,
) = ) =
if t.checkUsage(proto): if t.checkUsage(proto):
let requestStartTime = getTime().toUnixFloat()
waku_service_requests.inc(labelValues = [proto, "served"]) waku_service_requests.inc(labelValues = [proto, "served"])
bodyWithinLimit bodyWithinLimit
let requestDurationSec = getTime().toUnixFloat() - requestStartTime
waku_service_request_handling_duration_seconds.observe(
requestDurationSec, labelValues = [proto]
)
else: else:
waku_service_requests.inc(labelValues = [proto, "rejected"]) waku_service_requests.inc(labelValues = [proto, "rejected"])
bodyRejected bodyRejected