Commit 34e8d901c7c47e10984bc1069950e0700716f709 - golang-github-go-kit-kit

examples/addsvc: use improved FooToBar syntax Peter Bourgon 6 years ago

2 changed file(s) with 8 addition(s) and 8 deletion(s). Raw diff Collapse all Expand all

-4

examples/addsvc/pkg/addtransport/grpc.go less more

38	38	endpoints.SumEndpoint,
39	39	decodeGRPCSumRequest,
40	40	encodeGRPCSumResponse,
41		append(options, grpctransport.ServerBefore(opentracing.FromGRPCRequest(tracer, "Sum", logger)))...,
	41	append(options, grpctransport.ServerBefore(opentracing.GRPCToContext(tracer, "Sum", logger)))...,
42	42	),
43	43	concat: grpctransport.NewServer(
44	44	endpoints.ConcatEndpoint,
45	45	decodeGRPCConcatRequest,
46	46	encodeGRPCConcatResponse,
47		append(options, grpctransport.ServerBefore(opentracing.FromGRPCRequest(tracer, "Concat", logger)))...,
	47	append(options, grpctransport.ServerBefore(opentracing.GRPCToContext(tracer, "Concat", logger)))...,
48	48	),
49	49	}
50	50	}

90	90	encodeGRPCSumRequest,
91	91	decodeGRPCSumResponse,
92	92	pb.SumReply{},
93		grpctransport.ClientBefore(opentracing.ToGRPCRequest(tracer, logger)),
	93	grpctransport.ClientBefore(opentracing.ContextToGRPC(tracer, logger)),
94	94	).Endpoint()
95	95	sumEndpoint = opentracing.TraceClient(tracer, "Sum")(sumEndpoint)
96	96	sumEndpoint = limiter(sumEndpoint)

111	111	encodeGRPCConcatRequest,
112	112	decodeGRPCConcatResponse,
113	113	pb.ConcatReply{},
114		grpctransport.ClientBefore(opentracing.ToGRPCRequest(tracer, logger)),
	114	grpctransport.ClientBefore(opentracing.ContextToGRPC(tracer, logger)),
115	115	).Endpoint()
116	116	concatEndpoint = opentracing.TraceClient(tracer, "Concat")(concatEndpoint)
117	117	concatEndpoint = limiter(concatEndpoint)

-4

examples/addsvc/pkg/addtransport/http.go less more

37	37	endpoints.SumEndpoint,
38	38	decodeHTTPSumRequest,
39	39	encodeHTTPGenericResponse,
40		append(options, httptransport.ServerBefore(opentracing.FromHTTPRequest(tracer, "Sum", logger)))...,
	40	append(options, httptransport.ServerBefore(opentracing.HTTPToContext(tracer, "Sum", logger)))...,
41	41	))
42	42	m.Handle("/concat", httptransport.NewServer(
43	43	endpoints.ConcatEndpoint,
44	44	decodeHTTPConcatRequest,
45	45	encodeHTTPGenericResponse,
46		append(options, httptransport.ServerBefore(opentracing.FromHTTPRequest(tracer, "Concat", logger)))...,
	46	append(options, httptransport.ServerBefore(opentracing.HTTPToContext(tracer, "Concat", logger)))...,
47	47	))
48	48	return m
49	49	}

80	80	copyURL(u, "/sum"),
81	81	encodeHTTPGenericRequest,
82	82	decodeHTTPSumResponse,
83		httptransport.ClientBefore(opentracing.ToHTTPRequest(tracer, logger)),
	83	httptransport.ClientBefore(opentracing.ContextToHTTP(tracer, logger)),
84	84	).Endpoint()
85	85	sumEndpoint = opentracing.TraceClient(tracer, "Sum")(sumEndpoint)
86	86	sumEndpoint = limiter(sumEndpoint)

99	99	copyURL(u, "/concat"),
100	100	encodeHTTPGenericRequest,
101	101	decodeHTTPConcatResponse,
102		httptransport.ClientBefore(opentracing.ToHTTPRequest(tracer, logger)),
	102	httptransport.ClientBefore(opentracing.ContextToHTTP(tracer, logger)),
103	103	).Endpoint()
104	104	concatEndpoint = opentracing.TraceClient(tracer, "Concat")(concatEndpoint)
105	105	concatEndpoint = limiter(concatEndpoint)