Persistence: rename IReporter to IPersistenceReporter

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

@@ -25,7 +25,7 @@ namespace Abc.Zebus.Persistence.Cassandra.Tests
 
         private CqlStorage _storage;
         private Mock<IPersistenceConfiguration> _configurationMock;
-        private Mock<IReporter> _reporterMock;
+        private Mock<IPersistenceReporter> _reporterMock;
 
         public override void CreateSchema()
         {
@@ -44,7 +44,7 @@ namespace Abc.Zebus.Persistence.Cassandra.Tests
         public void SetUp()
         {
             _configurationMock = new Mock<IPersistenceConfiguration>();
-            _reporterMock = new Mock<IReporter>();
+            _reporterMock = new Mock<IPersistenceReporter>();
             _storage = new CqlStorage(DataContext, _configurationMock.Object, _reporterMock.Object);
             _storage.Start();
         }

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

@@ -26,10 +26,10 @@ namespace Abc.Zebus.Persistence.Cassandra.Cql
         private readonly PersistenceCqlDataContext _dataContext;
         private readonly PeerStateRepository _peerStateRepository;
         private readonly IPersistenceConfiguration _configuration;
-        private readonly IReporter _reporter;
+        private readonly IPersistenceReporter _reporter;
         private readonly PreparedStatement _preparedStatement;
 
-        public CqlStorage(PersistenceCqlDataContext dataContext, IPersistenceConfiguration configuration, IReporter reporter)
+        public CqlStorage(PersistenceCqlDataContext dataContext, IPersistenceConfiguration configuration, IPersistenceReporter reporter)
         {
             _dataContext = dataContext;
             _peerStateRepository = new PeerStateRepository(dataContext);

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

@@ -24,7 +24,7 @@ namespace Abc.Zebus.Persistence.RocksDb.Tests
         [SetUp]
         public void SetUp()
         {
-            _storage = new RocksDbStorage(Guid.NewGuid().ToString(), new NoopReporter());
+            _storage = new RocksDbStorage(Guid.NewGuid().ToString(), new NoopPersistenceReporter());
             _storage.Start();
         }
 

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

@@ -19,7 +19,7 @@ namespace Abc.Zebus.Persistence.RocksDb.Tests
     public class RocksDbStorageTests
     {
         private RocksDbStorage _storage;
-        private Mock<IReporter> _reporterMock;
+        private Mock<IPersistenceReporter> _reporterMock;
         private string _databaseDirectoryPath;
 
         [SetUp]
@@ -27,7 +27,7 @@ namespace Abc.Zebus.Persistence.RocksDb.Tests
         {
             _databaseDirectoryPath = Path.Combine(Path.GetTempPath(), Guid.NewGuid().ToString());
 
-            _reporterMock = new Mock<IReporter>();
+            _reporterMock = new Mock<IPersistenceReporter>();
             _storage = new RocksDbStorage(_databaseDirectoryPath,  _reporterMock.Object);
             _storage.Start();
         }

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

@@ -22,7 +22,7 @@ namespace Abc.Zebus.Persistence.RocksDb
     /// </summary>
     public class RocksDbStorage : IStorage, IDisposable
     {
-        private readonly IReporter _reporter;
+        private readonly IPersistenceReporter _reporter;
         private static readonly int _guidLength = Guid.Empty.ToByteArray().Length;
 
         private readonly ConcurrentDictionary<MessageId, bool> _outOfOrderAcks = new ConcurrentDictionary<MessageId, bool>();
@@ -34,12 +34,12 @@ namespace Abc.Zebus.Persistence.RocksDb
         private ColumnFamilyHandle _acksColumnFamily = default!;
 
         [DefaultConstructor]
-        public RocksDbStorage(IReporter reporter)
+        public RocksDbStorage(IPersistenceReporter reporter)
             : this(Path.Combine(AppDomain.CurrentDomain.BaseDirectory!, "database"), reporter)
         {
         }
 
-        public RocksDbStorage(string databaseDirectoryPath, IReporter reporter)
+        public RocksDbStorage(string databaseDirectoryPath, IPersistenceReporter reporter)
         {
             _databaseDirectoryPath = databaseDirectoryPath;
             _reporter = reporter;

src/Abc.Zebus.Persistence.Runner/Program.cs

@@ -123,7 +123,7 @@ namespace Abc.Zebus.Persistence.Runner
                 c.Forward<IInMemoryMessageMatcher, IProvideQueueLength>();
                 c.ForSingletonOf<IStoppingStrategy>().Use<PersistenceStoppingStrategy>();
 
-                c.ForSingletonOf<IReporter>().Use<NoopReporter>();
+                c.ForSingletonOf<IPersistenceReporter>().Use<NoopPersistenceReporter>();
 
                 // Cassandra specific
                 if (useCassandraStorage)

src/Abc.Zebus.Persistence.Tests/MessageReplayerRepositoryTests.cs

@@ -24,7 +24,7 @@ namespace Abc.Zebus.Persistence.Tests
             var transportMock = new Mock<ITransport>();
             var batchPersisterMock = new Mock<IInMemoryMessageMatcher>();
             var storage = new Mock<IStorage>();
-            var speedReporter = new Mock<IReporter>();
+            var speedReporter = new Mock<IPersistenceReporter>();
 
             _repository = new MessageReplayerRepository(persistenceConfigurationMock.Object, storage.Object, new TestBus(), transportMock.Object, batchPersisterMock.Object, speedReporter.Object, Mock.Of<IMessageSerializer>());
 

src/Abc.Zebus.Persistence.Tests/MessageReplayerTests.cs

@@ -63,7 +63,7 @@ namespace Abc.Zebus.Persistence.Tests
 
             readerMock.Setup(x => x.GetUnackedMessages()).Returns(_insertedMessages);
 
-            var speedReporter = new Mock<IReporter>();
+            var speedReporter = new Mock<IPersistenceReporter>();
 
             _replayer = new MessageReplayer(_configurationMock.Object, _storageMock.Object, _bus, _transport, _messageMatcherMock.Object, _targetPeer, _replayId, speedReporter.Object, new MessageSerializer());
 

src/Abc.Zebus.Persistence/Initialization/PersistenceRegistry.cs

@@ -8,7 +8,7 @@ namespace Abc.Zebus.Persistence.Initialization
     {
         public PersistenceRegistry()
         {
-            ForSingletonOf<IReporter>().UseIfNone<NoopReporter>();
+            ForSingletonOf<IPersistenceReporter>().UseIfNone<NoopPersistenceReporter>();
             ForSingletonOf<PersistMessageCommandHandler>().Use<PersistMessageCommandHandler>();
         }
     }

src/Abc.Zebus.Persistence/MessageReplayer.cs

@@ -28,7 +28,7 @@ namespace Abc.Zebus.Persistence
         private readonly Peer _self;
         private readonly Peer _peer;
         private readonly Guid _replayId;
-        private readonly IReporter _reporter;
+        private readonly IPersistenceReporter _reporter;
         private readonly IMessageSerializer _messageSerializer;
         private CancellationTokenSource? _cancellationTokenSource;
         private Thread? _runThread;
@@ -43,7 +43,7 @@ namespace Abc.Zebus.Persistence
                                IInMemoryMessageMatcher inMemoryMessageMatcher,
                                Peer peer,
                                Guid replayId,
-                               IReporter reporter,
+                               IPersistenceReporter reporter,
                                IMessageSerializer messageSerializer)
         {
             _persistenceConfiguration = persistenceConfiguration;

src/Abc.Zebus.Persistence/MessageReplayerRepository.cs

@@ -16,7 +16,7 @@ namespace Abc.Zebus.Persistence
         private readonly IBus _bus;
         private readonly ITransport _transport;
         private readonly IInMemoryMessageMatcher _inMemoryMessageMatcher;
-        private readonly IReporter _speedReporter;
+        private readonly IPersistenceReporter _speedReporter;
         private readonly IMessageSerializer _messageSerializer;
         private bool _messageReplayersEnabled = true;
 
@@ -25,7 +25,7 @@ namespace Abc.Zebus.Persistence
                                          IBus bus,
                                          ITransport transport,
                                          IInMemoryMessageMatcher inMemoryMessageMatcher,
-                                         IReporter speedReporter,
+                                         IPersistenceReporter speedReporter,
                                          IMessageSerializer messageSerializer)
         {
             _persistenceConfiguration = persistenceConfiguration;

src/Abc.Zebus.Persistence/Reporter/IReporter.cs → src/Abc.Zebus.Persistence/Reporter/IPersistenceReporter.cs

@@ -2,7 +2,7 @@ using System;
 
 namespace Abc.Zebus.Persistence.Reporter
 {
-    public interface IReporter
+    public interface IPersistenceReporter
     {
         void AddReplaySpeedReport(ReplaySpeedReport replaySpeedReport);
         void AddStorageReport(StorageReport storageReport);

src/Abc.Zebus.Persistence/Reporter/NoopReporter.cs → src/Abc.Zebus.Persistence/Reporter/NoopPersistenceReporter.cs

@@ -3,7 +3,7 @@ using System.Collections.Generic;
 
 namespace Abc.Zebus.Persistence.Reporter
 {
-    public class NoopReporter : IReporter
+    public class NoopPersistenceReporter : IPersistenceReporter
     {
         private static readonly List<ReplaySpeedReport> _emptyReplayReports = new(0);
         private static readonly List<StorageReport> _emptyStorageReports = new(0);