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) DevPubMsg(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) DevPubMsg

func (n *NatsClient) DevPubMsg(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 {
	DevPubMsg(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)