This commit is contained in:
KirillPamPam
2024-10-23 18:45:33 +04:00
committed by GitHub
parent 697db618b7
commit d2d722a0e8

View File

@@ -246,19 +246,20 @@ open class GenericUpstream(
} }
private fun detectSettings() { private fun detectSettings() {
if (settingsDetector != null) {
settingsDetectorSubscription.set( settingsDetectorSubscription.set(
Flux.interval( Flux.interval(
Duration.ZERO, Duration.ZERO,
Duration.ofSeconds(getOptions().validationInterval.toLong() * 5), Duration.ofSeconds(getOptions().validationInterval.toLong() * 5),
).flatMap { ).flatMap {
Flux.merge( Flux.merge(
settingsDetector?.detectLabels() settingsDetector.detectLabels()
?.doOnNext { label -> .doOnNext { label ->
updateLabels(label) updateLabels(label)
sendUpstreamStateEvent(UPDATED) sendUpstreamStateEvent(UPDATED)
}, },
settingsDetector?.detectClientVersion() settingsDetector.detectClientVersion()
?.doOnNext { .doOnNext {
log.info("Detected node version $it for upstream ${getId()}") log.info("Detected node version $it for upstream ${getId()}")
clientVersion.set(it) clientVersion.set(it)
}, },
@@ -267,6 +268,7 @@ open class GenericUpstream(
}.subscribe(), }.subscribe(),
) )
} }
}
private fun detectRpcMethods( private fun detectRpcMethods(
config: UpstreamsConfig.Upstream<*>, config: UpstreamsConfig.Upstream<*>,