pubInner

Documentation

Index

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

Types

type ConnType

type ConnType int8

const (
	Connect ConnType = iota
	DisConnect
)

type NatsJsClient

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

func (*NatsJsClient) DevPubConfig

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

func (*NatsJsClient) DevPubGateway

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

func (*NatsJsClient) DevPubMsg

func (n *NatsJsClient) DevPubMsg(ctx context.Context, publishMsg *devices.DevPublish) error

func (*NatsJsClient) DevPubOta

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

func (*NatsJsClient) DevPubSDKLog

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

func (*NatsJsClient) DevPubShadow

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

func (*NatsJsClient) DevPubThing

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

func (*NatsJsClient) PubConn

func (n *NatsJsClient) 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, protocolCode string, nodeID int64) (PubInner, error)