Add configurable Redis key prefixes

src/AspNetCoreRateLimit.Redis/RedisProcessingStrategy.cs

@@ -3,20 +3,23 @@
 using System;
 using System.Threading;
 using System.Threading.Tasks;
+using Microsoft.Extensions.Options;
 
 namespace AspNetCoreRateLimit.Redis
 {
     public class RedisProcessingStrategy : ProcessingStrategy
     {
         private readonly IConnectionMultiplexer _connectionMultiplexer;
         private readonly IRateLimitConfiguration _config;
+        private readonly RedisRateLimitOptions _options;
         private readonly ILogger<RedisProcessingStrategy> _logger;
 
-        public RedisProcessingStrategy(IConnectionMultiplexer connectionMultiplexer, IRateLimitConfiguration config, ILogger<RedisProcessingStrategy> logger)
+        public RedisProcessingStrategy(IConnectionMultiplexer connectionMultiplexer, IRateLimitConfiguration config, IOptions<RedisRateLimitOptions> redisOptions, ILogger<RedisProcessingStrategy> logger)
             : base(config)
         {
             _connectionMultiplexer = connectionMultiplexer ?? throw new ArgumentException("IConnectionMultiplexer was null. Ensure StackExchange.Redis was successfully registered");
             _config = config;
+            _options = redisOptions.Value;
             _logger = logger;
         }
 
@@ -42,5 +45,11 @@ public async Task<RateLimitCounter> IncrementAsync(string counterId, TimeSpan in
                 Timestamp = intervalStart
             };
         }
+
+        protected override string BuildCounterKey(ClientRequestIdentity requestIdentity, RateLimitRule rule, ICounterKeyBuilder counterKeyBuilder,
+            RateLimitOptions rateLimitOptions)
+        {
+            return $"{_options.KeyPrefix}{base.BuildCounterKey(requestIdentity, rule, counterKeyBuilder, rateLimitOptions)}";
+        }
     }
 }

src/AspNetCoreRateLimit.Redis/RedisRateLimitOptions.cs

@@ -0,0 +1,10 @@
+namespace AspNetCoreRateLimit.Redis
+{
+    public class RedisRateLimitOptions
+    {
+        /// <summary>
+        ///     Gets or sets the Redis key prefix
+        /// </summary>
+        public string KeyPrefix { get; set; } = "ratelimits:";
+    }
+}

test/AspNetCoreRateLimit.Demo/Startup.cs

@@ -28,12 +28,15 @@ public void ConfigureServices(IServiceCollection services)
             // configure client rate limiting middleware
             services.Configure<ClientRateLimitOptions>(Configuration.GetSection("ClientRateLimiting"));
             services.Configure<ClientRateLimitPolicies>(Configuration.GetSection("ClientRateLimitPolicies"));
+
+            // configure Redis rate limiting strategy
+            services.Configure<RedisRateLimitOptions>(Configuration.GetSection("RedisRateLimitPolicies"));
 
             // register stores
             services.AddInMemoryRateLimiting();
-            //services.AddDistributedRateLimiting<AsyncKeyLockProcessingStrategy>();
-            //services.AddDistributedRateLimiting<RedisProcessingStrategy>();
-            //services.AddRedisRateLimiting();
+            // services.AddDistributedRateLimiting<AsyncKeyLockProcessingStrategy>();
+            // services.AddDistributedRateLimiting<RedisProcessingStrategy>();
+            // services.AddRedisRateLimiting();
 
             services.AddMvc((options) =>
             {

test/AspNetCoreRateLimit.Demo/appsettings.json

@@ -216,5 +216,9 @@
         ]
       }
     ]
+  },
+
+  "RedisRateLimitPolicies": {
+    "KeyPrefix": "ratelimits:"
   }
 }