From 5b3d5da4ada9478a6bdc3363f93dabca01313e45 Mon Sep 17 00:00:00 2001 From: SpontaneousOverthrow Date: Sat, 31 Jul 2021 18:19:52 +0300 Subject: [PATCH] solution: dshackle_request_jsonrpc_request_total metric --- src/main/kotlin/io/emeraldpay/dshackle/proxy/ProxyServer.kt | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/proxy/ProxyServer.kt b/src/main/kotlin/io/emeraldpay/dshackle/proxy/ProxyServer.kt index f9e37edd..b39f0cac 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/proxy/ProxyServer.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/proxy/ProxyServer.kt @@ -131,6 +131,7 @@ class ProxyServer( fun processRequest(chain: Common.ChainRef, request: Mono): Flux { val metrics = chainMetrics.get(chain) val startTime = System.currentTimeMillis() + metrics.requestMetric.increment() return request .map(readRpcJson) .flatMapMany { call -> execute(chain, call) } @@ -168,5 +169,8 @@ class ProxyServer( val errorMetric = Counter.builder("request.jsonrpc.err") .tag("chain", chain.chainCode) .register(Metrics.globalRegistry) + val requestMetric = Counter.builder("request.jsonrpc.request.total") + .tag("chain", chain.chainCode) + .register(Metrics.globalRegistry) } -} \ No newline at end of file +}