client

Documentation

Index

• type Client
  • func NewClient(opts opt.Option) *Client
  • func (s *Client) CloseClient()
  • func (s *Client) InvokeRC(c *context.Context, method string, req chan []byte, ...) chan []byte
  • func (s *Client) InvokeRR(c *context.Context, method string, req, rsp proto.Message, ...) error
  • func (s *Client) InvokeRS(c *context.Context, method string, req proto.Message, ...) chan []byte

Types

type Client

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

func NewClient

func NewClient(opts opt.Option) *Client

func (*Client) CloseClient

func (s *Client) CloseClient()

func (*Client) InvokeRC

func (s *Client) InvokeRC(
	c *context.Context,
	method string,
	req chan []byte,
	opts ...invoke.InvokeOptions,
) chan []byte

InvokeRC rpc request requestChannel,it's multiple request and multiple response

func (*Client) InvokeRR

func (s *Client) InvokeRR(
	c *context.Context,
	method string,
	req, rsp proto.Message,
	opts ...invoke.InvokeOptions,
) error

InvokeRR rpc request requestResponse,it's block request,one request one response

func (*Client) InvokeRS

func (s *Client) InvokeRS(
	c *context.Context,
	method string,
	req proto.Message,
	opts ...invoke.InvokeOptions,
) chan []byte

InvokeRS rpc request requestStream,it's one request and multiple response