Documentation
¶
Index ¶
- func DefaultAccessLog(ctxi *httpctx.Context, param *AccessLogParam)
- func DefaultGrpcAccessLog(ctxi *httpctx.Context, param *GrpcAccessLogParam)
- func StreamValidator(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) (err error)
- type AccessLog
- type AccessLogConfig
- type AccessLogParam
- type ApiDocConfig
- type Body
- type CorsConfig
- type DebugHandlerConfig
- type GRPCStatus
- type GrpcAccessLog
- type GrpcAccessLogParam
- type GrpcConfig
- type Http3
- type Option
- func WithContext(ctx context.Context) Option
- func WithCors(handler func(cors *cors.Options)) Option
- func WithGinHandler(handler func(*gin.Engine)) Option
- func WithGrpc(handler func(option *GrpcConfig)) Option
- func WithGrpcHandler(handler func(*grpc.Server)) Option
- func WithHTTP3(handler func(s *Http3)) Option
- func WithHttp(handler func(s *http.Server)) Option
- func WithHttp2(handler func(s *http2.Server)) Option
- func WithMiddleware(mw ...httpx.Middleware) Option
- func WithTelemetry(handler func(telemetry *TelemetryConfig)) Option
- type PrometheusConfig
- 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) StreamAccess(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) (err error)
- 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 DefaultGrpcAccessLog ¶ added in v1.19.12
func DefaultGrpcAccessLog(ctxi *httpctx.Context, param *GrpcAccessLogParam)
func StreamValidator ¶
func StreamValidator(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) (err error)
Types ¶
type AccessLog ¶
type AccessLog = func(ctxi *httpctx.Context, pram *AccessLogParam)
type AccessLogConfig ¶ added in v1.19.11
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 GRPCStatus ¶ added in v1.19.13
type GrpcAccessLog ¶ added in v1.19.12
type GrpcAccessLog = func(ctxi *httpctx.Context, pram *GrpcAccessLogParam)
type GrpcAccessLogParam ¶ added in v1.19.12
type GrpcAccessLogParam struct {
Method string
// contains filtered or unexported fields
}
type GrpcConfig ¶ added in v1.18.6
type GrpcConfig struct {
RecordFunc GrpcAccessLog
EnableGrpcWeb bool
GrpcWebOptions []web.Option
Options []grpc.ServerOption
UnaryServerInterceptors []grpc.UnaryServerInterceptor
StreamServerInterceptors []grpc.StreamServerInterceptor
}
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(handler func(option *GrpcConfig)) Option
func WithGrpcHandler ¶ added in v1.16.7
func WithMiddleware ¶ added in v1.19.12
func WithMiddleware(mw ...httpx.Middleware) Option
func WithTelemetry ¶ added in v1.16.7
func WithTelemetry(handler func(telemetry *TelemetryConfig)) Option
type PrometheusConfig ¶ added in v1.19.11
type Server ¶
type Server struct {
http.Server
CertFile string
KeyFile string
AccessLog AccessLogConfig
HTTP2 http2.Server
HTTP3 Http3
Cors CorsConfig
Grpc GrpcConfig
InternalServer http.Server
ApiDoc ApiDocConfig
Telemetry TelemetryConfig
DebugHandler DebugHandlerConfig
BaseContext context.Context
Middlewares []httpx.Middleware
GinServer *gin.Engine
// 注册 grpc 服务
GrpcHandler func(*grpc.Server)
}
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) StreamAccess ¶ added in v1.19.20
func (s *Server) StreamAccess(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) (err error)
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
Prometheus PrometheusConfig
// 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.
