mqtt

Documentation

Index

• func NewConsumer(cfg *mqtt.ClientOptions, logger log.Logger) (mq.Consumer, error)
• func NewProducer(cfg *mqtt.ClientOptions) (mq.Producer, error)
• type ConsumerImpl
  • func (x *ConsumerImpl) Close(ctx context.Context) error
  • func (x *ConsumerImpl) Subscribe(ctx context.Context, topic string, channel string) (<-chan mq.Message, error)
• type ProducerImpl
  • func (x *ProducerImpl) Close(ctx context.Context) error
  • func (x *ProducerImpl) Publish(ctx context.Context, topic string, message mq.Message) error

Functions

func NewConsumer

func NewConsumer(cfg *mqtt.ClientOptions, logger log.Logger) (mq.Consumer, error)

func NewProducer

func NewProducer(cfg *mqtt.ClientOptions) (mq.Producer, error)

Types

type ConsumerImpl

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

func (*ConsumerImpl) Close

func (x *ConsumerImpl) Close(ctx context.Context) error

func (*ConsumerImpl) Subscribe

func (x *ConsumerImpl) Subscribe(ctx context.Context, topic string, channel string) (<-chan mq.Message, error)

type ProducerImpl

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

func (*ProducerImpl) Close

func (x *ProducerImpl) Close(ctx context.Context) error

func (*ProducerImpl) Publish

func (x *ProducerImpl) Publish(ctx context.Context, topic string, message mq.Message) error