aboutsummaryrefslogtreecommitdiff
path: root/plugin/pkg/proxy/proxy.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugin/pkg/proxy/proxy.go')
-rw-r--r--plugin/pkg/proxy/proxy.go13
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
}