server

Documentation

Index

• func ContextTimeout(ctx context.Context)
• func RecoveryInterceptor(p interface{}) error
• func TimeoutInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• func UnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• type Server
  • func NewServer(conf config.Service) *Server
  • func (srv *Server) GetgRPCServer() *grpc.Server
  • func (srv *Server) HandleSig(sig string)
  • func (srv *Server) Listen()
  • func (srv *Server) StartPrometheus()

Functions

func ContextTimeout

func ContextTimeout(ctx context.Context)

ContextTimeout ... TODO: refactor

func RecoveryInterceptor

func RecoveryInterceptor(p interface{}) error

RecoveryInterceptor intercepts panic signals and tries to recover.

func TimeoutInterceptor

func TimeoutInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

TimeoutInterceptor cancels a request if it does not complete within 'requestTimeout' seconds.

func UnaryInterceptor

func UnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

UnaryInterceptor ... TODO: example of UnaryInterceptor, use it for auth

Types

type Server

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

Server ...

func NewServer

func NewServer(conf config.Service) *Server

NewServer creates a new gRPC server.

func (*Server) GetgRPCServer

func (srv *Server) GetgRPCServer() *grpc.Server

GetgRPCServer ...

func (*Server) HandleSig

func (srv *Server) HandleSig(sig string)

HandleSig ...

func (*Server) Listen

func (srv *Server) Listen()

Listen starts listening on a port.

func (*Server) StartPrometheus

func (srv *Server) StartPrometheus()

StartPrometheus ...