@@ -21,30 +21,30 @@ __DATA__
2121=== TEST 1 : Get the master
2222-- - http_config eval: $::HttpConfig
2323-- - config
24- location / t {
25- content_by_lua '
26- local redis_connector = require "resty.redis.connector"
27- local rc = redis_connector.new()
28-
29- local sentinel, err = rc:connect{ url = "redis://127.0.0.1:6381" }
30- if not sentinel then
31- ngx.say("failed to connect: ", err)
32- return
33- end
34-
35- local redis_sentinel = require "resty.redis.sentinel"
36-
37- local master, err = redis_sentinel.get_master(sentinel, "mymaster")
38- if not master then
39- ngx.say(err)
40- else
41- ngx.say("host: ", master.host)
42- ngx.say("port: ", master.port)
43- end
44-
45- sentinel:close()
46- ' ;
47- }
24+ location / t {
25+ content_by_lua_block {
26+ local redis_connector = require " resty.redis.connector"
27+ local rc = redis_connector. new ()
28+
29+ local sentinel, err = rc: connect{ url = " redis://127.0.0.1:6381" }
30+ if not sentinel then
31+ ngx. say (" failed to connect: " , err)
32+ return
33+ end
34+
35+ local redis_sentinel = require " resty.redis.sentinel"
36+
37+ local master, err = redis_sentinel. get_master(sentinel, " mymaster" )
38+ if not master then
39+ ngx. say (err)
40+ else
41+ ngx. say (" host: " , master. host)
42+ ngx. say (" port: " , master. port)
43+ end
44+
45+ sentinel: close()
46+ }
47+ }
4848-- - request
4949 GET / t
5050-- - response_body
@@ -57,37 +57,37 @@ port: 6379
5757=== TEST 2 : Get slaves
5858-- - http_config eval: $::HttpConfig
5959-- - config
60- location / t {
61- content_by_lua '
62- local redis_connector = require "resty.redis.connector"
63- local rc = redis_connector.new()
64-
65- local sentinel, err = rc:connect{ url = "redis://127.0.0.1:6381" }
66- if not sentinel then
67- ngx.say("failed to connect: ", err)
68- return
60+ location / t {
61+ content_by_lua_block {
62+ local redis_connector = require " resty.redis.connector"
63+ local rc = redis_connector. new ()
64+
65+ local sentinel, err = rc: connect{ url = " redis://127.0.0.1:6381" }
66+ if not sentinel then
67+ ngx. say (" failed to connect: " , err)
68+ return
69+ end
70+
71+ local redis_sentinel = require " resty.redis.sentinel"
72+
73+ local slaves, err = redis_sentinel. get_slaves(sentinel, " mymaster" )
74+ if not slaves then
75+ ngx. say (err)
76+ else
77+ -- order is undefined
78+ local all = {}
79+ for i,slave in ipairs(slaves) do
80+ all [i] = tonumber(slave. port)
6981 end
70-
71- local redis_sentinel = require "resty.redis.sentinel"
72-
73- local slaves, err = redis_sentinel.get_slaves(sentinel, "mymaster")
74- if not slaves then
75- ngx.say(err)
76- else
77- -- order is undefined
78- local all = {}
79- for i,slave in ipairs(slaves) do
80- all[i] = tonumber(slave.port)
81- end
82- table.sort(all)
83- for _,p in ipairs(all) do
84- ngx.say(p)
85- end
82+ table. sort (all )
83+ for _,p in ipairs(all ) do
84+ ngx. say (p)
8685 end
86+ end
8787
88- sentinel:close()
89- ' ;
88+ sentinel: close()
9089 }
90+ }
9191-- - request
9292 GET / t
9393-- - response_body
@@ -99,40 +99,39 @@ port: 6379
9999=== TEST 3 : Get only healthy slaves
100100-- - http_config eval: $::HttpConfig
101101-- - config
102- location / t {
103- content_by_lua '
104-
105- local redis = require "resty.redis"
106- local r = redis.new()
107- r:connect("127.0.0.1", 6378)
108- r:slaveof("127.0.0.1", 7000)
109-
110- ngx.sleep(9)
111-
112- local redis_connector = require "resty.redis.connector"
113- local rc = redis_connector.new()
114-
115- local sentinel, err = rc:connect{ url = "redis://127.0.0.1:6381" }
116- if not sentinel then
117- ngx.say("failed to connect: ", err)
118- return
119- end
120-
121- local redis_sentinel = require "resty.redis.sentinel"
122-
123- local slaves, err = redis_sentinel.get_slaves(sentinel, "mymaster")
124- if not slaves then
125- ngx.say(err)
126- else
127- for _,slave in ipairs(slaves) do
128- ngx.say("host: ", slave.host)
129- ngx.say("port: ", slave.port)
130- end
102+ location / t {
103+ content_by_lua_block {
104+ local redis = require " resty.redis"
105+ local r = redis. new ()
106+ r: connect(" 127.0.0.1" , 6378 )
107+ r: slaveof(" 127.0.0.1" , 7000 )
108+
109+ ngx. sleep (9 )
110+
111+ local redis_connector = require " resty.redis.connector"
112+ local rc = redis_connector. new ()
113+
114+ local sentinel, err = rc: connect{ url = " redis://127.0.0.1:6381" }
115+ if not sentinel then
116+ ngx. say (" failed to connect: " , err)
117+ return
118+ end
119+
120+ local redis_sentinel = require " resty.redis.sentinel"
121+
122+ local slaves, err = redis_sentinel. get_slaves(sentinel, " mymaster" )
123+ if not slaves then
124+ ngx. say (err)
125+ else
126+ for _,slave in ipairs(slaves) do
127+ ngx. say (" host: " , slave. host)
128+ ngx. say (" port: " , slave. port)
131129 end
130+ end
132131
133- sentinel:close()
134- ' ;
132+ sentinel: close()
135133 }
134+ }
136135-- - request
137136 GET / t
138137-- - timeout: 10
0 commit comments