From cce8a97677e57f289485f8397a22793a6725e996 Mon Sep 17 00:00:00 2001 From: yangxiaodong Date: Sun, 27 Aug 2017 18:32:03 +0800 Subject: [PATCH] add empty implement --- src/DotNetCore.CAP.MySql/MySqlStorage.cs | 11 ++++++++++ .../MySqlStorageConnection.cs | 20 +++++++++++++++++++ .../PostgreSqlStorage.cs | 11 ++++++++++ .../PostgreSqlStorageConnection.cs | 20 +++++++++++++++++++ .../SqlServerStorage.cs | 11 ++++++++++ .../SqlServerStorageConnection.cs | 20 +++++++++++++++++++ 6 files changed, 93 insertions(+) diff --git a/src/DotNetCore.CAP.MySql/MySqlStorage.cs b/src/DotNetCore.CAP.MySql/MySqlStorage.cs index 137a69f..76ff1cf 100644 --- a/src/DotNetCore.CAP.MySql/MySqlStorage.cs +++ b/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; diff --git a/src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs b/src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs index 946f697..839ad93 100644 --- a/src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs +++ b/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 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(); + } } } \ No newline at end of file diff --git a/src/DotNetCore.CAP.PostgreSql/PostgreSqlStorage.cs b/src/DotNetCore.CAP.PostgreSql/PostgreSqlStorage.cs index 2704780..62cc7be 100644 --- a/src/DotNetCore.CAP.PostgreSql/PostgreSqlStorage.cs +++ b/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; diff --git a/src/DotNetCore.CAP.PostgreSql/PostgreSqlStorageConnection.cs b/src/DotNetCore.CAP.PostgreSql/PostgreSqlStorageConnection.cs index 3ddd3ab..451372a 100644 --- a/src/DotNetCore.CAP.PostgreSql/PostgreSqlStorageConnection.cs +++ b/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 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(); + } } } \ No newline at end of file diff --git a/src/DotNetCore.CAP.SqlServer/SqlServerStorage.cs b/src/DotNetCore.CAP.SqlServer/SqlServerStorage.cs index 9ef0247..1d008cd 100644 --- a/src/DotNetCore.CAP.SqlServer/SqlServerStorage.cs +++ b/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; diff --git a/src/DotNetCore.CAP.SqlServer/SqlServerStorageConnection.cs b/src/DotNetCore.CAP.SqlServer/SqlServerStorageConnection.cs index b8fba46..c9cbdd9 100644 --- a/src/DotNetCore.CAP.SqlServer/SqlServerStorageConnection.cs +++ b/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 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(); + } } } \ No newline at end of file