Documentation
¶
Index ¶
- type HassClient
- func (c *HassClient) Connect(lwt MqttMessage) error
- func (c *HassClient) Disconnect()
- func (c *HassClient) Publish(message MqttMessage) mqtt.Token
- func (c *HassClient) PublishAutoDiscovery(entity model.HassAutoDiscoverable) (mqtt.Token, error)
- func (c *HassClient) Subscribe(topic string, handler MessageHandler)
- type MessageHandler
- type MqttMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HassClient ¶
type HassClient struct {
Namespace string // prefix all MQTT topics with this NS
Device *model.HassDevice
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(namespace string, device *model.HassDevice) *HassClient
func (*HassClient) Connect ¶
func (c *HassClient) Connect(lwt MqttMessage) error
func (*HassClient) Disconnect ¶
func (c *HassClient) Disconnect()
func (*HassClient) Publish ¶
func (c *HassClient) Publish(message MqttMessage) mqtt.Token
func (*HassClient) PublishAutoDiscovery ¶
func (c *HassClient) PublishAutoDiscovery(entity model.HassAutoDiscoverable) (mqtt.Token, error)
func (*HassClient) Subscribe ¶
func (c *HassClient) Subscribe(topic string, handler MessageHandler)
type MessageHandler ¶
type MqttMessage ¶
type MqttMessage struct {
// contains filtered or unexported fields
}
func MakeMqttMessage ¶
func MakeMqttMessage(topic string, payload string) MqttMessage
func (MqttMessage) Qos ¶
func (m MqttMessage) Qos(qos byte) MqttMessage
func (MqttMessage) Retained ¶
func (m MqttMessage) Retained() MqttMessage
Source Files
Click to show internal directories.
Click to hide internal directories.