Versions in this module Expand all Collapse all v1 v1.0.0 Sep 8, 2026 Changes in this version + type Config struct + ProjectID string + func (cfg *Config) ValidateWithContext(ctx context.Context) error + type ConsumerProvider struct + func NewPubSubConsumerProvider(client *pubsub.Client, opts ...Option) *ConsumerProvider + func (p *ConsumerProvider) Close() + func (p *ConsumerProvider) NewConsumer(_ 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 NewPubSubPublisherProvider(client *pubsub.Client, projectID string, opts ...Option) *PublisherProvider + func (p *PublisherProvider) Close() + func (p *PublisherProvider) NewPublisher(ctx context.Context, topicName string) (messagequeue.Publisher, error) + func (p *PublisherProvider) Ping(context.Context) error Other modules containing this package github.com/primandproper/primitives-go/v2
Go to main page