deviceshifumqtt

Documentation

Index

• Constants
• type DeviceCommandHandlerMQTT
• type DeviceShifu
  • func New(deviceShifuMetadata *deviceshifubase.DeviceShifuMetaData) (*DeviceShifu, error)
  • func (ds *DeviceShifu) Start(stopCh <-chan struct{}) error
  • func (ds *DeviceShifu) Stop() error
• type HandlerMetaData
• type ReturnBody

Constants

const (
	MqttDataEndpoint          string = "mqtt_data"
	DefaultUpdateIntervalInMS int64  = 3000
)

Str and default value

Types

type DeviceCommandHandlerMQTT

type DeviceCommandHandlerMQTT struct {
	// client                         *rest.RESTClient
	HandlerMetaData *HandlerMetaData
}

DeviceCommandHandlerMQTT handler for Mqtt

type DeviceShifu

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

DeviceShifu implemented from deviceshifuBase

func New

func New(deviceShifuMetadata *deviceshifubase.DeviceShifuMetaData) (*DeviceShifu, error)

New new MQTT Deviceshifu

func (*DeviceShifu) Start

func (ds *DeviceShifu) Start(stopCh <-chan struct{}) error

Start start Mqtt Telemetry

func (*DeviceShifu) Stop

func (ds *DeviceShifu) Stop() error

Stop Stop Http Server

type HandlerMetaData

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

HandlerMetaData MetaData for EdgeDevice Setting

type ReturnBody

type ReturnBody struct {
	MQTTMessage   string `json:"mqtt_message"`
	MQTTTimestamp string `json:"mqtt_receive_timestamp"`
}

ReturnBody Body of mqtt's reply