nsq

Documentation

Index

• func NewProducer(lc fx.Lifecycle, cfg *Config, m marshaller.Marshaller, opts ...ProducerOption) (producer.Producer, error)
• func RegisterConsumer(lc fx.Lifecycle, topic, channel string, cfg *Config, h handler.Handler, ...) error
• type Config
• type ConsumerOption
  • func WithConsumerLogger(logger *zap.Logger) ConsumerOption
  • func WithConsumerMetrics(meter metric.Meter) ConsumerOption
  • func WithConsumerTracer(tracer ntracer.Tracer) ConsumerOption
• type ProducerOption
  • func WithProducerBreaker() ProducerOption
  • func WithProducerLogger(logger *zap.Logger) ProducerOption
  • func WithProducerMetrics(meter metric.Meter) ProducerOption
  • func WithProducerRetry() ProducerOption
  • func WithProducerTracer(tracer ntracer.Tracer) ProducerOption

Functions

func NewProducer

func NewProducer(lc fx.Lifecycle, cfg *Config, m marshaller.Marshaller, opts ...ProducerOption) (producer.Producer, error)

NewProducer for NSQ.

func RegisterConsumer

func RegisterConsumer(lc fx.Lifecycle, topic, channel string, cfg *Config, h handler.Handler, m marshaller.Marshaller, opts ...ConsumerOption) error

RegisterConsumer for NSQ.

Types

type Config

type Config struct {
	LookupHost string       `yaml:"lookup_host" json:"lookup_host" toml:"lookup_host"`
	Host       string       `yaml:"host" json:"host" toml:"host"`
	Retry      retry.Config `yaml:"retry" json:"retry" toml:"retry"`
	UserAgent  string       `yaml:"user_agent" json:"user_agent" toml:"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(meter metric.Meter) ConsumerOption

WithConsumerMetrics for NSQ.

func WithConsumerTracer

func WithConsumerTracer(tracer ntracer.Tracer) ConsumerOption

WithConsumerConfig 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(meter metric.Meter) ProducerOption

WithProducerMetrics for NSQ.

func WithProducerRetry

func WithProducerRetry() ProducerOption

WithProducerRetry for NSQ.

func WithProducerTracer

func WithProducerTracer(tracer ntracer.Tracer) ProducerOption

WithProducerConfig for NSQ.