diff --git a/go.mod b/go.mod index b462c1c..9e05dab 100644 --- a/go.mod +++ b/go.mod @@ -1,9 +1,16 @@ module go.unistack.org/micro-server-http/v3 -go 1.16 +go 1.18 require ( + go.unistack.org/micro-proto/v3 v3.3.1 go.unistack.org/micro/v3 v3.10.13 golang.org/x/net v0.7.0 +) + +require ( + github.com/golang/protobuf v1.5.2 // indirect + github.com/google/gnostic v0.6.9 // indirect + google.golang.org/protobuf v1.28.1 // indirect gopkg.in/yaml.v3 v3.0.1 // indirect ) diff --git a/go.sum b/go.sum index 3fe3a8b..0c4cb96 100644 --- a/go.sum +++ b/go.sum @@ -71,7 +71,6 @@ github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5 github.com/xeipuuv/gojsonpointer v0.0.0-20180127040702-4e3ac2762d5f/go.mod h1:N2zxlSyiKSe5eX1tZViRH5QA0qijqEDrYZiPEAiq3wU= github.com/xeipuuv/gojsonreference v0.0.0-20180127040603-bd5ef7bd5415/go.mod h1:GwrjFmJcFw6At/Gs6z4yjiIwzuJ1/+UwLxMQDVQXShQ= github.com/xeipuuv/gojsonschema v1.2.0/go.mod h1:anYRn/JVcOK2ZgGU+IjEV4nwlhoK5sQluxsYJ78Id3Y= -github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY= go.opentelemetry.io/proto/otlp v0.7.0/go.mod h1:PqfVotwruBrMGOCsRd/89rSnXhoiJIqeYNgFYFoEGnI= go.unistack.org/micro-proto/v3 v3.3.1 h1:nQ0MtWvP2G3QrpOgawVOPhpZZYkq6umTGDqs8FxJYIo= go.unistack.org/micro-proto/v3 v3.3.1/go.mod h1:cwRyv8uInM2I7EbU7O8Fx2Ls3N90Uw9UCCcq4olOdfE= @@ -79,24 +78,19 @@ go.unistack.org/micro/v3 v3.10.13 h1:GtQwCXvOw3ywwgNKRPE/NA7hNoHnVIvFElDjjfy5Xtc go.unistack.org/micro/v3 v3.10.13/go.mod h1:gI4RkJKHLPW7KV6h4+ZBOZD997MRvFRXMPQIHpozikI= golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= -golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA= golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE= golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU= golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc= -golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4= golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20190108225652-1e06a53dbb7e/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg= golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg= -golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= golang.org/x/net v0.0.0-20200822124328-c89045814202/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA= -golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= golang.org/x/net v0.0.0-20210405180319-a5a99cb37ef4/go.mod h1:p54w0d4576C0XHj96bSt6lcn1PtDYWL6XObtHCRCNQM= golang.org/x/net v0.0.0-20210805182204-aaa1db679c0d/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= -golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c= golang.org/x/net v0.7.0 h1:rJrUqqhjsgNp7KqAIc25s9pZnjU7TUcSY7HcVZjdn1g= golang.org/x/net v0.7.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs= golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U= @@ -105,7 +99,6 @@ golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJ golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= -golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= @@ -114,27 +107,16 @@ golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7w golang.org/x/sys v0.0.0-20210330210617-4fbd30eecc44/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210510120138-977fb7262007/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= -golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8= -golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k= golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= golang.org/x/text v0.3.5/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= -golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= -golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY= golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs= golang.org/x/tools v0.0.0-20190524140312-2c0ae7006135/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q= -golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= -golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc= -golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 h1:go1bK/D/BFZV2I8cIQd1NKEZ+0owSTG1fDTci4IqFcE= golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= diff --git a/handler/health/generate.go b/handler/health/generate.go new file mode 100644 index 0000000..c783863 --- /dev/null +++ b/handler/health/generate.go @@ -0,0 +1,8 @@ +package health + +//go:generate sh -c "protoc -I./ -I$(go list -f '{{ .Dir }}' -m go.unistack.org/micro-proto/v3) --go-micro_out='components=micro|http|server',standalone=false,debug=true,paths=source_relative:./ health.proto" + +import ( + // import required packages + _ "go.unistack.org/micro-proto/v3/openapiv3" +) diff --git a/handler/health/health.go b/handler/health/health.go new file mode 100644 index 0000000..4399cf3 --- /dev/null +++ b/handler/health/health.go @@ -0,0 +1,82 @@ +package health // import "go.unistack.org/micro-server-http/v3/handler/health" + +import ( + "context" + + codecpb "go.unistack.org/micro-proto/v3/codec" + "go.unistack.org/micro/v3/errors" +) + +var _ HealthServiceServer = &Handler{} + +type Handler struct { + opts Options +} + +type CheckFunc func(context.Context) error + +type Option func(*Options) + +type Options struct { + Version string + Name string + LiveChecks []CheckFunc + ReadyChecks []CheckFunc +} + +func LiveChecks(fns ...CheckFunc) Option { + return func(o *Options) { + o.LiveChecks = append(o.LiveChecks, fns...) + } +} + +func ReadyChecks(fns ...CheckFunc) Option { + return func(o *Options) { + o.ReadyChecks = append(o.ReadyChecks, fns...) + } +} + +func Name(name string) Option { + return func(o *Options) { + o.Name = name + } +} + +func Version(version string) Option { + return func(o *Options) { + o.Version = version + } +} + +func NewHandler(opts ...Option) *Handler { + options := Options{} + for _, o := range opts { + o(&options) + } + return &Handler{opts: options} +} + +func (h *Handler) Live(ctx context.Context, req *codecpb.Frame, rsp *codecpb.Frame) error { + var err error + for _, fn := range h.opts.LiveChecks { + if err = fn(ctx); err != nil { + return errors.ServiceUnavailable(h.opts.Name, "%v", err) + } + } + return nil +} + +func (h *Handler) Ready(ctx context.Context, req *codecpb.Frame, rsp *codecpb.Frame) error { + var err error + for _, fn := range h.opts.ReadyChecks { + if err = fn(ctx); err != nil { + return errors.ServiceUnavailable(h.opts.Name, "%v", err) + } + } + return nil +} + +func (h *Handler) Version(ctx context.Context, req *codecpb.Frame, rsp *codecpb.Frame) error { + rsp.Data = []byte(h.opts.Version) + return nil +} diff --git a/handler/health/health.proto b/handler/health/health.proto new file mode 100644 index 0000000..1795501 --- /dev/null +++ b/handler/health/health.proto @@ -0,0 +1,50 @@ +syntax = "proto3"; + +package micro.server.http.v3.handler.health; +option go_package = "go.unistack.org/micro-server-http/v3/handler/health;health"; + +import "api/annotations.proto"; +import "openapiv3/annotations.proto"; +import "codec/frame.proto"; + +service HealthService { + rpc Live(micro.codec.Frame) returns (micro.codec.Frame) { + option (micro.openapiv3.openapiv3_operation) = { + operation_id: "Live"; + responses: { + default: { + reference: { + _ref: "micro.codec.Frame"; + }; + }; + }; + }; + option (micro.api.http) = { get: "/live"; }; + }; + rpc Ready(micro.codec.Frame) returns (micro.codec.Frame) { + option (micro.openapiv3.openapiv3_operation) = { + operation_id: "Ready"; + responses: { + default: { + reference: { + _ref: "micro.codec.Frame"; + }; + }; + }; + }; + option (micro.api.http) = { get: "/ready"; }; + }; + rpc Version(micro.codec.Frame) returns (micro.codec.Frame) { + option (micro.openapiv3.openapiv3_operation) = { + operation_id: "Version"; + responses: { + default: { + reference: { + _ref: "micro.codec.Frame"; + }; + }; + }; + }; + option (micro.api.http) = { get: "/version"; }; + }; +}; diff --git a/handler/health/health_micro.pb.go b/handler/health/health_micro.pb.go new file mode 100644 index 0000000..3e6f6a0 --- /dev/null +++ b/handler/health/health_micro.pb.go @@ -0,0 +1,48 @@ +// Code generated by protoc-gen-go-micro. DO NOT EDIT. +// versions: +// - protoc-gen-go-micro v3.10.2 +// - protoc v3.21.12 +// source: health.proto + +package health + +import ( + context "context" + codec "go.unistack.org/micro-proto/v3/codec" + v3 "go.unistack.org/micro-server-http/v3" +) + +var ( + HealthServiceName = "HealthService" +) +var ( + HealthServiceServerEndpoints = []v3.EndpointMetadata{ + { + Name: "HealthService.Live", + Path: "/live", + Method: "GET", + Body: "", + Stream: false, + }, + { + Name: "HealthService.Ready", + Path: "/ready", + Method: "GET", + Body: "", + Stream: false, + }, + { + Name: "HealthService.Version", + Path: "/version", + Method: "GET", + Body: "", + Stream: false, + }, + } +) + +type HealthServiceServer interface { + Live(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error + Ready(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error + Version(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error +} diff --git a/handler/health/health_micro_http.pb.go b/handler/health/health_micro_http.pb.go new file mode 100644 index 0000000..0e3c6e7 --- /dev/null +++ b/handler/health/health_micro_http.pb.go @@ -0,0 +1,43 @@ +// Code generated by protoc-gen-go-micro. DO NOT EDIT. +// protoc-gen-go-micro version: v3.10.2 +// source: health.proto + +package health + +import ( + context "context" + codec "go.unistack.org/micro-proto/v3/codec" + v3 "go.unistack.org/micro-server-http/v3" + server "go.unistack.org/micro/v3/server" +) + +type healthServiceServer struct { + HealthServiceServer +} + +func (h *healthServiceServer) Live(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error { + return h.HealthServiceServer.Live(ctx, req, rsp) +} + +func (h *healthServiceServer) Ready(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error { + return h.HealthServiceServer.Ready(ctx, req, rsp) +} + +func (h *healthServiceServer) Version(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error { + return h.HealthServiceServer.Version(ctx, req, rsp) +} + +func RegisterHealthServiceServer(s server.Server, sh HealthServiceServer, opts ...server.HandlerOption) error { + type healthService interface { + Live(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error + Ready(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error + Version(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error + } + type HealthService struct { + healthService + } + h := &healthServiceServer{sh} + var nopts []server.HandlerOption + nopts = append(nopts, v3.HandlerEndpoints(HealthServiceServerEndpoints)) + return s.Handle(s.NewHandler(&HealthService{h}, append(nopts, opts...)...)) +} diff --git a/handler/meter/generate.go b/handler/meter/generate.go new file mode 100644 index 0000000..1605764 --- /dev/null +++ b/handler/meter/generate.go @@ -0,0 +1,8 @@ +package meter + +//go:generate sh -c "protoc -I./ -I$(go list -f '{{ .Dir }}' -m go.unistack.org/micro-proto/v3) --go-micro_out='components=micro|http|server',standalone=false,debug=true,paths=source_relative:./ meter.proto" + +import ( + // import required packages + _ "go.unistack.org/micro-proto/v3/openapiv3" +) diff --git a/handler/meter/meter.go b/handler/meter/meter.go new file mode 100644 index 0000000..f92830e --- /dev/null +++ b/handler/meter/meter.go @@ -0,0 +1,67 @@ +package meter // import "go.unistack.org/micro-server-http/v3/handler/meter" + +import ( + "bytes" + "context" + + codecpb "go.unistack.org/micro-proto/v3/codec" + "go.unistack.org/micro/v3/errors" + "go.unistack.org/micro/v3/meter" +) + +// guard to fail early +var _ MeterServiceServer = &Handler{} + +type Handler struct { + opts Options +} + +type Option func(*Options) + +type Options struct { + Meter meter.Meter + Name string + MeterOptions []meter.Option +} + +func Meter(m meter.Meter) Option { + return func(o *Options) { + o.Meter = m + } +} + +func Name(name string) Option { + return func(o *Options) { + o.Name = name + } +} + +func MeterOptions(opts ...meter.Option) Option { + return func(o *Options) { + o.MeterOptions = append(o.MeterOptions, opts...) + } +} + +func NewOptions(opts ...Option) Options { + options := Options{Meter: meter.DefaultMeter} + for _, o := range opts { + o(&options) + } + return options +} + +func NewHandler(opts ...Option) *Handler { + options := NewOptions(opts...) + return &Handler{opts: options} +} + +func (h *Handler) Metrics(ctx context.Context, req *codecpb.Frame, rsp *codecpb.Frame) error { + buf := bytes.NewBuffer(nil) + if err := h.opts.Meter.Write(buf, h.opts.MeterOptions...); err != nil { + return errors.InternalServerError(h.opts.Name, "%v", err) + } + + rsp.Data = buf.Bytes() + + return nil +} diff --git a/handler/meter/meter.proto b/handler/meter/meter.proto new file mode 100644 index 0000000..7fc653e --- /dev/null +++ b/handler/meter/meter.proto @@ -0,0 +1,24 @@ +syntax = "proto3"; + +package micro.server.http.v3.handler.meter; +option go_package = "go.unistack.org/micro-server-http/v3/handler/meter;meter"; + +import "api/annotations.proto"; +import "openapiv3/annotations.proto"; +import "codec/frame.proto"; + +service MeterService { + rpc Metrics(micro.codec.Frame) returns (micro.codec.Frame) { + option (micro.openapiv3.openapiv3_operation) = { + operation_id: "Metrics"; + responses: { + default: { + reference: { + _ref: "micro.codec.Frame"; + }; + }; + }; + }; + option (micro.api.http) = { get: "/metrics"; }; + }; +}; diff --git a/handler/meter/meter_micro.pb.go b/handler/meter/meter_micro.pb.go new file mode 100644 index 0000000..d9ba8aa --- /dev/null +++ b/handler/meter/meter_micro.pb.go @@ -0,0 +1,32 @@ +// Code generated by protoc-gen-go-micro. DO NOT EDIT. +// versions: +// - protoc-gen-go-micro v3.10.2 +// - protoc v3.21.12 +// source: meter.proto + +package meter + +import ( + context "context" + codec "go.unistack.org/micro-proto/v3/codec" + v3 "go.unistack.org/micro-server-http/v3" +) + +var ( + MeterServiceName = "MeterService" +) +var ( + MeterServiceServerEndpoints = []v3.EndpointMetadata{ + { + Name: "MeterService.Metrics", + Path: "/metrics", + Method: "GET", + Body: "", + Stream: false, + }, + } +) + +type MeterServiceServer interface { + Metrics(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error +} diff --git a/handler/meter/meter_micro_http.pb.go b/handler/meter/meter_micro_http.pb.go new file mode 100644 index 0000000..e79500a --- /dev/null +++ b/handler/meter/meter_micro_http.pb.go @@ -0,0 +1,33 @@ +// Code generated by protoc-gen-go-micro. DO NOT EDIT. +// protoc-gen-go-micro version: v3.10.2 +// source: meter.proto + +package meter + +import ( + context "context" + codec "go.unistack.org/micro-proto/v3/codec" + v3 "go.unistack.org/micro-server-http/v3" + server "go.unistack.org/micro/v3/server" +) + +type meterServiceServer struct { + MeterServiceServer +} + +func (h *meterServiceServer) Metrics(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error { + return h.MeterServiceServer.Metrics(ctx, req, rsp) +} + +func RegisterMeterServiceServer(s server.Server, sh MeterServiceServer, opts ...server.HandlerOption) error { + type meterService interface { + Metrics(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error + } + type MeterService struct { + meterService + } + h := &meterServiceServer{sh} + var nopts []server.HandlerOption + nopts = append(nopts, v3.HandlerEndpoints(MeterServiceServerEndpoints)) + return s.Handle(s.NewHandler(&MeterService{h}, append(nopts, opts...)...)) +}