forked from devimteam/microgen
/
server.microgen.go
67 lines (64 loc) · 2.41 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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
// Code generated by microgen 0.9.0. DO NOT EDIT.
package transporthttp
import (
transport "github.com/devimteam/microgen/examples/usersvc/pkg/transport"
log "github.com/go-kit/kit/log"
opentracing "github.com/go-kit/kit/tracing/opentracing"
http "github.com/go-kit/kit/transport/http"
mux "github.com/gorilla/mux"
opentracinggo "github.com/opentracing/opentracing-go"
http1 "net/http"
)
func NewHTTPHandler(endpoints *transport.EndpointsSet, logger log.Logger, tracer opentracinggo.Tracer, opts ...http.ServerOption) http1.Handler {
mux := mux.NewRouter()
mux.Methods("POST").Path("/create-user").Handler(
http.NewServer(
endpoints.CreateUserEndpoint,
_Decode_CreateUser_Request,
_Encode_CreateUser_Response,
append(opts, http.ServerBefore(
opentracing.HTTPToContext(tracer, "CreateUser", logger)))...))
mux.Methods("POST").Path("/update-user").Handler(
http.NewServer(
endpoints.UpdateUserEndpoint,
_Decode_UpdateUser_Request,
_Encode_UpdateUser_Response,
append(opts, http.ServerBefore(
opentracing.HTTPToContext(tracer, "UpdateUser", logger)))...))
mux.Methods("POST").Path("/get-user").Handler(
http.NewServer(
endpoints.GetUserEndpoint,
_Decode_GetUser_Request,
_Encode_GetUser_Response,
append(opts, http.ServerBefore(
opentracing.HTTPToContext(tracer, "GetUser", logger)))...))
mux.Methods("POST").Path("/find-users").Handler(
http.NewServer(
endpoints.FindUsersEndpoint,
_Decode_FindUsers_Request,
_Encode_FindUsers_Response,
append(opts, http.ServerBefore(
opentracing.HTTPToContext(tracer, "FindUsers", logger)))...))
mux.Methods("POST").Path("/create-comment").Handler(
http.NewServer(
endpoints.CreateCommentEndpoint,
_Decode_CreateComment_Request,
_Encode_CreateComment_Response,
append(opts, http.ServerBefore(
opentracing.HTTPToContext(tracer, "CreateComment", logger)))...))
mux.Methods("POST").Path("/get-comment").Handler(
http.NewServer(
endpoints.GetCommentEndpoint,
_Decode_GetComment_Request,
_Encode_GetComment_Response,
append(opts, http.ServerBefore(
opentracing.HTTPToContext(tracer, "GetComment", logger)))...))
mux.Methods("POST").Path("/get-user-comments").Handler(
http.NewServer(
endpoints.GetUserCommentsEndpoint,
_Decode_GetUserComments_Request,
_Encode_GetUserComments_Response,
append(opts, http.ServerBefore(
opentracing.HTTPToContext(tracer, "GetUserComments", logger)))...))
return mux
}