lib

Documentation

Index

• Constants
• type Device
  • func (d *Device) GetConfigFromFile(filename string)
  • func (d *Device) Listen()
• type MQTT
  • func (b *MQTT) Connect()
  • func (b *MQTT) MqttHandlerJSON(channel string) func(client mqtt.Client, message mqtt.Message)
  • func (b *MQTT) Subscribe(channel string)

Constants

const (
	DeviceETPrefix          = "$hw/events/device/"
	TwinETUpdateSuffix      = "/twin/update"
	TwinETUpdateDeltaSuffix = "/twin/update/delta"
)

Types

type Device

type Device struct {
	Type     string `yaml:"type"`
	Model    string `yaml:"model"`
	Launcher string `yaml:"launchers"`
	MQTT     MQTT   `yaml:"broker"`
	Path     string `yaml:"sourcepath"`
	DeviceID string `yaml:"DeviceID"`
	// Channel used to kill a running app
	Stop chan string
	// contains filtered or unexported fields
}

Device Type

func (*Device) GetConfigFromFile

func (d *Device) GetConfigFromFile(filename string)

Function used to parse a yaml file to a Device configuration

func (*Device) Listen

func (d *Device) Listen()

Function that initialise the Mapper and keep it open.

type MQTT

type MQTT struct {
	BrokerHost string `yaml:"host"`
	BrokerPort string `yaml:"port"`
	Topic      string `yaml:"topic"`
	Client     mqtt.Client
	ID         string
	Action     func(mqtt.Message, mqtt.Client, string)
}

func (*MQTT) Connect

func (b *MQTT) Connect()

func (*MQTT) MqttHandlerJSON

func (b *MQTT) MqttHandlerJSON(channel string) func(client mqtt.Client, message mqtt.Message)

Action made when the device receive a message from the specified Topic

func (*MQTT) Subscribe

func (b *MQTT) Subscribe(channel string)