package
1.0.0
Repository: https://github.com/elastic/apm-queue.git
Documentation: pkg.go.dev

# Functions

JoinTopicConsumer returns a Pub/Sub Lite subscription name for the given topic and consumer name.
NewConsumer creates a new consumer instance for a single subscription.
NewManager returns a new Manager with the given config.
NewProducer creates a new PubSub Lite producer for a single project.
SplitTopicConsumer does the opposite of JoinTopicConsumer by parsing topic and consumer out of a subscription name.

# Structs

CommonConfig defines common configuration for Pub/Sub Lite consumers, producers, and managers.
Consumer receives PubSub Lite messages from a existing subscription(s).
ConsumerConfig defines the configuration for the PubSub Lite consumer.
Manager manages GCP Pub/Sub topics.
ManagerConfig holds configuration for managing GCP Pub/Sub Lite resources.
Producer implementes the apmqueue.Producer interface and sends each of the events in a batch to a PubSub Lite topic, which is determined by calling the configured TopicRouter.
ProducerConfig for the PubSub Lite producer.
TopicCreator creates GCP Pub/Sub topics.
TopicCreatorConfig holds configuration for managing GCP Pub/Sub Lite topics.