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

package io.github.flink.gcp.connector.testutils.pubsub
  • 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.