| @@ -1,7 +1,7 @@ | |||||||
| syntax = "proto3"; | syntax = "proto3"; | ||||||
|  |  | ||||||
| package micro.server.http.v3.handler.health; | package micro.server.http.v3.handler.health; | ||||||
| option go_package = "go.unistack.org/micro-server-http/v3/handler/health;health"; | option go_package = "go.unistack.org/micro-server-http/v3/handler/health;health_handler"; | ||||||
|  |  | ||||||
| import "api/annotations.proto"; | import "api/annotations.proto"; | ||||||
| import "openapiv3/annotations.proto"; | import "openapiv3/annotations.proto"; | ||||||
|   | |||||||
| @@ -1,45 +1,26 @@ | |||||||
| // Code generated by protoc-gen-go-micro. DO NOT EDIT. | // Code generated by protoc-gen-go-micro. DO NOT EDIT. | ||||||
| // versions: | // versions: | ||||||
| // - protoc-gen-go-micro v3.10.2 | // - protoc-gen-go-micro v3.10.4 | ||||||
| // - protoc              v3.21.12 | // - protoc              v5.26.1 | ||||||
| // source: health.proto | // source: health/health.proto | ||||||
|  |  | ||||||
| package health | package health_handler | ||||||
|  |  | ||||||
| import ( | import ( | ||||||
| 	context "context" | 	context "context" | ||||||
| 	codec "go.unistack.org/micro-proto/v3/codec" | 	codec "go.unistack.org/micro-proto/v3/codec" | ||||||
| 	v3 "go.unistack.org/micro-server-http/v3" | 	client "go.unistack.org/micro/v3/client" | ||||||
| ) | ) | ||||||
|  |  | ||||||
| var ( | var ( | ||||||
| 	HealthServiceName = "HealthService" | 	HealthServiceName = "HealthService" | ||||||
| ) | ) | ||||||
| var ( |  | ||||||
| 	HealthServiceServerEndpoints = []v3.EndpointMetadata{ | type HealthServiceClient interface { | ||||||
| 		{ | 	Live(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error) | ||||||
| 			Name:   "HealthService.Live", | 	Ready(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error) | ||||||
| 			Path:   "/live", | 	Version(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error) | ||||||
| 			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 { | type HealthServiceServer interface { | ||||||
| 	Live(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error | 	Live(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error | ||||||
|   | |||||||
| @@ -1,16 +1,108 @@ | |||||||
| // Code generated by protoc-gen-go-micro. DO NOT EDIT. | // Code generated by protoc-gen-go-micro. DO NOT EDIT. | ||||||
| // protoc-gen-go-micro version: v3.10.2 | // protoc-gen-go-micro version: v3.10.4 | ||||||
| // source: health.proto | // source: health/health.proto | ||||||
|  |  | ||||||
| package health | package health_handler | ||||||
|  |  | ||||||
| import ( | import ( | ||||||
| 	context "context" | 	context "context" | ||||||
|  | 	v31 "go.unistack.org/micro-client-http/v3" | ||||||
| 	codec "go.unistack.org/micro-proto/v3/codec" | 	codec "go.unistack.org/micro-proto/v3/codec" | ||||||
| 	v3 "go.unistack.org/micro-server-http/v3" | 	v3 "go.unistack.org/micro-server-http/v3" | ||||||
|  | 	client "go.unistack.org/micro/v3/client" | ||||||
| 	server "go.unistack.org/micro/v3/server" | 	server "go.unistack.org/micro/v3/server" | ||||||
|  | 	http "net/http" | ||||||
| ) | ) | ||||||
|  |  | ||||||
|  | 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 healthServiceClient struct { | ||||||
|  | 	c    client.Client | ||||||
|  | 	name string | ||||||
|  | } | ||||||
|  |  | ||||||
|  | func NewHealthServiceClient(name string, c client.Client) HealthServiceClient { | ||||||
|  | 	return &healthServiceClient{c: c, name: name} | ||||||
|  | } | ||||||
|  |  | ||||||
|  | func (c *healthServiceClient) Live(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error) { | ||||||
|  | 	errmap := make(map[string]interface{}, 1) | ||||||
|  | 	errmap["default"] = &codec.Frame{} | ||||||
|  | 	opts = append(opts, | ||||||
|  | 		v31.ErrorMap(errmap), | ||||||
|  | 	) | ||||||
|  | 	opts = append(opts, | ||||||
|  | 		v31.Method(http.MethodGet), | ||||||
|  | 		v31.Path("/live"), | ||||||
|  | 	) | ||||||
|  | 	rsp := &codec.Frame{} | ||||||
|  | 	err := c.c.Call(ctx, c.c.NewRequest(c.name, "HealthService.Live", req), rsp, opts...) | ||||||
|  | 	if err != nil { | ||||||
|  | 		return nil, err | ||||||
|  | 	} | ||||||
|  | 	return rsp, nil | ||||||
|  | } | ||||||
|  |  | ||||||
|  | func (c *healthServiceClient) Ready(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error) { | ||||||
|  | 	errmap := make(map[string]interface{}, 1) | ||||||
|  | 	errmap["default"] = &codec.Frame{} | ||||||
|  | 	opts = append(opts, | ||||||
|  | 		v31.ErrorMap(errmap), | ||||||
|  | 	) | ||||||
|  | 	opts = append(opts, | ||||||
|  | 		v31.Method(http.MethodGet), | ||||||
|  | 		v31.Path("/ready"), | ||||||
|  | 	) | ||||||
|  | 	rsp := &codec.Frame{} | ||||||
|  | 	err := c.c.Call(ctx, c.c.NewRequest(c.name, "HealthService.Ready", req), rsp, opts...) | ||||||
|  | 	if err != nil { | ||||||
|  | 		return nil, err | ||||||
|  | 	} | ||||||
|  | 	return rsp, nil | ||||||
|  | } | ||||||
|  |  | ||||||
|  | func (c *healthServiceClient) Version(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error) { | ||||||
|  | 	errmap := make(map[string]interface{}, 1) | ||||||
|  | 	errmap["default"] = &codec.Frame{} | ||||||
|  | 	opts = append(opts, | ||||||
|  | 		v31.ErrorMap(errmap), | ||||||
|  | 	) | ||||||
|  | 	opts = append(opts, | ||||||
|  | 		v31.Method(http.MethodGet), | ||||||
|  | 		v31.Path("/version"), | ||||||
|  | 	) | ||||||
|  | 	rsp := &codec.Frame{} | ||||||
|  | 	err := c.c.Call(ctx, c.c.NewRequest(c.name, "HealthService.Version", req), rsp, opts...) | ||||||
|  | 	if err != nil { | ||||||
|  | 		return nil, err | ||||||
|  | 	} | ||||||
|  | 	return rsp, nil | ||||||
|  | } | ||||||
|  |  | ||||||
| type healthServiceServer struct { | type healthServiceServer struct { | ||||||
| 	HealthServiceServer | 	HealthServiceServer | ||||||
| } | } | ||||||
|   | |||||||
| @@ -1,7 +1,7 @@ | |||||||
| syntax = "proto3"; | syntax = "proto3"; | ||||||
|  |  | ||||||
| package micro.server.http.v3.handler.meter; | package micro.server.http.v3.handler.meter; | ||||||
| option go_package = "go.unistack.org/micro-server-http/v3/handler/meter;meter"; | option go_package = "go.unistack.org/micro-server-http/v3/handler/meter;meter_handler"; | ||||||
|  |  | ||||||
| import "api/annotations.proto"; | import "api/annotations.proto"; | ||||||
| import "openapiv3/annotations.proto"; | import "openapiv3/annotations.proto"; | ||||||
|   | |||||||
| @@ -1,31 +1,24 @@ | |||||||
| // Code generated by protoc-gen-go-micro. DO NOT EDIT. | // Code generated by protoc-gen-go-micro. DO NOT EDIT. | ||||||
| // versions: | // versions: | ||||||
| // - protoc-gen-go-micro v3.10.2 | // - protoc-gen-go-micro v3.10.4 | ||||||
| // - protoc              v3.21.12 | // - protoc              v5.26.1 | ||||||
| // source: meter.proto | // source: meter/meter.proto | ||||||
|  |  | ||||||
| package meter | package meter_handler | ||||||
|  |  | ||||||
| import ( | import ( | ||||||
| 	context "context" | 	context "context" | ||||||
| 	codec "go.unistack.org/micro-proto/v3/codec" | 	codec "go.unistack.org/micro-proto/v3/codec" | ||||||
| 	v3 "go.unistack.org/micro-server-http/v3" | 	client "go.unistack.org/micro/v3/client" | ||||||
| ) | ) | ||||||
|  |  | ||||||
| var ( | var ( | ||||||
| 	MeterServiceName = "MeterService" | 	MeterServiceName = "MeterService" | ||||||
| ) | ) | ||||||
| var ( |  | ||||||
| 	MeterServiceServerEndpoints = []v3.EndpointMetadata{ | type MeterServiceClient interface { | ||||||
| 		{ | 	Metrics(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error) | ||||||
| 			Name:   "MeterService.Metrics", | } | ||||||
| 			Path:   "/metrics", |  | ||||||
| 			Method: "GET", |  | ||||||
| 			Body:   "", |  | ||||||
| 			Stream: false, |  | ||||||
| 		}, |  | ||||||
| 	} |  | ||||||
| ) |  | ||||||
|  |  | ||||||
| type MeterServiceServer interface { | type MeterServiceServer interface { | ||||||
| 	Metrics(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error | 	Metrics(ctx context.Context, req *codec.Frame, rsp *codec.Frame) error | ||||||
|   | |||||||
| @@ -1,16 +1,58 @@ | |||||||
| // Code generated by protoc-gen-go-micro. DO NOT EDIT. | // Code generated by protoc-gen-go-micro. DO NOT EDIT. | ||||||
| // protoc-gen-go-micro version: v3.10.2 | // protoc-gen-go-micro version: v3.10.4 | ||||||
| // source: meter.proto | // source: meter/meter.proto | ||||||
|  |  | ||||||
| package meter | package meter_handler | ||||||
|  |  | ||||||
| import ( | import ( | ||||||
| 	context "context" | 	context "context" | ||||||
|  | 	v31 "go.unistack.org/micro-client-http/v3" | ||||||
| 	codec "go.unistack.org/micro-proto/v3/codec" | 	codec "go.unistack.org/micro-proto/v3/codec" | ||||||
| 	v3 "go.unistack.org/micro-server-http/v3" | 	v3 "go.unistack.org/micro-server-http/v3" | ||||||
|  | 	client "go.unistack.org/micro/v3/client" | ||||||
| 	server "go.unistack.org/micro/v3/server" | 	server "go.unistack.org/micro/v3/server" | ||||||
|  | 	http "net/http" | ||||||
| ) | ) | ||||||
|  |  | ||||||
|  | var ( | ||||||
|  | 	MeterServiceServerEndpoints = []v3.EndpointMetadata{ | ||||||
|  | 		{ | ||||||
|  | 			Name:   "MeterService.Metrics", | ||||||
|  | 			Path:   "/metrics", | ||||||
|  | 			Method: "GET", | ||||||
|  | 			Body:   "", | ||||||
|  | 			Stream: false, | ||||||
|  | 		}, | ||||||
|  | 	} | ||||||
|  | ) | ||||||
|  |  | ||||||
|  | type meterServiceClient struct { | ||||||
|  | 	c    client.Client | ||||||
|  | 	name string | ||||||
|  | } | ||||||
|  |  | ||||||
|  | func NewMeterServiceClient(name string, c client.Client) MeterServiceClient { | ||||||
|  | 	return &meterServiceClient{c: c, name: name} | ||||||
|  | } | ||||||
|  |  | ||||||
|  | func (c *meterServiceClient) Metrics(ctx context.Context, req *codec.Frame, opts ...client.CallOption) (*codec.Frame, error) { | ||||||
|  | 	errmap := make(map[string]interface{}, 1) | ||||||
|  | 	errmap["default"] = &codec.Frame{} | ||||||
|  | 	opts = append(opts, | ||||||
|  | 		v31.ErrorMap(errmap), | ||||||
|  | 	) | ||||||
|  | 	opts = append(opts, | ||||||
|  | 		v31.Method(http.MethodGet), | ||||||
|  | 		v31.Path("/metrics"), | ||||||
|  | 	) | ||||||
|  | 	rsp := &codec.Frame{} | ||||||
|  | 	err := c.c.Call(ctx, c.c.NewRequest(c.name, "MeterService.Metrics", req), rsp, opts...) | ||||||
|  | 	if err != nil { | ||||||
|  | 		return nil, err | ||||||
|  | 	} | ||||||
|  | 	return rsp, nil | ||||||
|  | } | ||||||
|  |  | ||||||
| type meterServiceServer struct { | type meterServiceServer struct { | ||||||
| 	MeterServiceServer | 	MeterServiceServer | ||||||
| } | } | ||||||
|   | |||||||
| @@ -1,20 +0,0 @@ | |||||||
| window.onload = function() { |  | ||||||
|   //<editor-fold desc="Changeable Configuration Block"> |  | ||||||
|  |  | ||||||
|   // the following lines will be replaced by docker/configurator, when it runs in a docker-container |  | ||||||
|   window.ui = SwaggerUIBundle({ |  | ||||||
|     url: "{{ .SWAGGER }}", |  | ||||||
|     dom_id: '#swagger-ui', |  | ||||||
|     deepLinking: true, |  | ||||||
|     presets: [ |  | ||||||
|       SwaggerUIBundle.presets.apis, |  | ||||||
|       SwaggerUIStandalonePreset |  | ||||||
|     ], |  | ||||||
|     plugins: [ |  | ||||||
|       SwaggerUIBundle.plugins.DownloadUrl |  | ||||||
|     ], |  | ||||||
|     layout: "StandaloneLayout" |  | ||||||
|   }); |  | ||||||
|  |  | ||||||
|   //</editor-fold> |  | ||||||
| }; |  | ||||||
| @@ -1,4 +1,4 @@ | |||||||
| package swaggerui | package swaggerui_handler | ||||||
|  |  | ||||||
| import ( | import ( | ||||||
| 	"net/http" | 	"net/http" | ||||||
|   | |||||||
							
								
								
									
										6
									
								
								http.go
									
									
									
									
									
								
							
							
						
						
									
										6
									
								
								http.go
									
									
									
									
									
								
							| @@ -561,7 +561,7 @@ func (h *Server) Start() error { | |||||||
|  |  | ||||||
| 	if err := config.RegisterCheck(h.opts.Context); err != nil { | 	if err := config.RegisterCheck(h.opts.Context); err != nil { | ||||||
| 		if config.Logger.V(logger.ErrorLevel) { | 		if config.Logger.V(logger.ErrorLevel) { | ||||||
| 			config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register check error", config.Name, config.ID) err) | 			config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register check error", config.Name, config.ID), err) | ||||||
| 		} | 		} | ||||||
| 	} else { | 	} else { | ||||||
| 		if err = h.Register(); err != nil { | 		if err = h.Register(); err != nil { | ||||||
| @@ -621,7 +621,7 @@ func (h *Server) Start() error { | |||||||
| 				// nolint: nestif | 				// nolint: nestif | ||||||
| 				if rerr != nil && registered { | 				if rerr != nil && registered { | ||||||
| 					if config.Logger.V(logger.ErrorLevel) { | 					if config.Logger.V(logger.ErrorLevel) { | ||||||
| 						config.Logger.Error(config.Context,fmt.Sprintf("Server %s-%s register check error, deregister it", config.Name, config.ID), rerr) | 						config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register check error, deregister it", config.Name, config.ID), rerr) | ||||||
| 					} | 					} | ||||||
| 					// deregister self in case of error | 					// deregister self in case of error | ||||||
| 					if err := h.Deregister(); err != nil { | 					if err := h.Deregister(); err != nil { | ||||||
| @@ -637,7 +637,7 @@ func (h *Server) Start() error { | |||||||
| 				} | 				} | ||||||
| 				if err := h.Register(); err != nil { | 				if err := h.Register(); err != nil { | ||||||
| 					if config.Logger.V(logger.ErrorLevel) { | 					if config.Logger.V(logger.ErrorLevel) { | ||||||
| 						config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register error: %s", config.Name, config.ID), err) | 						config.Logger.Error(config.Context, fmt.Sprintf("Server %s-%s register error", config.Name, config.ID), err) | ||||||
| 					} | 					} | ||||||
| 				} | 				} | ||||||
|  |  | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user