data

Documentation

Index

• Constants
• Variables
• func OnSubMessageReceived(client MQTT.Client, message MQTT.Message)
• type Client
  • func (mq *Client) InitSubClient()

Constants

const UploadTopic = "SYS/dis/upload_records"

Variables

var (
	// MQTTHub client
	MQTTHub *Client
	// GroupID stands for group id
	GroupID string
	// ConnectedTopic to send connect event
	ConnectedTopic = "$hw/events/connected/%s"
	// DisconnectedTopic to send disconnect event
	DisconnectedTopic = "$hw/events/disconnected/%s"
	// MemberGet to get membership device
	MemberGet = "$hw/events/edgeGroup/%s/membership/get"
	// MemberGetRes to get membership device
	MemberGetRes = "$hw/events/edgeGroup/%s/membership/get/result"
	// MemberDetail which edge-client should be pub when service start
	MemberDetail = "$hw/events/edgeGroup/%s/membership/detail"
	// MemberDetailRes MemberDetail topic resp
	MemberDetailRes = "$hw/events/edgeGroup/%s/membership/detail/result"
	// MemberUpdate updating of the twin
	MemberUpdate = "$hw/events/edgeGroup/%s/membership/updated"
	// GroupUpdate updates a edgegroup
	GroupUpdate = "$hw/events/edgeGroup/%s/updated"
	// GroupAuthGet get temperary aksk from cloudhub
	GroupAuthGet = "$hw/events/edgeGroup/%s/authInfo/get"
	// GroupAuthGetRes temperary aksk from cloudhub
	GroupAuthGetRes = "$hw/events/edgeGroup/%s/authInfo/get/result"
	// SubTopics which edge-client should be sub
	SubTopics = []string{
		"$hw/events/upload/#",
		"$hw/events/device/+/state/update",
		"$hw/events/device/+/twin/+",
		"$hw/events/node/+/membership/get",
		UploadTopic,
	}
)

Functions

func OnSubMessageReceived

func OnSubMessageReceived(client MQTT.Client, message MQTT.Message)

OnSubMessageReceived msg received callback

Types

type Client

type Client struct {
	MQTTUrl string
	// 由于我们只需要从broker中拿数据，所以只要定义一个subclient
	//PubCli  MQTT.Client
	SubCli MQTT.Client
}

Client struct

func (*Client) InitSubClient

func (mq *Client) InitSubClient()

InitSubClient init sub client