service

Documentation

Index

• func Interactive(data *model.CmdData, client model.Client) (device *model.Device)
• func Into(client model.Client, deviceId string) (device *model.Device)
• func NewTopic(topicName string) (err error)
• func TopicAddDevice(topicName, device string) (err error)
• func TopicDelDevice(topicName, device string) (err error)
• func TopicDisconnectionDevice(topicName string) (err error)
• func TopicIsHave(topicName string) bool
• func TopicSend(topicName, msg string) (err error)
• type GetTopicSendBody
  • func GetTopicSend(topicName string, page, limit int64) (data *GetTopicSendBody, err error)
• type TopicMsgData

Functions

func Interactive

func Interactive(data *model.CmdData, client model.Client) (device *model.Device)

func Into

func Into(client model.Client, deviceId string) (device *model.Device)

func NewTopic

func NewTopic(topicName string) (err error)

func TopicAddDevice

func TopicAddDevice(topicName, device string) (err error)

func TopicDelDevice

func TopicDelDevice(topicName, device string) (err error)

func TopicDisconnectionDevice

func TopicDisconnectionDevice(topicName string) (err error)

func TopicIsHave

func TopicIsHave(topicName string) bool

func TopicSend

func TopicSend(topicName, msg string) (err error)

Types

type GetTopicSendBody

type GetTopicSendBody struct {
	List  []*TopicMsgData `json:"list"`
	Count int64           `json:"count"`
	Page  int64           `json:"page"`
	Limit int64           `json:"limit"`
}

返回的 获取推送数据

func GetTopicSend

func GetTopicSend(topicName string, page, limit int64) (data *GetTopicSendBody, err error)

获取推送数据

type TopicMsgData

type TopicMsgData struct {
	Message  string `bson:"message"`
	SendTime string `bson:"send_time"`
}