Documentation ¶
Index ¶
- type Client
- func (c *Client) AddConsumer(ctx context.Context, topic string, consumer *nsq.Consumer) error
- func (c *Client) ClearConsumers()
- func (c *Client) Close(KeepAlive bool)
- func (c *Client) ReadPump()
- func (c *Client) Send() chan Message
- func (c *Client) Session() *model.Session
- func (c *Client) Start() error
- func (c *Client) StartWithContext(ctx context.Context) error
- func (c *Client) StopConsumers(topic string) int
- func (c *Client) WritePump()
- type ClientCfg
- type Data
- type Hub
- type Message
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client per connection (each device should have at most 1 connection)
func (*Client) AddConsumer ¶
func (*Client) ClearConsumers ¶
func (c *Client) ClearConsumers()
func (*Client) StopConsumers ¶
Click to show internal directories.
Click to hide internal directories.