add empty implement

src/DotNetCore.CAP.MySql/MySqlStorage.cs

@@ -1,6 +1,7 @@
 using System.Threading;
 using System.Threading.Tasks;
 using Dapper;
+using DotNetCore.CAP.Dashboard;
 using Microsoft.Extensions.Logging;
 using MySql.Data.MySqlClient;
 
@@ -17,6 +18,16 @@ namespace DotNetCore.CAP.MySql
             _logger = logger;
         }
 
+        public IStorageConnection GetConnection()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public IMonitoringApi GetMonitoringApi()
+        {
+            throw new System.NotImplementedException();
+        }
+
         public async Task InitializeAsync(CancellationToken cancellationToken)
         {
             if (cancellationToken.IsCancellationRequested) return;

src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs

@@ -148,5 +148,25 @@ VALUES(@Name,@Group,@Content,@Retries,@Added,@ExpiresAt,@StatusName);";
 
             return new MySqlFetchedMessage(fetchedMessage.MessageId, fetchedMessage.MessageType, connection, transaction);
         }
+
+        public long GetSetCount(string key)
+        {
+            throw new NotImplementedException();
+        }
+
+        public List<string> GetRangeFromSet(string key, int startingFrom, int endingAt)
+        {
+            throw new NotImplementedException();
+        }
+
+        public MessageData GetJobData(string jobId)
+        {
+            throw new NotImplementedException();
+        }
+
+        public StateData GetStateData(string jobId)
+        {
+            throw new NotImplementedException();
+        }
     }
 }

src/DotNetCore.CAP.PostgreSql/PostgreSqlStorage.cs

@@ -1,6 +1,7 @@
 using System.Threading;
 using System.Threading.Tasks;
 using Dapper;
+using DotNetCore.CAP.Dashboard;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.Logging;
 using Npgsql;
@@ -18,6 +19,16 @@ namespace DotNetCore.CAP.PostgreSql
             _logger = logger;
         }
 
+        public IStorageConnection GetConnection()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public IMonitoringApi GetMonitoringApi()
+        {
+            throw new System.NotImplementedException();
+        }
+
         public async Task InitializeAsync(CancellationToken cancellationToken)
         {
             if (cancellationToken.IsCancellationRequested) return;

src/DotNetCore.CAP.PostgreSql/PostgreSqlStorageConnection.cs

@@ -133,5 +133,25 @@ namespace DotNetCore.CAP.PostgreSql
 
             return new PostgreSqlFetchedMessage(fetchedMessage.MessageId, fetchedMessage.MessageType, connection, transaction);
         }
+
+        public long GetSetCount(string key)
+        {
+            throw new NotImplementedException();
+        }
+
+        public List<string> GetRangeFromSet(string key, int startingFrom, int endingAt)
+        {
+            throw new NotImplementedException();
+        }
+
+        public MessageData GetJobData(string jobId)
+        {
+            throw new NotImplementedException();
+        }
+
+        public StateData GetStateData(string jobId)
+        {
+            throw new NotImplementedException();
+        }
     }
 }

src/DotNetCore.CAP.SqlServer/SqlServerStorage.cs

@@ -2,6 +2,7 @@ using System.Data.SqlClient;
 using System.Threading;
 using System.Threading.Tasks;
 using Dapper;
+using DotNetCore.CAP.Dashboard;
 using Microsoft.Extensions.Logging;
 
 namespace DotNetCore.CAP.SqlServer
@@ -17,6 +18,16 @@ namespace DotNetCore.CAP.SqlServer
             _logger = logger;
         }
 
+        public IStorageConnection GetConnection()
+        {
+            throw new System.NotImplementedException();
+        }
+
+        public IMonitoringApi GetMonitoringApi()
+        {
+            throw new System.NotImplementedException();
+        }
+
         public async Task InitializeAsync(CancellationToken cancellationToken)
         {
             if (cancellationToken.IsCancellationRequested) return;

src/DotNetCore.CAP.SqlServer/SqlServerStorageConnection.cs

@@ -139,5 +139,25 @@ VALUES(@Name,@Group,@Content,@Retries,@Added,@ExpiresAt,@StatusName);";
 
             return new SqlServerFetchedMessage(fetchedMessage.MessageId, fetchedMessage.MessageType, connection, transaction);
         }
+
+        public long GetSetCount(string key)
+        {
+            throw new NotImplementedException();
+        }
+
+        public List<string> GetRangeFromSet(string key, int startingFrom, int endingAt)
+        {
+            throw new NotImplementedException();
+        }
+
+        public MessageData GetJobData(string jobId)
+        {
+            throw new NotImplementedException();
+        }
+
+        public StateData GetStateData(string jobId)
+        {
+            throw new NotImplementedException();
+        }
     }
 }