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.