server

Documentation

Index

• func BuildGRPCInterceptors(recovery *middleware.RecoveryInterceptor, ...) ([]grpc.UnaryServerInterceptor, []grpc.StreamServerInterceptor)
• type GRPCServer
  • func NewGRPCServer(cfg *config.GRPCConfig, logger *zap.Logger, opts ...grpc.ServerOption) *GRPCServer
  • func (s *GRPCServer) Server() *grpc.Server
  • func (s *GRPCServer) Start() error
  • func (s *GRPCServer) Stop()
• type HTTPServer
  • func NewHTTPServer(cfg *config.ServerConfig, logger *zap.Logger, ...) *HTTPServer
  • func (s *HTTPServer) Router() *chi.Mux
  • func (s *HTTPServer) Start() error
  • func (s *HTTPServer) Stop(ctx context.Context) error

Functions

func BuildGRPCInterceptors

func BuildGRPCInterceptors(
	recovery *middleware.RecoveryInterceptor,
	logging *middleware.LoggingInterceptor,
	auth *middleware.JWTValidator,
	rateLimiter *middleware.RateLimiter,
	circuitBreaker *middleware.CircuitBreaker,
) ([]grpc.UnaryServerInterceptor, []grpc.StreamServerInterceptor)

Types

type GRPCServer

type GRPCServer struct {
	// contains filtered or unexported fields
}

func NewGRPCServer

func NewGRPCServer(cfg *config.GRPCConfig, logger *zap.Logger, opts ...grpc.ServerOption) *GRPCServer

func (*GRPCServer) Server

func (s *GRPCServer) Server() *grpc.Server

func (*GRPCServer) Start

func (s *GRPCServer) Start() error

func (*GRPCServer) Stop

func (s *GRPCServer) Stop()

type HTTPServer

type HTTPServer struct {
	// contains filtered or unexported fields
}

func NewHTTPServer

func NewHTTPServer(cfg *config.ServerConfig, logger *zap.Logger, jwtValidator *middleware.JWTValidator, rateLimiter *middleware.RateLimiter) *HTTPServer

func (*HTTPServer) Router

func (s *HTTPServer) Router() *chi.Mux

func (*HTTPServer) Start

func (s *HTTPServer) Start() error

func (*HTTPServer) Stop

func (s *HTTPServer) Stop(ctx context.Context) error