Source-Date: Sun Mar 14 20:47:20 2021 -0700
Source-Repo: googleapis/googleapis
Source-Sha: 1305ca41d554eb0725237561e34129373bb8cbc1
Source-Link: https://github.com/googleapis/googleapis/commit/1305ca41d554eb0725237561e34129373bb8cbc1
---
.../v1/DataTransferServiceClient.java | 34 +++++++++++
.../v1/MockDataTransferServiceImpl.java | 56 +++++++++----------
synth.metadata | 6 +-
3 files changed, 65 insertions(+), 31 deletions(-)
diff --git a/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/DataTransferServiceClient.java b/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/DataTransferServiceClient.java
index 9a9cf2fe..ee6806e9 100644
--- a/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/DataTransferServiceClient.java
+++ b/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/DataTransferServiceClient.java
@@ -394,6 +394,13 @@ public final ListDataSourcesPagedResponse listDataSources(ListDataSourcesRequest
*
* {@code
* try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * ListDataSourcesRequest request =
+ * ListDataSourcesRequest.newBuilder()
+ * .setParent(
+ * DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]").toString())
+ * .setPageToken("pageToken873572522")
+ * .setPageSize(883849137)
+ * .build();
* while (true) {
* ListDataSourcesResponse response =
* dataTransferServiceClient.listDataSourcesCallable().call(request);
@@ -1015,6 +1022,15 @@ public final ListTransferConfigsPagedResponse listTransferConfigs(
*
* {@code
* try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * ListTransferConfigsRequest request =
+ * ListTransferConfigsRequest.newBuilder()
+ * .setParent(
+ * TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]")
+ * .toString())
+ * .addAllDataSourceIds(new ArrayList())
+ * .setPageToken("pageToken873572522")
+ * .setPageSize(883849137)
+ * .build();
* while (true) {
* ListTransferConfigsResponse response =
* dataTransferServiceClient.listTransferConfigsCallable().call(request);
@@ -1567,6 +1583,15 @@ public final ListTransferRunsPagedResponse listTransferRuns(ListTransferRunsRequ
*
* {@code
* try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * ListTransferRunsRequest request =
+ * ListTransferRunsRequest.newBuilder()
+ * .setParent(
+ * RunName.ofProjectTransferConfigRunName("[PROJECT]", "[TRANSFER_CONFIG]", "[RUN]")
+ * .toString())
+ * .addAllStates(new ArrayList())
+ * .setPageToken("pageToken873572522")
+ * .setPageSize(883849137)
+ * .build();
* while (true) {
* ListTransferRunsResponse response =
* dataTransferServiceClient.listTransferRunsCallable().call(request);
@@ -1717,6 +1742,15 @@ public final ListTransferLogsPagedResponse listTransferLogs(ListTransferLogsRequ
*
* {@code
* try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * ListTransferLogsRequest request =
+ * ListTransferLogsRequest.newBuilder()
+ * .setParent(
+ * RunName.ofProjectTransferConfigRunName("[PROJECT]", "[TRANSFER_CONFIG]", "[RUN]")
+ * .toString())
+ * .setPageToken("pageToken873572522")
+ * .setPageSize(883849137)
+ * .addAllMessageTypes(new ArrayList())
+ * .build();
* while (true) {
* ListTransferLogsResponse response =
* dataTransferServiceClient.listTransferLogsCallable().call(request);
diff --git a/google-cloud-bigquerydatatransfer/src/test/java/com/google/cloud/bigquery/datatransfer/v1/MockDataTransferServiceImpl.java b/google-cloud-bigquerydatatransfer/src/test/java/com/google/cloud/bigquery/datatransfer/v1/MockDataTransferServiceImpl.java
index 631776bd..0a515afe 100644
--- a/google-cloud-bigquerydatatransfer/src/test/java/com/google/cloud/bigquery/datatransfer/v1/MockDataTransferServiceImpl.java
+++ b/google-cloud-bigquerydatatransfer/src/test/java/com/google/cloud/bigquery/datatransfer/v1/MockDataTransferServiceImpl.java
@@ -62,7 +62,7 @@ public void reset() {
@Override
public void getDataSource(
GetDataSourceRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof DataSource) {
requests.add(request);
responseObserver.onNext(((DataSource) response));
@@ -74,7 +74,7 @@ public void getDataSource(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetDataSource, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
DataSource.class.getName(),
Exception.class.getName())));
}
@@ -83,7 +83,7 @@ public void getDataSource(
@Override
public void listDataSources(
ListDataSourcesRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListDataSourcesResponse) {
requests.add(request);
responseObserver.onNext(((ListDataSourcesResponse) response));
@@ -95,7 +95,7 @@ public void listDataSources(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListDataSources, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListDataSourcesResponse.class.getName(),
Exception.class.getName())));
}
@@ -104,7 +104,7 @@ public void listDataSources(
@Override
public void createTransferConfig(
CreateTransferConfigRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof TransferConfig) {
requests.add(request);
responseObserver.onNext(((TransferConfig) response));
@@ -116,7 +116,7 @@ public void createTransferConfig(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CreateTransferConfig, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
TransferConfig.class.getName(),
Exception.class.getName())));
}
@@ -125,7 +125,7 @@ public void createTransferConfig(
@Override
public void updateTransferConfig(
UpdateTransferConfigRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof TransferConfig) {
requests.add(request);
responseObserver.onNext(((TransferConfig) response));
@@ -137,7 +137,7 @@ public void updateTransferConfig(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method UpdateTransferConfig, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
TransferConfig.class.getName(),
Exception.class.getName())));
}
@@ -146,7 +146,7 @@ public void updateTransferConfig(
@Override
public void deleteTransferConfig(
DeleteTransferConfigRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -158,7 +158,7 @@ public void deleteTransferConfig(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteTransferConfig, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -167,7 +167,7 @@ public void deleteTransferConfig(
@Override
public void getTransferConfig(
GetTransferConfigRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof TransferConfig) {
requests.add(request);
responseObserver.onNext(((TransferConfig) response));
@@ -179,7 +179,7 @@ public void getTransferConfig(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetTransferConfig, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
TransferConfig.class.getName(),
Exception.class.getName())));
}
@@ -189,7 +189,7 @@ public void getTransferConfig(
public void listTransferConfigs(
ListTransferConfigsRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListTransferConfigsResponse) {
requests.add(request);
responseObserver.onNext(((ListTransferConfigsResponse) response));
@@ -201,7 +201,7 @@ public void listTransferConfigs(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListTransferConfigs, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListTransferConfigsResponse.class.getName(),
Exception.class.getName())));
}
@@ -211,7 +211,7 @@ public void listTransferConfigs(
public void scheduleTransferRuns(
ScheduleTransferRunsRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ScheduleTransferRunsResponse) {
requests.add(request);
responseObserver.onNext(((ScheduleTransferRunsResponse) response));
@@ -223,7 +223,7 @@ public void scheduleTransferRuns(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ScheduleTransferRuns, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ScheduleTransferRunsResponse.class.getName(),
Exception.class.getName())));
}
@@ -233,7 +233,7 @@ public void scheduleTransferRuns(
public void startManualTransferRuns(
StartManualTransferRunsRequest request,
StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof StartManualTransferRunsResponse) {
requests.add(request);
responseObserver.onNext(((StartManualTransferRunsResponse) response));
@@ -245,7 +245,7 @@ public void startManualTransferRuns(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method StartManualTransferRuns, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
StartManualTransferRunsResponse.class.getName(),
Exception.class.getName())));
}
@@ -254,7 +254,7 @@ public void startManualTransferRuns(
@Override
public void getTransferRun(
GetTransferRunRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof TransferRun) {
requests.add(request);
responseObserver.onNext(((TransferRun) response));
@@ -266,7 +266,7 @@ public void getTransferRun(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method GetTransferRun, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
TransferRun.class.getName(),
Exception.class.getName())));
}
@@ -275,7 +275,7 @@ public void getTransferRun(
@Override
public void deleteTransferRun(
DeleteTransferRunRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof Empty) {
requests.add(request);
responseObserver.onNext(((Empty) response));
@@ -287,7 +287,7 @@ public void deleteTransferRun(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method DeleteTransferRun, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
Empty.class.getName(),
Exception.class.getName())));
}
@@ -296,7 +296,7 @@ public void deleteTransferRun(
@Override
public void listTransferRuns(
ListTransferRunsRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListTransferRunsResponse) {
requests.add(request);
responseObserver.onNext(((ListTransferRunsResponse) response));
@@ -308,7 +308,7 @@ public void listTransferRuns(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListTransferRuns, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListTransferRunsResponse.class.getName(),
Exception.class.getName())));
}
@@ -317,7 +317,7 @@ public void listTransferRuns(
@Override
public void listTransferLogs(
ListTransferLogsRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof ListTransferLogsResponse) {
requests.add(request);
responseObserver.onNext(((ListTransferLogsResponse) response));
@@ -329,7 +329,7 @@ public void listTransferLogs(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method ListTransferLogs, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
ListTransferLogsResponse.class.getName(),
Exception.class.getName())));
}
@@ -338,7 +338,7 @@ public void listTransferLogs(
@Override
public void checkValidCreds(
CheckValidCredsRequest request, StreamObserver responseObserver) {
- Object response = responses.remove();
+ Object response = responses.poll();
if (response instanceof CheckValidCredsResponse) {
requests.add(request);
responseObserver.onNext(((CheckValidCredsResponse) response));
@@ -350,7 +350,7 @@ public void checkValidCreds(
new IllegalArgumentException(
String.format(
"Unrecognized response type %s for method CheckValidCreds, expected %s or %s",
- response.getClass().getName(),
+ response == null ? "null" : response.getClass().getName(),
CheckValidCredsResponse.class.getName(),
Exception.class.getName())));
}
diff --git a/synth.metadata b/synth.metadata
index 22de0e2f..709d45f3 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -11,15 +11,15 @@
"git": {
"name": ".",
"remote": "https://github.com/googleapis/java-bigquerydatatransfer.git",
- "sha": "9ae502fc1b92b51953b2cd9361d42fed10f8fa25"
+ "sha": "a6c4e691788d217c2c744170d58e89b130da7afe"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "0e915217fb5261c1e57bfaf0e16ee5c7feaaba89",
- "internalRef": "361377784"
+ "sha": "1305ca41d554eb0725237561e34129373bb8cbc1",
+ "internalRef": "362856902"
}
},
{
From 577de76db00c7f0e39c1dd891365de1d5c5b9126 Mon Sep 17 00:00:00 2001
From: WhiteSource Renovate
Date: Mon, 15 Mar 2021 18:03:54 +0100
Subject: [PATCH 08/10] deps: update dependency
com.google.cloud:google-cloud-bigquery to v1.127.8 (#687)
---
samples/install-without-bom/pom.xml | 2 +-
samples/snapshot/pom.xml | 2 +-
samples/snippets/pom.xml | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/samples/install-without-bom/pom.xml b/samples/install-without-bom/pom.xml
index ef9d3cd1..2c81f20c 100644
--- a/samples/install-without-bom/pom.xml
+++ b/samples/install-without-bom/pom.xml
@@ -53,7 +53,7 @@
com.google.cloud
google-cloud-bigquery
- 1.127.6
+ 1.127.8
test
diff --git a/samples/snapshot/pom.xml b/samples/snapshot/pom.xml
index d7890dfb..7eddfa58 100644
--- a/samples/snapshot/pom.xml
+++ b/samples/snapshot/pom.xml
@@ -53,7 +53,7 @@
com.google.cloud
google-cloud-bigquery
- 1.127.6
+ 1.127.8
test
diff --git a/samples/snippets/pom.xml b/samples/snippets/pom.xml
index 7a288493..d1409eec 100644
--- a/samples/snippets/pom.xml
+++ b/samples/snippets/pom.xml
@@ -65,7 +65,7 @@
com.google.cloud
google-cloud-bigquery
- 1.127.6
+ 1.127.8
test
From a0003862f726a1d46b9e03f8821f10c9df2c45b9 Mon Sep 17 00:00:00 2001
From: WhiteSource Renovate
Date: Tue, 16 Mar 2021 17:27:34 +0100
Subject: [PATCH 09/10] deps: update dependency
com.google.cloud:google-cloud-pubsub to v1.112.0 (#693)
---
samples/install-without-bom/pom.xml | 2 +-
samples/snapshot/pom.xml | 2 +-
samples/snippets/pom.xml | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/samples/install-without-bom/pom.xml b/samples/install-without-bom/pom.xml
index 2c81f20c..8ea6b66f 100644
--- a/samples/install-without-bom/pom.xml
+++ b/samples/install-without-bom/pom.xml
@@ -59,7 +59,7 @@
com.google.cloud
google-cloud-pubsub
- 1.111.4
+ 1.112.0
test