pubInner

Documentation

Index

• type ConnType
• type NatsClient
  • func (n *NatsClient) DevPubConfig(ctx context.Context, publishMsg *devices.DevPublish) error
  • func (n *NatsClient) DevPubGateway(ctx context.Context, publishMsg *devices.DevPublish) error
  • func (n *NatsClient) DevPubOta(ctx context.Context, publishMsg *devices.DevPublish) error
  • func (n *NatsClient) DevPubSDKLog(ctx context.Context, publishMsg *devices.DevPublish) error
  • func (n *NatsClient) DevPubShadow(ctx context.Context, publishMsg *devices.DevPublish) error
  • func (n *NatsClient) DevPubThing(ctx context.Context, publishMsg *devices.DevPublish) error
  • func (n *NatsClient) PubConn(ctx context.Context, conn ConnType, info *devices.DevConn) error
• type PubInner
  • func NewPubInner(c conf.EventConf) (PubInner, error)

Types

type ConnType

type ConnType int8

const (
	Connect ConnType = iota
	DisConnect
)

type NatsClient

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

func (*NatsClient) DevPubConfig

func (n *NatsClient) DevPubConfig(ctx context.Context, publishMsg *devices.DevPublish) error

func (*NatsClient) DevPubGateway

func (n *NatsClient) DevPubGateway(ctx context.Context, publishMsg *devices.DevPublish) error

func (*NatsClient) DevPubOta

func (n *NatsClient) DevPubOta(ctx context.Context, publishMsg *devices.DevPublish) error

func (*NatsClient) DevPubSDKLog

func (n *NatsClient) DevPubSDKLog(ctx context.Context, publishMsg *devices.DevPublish) error

func (*NatsClient) DevPubShadow

func (n *NatsClient) DevPubShadow(ctx context.Context, publishMsg *devices.DevPublish) error

func (*NatsClient) DevPubThing

func (n *NatsClient) DevPubThing(ctx context.Context, publishMsg *devices.DevPublish) error

func (*NatsClient) PubConn

func (n *NatsClient) PubConn(ctx context.Context, conn ConnType, info *devices.DevConn) error

type PubInner

type PubInner interface {
	// DevPubThing 向内部发布设备发布的物模型消息
	DevPubThing(ctx context.Context, publishMsg *devices.DevPublish) error
	// DevPubOta 发布ota升级相关消息
	DevPubOta(ctx context.Context, publishMsg *devices.DevPublish) error
	// DevPubShadow 发布设备影子消息
	DevPubShadow(ctx context.Context, publishMsg *devices.DevPublish) error
	// DevPubSDKLog 发布设备调试日志
	DevPubSDKLog(ctx context.Context, publishMsg *devices.DevPublish) error
	// DevPubGateway 发布网关子设备消息
	DevPubGateway(ctx context.Context, publishMsg *devices.DevPublish) error
	// DevPubConfig 发布设备配置相关消息
	DevPubConfig(ctx context.Context, publishMsg *devices.DevPublish) error
	// PubConn 向内部发布连接及断连消息
	PubConn(ctx context.Context, conn ConnType, info *devices.DevConn) error
}

func NewPubInner

func NewPubInner(c conf.EventConf) (PubInner, error)