diff options
Diffstat (limited to 'plugin/kubernetes')
| -rw-r--r-- | plugin/kubernetes/apiproxy.go | 4 | ||||
| -rw-r--r-- | plugin/kubernetes/kubernetes.go | 4 |
2 files changed, 3 insertions, 5 deletions
diff --git a/plugin/kubernetes/apiproxy.go b/plugin/kubernetes/apiproxy.go index 3e185f898..196ca5e60 100644 --- a/plugin/kubernetes/apiproxy.go +++ b/plugin/kubernetes/apiproxy.go @@ -23,10 +23,8 @@ type apiProxy struct { func (p *proxyHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) { upstream := p.Select() network := "tcp" - if upstream.Network != "" { - network = upstream.Network - } address := upstream.Name + d, err := net.Dial(network, address) if err != nil { log.Printf("[ERROR] Unable to establish connection to upstream %s://%s: %s", network, address, err) diff --git a/plugin/kubernetes/kubernetes.go b/plugin/kubernetes/kubernetes.go index 90fcd6182..afc48d0e0 100644 --- a/plugin/kubernetes/kubernetes.go +++ b/plugin/kubernetes/kubernetes.go @@ -190,9 +190,9 @@ func (k *Kubernetes) getClientConfig() (*rest.Config, error) { down := false - uh.CheckMu.Lock() + uh.Lock() until := uh.OkUntil - uh.CheckMu.Unlock() + uh.Unlock() if !until.IsZero() && time.Now().After(until) { down = true |