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) 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) 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
	DeviceThingEventReport(ctx context.Context, msg application.EventReport) error
}

func NewPubApp

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