Versions in this module Expand all Collapse all v10 v10.1.0 Aug 15, 2026 v10.0.0 Aug 12, 2026 Changes in this version + const ProviderKafka + const ProviderNoop + const ProviderPubSub + const ProviderRedis + const ProviderSQS + var ErrNilConfig = errors.New("nil 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/platform-go github.com/primandproper/platform-go/v11 github.com/primandproper/platform-go/v12 github.com/primandproper/platform-go/v2 github.com/primandproper/platform-go/v3 github.com/primandproper/platform-go/v4 github.com/primandproper/platform-go/v5 github.com/primandproper/platform-go/v6 github.com/primandproper/platform-go/v7 github.com/primandproper/platform-go/v8 github.com/primandproper/platform-go/v9
Go to main page