grpcserver

Documentation

Overview

Package grpcserver implements gRPC server.

Index

• func InterceptorLogger(l *zap.Logger) logging.Logger
• type GRPCServer
  • func NewGRPCServer(NumPoolWorkers uint32) *GRPCServer
  • func (s *GRPCServer) GetServer() *grpc.Server
  • func (s *GRPCServer) GracefulShutdown()
  • func (s *GRPCServer) Notify() <-chan error
  • func (s *GRPCServer) StartGRPCServer(l net.Listener)

Functions

func InterceptorLogger

func InterceptorLogger(l *zap.Logger) logging.Logger

InterceptorLogger adapts zap.Logger to logging.Logger.

Types

type GRPCServer

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

GRPCServer is a custom gRPC server with RPC requests logger.

func NewGRPCServer

func NewGRPCServer(NumPoolWorkers uint32) *GRPCServer

NewGRPCServer returns GRPCServer with the given number of goroutines for traffic processing.

func (*GRPCServer) GetServer

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

GetServer returns gRPC server field.

func (*GRPCServer) GracefulShutdown

func (s *GRPCServer) GracefulShutdown()

GracefulShutdown stops the gRPC server gracefully.

func (*GRPCServer) Notify

func (s *GRPCServer) Notify() <-chan error

Notify returns notify channel field.

func (*GRPCServer) StartGRPCServer

func (s *GRPCServer) StartGRPCServer(l net.Listener)

StartGRPCServer calls method for serving connection on the given listener and accepts err from it.