subDev

Documentation

Index

• Constants
• type Handle
• type InnerSubEvent
• type NatsClient
  • func (n *NatsClient) Subscribe(handle Handle) error
• type SubDev
  • func NewSubDev(c conf.EventConf) (SubDev, error)

Constants

const (
	ThingsDeliverGroup = "things_dm_group"
)

Types

type Handle

type Handle func(ctx context.Context) InnerSubEvent

type InnerSubEvent

type InnerSubEvent interface {
	// Thing 物模型消息
	Thing(out *deviceMsg.PublishMsg) error
	// SDKLog 设备调试日志
	SDKLog(out *deviceMsg.PublishMsg) error
	// Config 设备远程配置
	Config(out *deviceMsg.PublishMsg) error
	// Shadow 设备影子
	Shadow(out *deviceMsg.PublishMsg) error
	// Gateway 网关与子设备
	Gateway(out *deviceMsg.PublishMsg) error
	// Ota ota升级
	Ota(out *deviceMsg.PublishMsg) error
	// ext
	Ext(out *deviceMsg.PublishMsg) error

	Connected(out *deviceStatus.ConnectMsg) error
	Disconnected(out *deviceStatus.ConnectMsg) error
}

type NatsClient

type NatsClient struct {
	// contains filtered or unexported fields
}

func (*NatsClient) Subscribe

func (n *NatsClient) Subscribe(handle Handle) error

type SubDev

type SubDev interface {
	Subscribe(handle Handle) error
}

func NewSubDev

func NewSubDev(c conf.EventConf) (SubDev, error)