Async (#2)

Implement async APIs for ServiceStack.Redis

Author: mgravell

src/ServiceStack.Redis.sln

@@ -1,18 +1,18 @@
 
 Microsoft Visual Studio Solution File, Format Version 12.00
-# Visual Studio 15
-VisualStudioVersion = 15.0.27130.2010
+# Visual Studio Version 16
+VisualStudioVersion = 16.0.29721.120
 MinimumVisualStudioVersion = 10.0.40219.1
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Build", "Build", "{38F69F8F-9303-4BAF-B081-D28339163E07}"
 	ProjectSection(SolutionItems) = preProject
+		..\build\build-core.proj = ..\build\build-core.proj
 		..\build\build.bat = ..\build\build.bat
 		..\build\build.proj = ..\build\build.proj
 		..\build\build.tasks = ..\build\build.tasks
-		..\README.md = ..\README.md
 		Directory.Build.props = Directory.Build.props
-		ServiceStack.Redis\ServiceStack.Redis.Core.csproj = ServiceStack.Redis\ServiceStack.Redis.Core.csproj
-		..\build\build-core.proj = ..\build\build-core.proj
 		..\tests\Directory.Build.props = ..\tests\Directory.Build.props
+		..\README.md = ..\README.md
+		ServiceStack.Redis\ServiceStack.Redis.Core.csproj = ServiceStack.Redis\ServiceStack.Redis.Core.csproj
 	EndProjectSection
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ServiceStack.Redis", "ServiceStack.Redis\ServiceStack.Redis.csproj", "{AF99F19B-4C04-4F58-81EF-B092F1FCC540}"
@@ -23,6 +23,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Console.Tests", "..\tests\C
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ServiceStack.Redis.Tests.Sentinel", "..\tests\ServiceStack.Redis.Tests.Sentinel\ServiceStack.Redis.Tests.Sentinel.csproj", "{91C55091-A946-49B5-9517-8794EBCC5784}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ServiceStack.Redis.Benchmark", "..\tests\ServiceStack.Redis.Benchmark\ServiceStack.Redis.Benchmark.csproj", "{959CA5FE-6525-4EEF-86CA-F4978BEFF14F}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -77,6 +79,18 @@ Global
 		{91C55091-A946-49B5-9517-8794EBCC5784}.Release|x64.ActiveCfg = Release|Any CPU
 		{91C55091-A946-49B5-9517-8794EBCC5784}.Release|x64.Build.0 = Release|Any CPU
 		{91C55091-A946-49B5-9517-8794EBCC5784}.Release|x86.ActiveCfg = Release|Any CPU
+		{959CA5FE-6525-4EEF-86CA-F4978BEFF14F}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{959CA5FE-6525-4EEF-86CA-F4978BEFF14F}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{959CA5FE-6525-4EEF-86CA-F4978BEFF14F}.Debug|x64.ActiveCfg = Debug|Any CPU
+		{959CA5FE-6525-4EEF-86CA-F4978BEFF14F}.Debug|x64.Build.0 = Debug|Any CPU
+		{959CA5FE-6525-4EEF-86CA-F4978BEFF14F}.Debug|x86.ActiveCfg = Debug|Any CPU
+		{959CA5FE-6525-4EEF-86CA-F4978BEFF14F}.Debug|x86.Build.0 = Debug|Any CPU
+		{959CA5FE-6525-4EEF-86CA-F4978BEFF14F}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{959CA5FE-6525-4EEF-86CA-F4978BEFF14F}.Release|Any CPU.Build.0 = Release|Any CPU
+		{959CA5FE-6525-4EEF-86CA-F4978BEFF14F}.Release|x64.ActiveCfg = Release|Any CPU
+		{959CA5FE-6525-4EEF-86CA-F4978BEFF14F}.Release|x64.Build.0 = Release|Any CPU
+		{959CA5FE-6525-4EEF-86CA-F4978BEFF14F}.Release|x86.ActiveCfg = Release|Any CPU
+		{959CA5FE-6525-4EEF-86CA-F4978BEFF14F}.Release|x86.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

src/ServiceStack.Redis/AsyncInterfaces/IRedisClientAsync.cs

@@ -0,0 +1,46 @@
+//
+// https://github.com/ServiceStack/ServiceStack.Redis
+// ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system
+//
+// Authors:
+//   Demis Bellot ([email protected])
+//
+// Copyright 2017 ServiceStack, Inc. All Rights Reserved.
+//
+// Licensed under the same terms of ServiceStack.
+//
+
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+using ServiceStack.Caching;
+
+namespace ServiceStack.Redis
+{
+    public interface IRedisClientsManagerAsync : IAsyncDisposable
+    {
+        /// <summary>
+        /// Returns a Read/Write client (The default) using the hosts defined in ReadWriteHosts
+        /// </summary>
+        /// <returns></returns>
+        ValueTask<IRedisClientAsync> GetClientAsync(CancellationToken cancellationToken = default);
+
+        /// <summary>
+        /// Returns a ReadOnly client using the hosts defined in ReadOnlyHosts.
+        /// </summary>
+        /// <returns></returns>
+        ValueTask<IRedisClientAsync> GetReadOnlyClientAsync(CancellationToken cancellationToken = default);
+
+        /// <summary>
+        /// Returns a Read/Write ICacheClient (The default) using the hosts defined in ReadWriteHosts
+        /// </summary>
+        /// <returns></returns>
+        ValueTask<ICacheClientAsync> GetCacheClientAsync(CancellationToken cancellationToken = default);
+
+        /// <summary>
+        /// Returns a ReadOnly ICacheClient using the hosts defined in ReadOnlyHosts.
+        /// </summary>
+        /// <returns></returns>
+        ValueTask<ICacheClientAsync> GetReadOnlyCacheClientAsync(CancellationToken cancellationToken = default);
+    }
+}

src/ServiceStack.Redis/AsyncInterfaces/IRedisClientsManagerAsync.cs

@@ -0,0 +1,32 @@
+//
+// https://github.com/ServiceStack/ServiceStack.Redis
+// ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system
+//
+// Authors:
+//   Demis Bellot ([email protected])
+//
+// Copyright 2017 ServiceStack, Inc. All Rights Reserved.
+//
+// Licensed under the same terms of ServiceStack.
+//
+
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using ServiceStack.Model;
+
+namespace ServiceStack.Redis.Generic
+{
+    public interface IRedisHashAsync<TKey, TValue> : IAsyncEnumerable<KeyValuePair<TKey, TValue>>, IHasStringId
+    {
+        ValueTask<Dictionary<TKey, TValue>> GetAllAsync(CancellationToken cancellationToken = default);
+
+        ValueTask<int> CountAsync(CancellationToken cancellationToken = default);
+        ValueTask AddAsync(KeyValuePair<TKey, TValue> item, CancellationToken cancellationToken = default);
+        ValueTask AddAsync(TKey key, TValue value, CancellationToken cancellationToken = default);
+        ValueTask ClearAsync(CancellationToken cancellationToken = default);
+        ValueTask<bool> ContainsKeyAsync(TKey key, CancellationToken cancellationToken = default);
+        ValueTask<bool> RemoveAsync(TKey key, CancellationToken cancellationToken = default);
+    }
+
+}

src/ServiceStack.Redis/AsyncInterfaces/IRedisHashAsync.Generic.cs

@@ -0,0 +1,23 @@
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using ServiceStack.Model;
+
+namespace ServiceStack.Redis
+{
+    public interface IRedisHashAsync
+        : IAsyncEnumerable<KeyValuePair<string, string>>, IHasStringId
+    {
+        ValueTask<bool> AddIfNotExistsAsync(KeyValuePair<string, string> item, CancellationToken cancellationToken = default);
+        ValueTask AddRangeAsync(IEnumerable<KeyValuePair<string, string>> items, CancellationToken cancellationToken = default);
+        ValueTask<long> IncrementValueAsync(string key, int incrementBy, CancellationToken cancellationToken = default);
+
+        // shim the basic ICollection etc APIs
+        ValueTask<int> CountAsync(CancellationToken cancellationToken = default);
+        ValueTask AddAsync(KeyValuePair<string, string> item, CancellationToken cancellationToken = default);
+        ValueTask AddAsync(string key, string value, CancellationToken cancellationToken = default);
+        ValueTask ClearAsync(CancellationToken cancellationToken = default);
+        ValueTask<bool> ContainsKeyAsync(string key, CancellationToken cancellationToken = default);
+        ValueTask<bool> RemoveAsync(string key, CancellationToken cancellationToken = default);
+    }
+}

src/ServiceStack.Redis/AsyncInterfaces/IRedisHashAsync.cs

@@ -0,0 +1,64 @@
+//
+// https://github.com/ServiceStack/ServiceStack.Redis
+// ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system
+//
+// Authors:
+//   Demis Bellot Async([email protected], CancellationToken cancellationToken = default)
+//
+// Copyright 2017 ServiceStack, Inc. All Rights Reserved.
+//
+// Licensed under the same terms of ServiceStack.
+//
+
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using ServiceStack.Model;
+
+namespace ServiceStack.Redis.Generic
+{
+    /// <summary>
+    /// Wrap the common redis list operations under a IList[string] interface.
+    /// </summary>
+
+    public interface IRedisListAsync<T>
+        : IAsyncEnumerable<T>, IHasStringId
+    {
+        ValueTask<int> CountAsync(CancellationToken cancellationToken = default);
+        ValueTask<List<T>> GetAllAsync(CancellationToken cancellationToken = default);
+        ValueTask<List<T>> GetRangeAsync(int startingFrom, int endingAt, CancellationToken cancellationToken = default);
+        ValueTask<List<T>> GetRangeFromSortedListAsync(int startingFrom, int endingAt, CancellationToken cancellationToken = default);
+        ValueTask RemoveAllAsync(CancellationToken cancellationToken = default);
+        ValueTask TrimAsync(int keepStartingFrom, int keepEndingAt, CancellationToken cancellationToken = default);
+        ValueTask<long> RemoveValueAsync(T value, CancellationToken cancellationToken = default);
+        ValueTask<long> RemoveValueAsync(T value, int noOfMatches, CancellationToken cancellationToken = default);
+
+        ValueTask AddRangeAsync(IEnumerable<T> values, CancellationToken cancellationToken = default);
+        ValueTask AppendAsync(T value, CancellationToken cancellationToken = default);
+        ValueTask PrependAsync(T value, CancellationToken cancellationToken = default);
+        ValueTask<T> RemoveStartAsync(CancellationToken cancellationToken = default);
+        ValueTask<T> BlockingRemoveStartAsync(TimeSpan? timeOut, CancellationToken cancellationToken = default);
+        ValueTask<T> RemoveEndAsync(CancellationToken cancellationToken = default);
+
+        ValueTask EnqueueAsync(T value, CancellationToken cancellationToken = default);
+        ValueTask<T> DequeueAsync(CancellationToken cancellationToken = default);
+        ValueTask<T> BlockingDequeueAsync(TimeSpan? timeOut, CancellationToken cancellationToken = default);
+
+        ValueTask PushAsync(T value, CancellationToken cancellationToken = default);
+        ValueTask<T> PopAsync(CancellationToken cancellationToken = default);
+        ValueTask<T> BlockingPopAsync(TimeSpan? timeOut, CancellationToken cancellationToken = default);
+        ValueTask<T> PopAndPushAsync(IRedisListAsync<T> toList, CancellationToken cancellationToken = default);
+
+
+        ValueTask<bool> RemoveAsync(T item, CancellationToken cancellationToken = default);
+        ValueTask AddAsync(T item, CancellationToken cancellationToken = default);
+        ValueTask RemoveAtAsync(int index, CancellationToken cancellationToken = default);
+        ValueTask<bool> ContainsAsync(T item, CancellationToken cancellationToken = default);
+        ValueTask ClearAsync(CancellationToken cancellationToken = default);
+        ValueTask<int> IndexOfAsync(T item, CancellationToken cancellationToken = default);
+
+        ValueTask<T> ElementAtAsync(int index, CancellationToken cancellationToken = default);
+        ValueTask SetValueAsync(int index, T value, CancellationToken cancellationToken = default);
+    }
+}

src/ServiceStack.Redis/AsyncInterfaces/IRedisListAsync.Generic.cs

@@ -0,0 +1,58 @@
+//
+// https://github.com/ServiceStack/ServiceStack.Redis
+// ServiceStack.Redis: ECMA CLI Binding to the Redis key-value storage system
+//
+// Authors:
+//   Demis Bellot Async([email protected])
+//
+// Copyright 2017 ServiceStack, Inc. All Rights Reserved.
+//
+// Licensed under the same terms of ServiceStack.
+//
+
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using ServiceStack.Model;
+
+namespace ServiceStack.Redis
+{
+    public interface IRedisListAsync
+        : IAsyncEnumerable<string>, IHasStringId
+    {
+        ValueTask<int> CountAsync(CancellationToken cancellationToken = default);
+        ValueTask<List<string>> GetAllAsync(CancellationToken cancellationToken = default);
+        ValueTask<List<string>> GetRangeAsync(int startingFrom, int endingAt, CancellationToken cancellationToken = default);
+        ValueTask<List<string>> GetRangeFromSortedListAsync(int startingFrom, int endingAt, CancellationToken cancellationToken = default);
+        ValueTask RemoveAllAsync(CancellationToken cancellationToken = default);
+        ValueTask TrimAsync(int keepStartingFrom, int keepEndingAt, CancellationToken cancellationToken = default);
+        ValueTask<long> RemoveValueAsync(string value, CancellationToken cancellationToken = default);
+        ValueTask<long> RemoveValueAsync(string value, int noOfMatches, CancellationToken cancellationToken = default);
+
+        ValueTask PrependAsync(string value, CancellationToken cancellationToken = default);
+        ValueTask AppendAsync(string value, CancellationToken cancellationToken = default);
+        ValueTask<string> RemoveStartAsync(CancellationToken cancellationToken = default);
+        ValueTask<string> BlockingRemoveStartAsync(TimeSpan? timeOut, CancellationToken cancellationToken = default);
+        ValueTask<string> RemoveEndAsync(CancellationToken cancellationToken = default);
+
+        ValueTask EnqueueAsync(string value, CancellationToken cancellationToken = default);
+        ValueTask<string> DequeueAsync(CancellationToken cancellationToken = default);
+        ValueTask<string> BlockingDequeueAsync(TimeSpan? timeOut, CancellationToken cancellationToken = default);
+
+        ValueTask PushAsync(string value, CancellationToken cancellationToken = default);
+        ValueTask<string> PopAsync(CancellationToken cancellationToken = default);
+        ValueTask<string> BlockingPopAsync(TimeSpan? timeOut, CancellationToken cancellationToken = default);
+        ValueTask<string> PopAndPushAsync(IRedisListAsync toList, CancellationToken cancellationToken = default);
+        
+        ValueTask<bool> RemoveAsync(string item, CancellationToken cancellationToken = default);
+        ValueTask AddAsync(string item, CancellationToken cancellationToken = default);
+        ValueTask RemoveAtAsync(int index, CancellationToken cancellationToken = default);
+        ValueTask<bool> ContainsAsync(string item, CancellationToken cancellationToken = default);
+        ValueTask ClearAsync(CancellationToken cancellationToken = default);
+        ValueTask<int> IndexOfAsync(string item, CancellationToken cancellationToken = default);
+
+        ValueTask<string> ElementAtAsync(int index, CancellationToken cancellationToken = default);
+        ValueTask SetValueAsync(int index, string value, CancellationToken cancellationToken = default);
+    }
+}