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
  • func MustNewClient(rpcClient rpc.Client, serverName string, opts ...COption) *Client
  • func (c *Client) Coon() *grpc.ClientConn
  • func (c *Client) GetTarget() string
• type RegisterServer
• type SOption
  • func WithServeZero() 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) ServerEndpoint() string
  • 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
}

func MustNewClient

func MustNewClient(rpcClient rpc.Client, serverName string, opts ...COption) *Client

func (*Client) Coon

func (c *Client) Coon() *grpc.ClientConn

func (*Client) GetTarget

func (c *Client) GetTarget() string

type RegisterServer

type RegisterServer func(server *grpc.Server)

type SOption

type SOption func(*serverOption)

func WithServeZero

func WithServeZero() SOption

WithServeZero 设置服务启动运行在 0.0.0.0

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) ServerEndpoint

func (s *Server) ServerEndpoint() string

ServerEndpoint 服务真正运行的 endpoint

func (*Server) StopServe

func (s *Server) StopServe()

StopServe 停止服务