forked from devimteam/microgen
/
server.microgen.go
42 lines (36 loc) · 1.32 KB
/
server.microgen.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
// Code generated by microgen 0.9.0. DO NOT EDIT.
package transport
import (
"context"
addsvc "github.com/devimteam/microgen/examples/addsvc/addsvc"
endpoint "github.com/go-kit/kit/endpoint"
opentracing "github.com/go-kit/kit/tracing/opentracing"
opentracinggo "github.com/opentracing/opentracing-go"
)
func Endpoints(svc addsvc.Service) EndpointsSet {
return EndpointsSet{
ConcatEndpoint: ConcatEndpoint(svc),
SumEndpoint: SumEndpoint(svc),
}
}
// TraceServerEndpoints is used for tracing endpoints on server side.
func TraceServerEndpoints(endpoints EndpointsSet, tracer opentracinggo.Tracer) EndpointsSet {
return EndpointsSet{
ConcatEndpoint: opentracing.TraceServer(tracer, "Concat")(endpoints.ConcatEndpoint),
SumEndpoint: opentracing.TraceServer(tracer, "Sum")(endpoints.SumEndpoint),
}
}
func SumEndpoint(svc addsvc.Service) endpoint.Endpoint {
return func(arg0 context.Context, request interface{}) (interface{}, error) {
req := request.(*SumRequest)
res0, res1 := svc.Sum(arg0, req.A, req.B)
return &SumResponse{Result: res0}, res1
}
}
func ConcatEndpoint(svc addsvc.Service) endpoint.Endpoint {
return func(arg0 context.Context, request interface{}) (interface{}, error) {
req := request.(*ConcatRequest)
res0, res1 := svc.Concat(arg0, req.A, req.B)
return &ConcatResponse{Result: res0}, res1
}
}