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

Add client_type label to upstream lag and availability metrics (#815)

Browse Source
This commit is contained in:
Artem Rootman
2026-04-23 14:26:59 +00:00
committed by GitHub
parent 5414e06e46
commit ed7cfdc90b
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/kotlin/io/emeraldpay/dshackle/upstream/Multistream.kt
View File

@@ -108,6 +108,7 @@ abstract class Multistream(
private fun monitorUpstream(upstream: Upstream) { private fun monitorUpstream(upstream: Upstream) {
val upstreamId = upstream.getId() val upstreamId = upstream.getId()
val clientType = upstream.getLabels().firstOrNull()?.get("client_type") ?: ""
// otherwise metric will stuck with prev upstream instance // otherwise metric will stuck with prev upstream instance
removeUpstreamMeters(upstreamId) removeUpstreamMeters(upstreamId)
@@ -118,11 +119,13 @@ abstract class Multistream(
} }
.tag("chain", chain.chainCode) .tag("chain", chain.chainCode)
.tag("upstream", upstreamId) .tag("upstream", upstreamId)
.tag("client_type", clientType)
.register(Metrics.globalRegistry) .register(Metrics.globalRegistry)
.id, .id,
Gauge.builder("$metrics.availability.status", upstream) { it.getStatus().grpcId.toDouble() } Gauge.builder("$metrics.availability.status", upstream) { it.getStatus().grpcId.toDouble() }
.tag("chain", chain.chainCode) .tag("chain", chain.chainCode)
.tag("upstream", upstreamId) .tag("upstream", upstreamId)
.tag("client_type", clientType)
.register(Metrics.globalRegistry) .register(Metrics.globalRegistry)
.id, .id,
) )
@@ -449,6 +452,7 @@ abstract class Multistream(
UpstreamChangeEvent.ChangeType.REVALIDATED -> {} UpstreamChangeEvent.ChangeType.REVALIDATED -> {}
UpstreamChangeEvent.ChangeType.UPDATED -> { UpstreamChangeEvent.ChangeType.UPDATED -> {
onUpstreamsUpdated() onUpstreamsUpdated()
monitorUpstream(event.upstream)
updateUpstreams.emitNext(event.upstream) { _, res -> res == Sinks.EmitResult.FAIL_NON_SERIALIZED } updateUpstreams.emitNext(event.upstream) { _, res -> res == Sinks.EmitResult.FAIL_NON_SERIALIZED }
} }