Package io.github.flink.gcp.connector.testutils.pubsub

package io.github.flink.gcp.connector.testutils.pubsub

Related Packages

Package	Description
io.github.flink.gcp.connector.testutils
io.github.flink.gcp.connector.testutils.bigquery
io.github.flink.gcp.connector.testutils.bigtable
io.github.flink.gcp.connector.testutils.cloudtasks
io.github.flink.gcp.connector.testutils.spanner
io.github.flink.gcp.connector.testutils.sql

Classes

Class	Description
PubSubEmulatorContainers	The Pub/Sub emulator image shared by every harness that starts the emulator, so they cannot drift apart.
PubSubSplitReaders	Fetch-loop helpers for driving a Pub/Sub SplitReader directly in tests, typed against the flink-connector-base interface so the connector's reader class never crosses the module boundary.
PubSubTestClients	The Pub/Sub admin, publish and pull machinery every integration-test harness needs, parameterised over the transport: a plaintext channel with no credentials against the emulator, or application-default credentials against the real service.