server

Documentation

Index

• Variables
• func HandlePrometheusMetrics(mux *http.ServeMux)
• func LoggingPayloadDecider(config *viper.Viper) grpc_logging.ServerPayloadLoggingDecider
• func NewGatewayServeMux(params GatewayServeMuxParams) *runtime.ServeMux
• func NewGrpcServer(lc fx.Lifecycle, config *viper.Viper, logger *logrus.Entry, p GrpcServerParams) *grpc.Server
• func NewServeMux(lc fx.Lifecycle, config *viper.Viper, logger *logrus.Entry) *http.ServeMux
• func RegisterPrometheus(s *grpc.Server)
• func RegisterProtoMux(mux *http.ServeMux, gatewayMux *runtime.ServeMux)
• type GatewayServeMuxParams
• type GrpcServerParams
• type ServeMuxMarshallerParams
• type ServeMuxMarshallerResult
  • func NewServeMuxMarshallerOption(p ServeMuxMarshallerParams, config *viper.Viper) ServeMuxMarshallerResult
• type ServerInterceptorResult
  • func NewStreamServerInterceptors(logger *logrus.Entry, tracer opentracing.Tracer, ...) ServerInterceptorResult
  • func NewUnaryServerInterceptors(logger *logrus.Entry, tracer opentracing.Tracer, ...) ServerInterceptorResult

Variables

var GatewayMuxModule = fx.Options(
	fx.Provide(NewServeMuxMarshallerOption),
	fx.Provide(NewGatewayServeMux),
	fx.Invoke(RegisterProtoMux),
)

var GrpcLoggingPayloadModule = fx.Provide(LoggingPayloadDecider)

var HTTPModule = fx.Provide(NewServeMux)

var InterceptorsModule = fx.Provide(NewStreamServerInterceptors, NewUnaryServerInterceptors)

var Module = fx.Provide(NewGrpcServer)

Module register grpc server in DI container

var PrometheusMetrics = fx.Invoke(RegisterPrometheus)

PrometheusMetrics register grpc server in prometheus

var PrometheusMetricsHandler = fx.Invoke(HandlePrometheusMetrics)

PrometheusMetricsHandler .

Functions

func HandlePrometheusMetrics

func HandlePrometheusMetrics(mux *http.ServeMux)

HandlePrometheusMetrics .

func LoggingPayloadDecider

func LoggingPayloadDecider(config *viper.Viper) grpc_logging.ServerPayloadLoggingDecider

LoggingPayloadDecider decide is need to log payload

func NewGatewayServeMux

func NewGatewayServeMux(params GatewayServeMuxParams) *runtime.ServeMux

func NewGrpcServer

func NewGrpcServer(lc fx.Lifecycle, config *viper.Viper, logger *logrus.Entry, p GrpcServerParams) *grpc.Server

NewGrpcServer gives new predefined grpc server

func NewServeMux

func NewServeMux(lc fx.Lifecycle, config *viper.Viper, logger *logrus.Entry) *http.ServeMux

func RegisterPrometheus

func RegisterPrometheus(s *grpc.Server)

RegisterPrometheus .

func RegisterProtoMux

func RegisterProtoMux(mux *http.ServeMux, gatewayMux *runtime.ServeMux)

Types

type GatewayServeMuxParams

type GatewayServeMuxParams struct {
	fx.In

	Options []runtime.ServeMuxOption `group:"gateway_server_mux_options"`
}

type GrpcServerParams

type GrpcServerParams struct {
	fx.In

	ServerOptions []grpc.ServerOption `group:"grpc_server_options"`
}

GrpcServerParams .

type ServeMuxMarshallerParams

type ServeMuxMarshallerParams struct {
	fx.In

	AnyResolver jsonpb.AnyResolver `name:"gateway_marshaller_any_resolver" optional:"true"`
}

type ServeMuxMarshallerResult

type ServeMuxMarshallerResult struct {
	fx.Out

	Option runtime.ServeMuxOption `group:"gateway_server_mux_options"`
}

func NewServeMuxMarshallerOption

func NewServeMuxMarshallerOption(p ServeMuxMarshallerParams, config *viper.Viper) ServeMuxMarshallerResult

type ServerInterceptorResult

type ServerInterceptorResult struct {
	fx.Out

	Option grpc.ServerOption `group:"grpc_server_options"`
}

func NewStreamServerInterceptors

func NewStreamServerInterceptors(logger *logrus.Entry, tracer opentracing.Tracer,
	PayloadLoggingDecider grpcLogging.ServerPayloadLoggingDecider) ServerInterceptorResult

func NewUnaryServerInterceptors

func NewUnaryServerInterceptors(logger *logrus.Entry, tracer opentracing.Tracer,
	PayloadLoggingDecider grpcLogging.ServerPayloadLoggingDecider) ServerInterceptorResult