aboutsummaryrefslogtreecommitdiff
path: root/plugin/kubernetes/apiproxy.go
diff options
context:
space:
mode:
authorGravatar Miek Gieben <miek@miek.nl> 2018-04-19 07:41:56 +0100
committerGravatar GitHub <noreply@github.com> 2018-04-19 07:41:56 +0100
commit26d1432ae6c19c91fb6358e7629a9179a85b70f7 (patch)
tree8a9f94cf11dcebf1f079ab478d4ded4bf710c99f /plugin/kubernetes/apiproxy.go
parent2095eb7979f53618180f759d0e68e4070554870d (diff)
downloadcoredns-26d1432ae6c19c91fb6358e7629a9179a85b70f7.tar.gz
coredns-26d1432ae6c19c91fb6358e7629a9179a85b70f7.tar.zst
coredns-26d1432ae6c19c91fb6358e7629a9179a85b70f7.zip
Update all plugins to use plugin/pkg/log (#1694)
* Update all plugins to use plugin/pkg/log I wish this could have been done with sed. Alas manually changed all callers to use the new plugin/pkg/log package. * Error -> Info * Add docs to debug plugin as well
Diffstat (limited to 'plugin/kubernetes/apiproxy.go')
-rw-r--r--plugin/kubernetes/apiproxy.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/plugin/kubernetes/apiproxy.go b/plugin/kubernetes/apiproxy.go
index 097600096..a4d25879f 100644
--- a/plugin/kubernetes/apiproxy.go
+++ b/plugin/kubernetes/apiproxy.go
@@ -3,11 +3,11 @@ package kubernetes
import (
"fmt"
"io"
- "log"
"net"
"net/http"
"github.com/coredns/coredns/plugin/pkg/healthcheck"
+ "github.com/coredns/coredns/plugin/pkg/log"
)
type proxyHandler struct {
@@ -27,19 +27,19 @@ func (p *proxyHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
d, err := net.Dial(network, address)
if err != nil {
- log.Printf("[ERROR] Unable to establish connection to upstream %s://%s: %s", network, address, err)
+ log.Errorf("Unable to establish connection to upstream %s://%s: %s", network, address, err)
http.Error(w, fmt.Sprintf("Unable to establish connection to upstream %s://%s: %s", network, address, err), 500)
return
}
hj, ok := w.(http.Hijacker)
if !ok {
- log.Print("[ERROR] Unable to establish connection: no hijacker")
+ log.Error("Unable to establish connection: no hijacker")
http.Error(w, "Unable to establish connection: no hijacker", 500)
return
}
nc, _, err := hj.Hijack()
if err != nil {
- log.Printf("[ERROR] Unable to hijack connection: %s", err)
+ log.Errorf("Unable to hijack connection: %s", err)
http.Error(w, fmt.Sprintf("Unable to hijack connection: %s", err), 500)
return
}
@@ -48,7 +48,7 @@ func (p *proxyHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
err = r.Write(d)
if err != nil {
- log.Printf("[ERROR] Unable to copy connection to upstream %s://%s: %s", network, address, err)
+ log.Errorf("Unable to copy connection to upstream %s://%s: %s", network, address, err)
http.Error(w, fmt.Sprintf("Unable to copy connection to upstream %s://%s: %s", network, address, err), 500)
return
}