server

Documentation

Index

• Constants
• func DefaultCodeToLevelGRPC(c codes.Code) grpc_logging.Level
• func InterceptorLogger(l log.Logger) grpc_logging.Logger
• type Registerable
• type RegisterableFunc
  • func (f RegisterableFunc) Register(ctx context.Context, srv *grpc.Server, mux *runtime.ServeMux, endpoint string, ...) error
• type Server
  • func NewServer(reg *prometheus.Registry, version string) *Server
  • func (s *Server) ListenAndServe(ctx context.Context, logger log.Logger, uiFS fs.FS, addr string, ...) error
  • func (s *Server) Shutdown(ctx context.Context) error

Constants

const Name = "proto"

Name is the name registered for the proto compressor.

Functions

func DefaultCodeToLevelGRPC

func DefaultCodeToLevelGRPC(c codes.Code) grpc_logging.Level

DefaultCodeToLevelGRPC is the helper mapper that maps gRPC Response codes to log levels.

func InterceptorLogger

func InterceptorLogger(l log.Logger) grpc_logging.Logger

InterceptorLogger adapts go-kit logger to interceptor logger.

Types

type Registerable

type Registerable interface {
	Register(ctx context.Context, srv *grpc.Server, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) error
}

type RegisterableFunc

type RegisterableFunc func(ctx context.Context, srv *grpc.Server, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) error

func (RegisterableFunc) Register

func (f RegisterableFunc) Register(ctx context.Context, srv *grpc.Server, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) error

type Server

type Server struct {
	http.Server
	// contains filtered or unexported fields
}

Server is a wrapper around the http.Server.

func NewServer

func NewServer(reg *prometheus.Registry, version string) *Server

func (*Server) ListenAndServe

func (s *Server) ListenAndServe(
	ctx context.Context,
	logger log.Logger,
	uiFS fs.FS,
	addr string,
	readTimeout time.Duration,
	writeTimeout time.Duration,
	allowedCORSOrigins []string,
	pathPrefix string,
	registerables ...Registerable,
) error

ListenAndServe starts the http grpc gateway server.

func (*Server) Shutdown

func (s *Server) Shutdown(ctx context.Context) error

Shutdown the server.