zrpc

README

zrpc

倍通内部rpc框架，基于gRPC

Documentation

Index

• func Block() grpc.DialOption
• func Insecure() grpc.DialOption
• func MustNewClientConn(rpcClient rpc.Client, serverName string, opts ...COption) *grpc.ClientConn
• type COption
  • func WithClientInterceptor(clientInterceptor ...grpc.UnaryClientInterceptor) COption
  • func WithDialOption(opts ...grpc.DialOption) COption
• type Client
• type RegisterServer
• type SOption
  • func WithServerInterceptor(serverInterceptor ...grpc.UnaryServerInterceptor) SOption
  • func WithServerOption(opts ...grpc.ServerOption) SOption
• type Server
  • func MustNewServer(ctx context.Context, server rpc.Server, registerServer RegisterServer, ...) *Server
  • func (s *Server) Serve() error
  • func (s *Server) StopServe()

Functions

func Block

func Block() grpc.DialOption

func Insecure

func Insecure() grpc.DialOption

func MustNewClientConn

func MustNewClientConn(rpcClient rpc.Client, serverName string, opts ...COption) *grpc.ClientConn

MustNewClientConn 新建一个 Client 实例

Types

type COption

type COption func(*clientOption)

func WithClientInterceptor

func WithClientInterceptor(clientInterceptor ...grpc.UnaryClientInterceptor) COption

func WithDialOption

func WithDialOption(opts ...grpc.DialOption) COption

type Client

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

type RegisterServer

type RegisterServer func(server *grpc.Server)

type SOption

type SOption func(*serverOption)

func WithServerInterceptor

func WithServerInterceptor(serverInterceptor ...grpc.UnaryServerInterceptor) SOption

WithServerInterceptor 生成服务端拦截器

func WithServerOption

func WithServerOption(opts ...grpc.ServerOption) SOption

WithServerOption 通过 grpc.ServerOption 生成 SOption

type Server

type Server struct {
	ServiceInstance *register.ServiceInstance
	// contains filtered or unexported fields
}

func MustNewServer

func MustNewServer(ctx context.Context, server rpc.Server, registerServer RegisterServer, serverOptions ...SOption) *Server

func (*Server) Serve

func (s *Server) Serve() error

Serve 启动服务

func (*Server) StopServe

func (s *Server) StopServe()

StopServe 停止服务