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

Change Status class to data class for better logging

Browse Source 
Log every node status change in blockchain rpc
This commit is contained in:
a10zn8
2023-01-25 13:25:47 +04:00
parent bbfec19d05
commit 1e8c4e1ab1
2 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/kotlin/io/emeraldpay/dshackle/rpc/BlockchainRpc.kt
View File

@@ -25,6 +25,7 @@ import io.emeraldpay.dshackle.SilentException
import io.micrometer.core.instrument.Counter import io.micrometer.core.instrument.Counter
import io.micrometer.core.instrument.Metrics import io.micrometer.core.instrument.Metrics
import io.micrometer.core.instrument.Timer import io.micrometer.core.instrument.Timer
import org.apache.commons.lang3.RandomStringUtils
import org.slf4j.LoggerFactory import org.slf4j.LoggerFactory
import org.springframework.beans.factory.annotation.Qualifier import org.springframework.beans.factory.annotation.Qualifier
import org.springframework.context.annotation.DependsOn import org.springframework.context.annotation.DependsOn
@@ -222,7 +223,11 @@ class BlockchainRpc(
} }
override fun subscribeNodeStatus(request: Mono<BlockchainOuterClass.SubscribeNodeStatusRequest>): Flux<BlockchainOuterClass.NodeStatusResponse> { override fun subscribeNodeStatus(request: Mono<BlockchainOuterClass.SubscribeNodeStatusRequest>): Flux<BlockchainOuterClass.NodeStatusResponse> {
return subscribeNodeStatus.subscribe(request).subscribeOn(scheduler).doOnError { failMetric.increment() } val subId = RandomStringUtils.randomAlphanumeric(8)
log.debug("Subscription for node status with id [$subId] created")
return subscribeNodeStatus.subscribe(request).subscribeOn(scheduler)
.doOnError { failMetric.increment() }
.doOnNext { log.debug("Emitted next node status to [$subId] with data [$it] ") }
} }
class RequestMetrics(val chain: Chain) { class RequestMetrics(val chain: Chain) {

2
src/main/kotlin/io/emeraldpay/dshackle/upstream/DefaultUpstream.kt
View File

@@ -163,5 +163,5 @@ abstract class DefaultUpstream(
return quorumByLabel return quorumByLabel
} }
class Status(val lag: Long, val avail: UpstreamAvailability, val status: UpstreamAvailability) data class Status(val lag: Long, val avail: UpstreamAvailability, val status: UpstreamAvailability)
} }