subApp

Documentation

Index

• Constants
• type AppSubEvent
• type Handle
• type NatsClient
  • func (n *NatsClient) Subscribe(handle Handle) error
• type SubApp
  • func NewSubApp(c conf.EventConf) (SubApp, error)

Constants

const (
	ThingsDeliverGroup = "things_rule_group"
)

Types

type AppSubEvent

type AppSubEvent interface {
	// DeviceEventReport 设备事件上报
	DeviceEventReport(out *application.EventReport) error
	// DevicePropertyReport 设备属性上报
	DevicePropertyReport(out *application.PropertyReport) error
	// DeviceStatusConnected 设备连接状态上报
	DeviceStatusConnected(out *application.ConnectMsg) error
	// DeviceStatusDisConnected 设备离线上报
	DeviceStatusDisConnected(out *application.ConnectMsg) error
}

type Handle

type Handle func(ctx context.Context) AppSubEvent

type NatsClient

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

func (*NatsClient) Subscribe

func (n *NatsClient) Subscribe(handle Handle) error

type SubApp

type SubApp interface {
	Subscribe(handle Handle) error
}

func NewSubApp

func NewSubApp(c conf.EventConf) (SubApp, error)