astelm
/
grpcurl
mirror of https://github.com/fullstorydev/grpcurl.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

grpclog.Printf deprecated; use Info instead

This commit is contained in:
Josh Humphries 2018-05-08 10:08:35 -04:00
parent ca5693f42c
commit e6ac789274
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
cmd/testserver/testserver.go
View File

@ -111,7 +111,7 @@ var id int32
func unaryLogger(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) { func unaryLogger(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error) {
i := atomic.AddInt32(&id, 1) - 1 i := atomic.AddInt32(&id, 1) - 1
grpclog.Printf("start <%d>: %s\n", i, info.FullMethod) grpclog.Infof("start <%d>: %s\n", i, info.FullMethod)
start := time.Now() start := time.Now()
rsp, err := handler(ctx, req) rsp, err := handler(ctx, req)
var code codes.Code var code codes.Code
@ -120,14 +120,14 @@ func unaryLogger(ctx context.Context, req interface{}, info *grpc.UnaryServerInf
} else { } else {
code = codes.Unknown code = codes.Unknown
} }
grpclog.Printf("completed <%d>: %v (%d) %v\n", i, code, code, time.Now().Sub(start)) grpclog.Infof("completed <%d>: %v (%d) %v\n", i, code, code, time.Now().Sub(start))
return rsp, err return rsp, err
} }
func streamLogger(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error { func streamLogger(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error {
i := atomic.AddInt32(&id, 1) - 1 i := atomic.AddInt32(&id, 1) - 1
start := time.Now() start := time.Now()
grpclog.Printf("start <%d>: %s\n", i, info.FullMethod) grpclog.Infof("start <%d>: %s\n", i, info.FullMethod)
err := handler(srv, loggingStream{ss: ss, id: i}) err := handler(srv, loggingStream{ss: ss, id: i})
var code codes.Code var code codes.Code
if stat, ok := status.FromError(err); ok { if stat, ok := status.FromError(err); ok {
@ -135,7 +135,7 @@ func streamLogger(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServer
} else { } else {
code = codes.Unknown code = codes.Unknown
} }
grpclog.Printf("completed <%d>: %v(%d) %v\n", i, code, code, time.Now().Sub(start)) grpclog.Infof("completed <%d>: %v(%d) %v\n", i, code, code, time.Now().Sub(start))
return err return err
} }
@ -163,7 +163,7 @@ func (l loggingStream) Context() context.Context {
func (l loggingStream) SendMsg(m interface{}) error { func (l loggingStream) SendMsg(m interface{}) error {
err := l.ss.SendMsg(m) err := l.ss.SendMsg(m)
if err == nil { if err == nil {
grpclog.Printf("stream <%d>: sent message\n", l.id) grpclog.Infof("stream <%d>: sent message\n", l.id)
} }
return err return err
} }
@ -171,7 +171,7 @@ func (l loggingStream) SendMsg(m interface{}) error {
func (l loggingStream) RecvMsg(m interface{}) error { func (l loggingStream) RecvMsg(m interface{}) error {
err := l.ss.RecvMsg(m) err := l.ss.RecvMsg(m)
if err == nil { if err == nil {
grpclog.Printf("stream <%d>: received message\n", l.id) grpclog.Infof("stream <%d>: received message\n", l.id)
} }
return err return err
} }