Documentation ¶
Index ¶
- func NewFromSourceConfig(g config.Generic) (s api.Source, err error)
- func NewFromTargetConfig(g config.Generic) (t api.Target, err error)
- func NewMqttClientOptions(url string, user string, password string) *mqtt.ClientOptions
- func ServerFromClient(client mqtt.Client) string
- func StripTrailingSlash(s string) string
- type Connector
- type Publisher
- type Subscriber
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFromSourceConfig ¶
NewFromSourceConfig creates MQTT data source
func NewFromTargetConfig ¶
NewFromTargetConfig creates MQTT data target
func NewMqttClientOptions ¶
func NewMqttClientOptions(url string, user string, password string) *mqtt.ClientOptions
func ServerFromClient ¶
func StripTrailingSlash ¶
Types ¶
type Publisher ¶
type Publisher struct { *Connector // contains filtered or unexported fields }
Publisher is the MQTT data target
func NewPublisher ¶
func NewPublisher(name string, topic string, mqttOptions *mqtt.ClientOptions) *Publisher
NewPublisher creates MQTT data target
type Subscriber ¶
type Subscriber struct { *Connector // contains filtered or unexported fields }
Subscriber is the MQTT data source
func NewSubscriber ¶
func NewSubscriber(name string, rootTopic string, mqttOptions *mqtt.ClientOptions) *Subscriber
NewSubscriber creates MQTT data source
Click to show internal directories.
Click to hide internal directories.