north

Documentation

Index

• Constants
• func CacheMsg(cache cache.Cache, bucketName string, failMsg chan []byte)
• type ClientNorth
  • func CreateNorthClient(cfg config.Config, bucketName string) (*ClientNorth, error)
  • func (n *ClientNorth) ClearUselessData(deviceArray []string)
  • func (n *ClientNorth) DataConvertFuncRun(msg *link.SendMessage) error
  • func (n *ClientNorth) EnableCacheMsgSend(bucket string)
  • func (n *ClientNorth) MsgSend(ctx *comctx.Context, msg *link.SendMessage) error
  • func (n *ClientNorth) Offline(ctx *comctx.Context, node string, info *dm.DeviceInfo) error
  • func (n *ClientNorth) Online(ctx *comctx.Context, node string, info *dm.DeviceInfo) error
  • func (n *ClientNorth) ReportDeviceEvents(ctx *comctx.Context, node string, info *dm.DeviceInfo, report v1.EventReport) error
  • func (n *ClientNorth) ReportDeviceProperties(ctx *comctx.Context, node string, info *dm.DeviceInfo, report v1.Report, ...) error

Constants

const MQTTSystemConfig = "baetyl-system"

Functions

func CacheMsg

func CacheMsg(cache cache.Cache, bucketName string, failMsg chan []byte)

Types

type ClientNorth

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

func CreateNorthClient

func CreateNorthClient(cfg config.Config, bucketName string) (*ClientNorth, error)

func (*ClientNorth) ClearUselessData

func (n *ClientNorth) ClearUselessData(deviceArray []string)

func (*ClientNorth) DataConvertFuncRun

func (n *ClientNorth) DataConvertFuncRun(msg *link.SendMessage) error

func (*ClientNorth) EnableCacheMsgSend

func (n *ClientNorth) EnableCacheMsgSend(bucket string)

func (*ClientNorth) MsgSend

func (n *ClientNorth) MsgSend(ctx *comctx.Context, msg *link.SendMessage) error

func (*ClientNorth) Offline

func (n *ClientNorth) Offline(ctx *comctx.Context, node string, info *dm.DeviceInfo) error

func (*ClientNorth) Online

func (n *ClientNorth) Online(ctx *comctx.Context, node string, info *dm.DeviceInfo) error

func (*ClientNorth) ReportDeviceEvents

func (n *ClientNorth) ReportDeviceEvents(ctx *comctx.Context, node string, info *dm.DeviceInfo, report v1.EventReport) error

func (*ClientNorth) ReportDeviceProperties

func (n *ClientNorth) ReportDeviceProperties(ctx *comctx.Context, node string, info *dm.DeviceInfo, report v1.Report, topic string) error