StakeSquid/dshackle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

solution: dshackle_request_jsonrpc_request_total metric

Browse Source
This commit is contained in:
SpontaneousOverthrow
2021-07-31 18:19:52 +03:00
committed by GitHub
parent ec9235afbb
commit 5b3d5da4ad
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/kotlin/io/emeraldpay/dshackle/proxy/ProxyServer.kt
View File

@@ -131,6 +131,7 @@ class ProxyServer(
fun processRequest(chain: Common.ChainRef, request: Mono<ByteArray>): Flux<ByteBuf> { fun processRequest(chain: Common.ChainRef, request: Mono<ByteArray>): Flux<ByteBuf> {
val metrics = chainMetrics.get(chain) val metrics = chainMetrics.get(chain)
val startTime = System.currentTimeMillis() val startTime = System.currentTimeMillis()
metrics.requestMetric.increment()
return request return request
.map(readRpcJson) .map(readRpcJson)
.flatMapMany { call -> execute(chain, call) } .flatMapMany { call -> execute(chain, call) }
@@ -168,5 +169,8 @@ class ProxyServer(
val errorMetric = Counter.builder("request.jsonrpc.err") val errorMetric = Counter.builder("request.jsonrpc.err")
.tag("chain", chain.chainCode) .tag("chain", chain.chainCode)
.register(Metrics.globalRegistry) .register(Metrics.globalRegistry)
val requestMetric = Counter.builder("request.jsonrpc.request.total")
.tag("chain", chain.chainCode)
.register(Metrics.globalRegistry)
} }
} }