grpc

Documentation

Overview

Package grpc implements an gRPC server.

Index

• func OpenTracingServerInterceptor(tracer opentracing.Tracer) grpc.UnaryServerInterceptor
• func RecoverServerInterceptor(logger tracelog.Logger) grpc.UnaryServerInterceptor
• func SimpleErrorServerInterceptor() grpc.UnaryServerInterceptor
• type Server
  • func NewServer(port uint16) *Server
  • func NewServerWithListener(listener net.Listener) *Server
  • func (s *Server) Addr() string
  • func (s *Server) BuildServer(tlsConfig *tls.Config, opts []grpc.ServerOption) (err error)
  • func (s *Server) Close() error
  • func (s *Server) RegistryDesc(services ...transport.Service)
  • func (s *Server) Serve() error

Functions

func OpenTracingServerInterceptor

func OpenTracingServerInterceptor(tracer opentracing.Tracer) grpc.UnaryServerInterceptor

OpenTracingServerInterceptor returns opentracing grpc interceptor.

func RecoverServerInterceptor

func RecoverServerInterceptor(logger tracelog.Logger) grpc.UnaryServerInterceptor

RecoverServerInterceptor returns recovery grpc interceptor.

func SimpleErrorServerInterceptor

func SimpleErrorServerInterceptor() grpc.UnaryServerInterceptor

SimpleErrorServerInterceptor returns error parser grpc interceptor.

Types

type Server

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

A Server defines configuration for running an gRPC server.

func NewServer

func NewServer(port uint16) *Server

NewServer returns gRPC server with port.

func NewServerWithListener

func NewServerWithListener(listener net.Listener) *Server

NewServerWithListener returns gRPC server with listener.

func (*Server) Addr

func (s *Server) Addr() string

Addr returns the server address.

func (*Server) BuildServer

func (s *Server) BuildServer(tlsConfig *tls.Config, opts []grpc.ServerOption) (err error)

BuildServer init gRPC server.

func (*Server) Close

func (s *Server) Close() error

Close closes the server.

func (*Server) RegistryDesc

func (s *Server) RegistryDesc(services ...transport.Service)

RegistryDesc in gRPC server.

func (*Server) Serve

func (s *Server) Serve() error

Serve starts serving incoming connections.