Versions in this module Expand all Collapse all v1 v1.0.0 Sep 8, 2026 Changes in this version + type Config struct + Password string + QueueAddresses []string + Username string + func (cfg *Config) ValidateWithContext(ctx context.Context) error + type ConsumerProvider struct + func NewRedisConsumerProvider(ctx context.Context, cfg Config, opts ...Option) (*ConsumerProvider, error) + func (p *ConsumerProvider) Close() + func (p *ConsumerProvider) NewConsumer(ctx context.Context, topic string, handlerFunc messagequeue.ConsumerFunc) (messagequeue.Consumer, error) + type Option func(*options) + func WithLogger(logger logging.Logger) Option + func WithMetricsProvider(metricsProvider metrics.Provider) Option + func WithTracerProvider(tracerProvider tracing.Provider) Option + type PublisherProvider struct + func NewRedisPublisherProvider(ctx context.Context, cfg Config, opts ...Option) (*PublisherProvider, error) + func (p *PublisherProvider) Close() + func (p *PublisherProvider) NewPublisher(ctx context.Context, topic string) (messagequeue.Publisher, error) + func (p *PublisherProvider) Ping(ctx context.Context) error Other modules containing this package github.com/primandproper/primitives-go/v2
Go to main page