Documentation ¶
Index ¶
- type Client
- func (c *Client) Close()
- func (c *Client) ConnectRPC()
- func (c *Client) Dial()
- func (c *Client) GetChannelUpdates(uuid string, timeout string, limit int) (packets []types.Packet, err error)
- func (c *Client) GetUpdates() (packets []types.Packet, err error)
- func (c *Client) GetUpdatesChan(bufferSize int) (UpdatesChannel, error)
- func (c *Client) Init(addr string, uuid string)
- func (c *Client) InitChannel(key string) (msg string, err error)
- func (c *Client) MakeRequest(request ChannelProduceRequest) (reply ChannelProduceResponse, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct { UUID string Timeout time.Duration Limit int Addr string MaxRetryInterval time.Duration Accept []router.RoutingRule // contains filtered or unexported fields }
func (*Client) ConnectRPC ¶
func (c *Client) ConnectRPC()
func (*Client) GetChannelUpdates ¶
func (*Client) GetUpdatesChan ¶
func (*Client) MakeRequest ¶
Click to show internal directories.
Click to hide internal directories.