service

package

v0.0.0-...-67d91c4 Latest Latest Go to latest Published: Jun 2, 2022 License: MIT 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

Repository

github.com/mangenotwork/extras

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL