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
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterConsumer ¶
func RegisterConsumer(topic string, channel string, opts ...ConsumerOption) error
RegisterConsumer for NSQ.
Types ¶
type ConsumerOption ¶ added in v1.59.0
type ConsumerOption interface {
// contains filtered or unexported methods
}
ConsumerOption for NSQ.
func WithConsumerConfig ¶ added in v1.59.0
func WithConsumerConfig(config *Config) ConsumerOption
WithConsumerConfig for NSQ.
func WithConsumerHandler ¶ added in v1.59.0
func WithConsumerHandler(handler handler.Handler) ConsumerOption
WithConsumerMarshaller for NSQ.
func WithConsumerLifecycle ¶ added in v1.59.0
func WithConsumerLifecycle(lifecycle fx.Lifecycle) ConsumerOption
WithConsumerLifecycle for NSQ.
func WithConsumerLogger ¶ added in v1.59.0
func WithConsumerLogger(logger *zap.Logger) ConsumerOption
WithConsumerLogger for NSQ.
func WithConsumerMarshaller ¶ added in v1.59.0
func WithConsumerMarshaller(marshaller marshaller.Marshaller) ConsumerOption
WithConsumerMarshaller for NSQ.
func WithConsumerTracer ¶ added in v1.59.0
func WithConsumerTracer(tracer opentracing.Tracer) ConsumerOption
WithConsumerConfig for NSQ.
type ProducerOption ¶ added in v1.59.0
type ProducerOption interface {
// contains filtered or unexported methods
}
ProducerOption for NSQ.
func WithProducerBreaker ¶ added in v1.59.0
func WithProducerBreaker() ProducerOption
WithProducerBreaker for NSQ.
func WithProducerConfig ¶ added in v1.59.0
func WithProducerConfig(config *Config) ProducerOption
WithProducerConfig for NSQ.
func WithProducerLifecycle ¶ added in v1.59.0
func WithProducerLifecycle(lifecycle fx.Lifecycle) ProducerOption
WithProducerLifecycle for NSQ.
func WithProducerLogger ¶ added in v1.59.0
func WithProducerLogger(logger *zap.Logger) ProducerOption
WithProducerLogger for NSQ.
func WithProducerMarshaller ¶ added in v1.59.0
func WithProducerMarshaller(marshaller marshaller.Marshaller) ProducerOption
WithProducerMarshaller for NSQ.
func WithProducerRetry ¶ added in v1.59.0
func WithProducerRetry() ProducerOption
WithProducerRetry for NSQ.
func WithProducerTracer ¶ added in v1.59.0
func WithProducerTracer(tracer opentracing.Tracer) ProducerOption
WithProducerConfig for NSQ.
Click to show internal directories.
Click to hide internal directories.