pubApp

Documentation

Index

• type NatsClient
  • func (n *NatsClient) DeviceStatusConnected(ctx context.Context, msg application.ConnectMsg) error
  • func (n *NatsClient) DeviceStatusDisConnected(ctx context.Context, msg application.ConnectMsg) error
  • func (n *NatsClient) DeviceThingActionReport(ctx context.Context, msg application.ActionReport) error
  • func (n *NatsClient) DeviceThingEventReport(ctx context.Context, msg application.EventReport) error
  • func (n *NatsClient) DeviceThingPropertyReport(ctx context.Context, msg application.PropertyReport) error
• type PubApp
  • func NewPubApp(c conf.EventConf) (PubApp, error)

Types

type NatsClient

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

func (*NatsClient) DeviceStatusConnected

func (n *NatsClient) DeviceStatusConnected(ctx context.Context, msg application.ConnectMsg) error

func (*NatsClient) DeviceStatusDisConnected

func (n *NatsClient) DeviceStatusDisConnected(ctx context.Context, msg application.ConnectMsg) error

func (*NatsClient) DeviceThingActionReport

func (n *NatsClient) DeviceThingActionReport(ctx context.Context, msg application.ActionReport) error

func (*NatsClient) DeviceThingEventReport

func (n *NatsClient) DeviceThingEventReport(ctx context.Context, msg application.EventReport) error

func (*NatsClient) DeviceThingPropertyReport

func (n *NatsClient) DeviceThingPropertyReport(ctx context.Context, msg application.PropertyReport) error

应用事件通知-设备物模型属性上报通知

type PubApp

type PubApp interface {
	DeviceStatusConnected(ctx context.Context, msg application.ConnectMsg) error
	DeviceStatusDisConnected(ctx context.Context, msg application.ConnectMsg) error
	//应用事件通知-设备物模型属性上报通知
	DeviceThingPropertyReport(ctx context.Context, msg application.PropertyReport) error
	DeviceThingActionReport(ctx context.Context, msg application.ActionReport) error
	DeviceThingEventReport(ctx context.Context, msg application.EventReport) error
}

func NewPubApp

func NewPubApp(c conf.EventConf) (PubApp, error)