deviceshifumqtt

Documentation

Index

• Constants
• Variables
• func ConfigFiniteStateMachine(minsts map[string]string)
• func MutexProcess(topic string, message string)
• 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 MQTTInstruction
• type MQTTInstructions
  • func CreateMQTTInstructions(dsInstructions *deviceshifubase.DeviceShifuInstructions) *MQTTInstructions
• type MQTTProtocolProperty
• type RequestBody
• type ReturnBody

Constants

const (
	DefaultUpdateIntervalInMS int64 = 3000
)

Str and default value

Variables

var (
	MQTTTopic string
)

Functions

func ConfigFiniteStateMachine

func ConfigFiniteStateMachine(minsts map[string]string)

func MutexProcess

func MutexProcess(topic string, message string)

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 MQTTInstruction

type MQTTInstruction struct {
	MQTTProtocolProperty *MQTTProtocolProperty
}

MQTTInstruction MQTT Instruction

type MQTTInstructions

type MQTTInstructions struct {
	Instructions map[string]*MQTTInstruction
}

MQTTInstructions MQTT Instructions

func CreateMQTTInstructions

func CreateMQTTInstructions(dsInstructions *deviceshifubase.DeviceShifuInstructions) *MQTTInstructions

CreateMQTTInstructions Create MQTT Instructions

type MQTTProtocolProperty

type MQTTProtocolProperty struct {
	MQTTTopic string
}

MQTTProtocolProperty MQTT Instruction's Property

type RequestBody

type RequestBody string

RequestBody Body of mqtt's request by POST method

type ReturnBody

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

ReturnBody Body of mqtt's reply