Add integration test for redissentinel with master + multiple slaves

Author: mythz

tests/ServiceStack.Redis.Tests/RedisSentinelTests.cs

@@ -1,6 +1,11 @@
-using System.Linq;
+using System;
+using System.Linq;
 using System.Text;
+using System.Threading;
 using NUnit.Framework;
+using ServiceStack.Logging;
+using ServiceStack.Text;
+using Timer = System.Timers.Timer;
 
 namespace ServiceStack.Redis.Tests
 {
@@ -112,5 +117,58 @@ public void Can_specify_db_on_RedisSentinel()
                 Assert.That(client.Db, Is.EqualTo(1));
             }
         }
+
+        [Test]
+        public void Run_sentinel_for_10_minutes()
+        {
+            LogManager.LogFactory = new ConsoleLogFactory(debugEnabled:true);
+
+            var sentinelHost = "{0}:{1}".Fmt(TestConfig.SentinelHost, TestConfig.RedisSentinelPort);
+            var sentinel = new RedisSentinel(sentinelHost, TestConfig.MasterName)
+            {
+                OnFailover = manager => 
+                {
+                    "Redis Managers Failed Over to new hosts".Print();
+                },
+                OnWorkerError = ex =>
+                {
+                    "Worker error: {0}".Print(ex);
+                },
+                OnSentinelMessageReceived = (channel, msg) =>
+                {
+                    "Received '{0}' on channel '{1}' from Sentinel".Print(channel, msg);
+                },                
+            };
+
+            var redisManager = sentinel.Start();
+
+            var aTimer = new Timer
+            {
+                Interval = 1000, 
+                Enabled = true
+            };
+            aTimer.Elapsed += (sender, args) => 
+            {
+                "Incrementing key".Print();
+
+                string key = null;
+                using (var redis = redisManager.GetClient())
+                {
+                    var counter = redis.Increment("key", 1);
+                    key = "key" + counter;
+                    "Set key {0} in read/write client".Print(key);
+                    redis.SetEntry(key, "value" + 1);
+                }
+
+                using (var redis = redisManager.GetClient())
+                {
+                    "Get key {0} in read-only client...".Print(key);
+                    var value = redis.GetEntry(key);
+                    "{0} = {1}".Print(key, value);
+                }
+            };
+
+            Thread.Sleep(TimeSpan.FromMinutes(10));
+        }
 	}
 }