nsq

Documentation

Index

• func NewProducer(params ProducerParams, opts ...ProducerOption) producer.Producer
• func RegisterConsumer(params ConsumerParams, opts ...ConsumerOption) error
• type Config
• type ConsumerOption
  • func WithConsumerLogger(logger *zap.Logger) ConsumerOption
  • func WithConsumerMetrics(metrics *prometheus.ConsumerMetrics) ConsumerOption
  • func WithConsumerTracer(tracer opentracing.Tracer) ConsumerOption
• type ConsumerParams
• type ProducerOption
  • func WithProducerBreaker() ProducerOption
  • func WithProducerLogger(logger *zap.Logger) ProducerOption
  • func WithProducerMetrics(metrics *prometheus.ProducerMetrics) ProducerOption
  • func WithProducerRetry() ProducerOption
  • func WithProducerTracer(tracer opentracing.Tracer) ProducerOption
• type ProducerParams

Functions

func NewProducer

func NewProducer(params ProducerParams, opts ...ProducerOption) producer.Producer

NewProducer for NSQ.

func RegisterConsumer

func RegisterConsumer(params ConsumerParams, opts ...ConsumerOption) error

RegisterConsumer for NSQ.

Types

type Config

type Config struct {
	LookupHost string       `yaml:"lookup_host"`
	Host       string       `yaml:"host"`
	Retry      retry.Config `yaml:"retry"`
	UserAgent  string       `yaml:"user_agent"`
}

type ConsumerOption

type ConsumerOption interface {
	// contains filtered or unexported methods
}

ConsumerOption for NSQ.

func WithConsumerLogger

func WithConsumerLogger(logger *zap.Logger) ConsumerOption

WithConsumerLogger for NSQ.

func WithConsumerMetrics

func WithConsumerMetrics(metrics *prometheus.ConsumerMetrics) ConsumerOption

WithConsumerMetrics for NSQ.

func WithConsumerTracer

func WithConsumerTracer(tracer opentracing.Tracer) ConsumerOption

WithConsumerConfig for NSQ.

type ConsumerParams

type ConsumerParams struct {
	Lifecycle fx.Lifecycle

	Topic, Channel string
	Config         *Config
	Handler        handler.Handler
	Marshaller     marshaller.Marshaller
}

ConsumerParams for NSQ.

type ProducerOption

type ProducerOption interface {
	// contains filtered or unexported methods
}

ProducerOption for NSQ.

func WithProducerBreaker

func WithProducerBreaker() ProducerOption

WithProducerBreaker for NSQ.

func WithProducerLogger

func WithProducerLogger(logger *zap.Logger) ProducerOption

WithProducerLogger for NSQ.

func WithProducerMetrics

func WithProducerMetrics(metrics *prometheus.ProducerMetrics) ProducerOption

WithProducerMetrics for NSQ.

func WithProducerRetry

func WithProducerRetry() ProducerOption

WithProducerRetry for NSQ.

func WithProducerTracer

func WithProducerTracer(tracer opentracing.Tracer) ProducerOption

WithProducerConfig for NSQ.

type ProducerParams

type ProducerParams struct {
	Lifecycle fx.Lifecycle

	Config     *Config
	Marshaller marshaller.Marshaller
}

ProducerParams for NSQ.