hi,We had a problem recently,when a cluster shuts down several nodes,we found that the project did not refresh the node,After checking, we found that in the commit_pipeline method
local ok, err = redis_client:connect(ip, port, self.config.connect_opts)
local authok, autherr = check_auth(self, redis_client)
if autherr then
return nil, autherr
end
if slave then
--set readonly
local ok, err = redis_client:readonly()
if not ok then
self:refresh_slots()
return nil, err
end
end
if ok then
redis_client:init_pipeline()
The if ok then should be in redis_client:connect behind,I think
hi,We had a problem recently,when a cluster shuts down several nodes,we found that the project did not refresh the node,After checking, we found that in the commit_pipeline method
The
if ok then
should be inredis_client:connect
behind,I think