broker

Documentation

Index

• type BrokerConnection
  • func StartBrokerConnection(host, login, password string) *BrokerConnection
  • func (srvCon *BrokerConnection) Subscribe() *Client
  • func (srvCon *BrokerConnection) Unsubscribe(client *Client)
• type Client
  • func (c *Client) GetRetained() []mqtt.Message
  • func (c *Client) Receive() <-chan mqtt.Message
  • func (c *Client) Send(topic string, qos byte, retained bool, payload interface{}) mqtt.Token
• type RetainedKeeper
  • func (keeper *RetainedKeeper) GetAll() []mqtt.Message

Types

type BrokerConnection

type BrokerConnection struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func StartBrokerConnection

func StartBrokerConnection(host, login, password string) *BrokerConnection

func (*BrokerConnection) Subscribe

func (srvCon *BrokerConnection) Subscribe() *Client

func (*BrokerConnection) Unsubscribe

func (srvCon *BrokerConnection) Unsubscribe(client *Client)

type Client

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

func (*Client) GetRetained

func (c *Client) GetRetained() []mqtt.Message

func (*Client) Receive

func (c *Client) Receive() <-chan mqtt.Message

func (*Client) Send

func (c *Client) Send(topic string, qos byte, retained bool, payload interface{}) mqtt.Token

type RetainedKeeper

type RetainedKeeper struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*RetainedKeeper) GetAll

func (keeper *RetainedKeeper) GetAll() []mqtt.Message