deviceSub

Documentation

Index

• type DeviceSubServer
  • func NewDeviceSubServer(svcCtx *svc.ServiceContext, ctx context.Context) *DeviceSubServer
  • func (s *DeviceSubServer) Connected(info *devices.DevConn) error
  • func (s *DeviceSubServer) Disconnected(info *devices.DevConn) error
  • func (s *DeviceSubServer) ExtMsg(topic string, payload []byte) error
  • func (s *DeviceSubServer) Msg(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) Connected

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

func (*DeviceSubServer) Disconnected

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

func (*DeviceSubServer) ExtMsg

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

func (*DeviceSubServer) Msg

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

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