nsq

Documentation

Index

• func NewConsumer(c *config.Config, logger log.Logger) (mq.Consumer, error)
• func NewNsqConfigWithConfig(c *config.Config) *nsq.Config
• func NewProducer(c *config.Config, logger log.Logger) (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(c *config.Config, logger log.Logger) (mq.Consumer, error)

func NewNsqConfigWithConfig

func NewNsqConfigWithConfig(c *config.Config) *nsq.Config

func NewProducer

func NewProducer(c *config.Config, logger log.Logger) (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