/
service_gen.go
44 lines (42 loc) · 2.6 KB
/
service_gen.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
// THIS FILE IS AUTO GENERATED BY GK-CLI DO NOT EDIT!!
package service
import (
endpoint1 "github.com/go-kit/kit/endpoint"
log "github.com/go-kit/kit/log"
prometheus "github.com/go-kit/kit/metrics/prometheus"
opentracing "github.com/go-kit/kit/tracing/opentracing"
http "github.com/go-kit/kit/transport/http"
endpoint "github.com/money-hub/MoneyDodo.service/authentication/pkg/endpoint"
service "github.com/money-hub/MoneyDodo.service/authentication/pkg/service"
group "github.com/oklog/oklog/pkg/group"
opentracinggo "github.com/opentracing/opentracing-go"
)
func createService(endpoints endpoint.Endpoints) (g *group.Group) {
g = &group.Group{}
initHttpHandler(endpoints, g)
return g
}
func defaultHttpOptions(logger log.Logger, tracer opentracinggo.Tracer) map[string][]http.ServerOption {
options := map[string][]http.ServerOption{
"AdminLogin": {http.ServerErrorLogger(logger), http.ServerBefore(opentracing.HTTPToContext(tracer, "AdminLogin", logger))},
"EnterpriseLogin": {http.ServerErrorLogger(logger), http.ServerBefore(opentracing.HTTPToContext(tracer, "EnterpriseLogin", logger))},
"GetOpenid": {http.ServerErrorLogger(logger), http.ServerBefore(opentracing.HTTPToContext(tracer, "GetOpenid", logger))},
"Logout": {http.ServerErrorLogger(logger), http.ServerBefore(opentracing.HTTPToContext(tracer, "Logout", logger))},
}
return options
}
func addDefaultEndpointMiddleware(logger log.Logger, duration *prometheus.Summary, mw map[string][]endpoint1.Middleware) {
mw["GetOpenid"] = []endpoint1.Middleware{endpoint.LoggingMiddleware(log.With(logger, "method", "GetOpenid")), endpoint.InstrumentingMiddleware(duration.With("method", "GetOpenid"))}
mw["AdminLogin"] = []endpoint1.Middleware{endpoint.LoggingMiddleware(log.With(logger, "method", "AdminLogin")), endpoint.InstrumentingMiddleware(duration.With("method", "AdminLogin"))}
mw["EnterpriseLogin"] = []endpoint1.Middleware{endpoint.LoggingMiddleware(log.With(logger, "method", "EnterpriseLogin")), endpoint.InstrumentingMiddleware(duration.With("method", "EnterpriseLogin"))}
mw["Logout"] = []endpoint1.Middleware{endpoint.LoggingMiddleware(log.With(logger, "method", "Logout")), endpoint.InstrumentingMiddleware(duration.With("method", "Logout"))}
}
func addDefaultServiceMiddleware(logger log.Logger, mw []service.Middleware) []service.Middleware {
return append(mw, service.LoggingMiddleware(logger))
}
func addEndpointMiddlewareToAllMethods(mw map[string][]endpoint1.Middleware, m endpoint1.Middleware) {
methods := []string{"GetOpenid", "AdminLogin", "EnterpriseLogin", "Logout"}
for _, v := range methods {
mw[v] = append(mw[v], m)
}
}