added dot net core di container extensions to exemplify registrations

Author: Craig Wardman

ChunkingRedisClient.csproj

@@ -14,6 +14,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="2.2.0" />
     <PackageReference Include="Newtonsoft.Json" Version="12.0.1" />
     <PackageReference Include="StackExchange.Redis" Version="2.0.519" />
   </ItemGroup>

Client/IRedisClientConfig.cs

@@ -0,0 +1,7 @@
+namespace ChunkingRedisClient.Client
+{
+    public interface IRedisClientConfig
+    {
+        string ConnectionString { get; }
+    }
+}

Client/RedisClient.cs

@@ -18,9 +18,9 @@ public class RedisClient<TKey, TItem> : IRedisClient<TKey, TItem>
         private readonly string _keyPrefix;
         private IDatabase _prefixedDatabase;
 
-        public RedisClient(string connectionString, IRedisWriter<TKey, TItem> redisWriter, IRedisReader<TKey, TItem> redisReader, IRedisDeleter<TKey, TItem> redisDeleter)
+        public RedisClient(IRedisClientConfig config, IRedisWriter<TKey, TItem> redisWriter, IRedisReader<TKey, TItem> redisReader, IRedisDeleter<TKey, TItem> redisDeleter)
         {
-            _connectionString = connectionString ?? throw new ArgumentNullException(nameof(connectionString));
+            _connectionString = string.IsNullOrEmpty(config?.ConnectionString) ? throw new ArgumentNullException(nameof(config.ConnectionString)) : config.ConnectionString;
             _redisWriter = redisWriter ?? throw new ArgumentNullException(nameof(redisWriter));
             _redisReader = redisReader ?? throw new ArgumentNullException(nameof(redisReader));
             _redisDeleter = redisDeleter ?? throw new ArgumentNullException(nameof(redisDeleter));

MicrosoftDiExtensions.cs

@@ -0,0 +1,38 @@
+using System;
+using ChunkingRedisClient.Client;
+using ChunkingRedisClient.Client.Deleter;
+using ChunkingRedisClient.Client.Reader;
+using ChunkingRedisClient.Client.Writer;
+using ChunkingRedisClient.Keys;
+using ChunkingRedisClient.Locking;
+using Microsoft.Extensions.DependencyInjection;
+
+namespace ChunkingRedisClient
+{
+    public static class MicrosoftDiExtensions
+    {
+        public static void AddRedisClient<TKey, TItem>(this IServiceCollection serviceCollection, int? chunkSize)
+        {
+            serviceCollection.AddSingleton<IKeygen<Guid>, GuidKeygen>(); // user to manually register any other keygen classes
+            serviceCollection.AddSingleton<IRedisLockFactory, RedisLockFactory>();
+
+            if (chunkSize.GetValueOrDefault(0) is int chunk && chunk > 0)
+            {
+                serviceCollection.AddScoped<IRedisReader<TKey, TItem>, ChunkedJsonRedisReader<TKey, TItem>>();
+                serviceCollection.AddScoped<IRedisDeleter<TKey, TItem>, ChunkedDeleter<TKey, TItem>>();
+                serviceCollection.AddScoped(provider => new ChunkedJsonRedisWriter<TKey, TItem>(
+                    provider.GetRequiredService<IKeygen<TKey>>(),
+                    provider.GetRequiredService<IRedisLockFactory>(),
+                    chunk));
+            }
+            else
+            {
+                serviceCollection.AddScoped<IRedisReader<TKey, TItem>, JsonRedisReader<TKey, TItem>>();
+                serviceCollection.AddScoped<IRedisDeleter<TKey, TItem>, StandardDeleter<TKey, TItem>>();
+                serviceCollection.AddScoped<IRedisWriter<TKey, TItem>, JsonRedisWriter<TKey, TItem>>();
+            }
+
+            serviceCollection.AddScoped<IRedisClient<TKey, TItem>, RedisClient<TKey, TItem>>(); // user to define IRedisClientConfig impl.
+        }
+    }
+}