*: use grpclog.LoggerV2

Signed-off-by: Gyu-Ho Lee <gyuhox@gmail.com>
This commit is contained in:
Gyu-Ho Lee 2017-09-08 14:42:30 -07:00
parent f37ff4a4e2
commit 3b3d392540
3 changed files with 6 additions and 5 deletions

View File

@ -20,7 +20,6 @@ import (
"fmt"
"io"
"io/ioutil"
"log"
"os"
"strings"
"time"
@ -31,6 +30,7 @@ import (
"github.com/coreos/etcd/pkg/srv"
"github.com/coreos/etcd/pkg/transport"
"github.com/spf13/cobra"
"google.golang.org/grpc/grpclog"
)
// GlobalFlags are flags that defined globally
@ -97,7 +97,7 @@ func mustClientFromCmd(cmd *cobra.Command) *clientv3.Client {
ExitWithError(ExitError, derr)
}
if debug {
clientv3.SetLogger(log.New(os.Stderr, "grpc: ", 0))
clientv3.SetLogger(grpclog.NewLoggerV2(os.Stderr, os.Stderr, os.Stderr))
}
endpoints, err := endpointsFromCmd(cmd)

View File

@ -18,12 +18,12 @@ import (
"context"
"crypto/rand"
"fmt"
"log"
"os"
"strings"
"github.com/coreos/etcd/clientv3"
"github.com/coreos/etcd/pkg/report"
"google.golang.org/grpc/grpclog"
)
var (
@ -98,7 +98,7 @@ func mustCreateConn() *clientv3.Client {
return mustCreateConn()
}
clientv3.SetLogger(log.New(os.Stderr, "grpc", 0))
clientv3.SetLogger(grpclog.NewLoggerV2(os.Stderr, os.Stderr, os.Stderr))
if err != nil {
fmt.Fprintf(os.Stderr, "dial error: %v\n", err)

View File

@ -16,6 +16,7 @@ package main
import (
"fmt"
"os"
"strings"
"sync"
"time"
@ -24,7 +25,7 @@ import (
"google.golang.org/grpc/grpclog"
)
func init() { grpclog.SetLogger(plog) }
func init() { grpclog.SetLoggerV2(grpclog.NewLoggerV2(os.Stderr, os.Stderr, os.Stderr)) }
type Stresser interface {
// Stress starts to stress the etcd cluster