diff --git a/internal/ingress/controller/nginx_test.go b/internal/ingress/controller/nginx_test.go index bb2ee092a..5b174f1c0 100644 --- a/internal/ingress/controller/nginx_test.go +++ b/internal/ingress/controller/nginx_test.go @@ -148,8 +148,8 @@ func TestConfigureDynamically(t *testing.T) { t.Errorf("unexpected target reference in JSON content: %v", body) } - if strings.Contains(body, "service") { - t.Errorf("unexpected service reference in JSON content: %v", body) + if !strings.Contains(body, "service") { + t.Errorf("service reference should be present in JSON content: %v", body) } })) diff --git a/rootfs/etc/nginx/lua/util/dns.lua b/rootfs/etc/nginx/lua/util/dns.lua index 194b1abd7..88cff2ce7 100644 --- a/rootfs/etc/nginx/lua/util/dns.lua +++ b/rootfs/etc/nginx/lua/util/dns.lua @@ -31,11 +31,15 @@ end function _M.resolve(host) local cached_addresses = cache:get(host) if cached_addresses then - ngx.log(ngx.INFO, string.format("addresses %s for host %s was resolved from cache", table.concat(cached_addresses, ", "), host)) + local message = string.format( + "addresses %s for host %s was resolved from cache", + table.concat(cached_addresses, ", "), host) + ngx.log(ngx.INFO, message) return cached_addresses end - local r, err = resolver:new{ + local r + r, err = resolver:new{ nameservers = util.deepcopy(configuration.nameservers), retrans = 5, timeout = 2000, -- 2 sec @@ -46,7 +50,8 @@ function _M.resolve(host) return { host } end - local answers, err, _tries = r:query(host, { qtype = r.TYPE_A }, {}) + local answers + answers, err = r:query(host, { qtype = r.TYPE_A }, {}) if not answers then ngx.log(ngx.ERR, "failed to query the DNS server: " .. tostring(err)) return { host } diff --git a/rootfs/etc/nginx/template/nginx.tmpl b/rootfs/etc/nginx/template/nginx.tmpl index 04888bcd5..fed5da7b8 100644 --- a/rootfs/etc/nginx/template/nginx.tmpl +++ b/rootfs/etc/nginx/template/nginx.tmpl @@ -673,6 +673,8 @@ stream { proxy_set_header X-Service-Name $service_name; proxy_set_header X-Service-Port $service_port; + set $proxy_upstream_name "upstream-default-backend"; + rewrite (.*) / break; {{ if $dynamicConfig }}