messageapp

Documentation

Index

• type MessageApp
  • func NewMessageApp(dic *di.Container, ekuiperaddr string) *MessageApp
  • func (tmq *MessageApp) DeviceStatusToMessageBus(ctx context.Context, deviceId, deviceStatus string)
  • func (tmq *MessageApp) ThingModelMsgReport(ctx context.Context, msg dtos.ThingModelMessage) (*drivercommon.CommonResponse, error)

Types

type MessageApp

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

func NewMessageApp

func NewMessageApp(dic *di.Container, ekuiperaddr string) *MessageApp

func (*MessageApp) DeviceStatusToMessageBus

func (tmq *MessageApp) DeviceStatusToMessageBus(ctx context.Context, deviceId, deviceStatus string)

func (*MessageApp) ThingModelMsgReport

func (tmq *MessageApp) ThingModelMsgReport(ctx context.Context, msg dtos.ThingModelMessage) (*drivercommon.CommonResponse, error)