client

Documentation

Index

• type Client
  • func NewClient(opts opt.Option) *Client
  • func (s *Client) Close()
  • func (s *Client) InvokeRC(c *context.Context, method string, req chan []byte, errIn chan error, ...) (chan []byte, chan error)
  • 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, chan error)

Types

type Client

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

func NewClient

func NewClient(opts opt.Option) *Client

func (*Client) Close

func (s *Client) Close()

func (*Client) InvokeRC

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

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,
	chan error,
)

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