Move all non-required but useful API's into IRedisResolverExtended, which are useful to query but not required to impl

mythz · mythz · commit 16635caadb5e · 2015-07-14T07:27:06.000+08:00
diff --git a/src/ServiceStack.Redis/IRedisResolver.cs b/src/ServiceStack.Redis/IRedisResolver.cs
@@ -1,4 +1,5 @@
-﻿using System.Collections.Generic;
+﻿using System;
+using System.Collections.Generic;
 
 namespace ServiceStack.Redis
 {
@@ -7,13 +8,21 @@ namespace ServiceStack.Redis
     /// </summary>
     public interface IRedisResolver
     {
+        Func<RedisEndpoint, RedisClient> ClientFactory { get; set; }
+
         int ReadWriteHostsCount { get; }
         int ReadOnlyHostsCount { get; }
 
         void ResetMasters(IEnumerable<string> hosts);
         void ResetSlaves(IEnumerable<string> hosts);
 
-        RedisClient CreateRedisClient(RedisEndpoint config, bool readWrite);
+        RedisClient CreateMasterClient(int desiredIndex);
+        RedisClient CreateSlaveClient(int desiredIndex);
+    }
+
+    public interface IRedisResolverExtended : IRedisResolver
+    {
+        RedisClient CreateRedisClient(RedisEndpoint config, bool master);
 
         RedisEndpoint GetReadWriteHost(int desiredIndex);
         RedisEndpoint GetReadOnlyHost(int desiredIndex);
@@ -23,4 +32,22 @@ public interface IHasRedisResolver
     {
         IRedisResolver RedisResolver { get; set; }
     }
+
+    public static class RedisResolverExtensions
+    {
+        public static RedisClient CreateRedisClient(this IRedisResolver resolver, RedisEndpoint config, bool master)
+        {
+            return ((IRedisResolverExtended)resolver).CreateRedisClient(config, master);
+        }
+
+        public static RedisEndpoint GetReadWriteHost(this IRedisResolver resolver, int desiredIndex)
+        {
+            return ((IRedisResolverExtended)resolver).GetReadWriteHost(desiredIndex);
+        }
+
+        public static RedisEndpoint GetReadOnlyHost(this IRedisResolver resolver, int desiredIndex)
+        {
+            return ((IRedisResolverExtended)resolver).GetReadOnlyHost(desiredIndex);
+        }
+    }
 }
