feat(): skip redis replica server

Author: phat

src/mix.heart/Services/RedisCacheClient.cs

@@ -1,14 +1,10 @@
 using Microsoft.Extensions.Caching.Distributed;
-using Mix.Heart.Extensions;
 using Mix.Heart.Interfaces;
 using StackExchange.Redis;
 using System;
 using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
-using System.Buffers.Text;
-using System.Text;
-using Newtonsoft.Json;
 using Mix.Heart.Helpers;
 namespace Mix.Heart.Services
 {
@@ -48,6 +44,12 @@ public async Task ClearCache(string key, CancellationToken cancellationToken = d
             foreach (var endpoint in endpoints)
             {
                 var server = _connectionMultiplexer.GetServer(endpoint);
+
+                if (server.IsReplica || !server.IsConnected)
+                {
+                    continue;
+                }
+
                 await _database.KeyDeleteAsync(server.Keys(pattern: $"{key}:*").ToArray());
             }
         }
@@ -60,6 +62,12 @@ public async Task ClearAllCache(CancellationToken cancellationToken = default)
                 foreach (var endpoint in endpoints)
                 {
                     var server = _connectionMultiplexer.GetServer(endpoint);
+
+                    if (server.IsReplica || !server.IsConnected)
+                    {
+                        continue;
+                    }
+
                     await server.FlushDatabaseAsync();
                 }
             }
@@ -74,4 +82,4 @@ public async Task ClearAllCache(CancellationToken cancellationToken = default)
 
         #endregion
     }
-}
+}