Codebase list golang-github-go-kit-kit / 72334e1
Minor cleanup to addsvc/client/grpc Peter Bourgon 8 years ago
1 changed file(s) with 24 addition(s) and 31 deletion(s). Raw diff Collapse all Expand all
+24
-31
examples/addsvc/client/grpc/encode_decode.go less more
00 package grpc
11
22 import (
3 "golang.org/x/net/context"
4
35 "github.com/go-kit/kit/examples/addsvc/pb"
46 "github.com/go-kit/kit/examples/addsvc/server"
5 "golang.org/x/net/context"
67 )
78
8 func encodeSumRequest(ctx context.Context, req interface{}) (interface{}, error) {
9 sumRequest := req.(server.SumRequest)
10
11 pbRequest := &pb.SumRequest{
12 A: int64(sumRequest.A),
13 B: int64(sumRequest.B),
14 }
15 return pbRequest, nil
9 func encodeSumRequest(ctx context.Context, request interface{}) (interface{}, error) {
10 req := request.(server.SumRequest)
11 return &pb.SumRequest{
12 A: int64(req.A),
13 B: int64(req.B),
14 }, nil
1615 }
1716
18 func encodeConcatRequest(ctx context.Context, req interface{}) (interface{}, error) {
19 concatRequest := req.(server.ConcatRequest)
20
21 pbRequest := &pb.ConcatRequest{
22 A: concatRequest.A,
23 B: concatRequest.B,
24 }
25 return pbRequest, nil
17 func encodeConcatRequest(ctx context.Context, request interface{}) (interface{}, error) {
18 req := request.(server.ConcatRequest)
19 return &pb.ConcatRequest{
20 A: req.A,
21 B: req.B,
22 }, nil
2623 }
2724
28 func decodeSumResponse(ctx context.Context, resp interface{}) (interface{}, error) {
29 pbResponse := resp.(pb.SumReply)
30
31 sumResponse := &server.SumResponse{
32 V: int(pbResponse.V),
33 }
34 return sumResponse, nil
25 func decodeSumResponse(ctx context.Context, response interface{}) (interface{}, error) {
26 resp := response.(pb.SumReply)
27 return &server.SumResponse{
28 V: int(resp.V),
29 }, nil
3530 }
3631
37 func decodeConcatResponse(ctx context.Context, resp interface{}) (interface{}, error) {
38 pbResponse := resp.(pb.ConcatReply)
39
40 concatResponse := &server.ConcatResponse{
41 V: pbResponse.V,
42 }
43 return concatResponse, nil
32 func decodeConcatResponse(ctx context.Context, response interface{}) (interface{}, error) {
33 resp := response.(pb.ConcatReply)
34 return &server.ConcatResponse{
35 V: resp.V,
36 }, nil
4437 }