diff options
Diffstat (limited to 'plugin/proxy/grpc.go')
| -rw-r--r-- | plugin/proxy/grpc.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/plugin/proxy/grpc.go b/plugin/proxy/grpc.go index 2844a1c71..334cd5264 100644 --- a/plugin/proxy/grpc.go +++ b/plugin/proxy/grpc.go @@ -3,9 +3,9 @@ package proxy import ( "crypto/tls" "fmt" - "log" "github.com/coredns/coredns/pb" + "github.com/coredns/coredns/plugin/pkg/log" "github.com/coredns/coredns/plugin/pkg/trace" "github.com/coredns/coredns/request" @@ -67,7 +67,7 @@ func (g *grpcClient) OnShutdown(p *Proxy) error { for i, conn := range g.conns { err := conn.Close() if err != nil { - log.Printf("[WARNING] Error closing connection %d: %s\n", i, err) + log.Warningf("Error closing connection %d: %s\n", i, err) } } g.conns = []*grpc.ClientConn{} @@ -84,13 +84,13 @@ func (g *grpcClient) OnStartup(p *Proxy) error { intercept := otgrpc.OpenTracingClientInterceptor(t.Tracer(), otgrpc.IncludingSpans(onlyIfParent)) dialOpts = append(dialOpts, grpc.WithUnaryInterceptor(intercept)) } else { - log.Printf("[WARNING] Wrong type for trace plugin reference: %s", p.Trace) + log.Warningf("Wrong type for trace plugin reference: %s", p.Trace) } } for _, host := range g.upstream.Hosts { conn, err := grpc.Dial(host.Name, dialOpts...) if err != nil { - log.Printf("[WARNING] Skipping gRPC host '%s' due to Dial error: %s\n", host.Name, err) + log.Warningf("Skipping gRPC host '%s' due to Dial error: %s\n", host.Name, err) } else { g.clients[host.Name] = pb.NewDnsServiceClient(conn) g.conns = append(g.conns, conn) |