sparrow/pkg/mqtt/provider.go

package mqtt

import (
	"github.com/gogf/gf/encoding/gjson"
	"sparrow/pkg/rpcs"
)

type Provider interface {
	ValidateDeviceToken(deviceid string, token []byte) error
	OnDeviceOnline(args rpcs.ArgsGetOnline) error
	OnDeviceOffline(deviceid string) error
	OnDeviceHeartBeat(deviceid string) error
	OnDeviceMessage(deviceid, vendorId string, msgtype string, message *gjson.Json)
}