Versions in this module Expand all Collapse all v1 v1.0.0 Sep 8, 2026 Changes in this version + const ProviderKafka + const ProviderNoop + const ProviderPubSub + const ProviderRedis + const ProviderSQS + var ErrNilConfig = errors.New("nil message queue config provided") + func NewConsumerProvider(ctx context.Context, c *Config, opts ...Option) (messagequeue.ConsumerProvider, error) + func NewPublisherProvider(ctx context.Context, c *Config, opts ...Option) (messagequeue.PublisherProvider, error) + func RegisterMessageQueue(i do.Injector) + type Config struct + Consumer MessageQueueConfig + Publisher MessageQueueConfig + func (c *Config) ValidateWithContext(ctx context.Context) error + type MessageQueueConfig struct + Kafka kafka.Config + Provider provider + PubSub pubsub.Config + Redis redis.Config + SQS sqs.Config + func (c *MessageQueueConfig) ValidateWithContext(ctx context.Context) error + type Option func(*options) + func WithLogger(logger logging.Logger) Option + func WithMetricsProvider(metricsProvider metrics.Provider) Option + func WithPillars(p *observability.Pillars) Option + func WithTracerProvider(tracerProvider tracing.Provider) Option Other modules containing this package github.com/primandproper/primitives-go/v2
Go to main page