deviceshifumqtt

package

v0.42.0 Latest Latest Go to latest Published: Apr 15, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	DefaultUpdateIntervalInMS int64 = 3000
)

Str and default value

View Source

var (
	MQTTTopic string
)

func ConfigFiniteStateMachine(minsts map[string]string)

func MutexProcess(topic string, message string)

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

DeviceCommandHandlerMQTT handler for Mqtt

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

DeviceShifu implemented from deviceshifuBase

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

New new MQTT Deviceshifu

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

Start start Mqtt Telemetry

func (ds *DeviceShifu) Stop() error

Stop Stop Http Server

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

HandlerMetaData MetaData for EdgeDevice Setting

type MQTTInstruction struct {
	MQTTProtocolProperty *MQTTProtocolProperty
}

MQTTInstruction MQTT Instruction

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

MQTTInstructions MQTT Instructions

func CreateMQTTInstructions(dsInstructions *deviceshifubase.DeviceShifuInstructions) *MQTTInstructions

CreateMQTTInstructions Create MQTT Instructions

type MQTTProtocolProperty struct {
	MQTTTopic string
}

MQTTProtocolProperty MQTT Instruction's Property

type RequestBody string

RequestBody Body of mqtt's request by POST method

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

ReturnBody Body of mqtt's reply