pubDev

Documentation

Index

• type CompareMsg
• type NatsClient
  • func (n *NatsClient) PublishToDev(ctx context.Context, respMsg *deviceMsg.PublishMsg) error
  • func (n *NatsClient) ReqToDeviceSync(ctx context.Context, reqMsg *deviceMsg.PublishMsg, timeout time.Duration, ...) (payload []byte, err error)
  • func (n *NatsClient) ReqToDeviceSync2(ctx context.Context, reqMsg *deviceMsg.PublishMsg, compareMsg CompareMsg) ([]byte, error)
• type PubDev
  • func NewPubDev(fast *eventBus.FastEvent) (PubDev, error)

Types

type CompareMsg

type CompareMsg func(payload []byte) bool

type NatsClient

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

func (*NatsClient) PublishToDev

func (n *NatsClient) PublishToDev(ctx context.Context, respMsg *deviceMsg.PublishMsg) error

func (*NatsClient) ReqToDeviceSync

func (n *NatsClient) ReqToDeviceSync(ctx context.Context, reqMsg *deviceMsg.PublishMsg, timeout time.Duration, compareMsg CompareMsg) (
	payload []byte, err error)

func (*NatsClient) ReqToDeviceSync2

func (n *NatsClient) ReqToDeviceSync2(ctx context.Context, reqMsg *deviceMsg.PublishMsg, compareMsg CompareMsg) ([]byte, error)

type PubDev

type PubDev interface {
	PublishToDev(ctx context.Context, msg *deviceMsg.PublishMsg) error
	ReqToDeviceSync(ctx context.Context, reqMsg *deviceMsg.PublishMsg, timeout time.Duration, compareMsg CompareMsg) ([]byte, error)
}

func NewPubDev

func NewPubDev(fast *eventBus.FastEvent) (PubDev, error)