diff options
author | 2023-07-04 15:35:55 +0100 | |
---|---|---|
committer | 2023-07-04 16:35:55 +0200 | |
commit | ea293da1d6bb0c4f598c8790c6941d56c79c0aa3 (patch) | |
tree | 9e808cf986b72673e2b9b176624cada501cd594e /plugin/pkg/proxy/proxy.go | |
parent | 6e1263d3d9ae1deef399df23d4ae47d2c3154e03 (diff) | |
download | coredns-ea293da1d6bb0c4f598c8790c6941d56c79c0aa3.tar.gz coredns-ea293da1d6bb0c4f598c8790c6941d56c79c0aa3.tar.zst coredns-ea293da1d6bb0c4f598c8790c6941d56c79c0aa3.zip |
Fix forward metrics for backwards compatibility (#6178)
Diffstat (limited to 'plugin/pkg/proxy/proxy.go')
-rw-r--r-- | plugin/pkg/proxy/proxy.go | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/plugin/pkg/proxy/proxy.go b/plugin/pkg/proxy/proxy.go index 414c34240..99fb5df78 100644 --- a/plugin/pkg/proxy/proxy.go +++ b/plugin/pkg/proxy/proxy.go @@ -12,8 +12,9 @@ import ( // Proxy defines an upstream host. type Proxy struct { - fails uint32 - addr string + fails uint32 + addr string + proxyName string transport *Transport @@ -25,15 +26,17 @@ type Proxy struct { } // NewProxy returns a new proxy. -func NewProxy(addr, trans string) *Proxy { +func NewProxy(proxyName, addr, trans string) *Proxy { p := &Proxy{ addr: addr, fails: 0, probe: up.New(), readTimeout: 2 * time.Second, - transport: newTransport(addr), + transport: newTransport(proxyName, addr), + health: NewHealthChecker(proxyName, trans, true, "."), + proxyName: proxyName, } - p.health = NewHealthChecker(trans, true, ".") + runtime.SetFinalizer(p, (*Proxy).finalizer) return p } |