Documentation
¶
Index ¶
- func DefaultAccessLog(ctxi *httpctx.Context, param *AccessLogParam)
- func StreamAccess(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) (err error)
- func StreamValidator(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) (err error)
- func UnaryValidator(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
- type AccessLog
- type AccessLogParam
- type ApiDocConfig
- type Body
- type CorsConfig
- type DebugHandlerConfig
- type GrpcConfig
- type Http
- type Http3
- type HttpOption
- type Option
- func WithContext(ctx context.Context) Option
- func WithCors(cors cors.Options) Option
- func WithGinHandler(handler func(*gin.Engine)) Option
- func WithGrpc(option GrpcConfig) Option
- func WithGrpcHandler(handler func(*grpc.Server)) Option
- func WithHTTP3(http3 Http3) Option
- func WithHttp(http Http) Option
- func WithTelemetry(telemetry TelemetryConfig) Option
- type Server
- func (s *Server) AfterInject()
- func (s *Server) BeforeInject()
- func (s *Server) Init()
- func (s *Server) InternalHandler()
- func (s *Server) Run()
- func (s *Server) UnaryAccess(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
- func (s *Server) WithOptions(options ...Option) *Server
- type TelemetryConfig
- func (c *TelemetryConfig) SetMeterProvider(meterProvider *sdkmetric.MeterProvider)
- func (c *TelemetryConfig) SetOtelgrpcOptsHandlerOpts(otelgrpcOpts []otelgrpc.Option)
- func (c *TelemetryConfig) SetOtelhttpHandlerOpts(otelhttpOpts []otelhttp.Option)
- func (c *TelemetryConfig) SetPrometheusOpts(prometheusOpts []prometheus.Option)
- func (c *TelemetryConfig) SetTextMapPropagator(propagator propagation.TextMapPropagator)
- func (c *TelemetryConfig) SetTracerProvider(tracerProvider *sdktrace.TracerProvider)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultAccessLog ¶ added in v1.17.20
func DefaultAccessLog(ctxi *httpctx.Context, param *AccessLogParam)
func StreamAccess ¶
func StreamAccess(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) (err error)
func StreamValidator ¶
func StreamValidator(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) (err error)
func UnaryValidator ¶
func UnaryValidator( ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler, ) (resp interface{}, err error)
Types ¶
type AccessLog ¶
type AccessLog = func(ctxi *httpctx.Context, pram *AccessLogParam)
type AccessLogParam ¶ added in v1.17.15
type ApiDocConfig ¶ added in v1.18.6
type CorsConfig ¶ added in v1.18.6
type DebugHandlerConfig ¶ added in v1.18.16
type GrpcConfig ¶ added in v1.18.6
type GrpcConfig struct {
EnableGrpcWeb bool
GrpcWebOptions []web.Option
Options []grpc.ServerOption
UnaryServerInterceptors []grpc.UnaryServerInterceptor
StreamServerInterceptors []grpc.StreamServerInterceptor
}
type HttpOption ¶
type Option ¶ added in v1.16.7
type Option func(server *Server)
func WithContext ¶ added in v1.16.7
func WithGinHandler ¶ added in v1.16.7
func WithGrpc ¶ added in v1.18.6
func WithGrpc(option GrpcConfig) Option
func WithGrpcHandler ¶ added in v1.16.7
func WithTelemetry ¶ added in v1.16.7
func WithTelemetry(telemetry TelemetryConfig) Option
type Server ¶
type Server struct {
Http
HTTP2 http2.Server
HTTP3 Http3
Gin gini.Config
Cors CorsConfig
Grpc GrpcConfig
ApiDoc ApiDocConfig
Telemetry TelemetryConfig
DebugHandler DebugHandlerConfig
BaseContext context.Context
Middlewares []http.HandlerFunc
// 注册 grpc 服务
GrpcHandler func(*grpc.Server)
// 注册 gin 服务
GinHandler func(*gin.Engine)
}
func (*Server) AfterInject ¶ added in v1.16.17
func (s *Server) AfterInject()
func (*Server) BeforeInject ¶ added in v1.16.17
func (s *Server) BeforeInject()
implement initialize
func (*Server) InternalHandler ¶ added in v1.18.16
func (s *Server) InternalHandler()
func (*Server) UnaryAccess ¶ added in v1.16.7
func (s *Server) UnaryAccess(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)
func (*Server) WithOptions ¶ added in v1.16.7
type TelemetryConfig ¶
type TelemetryConfig struct {
Enabled bool
EnablePrometheus bool
PromHttpUri string
// contains filtered or unexported fields
}
func (*TelemetryConfig) SetMeterProvider ¶
func (c *TelemetryConfig) SetMeterProvider(meterProvider *sdkmetric.MeterProvider)
func (*TelemetryConfig) SetOtelgrpcOptsHandlerOpts ¶ added in v1.18.6
func (c *TelemetryConfig) SetOtelgrpcOptsHandlerOpts(otelgrpcOpts []otelgrpc.Option)
func (*TelemetryConfig) SetOtelhttpHandlerOpts ¶ added in v1.18.6
func (c *TelemetryConfig) SetOtelhttpHandlerOpts(otelhttpOpts []otelhttp.Option)
func (*TelemetryConfig) SetPrometheusOpts ¶ added in v1.18.7
func (c *TelemetryConfig) SetPrometheusOpts(prometheusOpts []prometheus.Option)
func (*TelemetryConfig) SetTextMapPropagator ¶
func (c *TelemetryConfig) SetTextMapPropagator(propagator propagation.TextMapPropagator)
func (*TelemetryConfig) SetTracerProvider ¶
func (c *TelemetryConfig) SetTracerProvider(tracerProvider *sdktrace.TracerProvider)
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
_example
|
|
|
client
command
|
|
|
protobuf/user
Package user is a reverse proxy.
|
Package user is a reverse proxy. |
|
user
command
|
|
Click to show internal directories.
Click to hide internal directories.