pubsub

Documentation

Index

• func ProvidePubSubConsumerProvider(logger logging.Logger, tracerProvider tracing.TracerProvider, ...) messagequeue.ConsumerProvider
• func ProvidePubSubPublisherProvider(logger logging.Logger, tracerProvider tracing.TracerProvider, ...) messagequeue.PublisherProvider
• type Config
  • func (cfg *Config) ValidateWithContext(ctx context.Context) error

Functions

func ProvidePubSubConsumerProvider

func ProvidePubSubConsumerProvider(logger logging.Logger, tracerProvider tracing.TracerProvider, client *pubsub.Client) messagequeue.ConsumerProvider

ProvidePubSubConsumerProvider returns a ConsumerProvider for a given address.

func ProvidePubSubPublisherProvider

func ProvidePubSubPublisherProvider(logger logging.Logger, tracerProvider tracing.TracerProvider, client *pubsub.Client) messagequeue.PublisherProvider

ProvidePubSubPublisherProvider returns a PublisherProvider for a given address.

Types

type Config

type Config struct{}

Config configures a PubSub-backed pubSubConsumer.

func (*Config) ValidateWithContext

func (cfg *Config) ValidateWithContext(ctx context.Context) error

ValidateWithContext validates a Config struct.