downlink

Documentation

Index

• func Init(fetchSize int, idleTime time.Duration)
• type MessageDownLinkEngine
  • func GetInstance() *MessageDownLinkEngine

Functions

func Init

func Init(fetchSize int, idleTime time.Duration)

Types

type MessageDownLinkEngine

type MessageDownLinkEngine interface {
	StartDownLink()
	SaveMessage(data model.EventPayload) error                                                     // 保存消息
	ActiveDelayedMessage(appId string, deviceId string)                                            // 激活消息,准备发送
	PullDelayedMessage(appId string, deviceId string) (eventPayload model.EventPayload, err error) // 查询设备消息
	CloseExpiredDelayedMessages()                                                                  // 关闭过期的消息
}

func GetInstance

func GetInstance() *MessageDownLinkEngine