zap

Documentation

Index

• type Consumer
  • func NewConsumer(topic, channel string, logger *zap.Logger, handler nsq.Consumer) *Consumer
  • func (h *Consumer) Consume(ctx context.Context, message *nsq.Message) error
• type Producer
  • func NewProducer(logger *zap.Logger, producer nsq.Producer) *Producer
  • func (p *Producer) Produce(ctx context.Context, topic string, message *nsq.Message) error

Types

type Consumer

type Consumer struct {
	nsq.Consumer
	// contains filtered or unexported fields
}

Consumer for zap.

func NewConsumer

func NewConsumer(topic, channel string, logger *zap.Logger, handler nsq.Consumer) *Consumer

NewConsumer for zap.

func (*Consumer) Consume

func (h *Consumer) Consume(ctx context.Context, message *nsq.Message) error

type Producer

type Producer struct {
	nsq.Producer
	// contains filtered or unexported fields
}

Producer for zap.

func NewProducer

func NewProducer(logger *zap.Logger, producer nsq.Producer) *Producer

NewProducer for zap.

func (*Producer) Produce

func (p *Producer) Produce(ctx context.Context, topic string, message *nsq.Message) error