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

Class CloudTasksTestClients

java.lang.Object

io.github.flink.gcp.connector.testutils.cloudtasks.CloudTasksTestClients

All Implemented Interfaces:

AutoCloseable

@Internal
public final class CloudTasksTestClients
extends Object
implements AutoCloseable

A stock CloudTasksClient over one plaintext channel to the emulator, with no credentials, for queue administration and task inspection.

Stock and deliberately unshaded: in the SQL module's smoke test this runs beside the uber-jar's relocated copy, so that the two demonstrably coexist on one classpath — the same property testutils.bigtable.BigtableTestClients exists to show.

The instance owns the channel: close() closes the client and shuts the channel down, and a construction that fails half-way shuts it down too, so a caller's teardown only ever sees a fully-constructed instance.

Method Summary

Modifier and Type	Method	Description
com.google.cloud.tasks.v2.CloudTasksClient	client()
void	close()
static CloudTasksTestClients	forEmulator(String endpoint)	Opens a client against the emulator at endpoint (host:port).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

forEmulator

public static CloudTasksTestClients forEmulator(String endpoint)
                                         throws IOException

Opens a client against the emulator at endpoint (host:port).

Throws:

IOException

client

public com.google.cloud.tasks.v2.CloudTasksClient client()

close

public void close()

Specified by:

close in interface AutoCloseable