1 package test
2
3 import (
4 "context"
5
6 "github.com/go-kit/kit/transport/grpc/_grpc_test/pb"
7 )
8
9 func encodeRequest(ctx context.Context, req interface{}) (interface{}, error) {
10 r := req.(TestRequest)
11 return &pb.TestRequest{A: r.A, B: r.B}, nil
12 }
13
14 func decodeRequest(ctx context.Context, req interface{}) (interface{}, error) {
15 r := req.(*pb.TestRequest)
16 return TestRequest{A: r.A, B: r.B}, nil
17 }
18
19 func encodeResponse(ctx context.Context, resp interface{}) (interface{}, error) {
20 r := resp.(*TestResponse)
21 return &pb.TestResponse{V: r.V}, nil
22 }
23
24 func decodeResponse(ctx context.Context, resp interface{}) (interface{}, error) {
25 r := resp.(*pb.TestResponse)
26 return &TestResponse{V: r.V, Ctx: ctx}, nil
27 }
28
View as plain text