# Functions
CreateKafkaTopics interacts with the Kafka broker to create topics, deleting them when the test completes.
CreatePubsubTopics interacts with the Google Cloud API to create Pub/Sub Lite topics.
CreatePubsubTopicSubscriptions interacts with the Google Cloud API to create Pub/Sub Lite subscriptions.
DestroyKafka destroys the Redpanda Docker container.
No description provided by the author
InitKafka initialises Kafka configuration, and returns a pair of functions for provisioning and destroying a Kafka cluster.
InitPubSubLite initialises Pub/Sub Lite configuration, and returns a pair of functions for provisioning and destroying a Pub/Sub Lite throughput reservation and associated resources.
KafkaCommonConfig returns a kafka.CommonConfig suitable for connecting to the configured Kafka broker in tests.
NewKafkaManager returns a new kafka.Manager for the configured broker.
ProvisionKafka starts a single node Redpanda broker running as a local Docker container, and configures Kafka clients to communicate with the broker by forwarding the necessary port(s).
ProvisionPubSubLite provisions a Pub/Sub Lite throughput reservation using configuration taken from `gcloud` and $GOOGLE_REGION.
PubSubLiteCommonConfig returns a pubsublite.CommonConfig suitable for using to construct pubsublite resources.
RandomSuffix generates a lowercase alphabetic 8 character random string.
SuffixTopics suffixes the received topics with a random suffix.
TestLogger creates a new zap.Logger meant to be used for tests.
# Type aliases
DestroyInfraFunc is a function returned by Init* functions for destroying infrastructure.
ProvisionInfraFunc is a function returned by Init* functions for provisioning infrastructure.