File tree Expand file tree Collapse file tree 2 files changed +0
-3
lines changed Expand file tree Collapse file tree 2 files changed +0
-3
lines changed Original file line number Diff line number Diff line change @@ -188,7 +188,6 @@ object Monitor:
188
188
val step = Kamon .gauge(" connector.flush.config.step" ).withoutTags()
189
189
val interval = Kamon .gauge(" connector.flush.config.interval" ).withoutTags()
190
190
val maxDelay = Kamon .gauge(" connector.flush.config.maxDelay" ).withoutTags()
191
- val qSizeReal = Kamon .histogram(" connector.flush.qSize" ).withoutTags()
192
191
val qSizeEstimate = Kamon .histogram(" connector.flush.qSize.estimate" ).withoutTags()
193
192
val channelsToFlush = Kamon .histogram(" connector.flush.channelsToFlush" ).withoutTags()
194
193
val loopRuntimeMicroseconds = Kamon .histogram(" connector.flush.loopRuntimeMicroseconds" ).withoutTags()
Original file line number Diff line number Diff line change @@ -36,7 +36,6 @@ final private class ActorChannelConnector(
36
36
monitor.config.step.update(step.get())
37
37
monitor.config.interval.update(interval.get())
38
38
monitor.config.maxDelay.update(maxDelay.get())
39
- monitor.qSizeReal.record(flushQ.realSizeWithLinearPerformance())
40
39
41
40
def apply (endpoint : Endpoint , channel : Channel ): Unit =
42
41
val clientPromise = Promise [Client ]()
@@ -106,4 +105,3 @@ object ActorChannelConnector:
106
105
maybeChannel
107
106
108
107
def estimateSize (): Int = size.get()
109
- def realSizeWithLinearPerformance (): Int = queue.size()
You can’t perform that action at this time.
0 commit comments