rpcserver

Documentation

Index

• Constants
• func BlackListInterceptor() grpc.UnaryServerInterceptor
• func GetClientAddr(ctx context.Context) string
• func LoggingInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• func RecoveryInterceptor(ctx context.Context, req interface{}, _ *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
• type RPCServer
  • func NewRpcServer() (*RPCServer, error)
  • func (s *RPCServer) RegisterHandler() error
  • func (s *RPCServer) Start() error
  • func (s *RPCServer) Stop()

Constants

const (
	//UNKNOWN unknown string
	UNKNOWN = "unknown"
)

Functions

func BlackListInterceptor

func BlackListInterceptor() grpc.UnaryServerInterceptor

BlackListInterceptor - set ip blacklist interceptor

@return grpc.UnaryServerInterceptor

func GetClientAddr

func GetClientAddr(ctx context.Context) string

GetClientAddr 获取客户端地址

@param ctx
@return string

func LoggingInterceptor

func LoggingInterceptor(ctx context.Context, req interface{},
	info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

LoggingInterceptor - set logging interceptor

@return unc

func RecoveryInterceptor

func RecoveryInterceptor(ctx context.Context, req interface{},
	_ *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)

RecoveryInterceptor - set recovery interceptor

@return unc

Types

type RPCServer

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

RPCServer 结构体

func NewRpcServer

func NewRpcServer() (*RPCServer, error)

NewRpcServer 新建rpc服务

@return *RPCServer
@return error

func (*RPCServer) RegisterHandler

func (s *RPCServer) RegisterHandler() error

RegisterHandler - register apiservice handler to rpcserver

@receiver s
@return error

func (*RPCServer) Start

func (s *RPCServer) Start() error

Start - start RPCServer

@receiver s
@return error

func (*RPCServer) Stop

func (s *RPCServer) Stop()

Stop - stop RPCServer

@receiver s