rgrpc

Documentation

Index

• Variables
• func GetMaxConnectionAge() time.Duration
• func Register(name string, newFunc NewService)
• func RegisterStreamInterceptor(name string, newFunc NewStreamInterceptor)
• func RegisterUnaryInterceptor(name string, newFunc NewUnaryInterceptor)
• type NewService
• type NewStreamInterceptor
• type NewUnaryInterceptor
• type Server
  • func NewServer(m interface{}, log zerolog.Logger, tp trace.TracerProvider) (*Server, error)
  • func (s *Server) Address() string
  • func (s *Server) GracefulStop() error
  • func (s *Server) Network() string
  • func (s *Server) Start(ln net.Listener) error
  • func (s *Server) Stop() error
• type Service

Variables

var Services = map[string]NewService{}

Services is a map of service name and its new function.

var StreamInterceptors = map[string]NewStreamInterceptor{}

StreamInterceptors is a map of registered streaming grpc interceptor

var UnaryInterceptors = map[string]NewUnaryInterceptor{}

UnaryInterceptors is a map of registered unary grpc interceptors.

Functions

func GetMaxConnectionAge

func GetMaxConnectionAge() time.Duration

GetMaxConnectionAge returns the maximum grpc connection age.

func Register

func Register(name string, newFunc NewService)

Register registers a new gRPC service with name and new function.

func RegisterStreamInterceptor

func RegisterStreamInterceptor(name string, newFunc NewStreamInterceptor)

RegisterStreamInterceptor registers a new stream interceptor.

func RegisterUnaryInterceptor

func RegisterUnaryInterceptor(name string, newFunc NewUnaryInterceptor)

RegisterUnaryInterceptor registers a new unary interceptor.

Types

type NewService

type NewService func(conf map[string]interface{}, ss *grpc.Server) (Service, error)

NewService is the function that gRPC services need to register at init time. It returns an io.Closer to close the service and a list of service endpoints that need to be unprotected.

type NewStreamInterceptor

type NewStreamInterceptor func(m map[string]interface{}) (grpc.StreamServerInterceptor, int, error)

NewStreamInterceptor is the type that stream interceptors need to register.

type NewUnaryInterceptor

type NewUnaryInterceptor func(m map[string]interface{}) (grpc.UnaryServerInterceptor, int, error)

NewUnaryInterceptor is the type that unary interceptors need to register.

type Server

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

Server is a gRPC server.

func NewServer

func NewServer(m interface{}, log zerolog.Logger, tp trace.TracerProvider) (*Server, error)

NewServer returns a new Server.

func (*Server) Address

func (s *Server) Address() string

Address returns the network address.

func (*Server) GracefulStop

func (s *Server) GracefulStop() error

GracefulStop gracefully stops the server.

func (*Server) Network

func (s *Server) Network() string

Network returns the network type.

func (*Server) Start

func (s *Server) Start(ln net.Listener) error

Start starts the server.

func (*Server) Stop

func (s *Server) Stop() error

Stop stops the server.

type Service

type Service interface {
	Register(ss *grpc.Server)
	io.Closer
	UnprotectedEndpoints() []string
}

Service represents a grpc service.