grpc

Documentation

Index

• func ErrInvalidArgument(msg string) error
• func NewGrpcConnectionFactory(url string) grpcConnectionFactory
• func NewGrpcConnectionFactoryWithDefaults(url string) grpcConnectionFactory
• type Server
  • func NewServer(name string, keepAlive bool) *Server
  • func NewServerWithOpts(name string, keepAlive bool, ...) *Server
  • func (s *Server) RegisterService(f func(grpc.ServiceRegistrar))
  • func (s *Server) Serve(apiAddr, metricsAddr string) error
  • func (s *Server) ServeFromListener(apiLis net.Listener, metricsLis net.Listener) error
  • func (s *Server) Shutdown()

Functions

func ErrInvalidArgument

func ErrInvalidArgument(msg string) error

func NewGrpcConnectionFactory

func NewGrpcConnectionFactory(url string) grpcConnectionFactory

NewGrpcConnectionFactory creates a new factory for gRPC connections.

func NewGrpcConnectionFactoryWithDefaults

func NewGrpcConnectionFactoryWithDefaults(url string) grpcConnectionFactory

NewGrpcConnectionFactoryWithDefaults creates a new factory for gRPC connections and adds the following dial options: WithInsecure, WithBlock.

Types

type Server

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

Server is the implementation of an API Server

func NewServer

func NewServer(name string, keepAlive bool) *Server

NewServer returns a new configured instance of Server

func NewServerWithOpts

func NewServerWithOpts(name string, keepAlive bool, unaryServerInterceptors []grpc.UnaryServerInterceptor, streamServerInterceptors []grpc.StreamServerInterceptor) *Server

NewServerWithOpts returns a new configured instance of Server with additional interceptros specified

func (*Server) RegisterService

func (s *Server) RegisterService(f func(grpc.ServiceRegistrar))

RegisterService registers your gRPC service implementation with the server

func (*Server) Serve

func (s *Server) Serve(apiAddr, metricsAddr string) error

Serve starts the api listeners of the Server

func (*Server) ServeFromListener

func (s *Server) ServeFromListener(apiLis net.Listener, metricsLis net.Listener) error

ServeFromListener starts the api listeners of the Server

func (*Server) Shutdown

func (s *Server) Shutdown()

Tell the server to shutdown