event

Documentation

Index

• type DeviceSubServer
  • func NewDeviceSubServer(svcCtx *svc.ServiceContext, ctx context.Context) *DeviceSubServer
  • func (s *DeviceSubServer) Config(topic string, payload []byte) error
  • func (s *DeviceSubServer) Connected(info *devices.DevConn) error
  • func (s *DeviceSubServer) Disconnected(info *devices.DevConn) error
  • func (s *DeviceSubServer) Gateway(topic string, payload []byte) error
  • func (s *DeviceSubServer) Ota(topic string, payload []byte) error
  • func (s *DeviceSubServer) SDKLog(topic string, payload []byte) error
  • func (s *DeviceSubServer) Shadow(topic string, payload []byte) error
  • func (s *DeviceSubServer) Thing(topic string, payload []byte) error
• type InnerSubServer
  • func NewInnerSubServer(svcCtx *svc.ServiceContext, ctx context.Context) *InnerSubServer
  • func (s *InnerSubServer) PublishToDev(topic string, payload []byte) error

Types

type DeviceSubServer

type DeviceSubServer struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewDeviceSubServer

func NewDeviceSubServer(svcCtx *svc.ServiceContext, ctx context.Context) *DeviceSubServer

func (*DeviceSubServer) Config

func (s *DeviceSubServer) Config(topic string, payload []byte) error

Config 设备远程配置

func (*DeviceSubServer) Connected

func (s *DeviceSubServer) Connected(info *devices.DevConn) error

func (*DeviceSubServer) Disconnected

func (s *DeviceSubServer) Disconnected(info *devices.DevConn) error

func (*DeviceSubServer) Gateway

func (s *DeviceSubServer) Gateway(topic string, payload []byte) error

Log 设备调试日志

func (*DeviceSubServer) Ota

func (s *DeviceSubServer) Ota(topic string, payload []byte) error

Ota ota远程升级

func (*DeviceSubServer) SDKLog

func (s *DeviceSubServer) SDKLog(topic string, payload []byte) error

Log 设备调试日志

func (*DeviceSubServer) Shadow

func (s *DeviceSubServer) Shadow(topic string, payload []byte) error

Shadow 设备影子

func (*DeviceSubServer) Thing

func (s *DeviceSubServer) Thing(topic string, payload []byte) error

Thing 设备发布物模型消息的信息通过nats转发给内部服务

type InnerSubServer

type InnerSubServer struct {
	logx.Logger
	// contains filtered or unexported fields
}

func NewInnerSubServer

func NewInnerSubServer(svcCtx *svc.ServiceContext, ctx context.Context) *InnerSubServer

func (*InnerSubServer) PublishToDev

func (s *InnerSubServer) PublishToDev(topic string, payload []byte) error