Rename MessageTypeStats type

src/Abc.Zebus.Persistence.Cassandra.Tests/CqlStorageTests.cs

@@ -369,13 +369,13 @@ namespace Abc.Zebus.Persistence.Cassandra.Tests
                 MatcherEntry.Message(peer, MessageId.NextId(), new MessageTypeId("Abc.Message.Fat"), new byte[] { 0x01, 0x02, 0x03, 0x04 }),
             });
 
-            var entryTypeStatistics = new Dictionary<string, MessageTypeStatistics> { ["Abc.Message"] = new(1, 3),  ["Abc.Message.Fat"] = new(1, 4)  };
+            var entryTypeStatistics = new Dictionary<string, MessageTypeStorageReport> { ["Abc.Message"] = new(1, 3),  ["Abc.Message.Fat"] = new(1, 4)  };
             var storageReport = new StorageReport(2, 7, 4, "Abc.Message.Fat", entryTypeStatistics);
             _reporterMock.Verify(r => r.AddStorageReport(It.Is<StorageReport>(x => x.MessageCount == storageReport.MessageCount
                                                                               && x.BatchSizeInBytes == storageReport.BatchSizeInBytes
                                                                               && x.FattestMessageTypeId == storageReport.FattestMessageTypeId
                                                                               && x.FattestMessageSizeInBytes == storageReport.FattestMessageSizeInBytes
-                                                                              && x.MessageTypeStatistics.DeepCompare(storageReport.MessageTypeStatistics))));
+                                                                              && x.MessageTypeStorageReports.DeepCompare(storageReport.MessageTypeStorageReports))));
         }
 
         [Test]

src/Abc.Zebus.Persistence.Cassandra/Cql/CqlStorage.cs

@@ -133,7 +133,7 @@ namespace Abc.Zebus.Persistence.Cassandra.Cql
         {
             var fattestMessage = entriesToPersist.OrderByDescending(msg => msg.MessageLength).First();
             var entriesByTypeName = entriesToPersist.ToLookup(x => x.MessageTypeName)
-                                                    .ToDictionary(xs => xs.Key, xs => new MessageTypeStatistics(xs.Count(), xs.Sum(x => x.MessageLength)));
+                                                    .ToDictionary(xs => xs.Key, xs => new MessageTypeStorageReport(xs.Count(), xs.Sum(x => x.MessageLength)));
             return new StorageReport(entriesToPersist.Count, entriesToPersist.Sum(msg => msg.MessageLength), fattestMessage.MessageLength, fattestMessage.MessageTypeName, entriesByTypeName);
         }
 

src/Abc.Zebus.Persistence.RocksDb.Tests/RocksDbStorageTests.cs

@@ -236,13 +236,13 @@ namespace Abc.Zebus.Persistence.RocksDb.Tests
                 MatcherEntry.Message(peer, MessageId.NextId(), new MessageTypeId("Abc.Message.Fat"), new byte[] { 0x01, 0x02, 0x03, 0x04 }),
             });
 
-            var entryTypeStatistics = new Dictionary<string, MessageTypeStatistics> { ["Abc.Message"] = new(1, 3),  ["Abc.Message.Fat"] = new(1, 4)  };
+            var entryTypeStatistics = new Dictionary<string, MessageTypeStorageReport> { ["Abc.Message"] = new(1, 3),  ["Abc.Message.Fat"] = new(1, 4)  };
             var storageReport = new StorageReport(2, 7, 4, "Abc.Message.Fat", entryTypeStatistics);
             _reporterMock.Verify(r => r.AddStorageReport(It.Is<StorageReport>(x => x.MessageCount == storageReport.MessageCount
                                                                               && x.BatchSizeInBytes == storageReport.BatchSizeInBytes
                                                                               && x.FattestMessageTypeId == storageReport.FattestMessageTypeId
                                                                               && x.FattestMessageSizeInBytes == storageReport.FattestMessageSizeInBytes
-                                                                              && x.MessageTypeStatistics.DeepCompare(storageReport.MessageTypeStatistics))));
+                                                                              && x.MessageTypeStorageReports.DeepCompare(storageReport.MessageTypeStorageReports))));
         }
 
         private TransportMessage CreateTestTransportMessage(int i)

src/Abc.Zebus.Persistence.RocksDb/RocksDbStorage.cs

@@ -124,7 +124,7 @@ namespace Abc.Zebus.Persistence.RocksDb
         {
             var fattestMessage = entriesToPersist.OrderByDescending(msg => msg.MessageLength).First();
             var entriesByTypeName = entriesToPersist.ToLookup(x => x.MessageTypeName)
-                                                    .ToDictionary(xs => xs.Key, xs => new MessageTypeStatistics(xs.Count(), xs.Sum(x => x.MessageLength)));
+                                                    .ToDictionary(xs => xs.Key, xs => new MessageTypeStorageReport(xs.Count(), xs.Sum(x => x.MessageLength)));
             return new StorageReport(entriesToPersist.Count, entriesToPersist.Sum(msg => msg.MessageLength), fattestMessage.MessageLength, fattestMessage.MessageTypeName, entriesByTypeName);
         }
 

src/Abc.Zebus.Persistence/Reporter/StorageReport.cs

@@ -8,20 +8,20 @@ namespace Abc.Zebus.Persistence.Reporter
         public int BatchSizeInBytes { get; }
         public int FattestMessageSizeInBytes { get; }
         public string FattestMessageTypeId { get; }
-        public Dictionary<string, MessageTypeStatistics> MessageTypeStatistics { get; }
+        public Dictionary<string, MessageTypeStorageReport> MessageTypeStorageReports { get; }
 
-        public StorageReport(int messageCount, int batchSizeInBytes, int fattestMessageSizeInBytes, string fattestMessageTypeId, Dictionary<string, MessageTypeStatistics> messageTypeStatistics)
+        public StorageReport(int messageCount, int batchSizeInBytes, int fattestMessageSizeInBytes, string fattestMessageTypeId, Dictionary<string, MessageTypeStorageReport> messageTypeStorageReports)
         {
             MessageCount = messageCount;
             BatchSizeInBytes = batchSizeInBytes;
             FattestMessageSizeInBytes = fattestMessageSizeInBytes;
             FattestMessageTypeId = fattestMessageTypeId;
-            MessageTypeStatistics = messageTypeStatistics;
+            MessageTypeStorageReports = messageTypeStorageReports;
         }
 
         public override string ToString()
-            => $"{nameof(MessageCount)}: {MessageCount}, {nameof(BatchSizeInBytes)}: {BatchSizeInBytes}, {nameof(FattestMessageSizeInBytes)}: {FattestMessageSizeInBytes}, {nameof(FattestMessageTypeId)}: {FattestMessageTypeId}, {nameof(MessageTypeStatistics)}: {MessageTypeStatistics}";
+            => $"{nameof(MessageCount)}: {MessageCount}, {nameof(BatchSizeInBytes)}: {BatchSizeInBytes}, {nameof(FattestMessageSizeInBytes)}: {FattestMessageSizeInBytes}, {nameof(FattestMessageTypeId)}: {FattestMessageTypeId}, {nameof(MessageTypeStorageReports)}: {MessageTypeStorageReports}";
     }
 
-    public record MessageTypeStatistics(int Count, int TotalBytes);
+    public record MessageTypeStorageReport(int Count, int TotalBytes);
 }