Tests for healthy slaves

Author: hamishforbes

t/sentinel.t

@@ -3,7 +3,7 @@
 use Test::Nginx::Socket::Lua;
 use Cwd qw(cwd);
 
-repeat_each(2);
+#repeat_each(2);
 
 plan tests => repeat_each() * (3 * blocks());
 
@@ -38,7 +38,7 @@ __DATA__
             end
 
             local redis_sentinel = require "resty.redis.sentinel"
-            
+
             local master, err = redis_sentinel.get_master(sentinel, "mymaster")
             if not master then
                 ngx.say(err)
@@ -74,7 +74,57 @@ port: 6379
             end
 
             local redis_sentinel = require "resty.redis.sentinel"
-            
+
+            local slaves, err = redis_sentinel.get_slaves(sentinel, "mymaster")
+            if not slaves then
+                ngx.say(err)
+            else
+                -- order is undefined
+                local all = {}
+                for i,slave in ipairs(slaves) do
+                    all[i] = tonumber(slave.port)
+                end
+                table.sort(all)
+                for _,p in ipairs(all) do
+                    ngx.say(p)
+                end
+            end
+
+            sentinel:close()
+        ';
+    }
+--- request
+    GET /t
+--- response_body
+6378
+6380
+--- no_error_log
+[error]
+
+=== TEST 3: Get only healthy slaves
+--- http_config eval: $::HttpConfig
+--- config
+    location /t {
+        content_by_lua '
+
+            local redis = require "resty.redis"
+            local r = redis.new()
+            r:connect("127.0.0.1", 6378)
+            r:slaveof("127.0.0.1", 7000)
+
+            ngx.sleep(9)
+
+            local redis_connector = require "resty.redis.connector"
+            local rc = redis_connector.new()
+
+            local sentinel, err = rc:connect{ url = "redis://127.0.0.1:6381" }
+            if not sentinel then
+                ngx.say("failed to connect: ", err)
+                return
+            end
+
+            local redis_sentinel = require "resty.redis.sentinel"
+
             local slaves, err = redis_sentinel.get_slaves(sentinel, "mymaster")
             if not slaves then
                 ngx.say(err)
@@ -90,9 +140,9 @@ port: 6379
     }
 --- request
     GET /t
+--- timeout: 10
 --- response_body
 host: 127.0.0.1
 port: 6380
 --- no_error_log
 [error]
-