fix so the latest percentage is sent if no changes (#298)

koralium · Jan 12, 2024 · 511a3e0 · 511a3e0
1 parent f6ec556
commit 511a3e0
Showing 1 changed file with 4 additions and 3 deletions.
diff --git 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>((float)newHits / newTotal, new KeyValuePair<string, object?>("stream", m_streamName));
+                    m_metrics_lastSentPercentage = (float)newHits / newTotal;
+                    return new Measurement<float>(m_metrics_lastSentPercentage, new KeyValuePair<string, object?>("stream", m_streamName));
                 }
                 else
                 {
-                    var percentage = (float)m_metrics_lastSeenHits / m_metrics_lastSeenTotal;
-                    return new Measurement<float>(percentage, new KeyValuePair<string, object?>("stream", m_streamName));
+                    return new Measurement<float>(m_metrics_lastSentPercentage, new KeyValuePair<string, object?>("stream", m_streamName));
                 }
             });
         }