grpc

Documentation

Index

• Constants
• type Body
• type Client
  • func NewClient(registrar registry.Registrar, setting *clientConfig, reqPath *url.URL) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) RequestByString(ctx context.Context, input []byte, opts ...xrpc.RequestOption) (res xrpc.Body, err error)
• type Compressor
  • func (c *Compressor) Compress(w io.Writer) (io.WriteCloser, error)
  • func (c *Compressor) Decompress(r io.Reader) (io.Reader, error)
  • func (c *Compressor) Name() string
• type Request
  • func NewRequest(clientCfg *clientConfig) *Request
  • func (r *Request) Close() error
  • func (r *Request) Request(ctx sctx.Context, service string, input interface{}, ...) (res xrpc.Body, err error)
  • func (r *Request) Swap(ctx context.Context, service string, opts ...xrpc.RequestOption) (res xrpc.Body, err error)
• type Server
  • func (e *Server) GetAddr() string
  • func (e *Server) GetProto() string
  • func (e *Server) Serve(ctx context.Context) (err error)
  • func (e *Server) Stop(ctx context.Context) error

Constants

const Proto = "grpc"

const Snappy = "snappy"

Snappy is the name registered for the snappy Compressor.

Types

type Body

type Body interface {
	io.Reader
	Scan(obj interface{}) error
}

type Client

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

func NewClient

func NewClient(registrar registry.Registrar, setting *clientConfig, reqPath *url.URL) (*Client, error)

NewClient 创建RPC客户端,地址是远程RPC服务器地址或注册中心地址

func (*Client) Close

func (c *Client) Close()

Close 关闭RPC客户端连接

func (*Client) RequestByString

func (c *Client) RequestByString(ctx context.Context, input []byte, opts ...xrpc.RequestOption) (res xrpc.Body, err error)

RequestByString 发送Request请求

type Compressor

type Compressor struct {
}

func (*Compressor) Compress

func (c *Compressor) Compress(w io.Writer) (io.WriteCloser, error)

func (*Compressor) Decompress

func (c *Compressor) Decompress(r io.Reader) (io.Reader, error)

func (*Compressor) Name

func (c *Compressor) Name() string

type Request

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

Request RPC Request

func NewRequest

func NewRequest(clientCfg *clientConfig) *Request

NewRequest 构建请求

func (*Request) Close

func (r *Request) Close() error

Close 关闭RPC连接

func (*Request) Request

func (r *Request) Request(ctx sctx.Context, service string, input interface{}, opts ...xrpc.RequestOption) (res xrpc.Body, err error)

RequestByCtx RPC请求，可通过context撤销请求 service=grpc://servername/path

func (*Request) Swap

func (r *Request) Swap(ctx context.Context, service string, opts ...xrpc.RequestOption) (res xrpc.Body, err error)

Swap 将当前请求参数作为RPC参数并发送RPC请求

type Server

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

func (*Server) GetAddr

func (e *Server) GetAddr() string

func (*Server) GetProto

func (e *Server) GetProto() string

func (*Server) Serve

func (e *Server) Serve(ctx context.Context) (err error)

func (*Server) Stop

func (e *Server) Stop(ctx context.Context) error