allegro-internal/flex-roadmap#819 Migrated metrics to prometheus | ch…

…anged metrics names [2]
allegro · Oct 18, 2024 · 2132a07 · 2132a07
1 parent f43cedc
commit 2132a07
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...ntrol-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtils.kt b/...ntrol-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtils.kt
@@ -168,7 +168,11 @@ private fun innerBufferExtractor(index: Int) = { s: Scannable ->
 }
 
 private val queueSubscriptionBufferExtractor = { s: Fuseable.QueueSubscription<*> ->
-    s.size.toDouble()
+    if (s != null) {
+        s.size.toDouble()
+    } else {
+        -1.0
+    }
 }
 
 sealed class ParallelizableScheduler