nsq

Documentation

Index

• func NewProducer(opts ...ProducerOption) producer.Producer
• func RegisterConsumer(topic string, channel string, opts ...ConsumerOption) error
• type Config
• type ConsumerOption
  • func WithConsumerConfig(config *Config) ConsumerOption
  • func WithConsumerHandler(handler handler.Handler) ConsumerOption
  • func WithConsumerLifecycle(lifecycle fx.Lifecycle) ConsumerOption
  • func WithConsumerLogger(logger *zap.Logger) ConsumerOption
  • func WithConsumerMarshaller(marshaller marshaller.Marshaller) ConsumerOption
  • func WithConsumerTracer(tracer opentracing.Tracer) ConsumerOption
  • func WithConsumerVersion(version version.Version) ConsumerOption
• type ProducerOption
  • func WithProducerBreaker() ProducerOption
  • func WithProducerConfig(config *Config) ProducerOption
  • func WithProducerLifecycle(lifecycle fx.Lifecycle) ProducerOption
  • func WithProducerLogger(logger *zap.Logger) ProducerOption
  • func WithProducerMarshaller(marshaller marshaller.Marshaller) ProducerOption
  • func WithProducerRetry() ProducerOption
  • func WithProducerTracer(tracer opentracing.Tracer) ProducerOption
  • func WithProducerVersion(version version.Version) ProducerOption

Functions

func NewProducer

func NewProducer(opts ...ProducerOption) producer.Producer

NewProducer for NSQ.

func RegisterConsumer

func RegisterConsumer(topic string, channel string, 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 WithConsumerConfig

func WithConsumerConfig(config *Config) ConsumerOption

WithConsumerConfig for NSQ.

func WithConsumerHandler

func WithConsumerHandler(handler handler.Handler) ConsumerOption

WithConsumerMarshaller for NSQ.

func WithConsumerLifecycle

func WithConsumerLifecycle(lifecycle fx.Lifecycle) ConsumerOption

WithConsumerLifecycle for NSQ.

func WithConsumerLogger

func WithConsumerLogger(logger *zap.Logger) ConsumerOption

WithConsumerLogger for NSQ.

func WithConsumerMarshaller

func WithConsumerMarshaller(marshaller marshaller.Marshaller) ConsumerOption

WithConsumerMarshaller for NSQ.

func WithConsumerTracer

func WithConsumerTracer(tracer opentracing.Tracer) ConsumerOption

WithConsumerConfig for NSQ.

func WithConsumerVersion

func WithConsumerVersion(version version.Version) ConsumerOption

WithConsumerMarshaller for NSQ.

type ProducerOption

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

ProducerOption for NSQ.

func WithProducerBreaker

func WithProducerBreaker() ProducerOption

WithProducerBreaker for NSQ.

func WithProducerConfig

func WithProducerConfig(config *Config) ProducerOption

WithProducerConfig for NSQ.

func WithProducerLifecycle

func WithProducerLifecycle(lifecycle fx.Lifecycle) ProducerOption

WithProducerLifecycle for NSQ.

func WithProducerLogger

func WithProducerLogger(logger *zap.Logger) ProducerOption

WithProducerLogger for NSQ.

func WithProducerMarshaller

func WithProducerMarshaller(marshaller marshaller.Marshaller) ProducerOption

WithProducerMarshaller for NSQ.

func WithProducerRetry

func WithProducerRetry() ProducerOption

WithProducerRetry for NSQ.

func WithProducerTracer

func WithProducerTracer(tracer opentracing.Tracer) ProducerOption

WithProducerConfig for NSQ.

func WithProducerVersion

func WithProducerVersion(version version.Version) ProducerOption

WithCProducerVersion for NSQ.