function _M.connect()

in lib/shenyu/register/zookeeper/zk_cluster.lua [28:53]

• 24 lines of code
• 5 McCabe index (conditional complexity)

function _M.connect(self)
    local servers = self.servers
    if not servers then
        return nil, "servers is null"
    end
    
    
    local client, err = zkclient:new()
    if not client then
        ngx_log(ngx.ERR, "Failed to initialize zk Client" .. err)
        return nil, err
    end
    for _, _host in ipairs(servers) do
        ngx_log(ngx.INFO, "try to connect to zookeeper host : " .. _host)
        local ok, err = client:connect(_host)
        if not ok then
            ngx_log(ngx.INFO, "Failed to connect to zookeeper host : " .. _host .. err)
        else
            ngx_log(ngx.INFO, "Successful connection to zookeeper host : " .. _host)
            self.client = client
            return client
        end
    end
    ngx_log(ngx.ERR, "Failed to connect to zookeeper")
    return nil
end