diff --git a/src/FlowtideDotNet.Storage/StateManager/Internal/Sync/LruTableSync.cs b/src/FlowtideDotNet.Storage/StateManager/Internal/Sync/LruTableSync.cs index e0ae94f6b..edc9a6fbd 100644 --- a/src/FlowtideDotNet.Storage/StateManager/Internal/Sync/LruTableSync.cs +++ b/src/FlowtideDotNet.Storage/StateManager/Internal/Sync/LruTableSync.cs @@ -47,6 +47,7 @@ internal struct LinkedListValue private long m_metrics_lastSeenTotal; private long m_metrics_lastSeenHits; + private float m_metrics_lastSentPercentage; private bool m_disposedValue; private readonly Process _currentProcess; @@ -90,12 +91,12 @@ public LruTableSync(int maxSize, ILogger logger, Meter meter, string streamName, var newHits = hit - m_metrics_lastSeenHits; m_metrics_lastSeenTotal = total; m_metrics_lastSeenHits = hit; - return new Measurement((float)newHits / newTotal, new KeyValuePair("stream", m_streamName)); + m_metrics_lastSentPercentage = (float)newHits / newTotal; + return new Measurement(m_metrics_lastSentPercentage, new KeyValuePair("stream", m_streamName)); } else { - var percentage = (float)m_metrics_lastSeenHits / m_metrics_lastSeenTotal; - return new Measurement(percentage, new KeyValuePair("stream", m_streamName)); + return new Measurement(m_metrics_lastSentPercentage, new KeyValuePair("stream", m_streamName)); } }); }