Elgato_dark/bunkerweb
1
0
Fork 0
mirror of https://github.com/bunkerity/bunkerweb synced 2026-05-24 09:28:37 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Refactor clusterstore initialization and connection

Browse source
This commit is contained in:
Théophile Diot 2024-01-16 18:15:09 +00:00
parent 5fd72ea631
commit 5fcdc1c7b3
No known key found for this signature in database
GPG key ID: 248FEA4BAE400D06
1 changed files with 18 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
src/bw/lua/bunkerweb/clusterstore.lua
View file

@ -81,7 +81,14 @@ function clusterstore:initialize(pool)
else
sport = tonumber(sport)
end
table.insert(options.sentinels, { host = shost, port = sport })
local data = { host = shost, port = sport }
if options.sentinel_username ~= "" then
data.username = options.sentinel_username
end
if options.sentinel_password ~= "" then
data.password = options.sentinel_password
end
table.insert(options.sentinels, data)
end
end
self.options = options
@ -106,14 +113,21 @@ function clusterstore:connect(readonly)
self:close()
end
-- Connect to sentinels if needed
local redis_client, err
local redis_client, err, previous_errors
if #self.options.sentinels > 0 and readonly then
redis_client, err = self.redis_connector:connect({ role = "slave" })
redis_client, err, previous_errors = self.redis_connector:connect({ role = "slave" })
else
redis_client, err = self.redis_connector:connect()
redis_client, err, previous_errors = self.redis_connector:connect()
end
self.redis_client = redis_client
if not self.redis_client then
if previous_errors then
err = err .. " ( previous errors : "
for _, e in ipairs(previous_errors) do
err = err .. e .. ", "
end
err = err:sub(1, -3) .. " )"
end
return false, "error while getting redis client : " .. err
end
-- Everything went well