nsq

Documentation

Index

• func NewProducer(lc fx.Lifecycle, host string, m gn.Marshaller, opts ...ProducerOption) (gn.Producer, error)
• func RegisterConsumer(lc fx.Lifecycle, host, topic, channel string, con gn.Consumer, ...) 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(cfg *r.Config) ProducerOption
  • func WithProducerTracer(tracer ntracer.Tracer) ProducerOption
  • func WithProducerUserAgent(userAgent string) ProducerOption

Functions

func NewProducer

func NewProducer(lc fx.Lifecycle, host string, m gn.Marshaller, opts ...ProducerOption) (gn.Producer, error)

NewProducer for NSQ.

func RegisterConsumer

func RegisterConsumer(lc fx.Lifecycle, host, topic, channel string, con gn.Consumer, mar gn.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(cfg *r.Config) ProducerOption

WithProducerRetry for NSQ.

func WithProducerTracer

func WithProducerTracer(tracer ntracer.Tracer) ProducerOption

WithProducerConfig for NSQ.

func WithProducerUserAgent

func WithProducerUserAgent(userAgent string) ProducerOption

WithUserAgent for NSQ.