grpc

Documentation

Index

• type Server
  • func DefaultServer(opts ...ServerOption) *Server
  • func NewServer(opts ...ServerOption) *Server
  • func (s *Server) GetListener() net.Listener
  • func (s *Server) RegisterService(desc *grpc.ServiceDesc, impl interface{})
  • func (s *Server) Start(ctx context.Context) error
  • func (s *Server) Stop() error
• type ServerOption
  • func GrpcAddress(address string) ServerOption
  • func GrpcListener(lis net.Listener) ServerOption
  • func GrpcOptions(opts ...grpc.ServerOption) ServerOption
  • func StreamInterceptor(in ...grpc.StreamServerInterceptor) ServerOption
  • func UnaryInterceptor(in ...grpc.UnaryServerInterceptor) ServerOption

Types

type Server

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

Server of gRpc

func DefaultServer

func DefaultServer(opts ...ServerOption) *Server

DefaultServer 默认的grpc server入口

func NewServer

func NewServer(opts ...ServerOption) *Server

NewServer new server with options

func (*Server) GetListener

func (s *Server) GetListener() net.Listener

GetListener get servers listener

func (*Server) RegisterService

func (s *Server) RegisterService(desc *grpc.ServiceDesc, impl interface{})

RegisterService register gRpc service

func (*Server) Start

func (s *Server) Start(ctx context.Context) error

Start gRpc server

func (*Server) Stop

func (s *Server) Stop() error

Stop gRpc server

type ServerOption

type ServerOption func(server *Server)

ServerOption gRpc server option

func GrpcAddress

func GrpcAddress(address string) ServerOption

Address gRpc server listen address

func GrpcListener

func GrpcListener(lis net.Listener) ServerOption

Listener listener

func GrpcOptions

func GrpcOptions(opts ...grpc.ServerOption) ServerOption

Options set gRpc server options

func StreamInterceptor

func StreamInterceptor(in ...grpc.StreamServerInterceptor) ServerOption

StreamInterceptor register stream interceptors

func UnaryInterceptor

func UnaryInterceptor(in ...grpc.UnaryServerInterceptor) ServerOption

UnaryInterceptor register unary interceptors