topics

package
v1.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 14, 2025 License: AGPL-3.0 Imports: 0 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ServerCacheKeyDmProduct           = "cache:dm:product"
	ServerCacheKeyDmDevice            = "cache:dm:device"
	ServerCacheKeyDmProductSchema     = "cache:dm:product:schema"
	ServerCacheKeyDmDeviceSchema      = "cache:dm:device:schema"
	ServerCacheKeyDmUserShareDevice   = "cache:dm:user:share:device"
	ServerCacheKeyDmMultiDevicesShare = "cache:dm:user:multishare:devices"
	ServerCacheKeyDmDeviceBindToken   = "cache:dm:user:deviceBind:token"
)
View Source
const (
	DeviceUpMsg = "device.up.%s.%s.%s"
	DeviceUpAll = "device.up.>"
	//第一个参数是协议code,第二个参数是handle,第三和第四个参数是产品id和设备名
	DeviceDownMsg = "device.down.%s.%s.%s.%s"
	// DeviceDownAll dd模块订阅以下topic,收到内部的发布消息后向设备推送
	DeviceDownAll = "device.down.%s.>"

	// DeviceUpThing 物模型 最后两个是产品id和设备名称
	DeviceUpThing      = "device.up.thing.%s.%s"
	DeviceUpThingAll   = "device.up.thing.>"
	DeviceDownThing    = "device.down.thing.%s.%s"
	DeviceDownThingAll = "device.down.thing.>"
	// DeviceUpGateway 网关与子设备 最后两个是产品id和设备名称
	DeviceUpGateway      = "device.up.gateway.%s.%s"
	DeviceUpGatewayAll   = "device.up.gateway.>"
	DeviceDownGateway    = "device.down.gateway.%s.%s"
	DeviceDownGatewayAll = "device.down.gateway.>"

	// DeviceUpOta ota升级相关 最后两个是产品id和设备名称
	DeviceUpOta      = "device.up.ota.%s.%s"
	DeviceUpOtaAll   = "device.up.ota.>"
	DeviceDownOta    = "device.down.ota.%s.%s"
	DeviceDownOtaAll = "device.down.ota.>"
	// DeviceUpShadow 设备影子  最后两个是产品id和设备名称
	DeviceUpShadow      = "device.up.shadow.%s.%s"
	DeviceUpShadowAll   = "device.up.shadow.>"
	DeviceDownShadow    = "device.down.shadow.%s.%s"
	DeviceDownShadowAll = "device.down.shadow.>"
	// DeviceUpConfig 设备远程配置 最后两个是产品id和设备名称
	DeviceUpConfig      = "device.up.config.%s.%s"
	DeviceUpConfigAll   = "device.up.config.>"
	DeviceDownConfig    = "device.down.config.%s.%s"
	DeviceDownConfigAll = "device.down.config.>"
	// DeviceUpSDKLog 设备调试日志 最后两个是产品id和设备名称
	DeviceUpSDKLog      = "device.up.log.%s.%s"
	DeviceUpSDKLogAll   = "device.up.log.>"
	DeviceDownSdkLog    = "device.down.log.%s.%s"
	DeviceDownSDKLogAll = "device.down.log.>"

	// DeviceUpExt ext模块(包含ntp) 最后两个是产品id和设备名称
	DeviceUpExt    = "device.up.ext.%s.%s"
	DeviceUpExtAll = "device.up.ext.>"

	// DeviceUpStatusConnected 设备登录后向内部推送以下topic
	DeviceUpStatusConnected = "device.up.status.connected"
	// DeviceUpStatusDisconnected 设备的登出后向内部推送以下topic
	DeviceUpStatusDisconnected = "device.up.status.disconnected"
	DeviceUpStatus             = "device.up.status.>"

	// DeviceDownStatusConnected 设备在线状态修复,第一个参数是协议coe
	DeviceDownStatusConnected = "device.down.%s.status.fix"
)
View Source
const (
	DmDeviceInfoUnbind         = "server.things.dm.device.info.unbind"
	DmDeviceInfoCreate         = "server.things.dm.device.info.create"
	DmDeviceInfoDelete         = "server.things.dm.device.info.delete"
	DmDeviceOnlineStatusChange = "server.things.dm.device.onlineStatus.change"
	DmDeviceStaticOneHour      = "server.things.dm.device.static.2Hour"     //2小时统计
	DmDeviceStaticHalfHour     = "server.things.dm.device.static.halfHour"  //半小时统计
	DmDeviceStaticOneMinute    = "server.things.dm.device.static.oneMinute" //1分钟统计
	DmProductInfoCreate        = "server.things.dm.product.info.create"
	DmProductInfoUpdate        = "server.things.dm.product.info.update"
	DmProductInfoDelete        = "server.things.dm.product.info.delete"
	DmProductCustomUpdate      = "server.things.dm.product.custom.update"   //产品脚本有更新
	DmOtaDeviceUpgradePush     = "server.things.dm.ota.device.upgrade.push" //ota设备推送
	DmOtaJobDelayRun           = "server.things.dm.ota.job.delay.run"       //任务延时启动
	// DmProtocolInfoUpdate 中间的是协议code
	DmProtocolInfoUpdate  = "server.things.dm.protocol.%s.update" //自定义协议配置有更新
	UdRuleTimer           = "server.things.ud.rule.timer"
	UdRuleTimerTenMinutes = "server.things.ud.rule.timer.tenMinutes"

	//最后一个参数是告警模式
	UdRuleAlarmNotify = "server.things.ud.rule.alarm.%s" //trigger:触发告警 relieve:解除告警
	DgOnlineTimer     = "server.things.dg.online.timer"
	PAliTimer         = "server.things.pali.data.timer"

	DmActionCheckDelay = "server.things.dm.action.check.delay"
)
View Source
const (
	// ApplicationDeviceStatusConnected 设备登录状态推送 中间两个是产品id和设备名称
	ApplicationDeviceStatusConnected = "application.device.%s.%s.status.connected"
	// ApplicationDeviceStatusDisConnected 设备登出状态推送 中间两个是产品id和设备名称
	ApplicationDeviceStatusDisConnected = "application.device.%s.%s.status.disconnected"
	// ApplicationDeviceReportThingProperty 设备物模型属性上报通知 中间两个是产品id和设备名称,最后一个是属性id
	ApplicationDeviceReportThingProperty   = "application.device.%s.%s.report.thing.property.%s"
	ApplicationDeviceReportThingPropertyV2 = "application.v2.device.%s.%s.report.thing.property"
	// ApplicationDeviceReportThingEvent 设备物模型事件上报通知 中间两个是产品id和设备名称,最后两个是事件类型和事件id
	ApplicationDeviceReportThingEvent = "application.device.%s.%s.report.thing.event.%s.%s"
	// ApplicationDeviceReportThingAction 设备物模型事件上报通知 中间两个是产品id和设备名称,最后三个是actionID,请求类型(req resp)和调用方向
	ApplicationDeviceReportThingAction = "application.device.%s.%s.report.thing.action.%s.%s.%s"
	// ApplicationDeviceReportThingPropertyDevice 设备物模型属性上报通知 中间两个是产品id和设备名称
	ApplicationDeviceReportThingPropertyDevice = "application.device.%s.%s.report.thing.property"

	ApplicationDeviceReportThingEventAllDevice    = "application.device.*.*.report.thing.event.>"
	ApplicationDeviceReportThingPropertyAllDevice = "application.device.*.*.report.thing.property.>"
	ApplicationDeviceStatusConnectedAllDevice     = "application.device.*.*.status.connected"
	ApplicationDeviceStatusDisConnectedAllDevice  = "application.device.*.*.status.disconnected"
	ApplicationDeviceStatusAllDevice              = "application.device.*.*.status.>"
)

应用事件通知(设备状态变化,设备上报)

Variables

This section is empty.

Functions

This section is empty.

Types

This section is empty.

Jump to

Keyboard shortcuts

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