go/go-kit
1
0
Fork 0
mirror of https://github.com/go-kit/kit.git synced 2025-07-17 01:12:38 +02:00
Code Issues Releases Activity

transport/grpc: renamed SetClientBefore to ClientBefore to be more consistent with transport/grpc.Server

Browse Source
This commit is contained in:
Geoff Berger
2016-06-08 07:18:24 -06:00
parent 76070bff80
commit fe0aa960cb
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
examples/addsvc/client/grpc/client.go
View File

@ -39,7 +39,7 @@ func New(conn *grpc.ClientConn, tracer stdopentracing.Tracer, logger log.Logger)
addsvc.EncodeGRPCSumRequest,
addsvc.DecodeGRPCSumResponse,
pb.SumReply{},
grpctransport.SetClientBefore(opentracing.FromGRPCRequest(tracer, "Sum", logger)),
grpctransport.ClientBefore(opentracing.FromGRPCRequest(tracer, "Sum", logger)),
).Endpoint()
sumEndpoint = opentracing.TraceClient(tracer, "Sum")(sumEndpoint)
sumEndpoint = limiter(sumEndpoint)
@ -58,7 +58,7 @@ func New(conn *grpc.ClientConn, tracer stdopentracing.Tracer, logger log.Logger)
addsvc.EncodeGRPCConcatRequest,
addsvc.DecodeGRPCConcatResponse,
pb.ConcatReply{},
grpctransport.SetClientBefore(opentracing.FromGRPCRequest(tracer, "Concat", logger)),
grpctransport.ClientBefore(opentracing.FromGRPCRequest(tracer, "Concat", logger)),
).Endpoint()
concatEndpoint = opentracing.TraceClient(tracer, "Concat")(concatEndpoint)
concatEndpoint = limiter(concatEndpoint)

4
transport/grpc/client.go
View File

@ -64,9 +64,9 @@ func NewClient(
// ClientOption sets an optional parameter for clients.
type ClientOption func(*Client)
// SetClientBefore sets the RequestFuncs that are applied to the outgoing gRPC
// ClientBefore sets the RequestFuncs that are applied to the outgoing gRPC
// request before it's invoked.
func SetClientBefore(before ...RequestFunc) ClientOption {
func ClientBefore(before ...RequestFunc) ClientOption {
return func(c *Client) { c.before = before }
}