grpc

Documentation

Index

• func NewClient(address string) (conn *grpc.ClientConn, err error)
• type Server
  • func NewServer(address string) *Server
  • func (server *Server) RegisterService(register func(s *grpc.Server)) *Server
  • func (server *Server) Serve(stop <-chan struct{})
  • func (server *Server) Shutdown()
  • func (server *Server) WithChainUnaryInterceptor(interceptors ...grpc.UnaryServerInterceptor) *Server
  • func (server *Server) WithKeepAliveParams(kp keepalive.ServerParameters) *Server
  • func (server *Server) WithOptions(opts ...grpc.ServerOption) *Server

Functions

func NewClient

func NewClient(address string) (conn *grpc.ClientConn, err error)

NewClient returns a new client of grpc.

Types

type Server

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

Server represents a gRPC server.

func NewServer

func NewServer(address string) *Server

NewServer returns a new instance of the Server.

func (*Server) RegisterService

func (server *Server) RegisterService(register func(s *grpc.Server)) *Server

RegisterService registers grpc service

func (*Server) Serve

func (server *Server) Serve(stop <-chan struct{})

Serve start grpc listener

func (*Server) Shutdown

func (server *Server) Shutdown()

Shutdown shuts down the server.

func (*Server) WithChainUnaryInterceptor

func (server *Server) WithChainUnaryInterceptor(interceptors ...grpc.UnaryServerInterceptor) *Server

WithChainUnaryInterceptor sets the interceptors.It must be called before RegisterService.

func (*Server) WithKeepAliveParams

func (server *Server) WithKeepAliveParams(kp keepalive.ServerParameters) *Server

WithKeepAliveParams sets the KeepAlive option.It must be called before RegisterService.

func (*Server) WithOptions

func (server *Server) WithOptions(opts ...grpc.ServerOption) *Server

WithOptions sets the options for the RPC server.It must be called before RegisterService.