*
* try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * TransferConfigName name = TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
- * dataTransferServiceClient.deleteTransferConfig(name);
+ * DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
+ * DataSource response = dataTransferServiceClient.getDataSource(name);
* }
*
*
@@ -159,300 +159,6 @@ public DataTransferServiceStub getStub() {
return stub;
}
- // AUTO-GENERATED DOCUMENTATION AND METHOD
- /**
- * Deletes a data transfer configuration, including any associated transfer runs and logs.
- *
- * Sample code: - * - *
- * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * TransferConfigName name = TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
- * dataTransferServiceClient.deleteTransferConfig(name);
- * }
- * Sample code: - * - *
- * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * TransferConfigName name = TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
- * dataTransferServiceClient.deleteTransferConfig(name.toString());
- * }
- * Sample code: - * - *
- * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * TransferConfigName name = TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
- * DeleteTransferConfigRequest request = DeleteTransferConfigRequest.newBuilder()
- * .setName(name.toString())
- * .build();
- * dataTransferServiceClient.deleteTransferConfig(request);
- * }
- * Sample code: - * - *
- * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * TransferConfigName name = TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
- * DeleteTransferConfigRequest request = DeleteTransferConfigRequest.newBuilder()
- * .setName(name.toString())
- * .build();
- * ApiFuture<Void> future = dataTransferServiceClient.deleteTransferConfigCallable().futureCall(request);
- * // Do something
- * future.get();
- * }
- * Sample code: - * - *
- * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * RunName name = RunName.ofProjectTransferConfigRunName("[PROJECT]", "[TRANSFER_CONFIG]", "[RUN]");
- * dataTransferServiceClient.deleteTransferRun(name);
- * }
- * Sample code: - * - *
- * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * RunName name = RunName.ofProjectTransferConfigRunName("[PROJECT]", "[TRANSFER_CONFIG]", "[RUN]");
- * dataTransferServiceClient.deleteTransferRun(name.toString());
- * }
- * Sample code: - * - *
- * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * RunName name = RunName.ofProjectTransferConfigRunName("[PROJECT]", "[TRANSFER_CONFIG]", "[RUN]");
- * DeleteTransferRunRequest request = DeleteTransferRunRequest.newBuilder()
- * .setName(name.toString())
- * .build();
- * dataTransferServiceClient.deleteTransferRun(request);
- * }
- * Sample code: - * - *
- * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * RunName name = RunName.ofProjectTransferConfigRunName("[PROJECT]", "[TRANSFER_CONFIG]", "[RUN]");
- * DeleteTransferRunRequest request = DeleteTransferRunRequest.newBuilder()
- * .setName(name.toString())
- * .build();
- * ApiFuture<Void> future = dataTransferServiceClient.deleteTransferRunCallable().futureCall(request);
- * // Do something
- * future.get();
- * }
- * Sample code: - * - *
- * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
- * CheckValidCredsResponse response = dataTransferServiceClient.checkValidCreds(name);
- * }
- * Sample code: - * - *
- * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
- * CheckValidCredsResponse response = dataTransferServiceClient.checkValidCreds(name.toString());
- * }
- * Sample code: - * - *
- * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
- * CheckValidCredsRequest request = CheckValidCredsRequest.newBuilder()
- * .setName(name.toString())
- * .build();
- * CheckValidCredsResponse response = dataTransferServiceClient.checkValidCreds(request);
- * }
- * Sample code: - * - *
- * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
- * CheckValidCredsRequest request = CheckValidCredsRequest.newBuilder()
- * .setName(name.toString())
- * .build();
- * ApiFuture<CheckValidCredsResponse> future = dataTransferServiceClient.checkValidCredsCallable().futureCall(request);
- * // Do something
- * CheckValidCredsResponse response = future.get();
- * }
- *
* try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * TransferConfig transferConfig = TransferConfig.newBuilder().build();
- * FieldMask updateMask = FieldMask.newBuilder().build();
- * TransferConfig response = dataTransferServiceClient.updateTransferConfig(transferConfig, updateMask);
+ * TransferConfig transferConfig = TransferConfig.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * TransferConfig response = dataTransferServiceClient.updateTransferConfig(transferConfig, updateMask);
+ * }
+ * Sample code: + * + *
+ * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * TransferConfig transferConfig = TransferConfig.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * UpdateTransferConfigRequest request = UpdateTransferConfigRequest.newBuilder()
+ * .setTransferConfig(transferConfig)
+ * .setUpdateMask(updateMask)
+ * .build();
+ * TransferConfig response = dataTransferServiceClient.updateTransferConfig(request);
+ * }
+ * Sample code: + * + *
+ * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * TransferConfig transferConfig = TransferConfig.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * UpdateTransferConfigRequest request = UpdateTransferConfigRequest.newBuilder()
+ * .setTransferConfig(transferConfig)
+ * .setUpdateMask(updateMask)
+ * .build();
+ * ApiFuture<TransferConfig> future = dataTransferServiceClient.updateTransferConfigCallable().futureCall(request);
+ * // Do something
+ * TransferConfig response = future.get();
+ * }
+ * Sample code: + * + *
+ * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * TransferConfigName name = TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
+ * dataTransferServiceClient.deleteTransferConfig(name);
+ * }
+ * Sample code: + * + *
+ * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * TransferConfigName name = TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
+ * dataTransferServiceClient.deleteTransferConfig(name.toString());
* }
* Sample code: * *
* try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * TransferConfig transferConfig = TransferConfig.newBuilder().build();
- * FieldMask updateMask = FieldMask.newBuilder().build();
- * UpdateTransferConfigRequest request = UpdateTransferConfigRequest.newBuilder()
- * .setTransferConfig(transferConfig)
- * .setUpdateMask(updateMask)
+ * TransferConfigName name = TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
+ * DeleteTransferConfigRequest request = DeleteTransferConfigRequest.newBuilder()
+ * .setName(name.toString())
* .build();
- * TransferConfig response = dataTransferServiceClient.updateTransferConfig(request);
+ * dataTransferServiceClient.deleteTransferConfig(request);
* }
* Sample code: * *
* try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * TransferConfig transferConfig = TransferConfig.newBuilder().build();
- * FieldMask updateMask = FieldMask.newBuilder().build();
- * UpdateTransferConfigRequest request = UpdateTransferConfigRequest.newBuilder()
- * .setTransferConfig(transferConfig)
- * .setUpdateMask(updateMask)
+ * TransferConfigName name = TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
+ * DeleteTransferConfigRequest request = DeleteTransferConfigRequest.newBuilder()
+ * .setName(name.toString())
* .build();
- * ApiFuture<TransferConfig> future = dataTransferServiceClient.updateTransferConfigCallable().futureCall(request);
+ * ApiFuture<Void> future = dataTransferServiceClient.deleteTransferConfigCallable().futureCall(request);
* // Do something
- * TransferConfig response = future.get();
+ * future.get();
* }
* Sample code: + * + *
+ * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * RunName name = RunName.ofProjectTransferConfigRunName("[PROJECT]", "[TRANSFER_CONFIG]", "[RUN]");
+ * dataTransferServiceClient.deleteTransferRun(name);
+ * }
+ * Sample code: + * + *
+ * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * RunName name = RunName.ofProjectTransferConfigRunName("[PROJECT]", "[TRANSFER_CONFIG]", "[RUN]");
+ * dataTransferServiceClient.deleteTransferRun(name.toString());
+ * }
+ * Sample code: + * + *
+ * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * RunName name = RunName.ofProjectTransferConfigRunName("[PROJECT]", "[TRANSFER_CONFIG]", "[RUN]");
+ * DeleteTransferRunRequest request = DeleteTransferRunRequest.newBuilder()
+ * .setName(name.toString())
+ * .build();
+ * dataTransferServiceClient.deleteTransferRun(request);
+ * }
+ * Sample code: + * + *
+ * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * RunName name = RunName.ofProjectTransferConfigRunName("[PROJECT]", "[TRANSFER_CONFIG]", "[RUN]");
+ * DeleteTransferRunRequest request = DeleteTransferRunRequest.newBuilder()
+ * .setName(name.toString())
+ * .build();
+ * ApiFuture<Void> future = dataTransferServiceClient.deleteTransferRunCallable().futureCall(request);
+ * // Do something
+ * future.get();
+ * }
+ * Sample code: + * + *
+ * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
+ * CheckValidCredsResponse response = dataTransferServiceClient.checkValidCreds(name);
+ * }
+ * Sample code: + * + *
+ * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
+ * CheckValidCredsResponse response = dataTransferServiceClient.checkValidCreds(name.toString());
+ * }
+ * Sample code: + * + *
+ * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
+ * CheckValidCredsRequest request = CheckValidCredsRequest.newBuilder()
+ * .setName(name.toString())
+ * .build();
+ * CheckValidCredsResponse response = dataTransferServiceClient.checkValidCreds(request);
+ * }
+ * Sample code: + * + *
+ * try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
+ * DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
+ * CheckValidCredsRequest request = CheckValidCredsRequest.newBuilder()
+ * .setName(name.toString())
+ * .build();
+ * ApiFuture<CheckValidCredsResponse> future = dataTransferServiceClient.checkValidCredsCallable().futureCall(request);
+ * // Do something
+ * CheckValidCredsResponse response = future.get();
+ * }
+ * The builder of this class is recursive, so contained classes are themselves builders. When * build() is called, the tree of builders is called to create the complete settings object. * - *
For example, to set the total timeout of deleteTransferConfig to 30 seconds: + *
For example, to set the total timeout of getDataSource to 30 seconds: * *
*
* DataTransferServiceSettings.Builder dataTransferServiceSettingsBuilder =
* DataTransferServiceSettings.newBuilder();
* dataTransferServiceSettingsBuilder
- * .deleteTransferConfigSettings()
+ * .getDataSourceSettings()
* .setRetrySettings(
- * dataTransferServiceSettingsBuilder.deleteTransferConfigSettings().getRetrySettings().toBuilder()
+ * dataTransferServiceSettingsBuilder.getDataSourceSettings().getRetrySettings().toBuilder()
* .setTotalTimeout(Duration.ofSeconds(30))
* .build());
* DataTransferServiceSettings dataTransferServiceSettings = dataTransferServiceSettingsBuilder.build();
@@ -72,22 +72,6 @@
@Generated("by gapic-generator")
@BetaApi
public class DataTransferServiceSettings extends ClientSettings {
- /** Returns the object with the settings used for calls to deleteTransferConfig. */
- public UnaryCallSettings deleteTransferConfigSettings() {
- return ((DataTransferServiceStubSettings) getStubSettings()).deleteTransferConfigSettings();
- }
-
- /** Returns the object with the settings used for calls to deleteTransferRun. */
- public UnaryCallSettings deleteTransferRunSettings() {
- return ((DataTransferServiceStubSettings) getStubSettings()).deleteTransferRunSettings();
- }
-
- /** Returns the object with the settings used for calls to checkValidCreds. */
- public UnaryCallSettings
- checkValidCredsSettings() {
- return ((DataTransferServiceStubSettings) getStubSettings()).checkValidCredsSettings();
- }
-
/** Returns the object with the settings used for calls to getDataSource. */
public UnaryCallSettings getDataSourceSettings() {
return ((DataTransferServiceStubSettings) getStubSettings()).getDataSourceSettings();
@@ -112,6 +96,11 @@ public UnaryCallSettings getDataSourceSettings
return ((DataTransferServiceStubSettings) getStubSettings()).updateTransferConfigSettings();
}
+ /** Returns the object with the settings used for calls to deleteTransferConfig. */
+ public UnaryCallSettings deleteTransferConfigSettings() {
+ return ((DataTransferServiceStubSettings) getStubSettings()).deleteTransferConfigSettings();
+ }
+
/** Returns the object with the settings used for calls to getTransferConfig. */
public UnaryCallSettings getTransferConfigSettings() {
return ((DataTransferServiceStubSettings) getStubSettings()).getTransferConfigSettings();
@@ -141,6 +130,11 @@ public UnaryCallSettings getTransferRunSetti
return ((DataTransferServiceStubSettings) getStubSettings()).getTransferRunSettings();
}
+ /** Returns the object with the settings used for calls to deleteTransferRun. */
+ public UnaryCallSettings deleteTransferRunSettings() {
+ return ((DataTransferServiceStubSettings) getStubSettings()).deleteTransferRunSettings();
+ }
+
/** Returns the object with the settings used for calls to listTransferRuns. */
public PagedCallSettings<
ListTransferRunsRequest, ListTransferRunsResponse, ListTransferRunsPagedResponse>
@@ -155,6 +149,12 @@ public UnaryCallSettings getTransferRunSetti
return ((DataTransferServiceStubSettings) getStubSettings()).listTransferLogsSettings();
}
+ /** Returns the object with the settings used for calls to checkValidCreds. */
+ public UnaryCallSettings
+ checkValidCredsSettings() {
+ return ((DataTransferServiceStubSettings) getStubSettings()).checkValidCredsSettings();
+ }
+
public static final DataTransferServiceSettings create(DataTransferServiceStubSettings stub)
throws IOException {
return new DataTransferServiceSettings.Builder(stub.toBuilder()).build();
@@ -252,23 +252,6 @@ public Builder applyToAllUnaryMethods(
return this;
}
- /** Returns the builder for the settings used for calls to deleteTransferConfig. */
- public UnaryCallSettings.Builder
- deleteTransferConfigSettings() {
- return getStubSettingsBuilder().deleteTransferConfigSettings();
- }
-
- /** Returns the builder for the settings used for calls to deleteTransferRun. */
- public UnaryCallSettings.Builder deleteTransferRunSettings() {
- return getStubSettingsBuilder().deleteTransferRunSettings();
- }
-
- /** Returns the builder for the settings used for calls to checkValidCreds. */
- public UnaryCallSettings.Builder
- checkValidCredsSettings() {
- return getStubSettingsBuilder().checkValidCredsSettings();
- }
-
/** Returns the builder for the settings used for calls to getDataSource. */
public UnaryCallSettings.Builder getDataSourceSettings() {
return getStubSettingsBuilder().getDataSourceSettings();
@@ -293,6 +276,12 @@ public UnaryCallSettings.Builder getDataSource
return getStubSettingsBuilder().updateTransferConfigSettings();
}
+ /** Returns the builder for the settings used for calls to deleteTransferConfig. */
+ public UnaryCallSettings.Builder
+ deleteTransferConfigSettings() {
+ return getStubSettingsBuilder().deleteTransferConfigSettings();
+ }
+
/** Returns the builder for the settings used for calls to getTransferConfig. */
public UnaryCallSettings.Builder
getTransferConfigSettings() {
@@ -326,6 +315,11 @@ public UnaryCallSettings.Builder getTransfer
return getStubSettingsBuilder().getTransferRunSettings();
}
+ /** Returns the builder for the settings used for calls to deleteTransferRun. */
+ public UnaryCallSettings.Builder deleteTransferRunSettings() {
+ return getStubSettingsBuilder().deleteTransferRunSettings();
+ }
+
/** Returns the builder for the settings used for calls to listTransferRuns. */
public PagedCallSettings.Builder<
ListTransferRunsRequest, ListTransferRunsResponse, ListTransferRunsPagedResponse>
@@ -340,6 +334,12 @@ public UnaryCallSettings.Builder getTransfer
return getStubSettingsBuilder().listTransferLogsSettings();
}
+ /** Returns the builder for the settings used for calls to checkValidCreds. */
+ public UnaryCallSettings.Builder
+ checkValidCredsSettings() {
+ return getStubSettingsBuilder().checkValidCredsSettings();
+ }
+
@Override
public DataTransferServiceSettings build() throws IOException {
return new DataTransferServiceSettings(this);
diff --git a/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/package-info.java b/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/package-info.java
index 3c2b7078..5fe10fe5 100644
--- a/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/package-info.java
+++ b/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/package-info.java
@@ -30,8 +30,8 @@
*
*
* try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * TransferConfigName name = TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
- * dataTransferServiceClient.deleteTransferConfig(name);
+ * DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
+ * DataSource response = dataTransferServiceClient.getDataSource(name);
* }
*
*
diff --git a/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/stub/DataTransferServiceStub.java b/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/stub/DataTransferServiceStub.java
index 56aabbed..a9331f03 100644
--- a/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/stub/DataTransferServiceStub.java
+++ b/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/stub/DataTransferServiceStub.java
@@ -60,18 +60,6 @@
@BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public abstract class DataTransferServiceStub implements BackgroundResource {
- public UnaryCallable deleteTransferConfigCallable() {
- throw new UnsupportedOperationException("Not implemented: deleteTransferConfigCallable()");
- }
-
- public UnaryCallable deleteTransferRunCallable() {
- throw new UnsupportedOperationException("Not implemented: deleteTransferRunCallable()");
- }
-
- public UnaryCallable checkValidCredsCallable() {
- throw new UnsupportedOperationException("Not implemented: checkValidCredsCallable()");
- }
-
public UnaryCallable getDataSourceCallable() {
throw new UnsupportedOperationException("Not implemented: getDataSourceCallable()");
}
@@ -93,6 +81,10 @@ public UnaryCallable updateTransfer
throw new UnsupportedOperationException("Not implemented: updateTransferConfigCallable()");
}
+ public UnaryCallable deleteTransferConfigCallable() {
+ throw new UnsupportedOperationException("Not implemented: deleteTransferConfigCallable()");
+ }
+
public UnaryCallable getTransferConfigCallable() {
throw new UnsupportedOperationException("Not implemented: getTransferConfigCallable()");
}
@@ -121,6 +113,10 @@ public UnaryCallable getTransferRunCallable(
throw new UnsupportedOperationException("Not implemented: getTransferRunCallable()");
}
+ public UnaryCallable deleteTransferRunCallable() {
+ throw new UnsupportedOperationException("Not implemented: deleteTransferRunCallable()");
+ }
+
public UnaryCallable
listTransferRunsPagedCallable() {
throw new UnsupportedOperationException("Not implemented: listTransferRunsPagedCallable()");
@@ -141,6 +137,10 @@ public UnaryCallable getTransferRunCallable(
throw new UnsupportedOperationException("Not implemented: listTransferLogsCallable()");
}
+ public UnaryCallable checkValidCredsCallable() {
+ throw new UnsupportedOperationException("Not implemented: checkValidCredsCallable()");
+ }
+
@Override
public abstract void close();
}
diff --git a/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/stub/DataTransferServiceStubSettings.java b/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/stub/DataTransferServiceStubSettings.java
index f60857f0..2de39791 100644
--- a/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/stub/DataTransferServiceStubSettings.java
+++ b/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/stub/DataTransferServiceStubSettings.java
@@ -93,16 +93,16 @@
* The builder of this class is recursive, so contained classes are themselves builders. When
* build() is called, the tree of builders is called to create the complete settings object.
*
- *
For example, to set the total timeout of deleteTransferConfig to 30 seconds:
+ *
For example, to set the total timeout of getDataSource to 30 seconds:
*
*
*
* DataTransferServiceStubSettings.Builder dataTransferServiceSettingsBuilder =
* DataTransferServiceStubSettings.newBuilder();
* dataTransferServiceSettingsBuilder
- * .deleteTransferConfigSettings()
+ * .getDataSourceSettings()
* .setRetrySettings(
- * dataTransferServiceSettingsBuilder.deleteTransferConfigSettings().getRetrySettings().toBuilder()
+ * dataTransferServiceSettingsBuilder.getDataSourceSettings().getRetrySettings().toBuilder()
* .setTotalTimeout(Duration.ofSeconds(30))
* .build());
* DataTransferServiceStubSettings dataTransferServiceSettings = dataTransferServiceSettingsBuilder.build();
@@ -116,10 +116,6 @@ public class DataTransferServiceStubSettings extends StubSettings DEFAULT_SERVICE_SCOPES =
ImmutableList.builder().add("https://www.googleapis.com/auth/cloud-platform").build();
- private final UnaryCallSettings deleteTransferConfigSettings;
- private final UnaryCallSettings deleteTransferRunSettings;
- private final UnaryCallSettings
- checkValidCredsSettings;
private final UnaryCallSettings getDataSourceSettings;
private final PagedCallSettings<
ListDataSourcesRequest, ListDataSourcesResponse, ListDataSourcesPagedResponse>
@@ -128,6 +124,7 @@ public class DataTransferServiceStubSettings extends StubSettings
updateTransferConfigSettings;
+ private final UnaryCallSettings deleteTransferConfigSettings;
private final UnaryCallSettings
getTransferConfigSettings;
private final PagedCallSettings<
@@ -138,28 +135,15 @@ public class DataTransferServiceStubSettings extends StubSettings
startManualTransferRunsSettings;
private final UnaryCallSettings getTransferRunSettings;
+ private final UnaryCallSettings deleteTransferRunSettings;
private final PagedCallSettings<
ListTransferRunsRequest, ListTransferRunsResponse, ListTransferRunsPagedResponse>
listTransferRunsSettings;
private final PagedCallSettings<
ListTransferLogsRequest, ListTransferLogsResponse, ListTransferLogsPagedResponse>
listTransferLogsSettings;
-
- /** Returns the object with the settings used for calls to deleteTransferConfig. */
- public UnaryCallSettings deleteTransferConfigSettings() {
- return deleteTransferConfigSettings;
- }
-
- /** Returns the object with the settings used for calls to deleteTransferRun. */
- public UnaryCallSettings deleteTransferRunSettings() {
- return deleteTransferRunSettings;
- }
-
- /** Returns the object with the settings used for calls to checkValidCreds. */
- public UnaryCallSettings
- checkValidCredsSettings() {
- return checkValidCredsSettings;
- }
+ private final UnaryCallSettings
+ checkValidCredsSettings;
/** Returns the object with the settings used for calls to getDataSource. */
public UnaryCallSettings getDataSourceSettings() {
@@ -185,6 +169,11 @@ public UnaryCallSettings getDataSourceSettings
return updateTransferConfigSettings;
}
+ /** Returns the object with the settings used for calls to deleteTransferConfig. */
+ public UnaryCallSettings deleteTransferConfigSettings() {
+ return deleteTransferConfigSettings;
+ }
+
/** Returns the object with the settings used for calls to getTransferConfig. */
public UnaryCallSettings getTransferConfigSettings() {
return getTransferConfigSettings;
@@ -214,6 +203,11 @@ public UnaryCallSettings getTransferRunSetti
return getTransferRunSettings;
}
+ /** Returns the object with the settings used for calls to deleteTransferRun. */
+ public UnaryCallSettings deleteTransferRunSettings() {
+ return deleteTransferRunSettings;
+ }
+
/** Returns the object with the settings used for calls to listTransferRuns. */
public PagedCallSettings<
ListTransferRunsRequest, ListTransferRunsResponse, ListTransferRunsPagedResponse>
@@ -228,6 +222,12 @@ public UnaryCallSettings getTransferRunSetti
return listTransferLogsSettings;
}
+ /** Returns the object with the settings used for calls to checkValidCreds. */
+ public UnaryCallSettings
+ checkValidCredsSettings() {
+ return checkValidCredsSettings;
+ }
+
@BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public DataTransferServiceStub createStub() throws IOException {
if (getTransportChannelProvider()
@@ -297,20 +297,20 @@ public Builder toBuilder() {
protected DataTransferServiceStubSettings(Builder settingsBuilder) throws IOException {
super(settingsBuilder);
- deleteTransferConfigSettings = settingsBuilder.deleteTransferConfigSettings().build();
- deleteTransferRunSettings = settingsBuilder.deleteTransferRunSettings().build();
- checkValidCredsSettings = settingsBuilder.checkValidCredsSettings().build();
getDataSourceSettings = settingsBuilder.getDataSourceSettings().build();
listDataSourcesSettings = settingsBuilder.listDataSourcesSettings().build();
createTransferConfigSettings = settingsBuilder.createTransferConfigSettings().build();
updateTransferConfigSettings = settingsBuilder.updateTransferConfigSettings().build();
+ deleteTransferConfigSettings = settingsBuilder.deleteTransferConfigSettings().build();
getTransferConfigSettings = settingsBuilder.getTransferConfigSettings().build();
listTransferConfigsSettings = settingsBuilder.listTransferConfigsSettings().build();
scheduleTransferRunsSettings = settingsBuilder.scheduleTransferRunsSettings().build();
startManualTransferRunsSettings = settingsBuilder.startManualTransferRunsSettings().build();
getTransferRunSettings = settingsBuilder.getTransferRunSettings().build();
+ deleteTransferRunSettings = settingsBuilder.deleteTransferRunSettings().build();
listTransferRunsSettings = settingsBuilder.listTransferRunsSettings().build();
listTransferLogsSettings = settingsBuilder.listTransferLogsSettings().build();
+ checkValidCredsSettings = settingsBuilder.checkValidCredsSettings().build();
}
private static final PagedListDescriptor<
@@ -553,12 +553,6 @@ public static class Builder
extends StubSettings.Builder {
private final ImmutableList> unaryMethodSettingsBuilders;
- private final UnaryCallSettings.Builder
- deleteTransferConfigSettings;
- private final UnaryCallSettings.Builder
- deleteTransferRunSettings;
- private final UnaryCallSettings.Builder
- checkValidCredsSettings;
private final UnaryCallSettings.Builder getDataSourceSettings;
private final PagedCallSettings.Builder<
ListDataSourcesRequest, ListDataSourcesResponse, ListDataSourcesPagedResponse>
@@ -567,6 +561,8 @@ public static class Builder
createTransferConfigSettings;
private final UnaryCallSettings.Builder
updateTransferConfigSettings;
+ private final UnaryCallSettings.Builder
+ deleteTransferConfigSettings;
private final UnaryCallSettings.Builder
getTransferConfigSettings;
private final PagedCallSettings.Builder<
@@ -582,12 +578,16 @@ public static class Builder
startManualTransferRunsSettings;
private final UnaryCallSettings.Builder
getTransferRunSettings;
+ private final UnaryCallSettings.Builder
+ deleteTransferRunSettings;
private final PagedCallSettings.Builder<
ListTransferRunsRequest, ListTransferRunsResponse, ListTransferRunsPagedResponse>
listTransferRunsSettings;
private final PagedCallSettings.Builder<
ListTransferLogsRequest, ListTransferLogsResponse, ListTransferLogsPagedResponse>
listTransferLogsSettings;
+ private final UnaryCallSettings.Builder
+ checkValidCredsSettings;
private static final ImmutableMap>
RETRYABLE_CODE_DEFINITIONS;
@@ -596,11 +596,13 @@ public static class Builder
ImmutableMap.Builder> definitions =
ImmutableMap.builder();
definitions.put(
- "idempotent",
+ "retry_policy_1_codes",
ImmutableSet.copyOf(
Lists.newArrayList(
- StatusCode.Code.DEADLINE_EXCEEDED, StatusCode.Code.UNAVAILABLE)));
- definitions.put("non_idempotent", ImmutableSet.copyOf(Lists.newArrayList()));
+ StatusCode.Code.UNAVAILABLE, StatusCode.Code.DEADLINE_EXCEEDED)));
+ definitions.put("no_retry_codes", ImmutableSet.copyOf(Lists.newArrayList()));
+ definitions.put(
+ "no_retry_1_codes", ImmutableSet.copyOf(Lists.newArrayList()));
RETRYABLE_CODE_DEFINITIONS = definitions.build();
}
@@ -617,9 +619,19 @@ public static class Builder
.setInitialRpcTimeout(Duration.ofMillis(20000L))
.setRpcTimeoutMultiplier(1.0)
.setMaxRpcTimeout(Duration.ofMillis(20000L))
- .setTotalTimeout(Duration.ofMillis(600000L))
+ .setTotalTimeout(Duration.ofMillis(20000L))
+ .build();
+ definitions.put("retry_policy_1_params", settings);
+ settings = RetrySettings.newBuilder().setRpcTimeoutMultiplier(1.0).build();
+ definitions.put("no_retry_params", settings);
+ settings =
+ RetrySettings.newBuilder()
+ .setInitialRpcTimeout(Duration.ofMillis(30000L))
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ofMillis(30000L))
+ .setTotalTimeout(Duration.ofMillis(30000L))
.build();
- definitions.put("default", settings);
+ definitions.put("no_retry_1_params", settings);
RETRY_PARAM_DEFINITIONS = definitions.build();
}
@@ -630,12 +642,6 @@ protected Builder() {
protected Builder(ClientContext clientContext) {
super(clientContext);
- deleteTransferConfigSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
-
- deleteTransferRunSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
-
- checkValidCredsSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
-
getDataSourceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
listDataSourcesSettings = PagedCallSettings.newBuilder(LIST_DATA_SOURCES_PAGE_STR_FACT);
@@ -644,6 +650,8 @@ protected Builder(ClientContext clientContext) {
updateTransferConfigSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ deleteTransferConfigSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+
getTransferConfigSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
listTransferConfigsSettings =
@@ -655,26 +663,30 @@ protected Builder(ClientContext clientContext) {
getTransferRunSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ deleteTransferRunSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+
listTransferRunsSettings = PagedCallSettings.newBuilder(LIST_TRANSFER_RUNS_PAGE_STR_FACT);
listTransferLogsSettings = PagedCallSettings.newBuilder(LIST_TRANSFER_LOGS_PAGE_STR_FACT);
+ checkValidCredsSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+
unaryMethodSettingsBuilders =
ImmutableList.>of(
- deleteTransferConfigSettings,
- deleteTransferRunSettings,
- checkValidCredsSettings,
getDataSourceSettings,
listDataSourcesSettings,
createTransferConfigSettings,
updateTransferConfigSettings,
+ deleteTransferConfigSettings,
getTransferConfigSettings,
listTransferConfigsSettings,
scheduleTransferRunsSettings,
startManualTransferRunsSettings,
getTransferRunSettings,
+ deleteTransferRunSettings,
listTransferRunsSettings,
- listTransferLogsSettings);
+ listTransferLogsSettings,
+ checkValidCredsSettings);
initDefaults(this);
}
@@ -690,75 +702,75 @@ private static Builder createDefault() {
private static Builder initDefaults(Builder builder) {
- builder
- .deleteTransferConfigSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
-
- builder
- .deleteTransferRunSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
-
- builder
- .checkValidCredsSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
-
builder
.getDataSourceSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
builder
.listDataSourcesSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
builder
.createTransferConfigSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
builder
.updateTransferConfigSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
+
+ builder
+ .deleteTransferConfigSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
builder
.getTransferConfigSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
builder
.listTransferConfigsSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
builder
.scheduleTransferRunsSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
builder
.startManualTransferRunsSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_params"));
builder
.getTransferRunSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
+
+ builder
+ .deleteTransferRunSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
builder
.listTransferRunsSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
builder
.listTransferLogsSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
+
+ builder
+ .checkValidCredsSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
return builder;
}
@@ -766,37 +778,37 @@ private static Builder initDefaults(Builder builder) {
protected Builder(DataTransferServiceStubSettings settings) {
super(settings);
- deleteTransferConfigSettings = settings.deleteTransferConfigSettings.toBuilder();
- deleteTransferRunSettings = settings.deleteTransferRunSettings.toBuilder();
- checkValidCredsSettings = settings.checkValidCredsSettings.toBuilder();
getDataSourceSettings = settings.getDataSourceSettings.toBuilder();
listDataSourcesSettings = settings.listDataSourcesSettings.toBuilder();
createTransferConfigSettings = settings.createTransferConfigSettings.toBuilder();
updateTransferConfigSettings = settings.updateTransferConfigSettings.toBuilder();
+ deleteTransferConfigSettings = settings.deleteTransferConfigSettings.toBuilder();
getTransferConfigSettings = settings.getTransferConfigSettings.toBuilder();
listTransferConfigsSettings = settings.listTransferConfigsSettings.toBuilder();
scheduleTransferRunsSettings = settings.scheduleTransferRunsSettings.toBuilder();
startManualTransferRunsSettings = settings.startManualTransferRunsSettings.toBuilder();
getTransferRunSettings = settings.getTransferRunSettings.toBuilder();
+ deleteTransferRunSettings = settings.deleteTransferRunSettings.toBuilder();
listTransferRunsSettings = settings.listTransferRunsSettings.toBuilder();
listTransferLogsSettings = settings.listTransferLogsSettings.toBuilder();
+ checkValidCredsSettings = settings.checkValidCredsSettings.toBuilder();
unaryMethodSettingsBuilders =
ImmutableList.>of(
- deleteTransferConfigSettings,
- deleteTransferRunSettings,
- checkValidCredsSettings,
getDataSourceSettings,
listDataSourcesSettings,
createTransferConfigSettings,
updateTransferConfigSettings,
+ deleteTransferConfigSettings,
getTransferConfigSettings,
listTransferConfigsSettings,
scheduleTransferRunsSettings,
startManualTransferRunsSettings,
getTransferRunSettings,
+ deleteTransferRunSettings,
listTransferRunsSettings,
- listTransferLogsSettings);
+ listTransferLogsSettings,
+ checkValidCredsSettings);
}
// NEXT_MAJOR_VER: remove 'throws Exception'
@@ -815,23 +827,6 @@ public Builder applyToAllUnaryMethods(
return unaryMethodSettingsBuilders;
}
- /** Returns the builder for the settings used for calls to deleteTransferConfig. */
- public UnaryCallSettings.Builder
- deleteTransferConfigSettings() {
- return deleteTransferConfigSettings;
- }
-
- /** Returns the builder for the settings used for calls to deleteTransferRun. */
- public UnaryCallSettings.Builder deleteTransferRunSettings() {
- return deleteTransferRunSettings;
- }
-
- /** Returns the builder for the settings used for calls to checkValidCreds. */
- public UnaryCallSettings.Builder
- checkValidCredsSettings() {
- return checkValidCredsSettings;
- }
-
/** Returns the builder for the settings used for calls to getDataSource. */
public UnaryCallSettings.Builder getDataSourceSettings() {
return getDataSourceSettings;
@@ -856,6 +851,12 @@ public UnaryCallSettings.Builder getDataSource
return updateTransferConfigSettings;
}
+ /** Returns the builder for the settings used for calls to deleteTransferConfig. */
+ public UnaryCallSettings.Builder
+ deleteTransferConfigSettings() {
+ return deleteTransferConfigSettings;
+ }
+
/** Returns the builder for the settings used for calls to getTransferConfig. */
public UnaryCallSettings.Builder
getTransferConfigSettings() {
@@ -889,6 +890,11 @@ public UnaryCallSettings.Builder getTransfer
return getTransferRunSettings;
}
+ /** Returns the builder for the settings used for calls to deleteTransferRun. */
+ public UnaryCallSettings.Builder deleteTransferRunSettings() {
+ return deleteTransferRunSettings;
+ }
+
/** Returns the builder for the settings used for calls to listTransferRuns. */
public PagedCallSettings.Builder<
ListTransferRunsRequest, ListTransferRunsResponse, ListTransferRunsPagedResponse>
@@ -903,6 +909,12 @@ public UnaryCallSettings.Builder getTransfer
return listTransferLogsSettings;
}
+ /** Returns the builder for the settings used for calls to checkValidCreds. */
+ public UnaryCallSettings.Builder
+ checkValidCredsSettings() {
+ return checkValidCredsSettings;
+ }
+
@Override
public DataTransferServiceStubSettings build() throws IOException {
return new DataTransferServiceStubSettings(this);
diff --git a/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/stub/GrpcDataTransferServiceStub.java b/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/stub/GrpcDataTransferServiceStub.java
index a052c06b..e140e7a4 100644
--- a/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/stub/GrpcDataTransferServiceStub.java
+++ b/google-cloud-bigquerydatatransfer/src/main/java/com/google/cloud/bigquery/datatransfer/v1/stub/GrpcDataTransferServiceStub.java
@@ -71,37 +71,6 @@
@BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public class GrpcDataTransferServiceStub extends DataTransferServiceStub {
- private static final MethodDescriptor
- deleteTransferConfigMethodDescriptor =
- MethodDescriptor.newBuilder()
- .setType(MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(
- "google.cloud.bigquery.datatransfer.v1.DataTransferService/DeleteTransferConfig")
- .setRequestMarshaller(
- ProtoUtils.marshaller(DeleteTransferConfigRequest.getDefaultInstance()))
- .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
- .build();
- private static final MethodDescriptor
- deleteTransferRunMethodDescriptor =
- MethodDescriptor.newBuilder()
- .setType(MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(
- "google.cloud.bigquery.datatransfer.v1.DataTransferService/DeleteTransferRun")
- .setRequestMarshaller(
- ProtoUtils.marshaller(DeleteTransferRunRequest.getDefaultInstance()))
- .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
- .build();
- private static final MethodDescriptor
- checkValidCredsMethodDescriptor =
- MethodDescriptor.newBuilder()
- .setType(MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(
- "google.cloud.bigquery.datatransfer.v1.DataTransferService/CheckValidCreds")
- .setRequestMarshaller(
- ProtoUtils.marshaller(CheckValidCredsRequest.getDefaultInstance()))
- .setResponseMarshaller(
- ProtoUtils.marshaller(CheckValidCredsResponse.getDefaultInstance()))
- .build();
private static final MethodDescriptor
getDataSourceMethodDescriptor =
MethodDescriptor.newBuilder()
@@ -143,6 +112,16 @@ public class GrpcDataTransferServiceStub extends DataTransferServiceStub {
ProtoUtils.marshaller(UpdateTransferConfigRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(TransferConfig.getDefaultInstance()))
.build();
+ private static final MethodDescriptor
+ deleteTransferConfigMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.cloud.bigquery.datatransfer.v1.DataTransferService/DeleteTransferConfig")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(DeleteTransferConfigRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
+ .build();
private static final MethodDescriptor
getTransferConfigMethodDescriptor =
MethodDescriptor.newBuilder()
@@ -198,6 +177,16 @@ public class GrpcDataTransferServiceStub extends DataTransferServiceStub {
ProtoUtils.marshaller(GetTransferRunRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(TransferRun.getDefaultInstance()))
.build();
+ private static final MethodDescriptor
+ deleteTransferRunMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.cloud.bigquery.datatransfer.v1.DataTransferService/DeleteTransferRun")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(DeleteTransferRunRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
+ .build();
private static final MethodDescriptor
listTransferRunsMethodDescriptor =
MethodDescriptor.newBuilder()
@@ -220,13 +209,20 @@ public class GrpcDataTransferServiceStub extends DataTransferServiceStub {
.setResponseMarshaller(
ProtoUtils.marshaller(ListTransferLogsResponse.getDefaultInstance()))
.build();
+ private static final MethodDescriptor
+ checkValidCredsMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ "google.cloud.bigquery.datatransfer.v1.DataTransferService/CheckValidCreds")
+ .setRequestMarshaller(
+ ProtoUtils.marshaller(CheckValidCredsRequest.getDefaultInstance()))
+ .setResponseMarshaller(
+ ProtoUtils.marshaller(CheckValidCredsResponse.getDefaultInstance()))
+ .build();
private final BackgroundResource backgroundResources;
- private final UnaryCallable deleteTransferConfigCallable;
- private final UnaryCallable deleteTransferRunCallable;
- private final UnaryCallable
- checkValidCredsCallable;
private final UnaryCallable getDataSourceCallable;
private final UnaryCallable
listDataSourcesCallable;
@@ -236,6 +232,7 @@ public class GrpcDataTransferServiceStub extends DataTransferServiceStub {
createTransferConfigCallable;
private final UnaryCallable
updateTransferConfigCallable;
+ private final UnaryCallable deleteTransferConfigCallable;
private final UnaryCallable getTransferConfigCallable;
private final UnaryCallable
listTransferConfigsCallable;
@@ -246,6 +243,7 @@ public class GrpcDataTransferServiceStub extends DataTransferServiceStub {
private final UnaryCallable
startManualTransferRunsCallable;
private final UnaryCallable getTransferRunCallable;
+ private final UnaryCallable deleteTransferRunCallable;
private final UnaryCallable
listTransferRunsCallable;
private final UnaryCallable
@@ -254,6 +252,8 @@ public class GrpcDataTransferServiceStub extends DataTransferServiceStub {
listTransferLogsCallable;
private final UnaryCallable
listTransferLogsPagedCallable;
+ private final UnaryCallable
+ checkValidCredsCallable;
private final GrpcStubCallableFactory callableFactory;
@@ -296,46 +296,6 @@ protected GrpcDataTransferServiceStub(
throws IOException {
this.callableFactory = callableFactory;
- GrpcCallSettings deleteTransferConfigTransportSettings =
- GrpcCallSettings.newBuilder()
- .setMethodDescriptor(deleteTransferConfigMethodDescriptor)
- .setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(DeleteTransferConfigRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
- })
- .build();
- GrpcCallSettings deleteTransferRunTransportSettings =
- GrpcCallSettings.newBuilder()
- .setMethodDescriptor(deleteTransferRunMethodDescriptor)
- .setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(DeleteTransferRunRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
- })
- .build();
- GrpcCallSettings
- checkValidCredsTransportSettings =
- GrpcCallSettings.newBuilder()
- .setMethodDescriptor(checkValidCredsMethodDescriptor)
- .setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(CheckValidCredsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
- })
- .build();
GrpcCallSettings getDataSourceTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getDataSourceMethodDescriptor)
@@ -393,6 +353,19 @@ public Map extract(UpdateTransferConfigRequest request) {
}
})
.build();
+ GrpcCallSettings deleteTransferConfigTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(deleteTransferConfigMethodDescriptor)
+ .setParamsExtractor(
+ new RequestParamsExtractor() {
+ @Override
+ public Map extract(DeleteTransferConfigRequest request) {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
+ }
+ })
+ .build();
GrpcCallSettings getTransferConfigTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getTransferConfigMethodDescriptor)
@@ -462,6 +435,19 @@ public Map extract(GetTransferRunRequest request) {
}
})
.build();
+ GrpcCallSettings deleteTransferRunTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(deleteTransferRunMethodDescriptor)
+ .setParamsExtractor(
+ new RequestParamsExtractor() {
+ @Override
+ public Map extract(DeleteTransferRunRequest request) {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
+ }
+ })
+ .build();
GrpcCallSettings
listTransferRunsTransportSettings =
GrpcCallSettings.newBuilder()
@@ -490,20 +476,21 @@ public Map extract(ListTransferLogsRequest request) {
}
})
.build();
+ GrpcCallSettings
+ checkValidCredsTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(checkValidCredsMethodDescriptor)
+ .setParamsExtractor(
+ new RequestParamsExtractor() {
+ @Override
+ public Map extract(CheckValidCredsRequest request) {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
+ }
+ })
+ .build();
- this.deleteTransferConfigCallable =
- callableFactory.createUnaryCallable(
- deleteTransferConfigTransportSettings,
- settings.deleteTransferConfigSettings(),
- clientContext);
- this.deleteTransferRunCallable =
- callableFactory.createUnaryCallable(
- deleteTransferRunTransportSettings,
- settings.deleteTransferRunSettings(),
- clientContext);
- this.checkValidCredsCallable =
- callableFactory.createUnaryCallable(
- checkValidCredsTransportSettings, settings.checkValidCredsSettings(), clientContext);
this.getDataSourceCallable =
callableFactory.createUnaryCallable(
getDataSourceTransportSettings, settings.getDataSourceSettings(), clientContext);
@@ -523,6 +510,11 @@ public Map extract(ListTransferLogsRequest request) {
updateTransferConfigTransportSettings,
settings.updateTransferConfigSettings(),
clientContext);
+ this.deleteTransferConfigCallable =
+ callableFactory.createUnaryCallable(
+ deleteTransferConfigTransportSettings,
+ settings.deleteTransferConfigSettings(),
+ clientContext);
this.getTransferConfigCallable =
callableFactory.createUnaryCallable(
getTransferConfigTransportSettings,
@@ -551,6 +543,11 @@ public Map extract(ListTransferLogsRequest request) {
this.getTransferRunCallable =
callableFactory.createUnaryCallable(
getTransferRunTransportSettings, settings.getTransferRunSettings(), clientContext);
+ this.deleteTransferRunCallable =
+ callableFactory.createUnaryCallable(
+ deleteTransferRunTransportSettings,
+ settings.deleteTransferRunSettings(),
+ clientContext);
this.listTransferRunsCallable =
callableFactory.createUnaryCallable(
listTransferRunsTransportSettings, settings.listTransferRunsSettings(), clientContext);
@@ -563,22 +560,13 @@ public Map extract(ListTransferLogsRequest request) {
this.listTransferLogsPagedCallable =
callableFactory.createPagedCallable(
listTransferLogsTransportSettings, settings.listTransferLogsSettings(), clientContext);
+ this.checkValidCredsCallable =
+ callableFactory.createUnaryCallable(
+ checkValidCredsTransportSettings, settings.checkValidCredsSettings(), clientContext);
backgroundResources = new BackgroundResourceAggregation(clientContext.getBackgroundResources());
}
- public UnaryCallable deleteTransferConfigCallable() {
- return deleteTransferConfigCallable;
- }
-
- public UnaryCallable deleteTransferRunCallable() {
- return deleteTransferRunCallable;
- }
-
- public UnaryCallable checkValidCredsCallable() {
- return checkValidCredsCallable;
- }
-
public UnaryCallable getDataSourceCallable() {
return getDataSourceCallable;
}
@@ -600,6 +588,10 @@ public UnaryCallable updateTransfer
return updateTransferConfigCallable;
}
+ public UnaryCallable deleteTransferConfigCallable() {
+ return deleteTransferConfigCallable;
+ }
+
public UnaryCallable getTransferConfigCallable() {
return getTransferConfigCallable;
}
@@ -628,6 +620,10 @@ public UnaryCallable getTransferRunCallable(
return getTransferRunCallable;
}
+ public UnaryCallable deleteTransferRunCallable() {
+ return deleteTransferRunCallable;
+ }
+
public UnaryCallable
listTransferRunsPagedCallable() {
return listTransferRunsPagedCallable;
@@ -648,6 +644,10 @@ public UnaryCallable getTransferRunCallable(
return listTransferLogsCallable;
}
+ public UnaryCallable checkValidCredsCallable() {
+ return checkValidCredsCallable;
+ }
+
@Override
public final void close() {
shutdown();
diff --git a/google-cloud-bigquerydatatransfer/src/test/java/com/google/cloud/bigquery/datatransfer/v1/DataTransferServiceClientTest.java b/google-cloud-bigquerydatatransfer/src/test/java/com/google/cloud/bigquery/datatransfer/v1/DataTransferServiceClientTest.java
index e7c3149a..860e36ac 100644
--- a/google-cloud-bigquerydatatransfer/src/test/java/com/google/cloud/bigquery/datatransfer/v1/DataTransferServiceClientTest.java
+++ b/google-cloud-bigquerydatatransfer/src/test/java/com/google/cloud/bigquery/datatransfer/v1/DataTransferServiceClientTest.java
@@ -83,124 +83,6 @@ public void tearDown() throws Exception {
client.close();
}
- @Test
- @SuppressWarnings("all")
- public void deleteTransferConfigTest() {
- Empty expectedResponse = Empty.newBuilder().build();
- mockDataTransferService.addResponse(expectedResponse);
-
- TransferConfigName name =
- TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
-
- client.deleteTransferConfig(name);
-
- List actualRequests = mockDataTransferService.getRequests();
- Assert.assertEquals(1, actualRequests.size());
- DeleteTransferConfigRequest actualRequest = (DeleteTransferConfigRequest) actualRequests.get(0);
-
- Assert.assertEquals(name, TransferConfigName.parse(actualRequest.getName()));
- Assert.assertTrue(
- channelProvider.isHeaderSent(
- ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
- GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
- }
-
- @Test
- @SuppressWarnings("all")
- public void deleteTransferConfigExceptionTest() throws Exception {
- StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
- mockDataTransferService.addException(exception);
-
- try {
- TransferConfigName name =
- TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
-
- client.deleteTransferConfig(name);
- Assert.fail("No exception raised");
- } catch (InvalidArgumentException e) {
- // Expected exception
- }
- }
-
- @Test
- @SuppressWarnings("all")
- public void deleteTransferRunTest() {
- Empty expectedResponse = Empty.newBuilder().build();
- mockDataTransferService.addResponse(expectedResponse);
-
- RunName name =
- RunName.ofProjectTransferConfigRunName("[PROJECT]", "[TRANSFER_CONFIG]", "[RUN]");
-
- client.deleteTransferRun(name);
-
- List actualRequests = mockDataTransferService.getRequests();
- Assert.assertEquals(1, actualRequests.size());
- DeleteTransferRunRequest actualRequest = (DeleteTransferRunRequest) actualRequests.get(0);
-
- Assert.assertEquals(name, RunName.parse(actualRequest.getName()));
- Assert.assertTrue(
- channelProvider.isHeaderSent(
- ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
- GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
- }
-
- @Test
- @SuppressWarnings("all")
- public void deleteTransferRunExceptionTest() throws Exception {
- StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
- mockDataTransferService.addException(exception);
-
- try {
- RunName name =
- RunName.ofProjectTransferConfigRunName("[PROJECT]", "[TRANSFER_CONFIG]", "[RUN]");
-
- client.deleteTransferRun(name);
- Assert.fail("No exception raised");
- } catch (InvalidArgumentException e) {
- // Expected exception
- }
- }
-
- @Test
- @SuppressWarnings("all")
- public void checkValidCredsTest() {
- boolean hasValidCreds = false;
- CheckValidCredsResponse expectedResponse =
- CheckValidCredsResponse.newBuilder().setHasValidCreds(hasValidCreds).build();
- mockDataTransferService.addResponse(expectedResponse);
-
- DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
-
- CheckValidCredsResponse actualResponse = client.checkValidCreds(name);
- Assert.assertEquals(expectedResponse, actualResponse);
-
- List actualRequests = mockDataTransferService.getRequests();
- Assert.assertEquals(1, actualRequests.size());
- CheckValidCredsRequest actualRequest = (CheckValidCredsRequest) actualRequests.get(0);
-
- Assert.assertEquals(name, DataSourceName.parse(actualRequest.getName()));
- Assert.assertTrue(
- channelProvider.isHeaderSent(
- ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
- GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
- }
-
- @Test
- @SuppressWarnings("all")
- public void checkValidCredsExceptionTest() throws Exception {
- StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
- mockDataTransferService.addException(exception);
-
- try {
- DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
-
- client.checkValidCreds(name);
- Assert.fail("No exception raised");
- } catch (InvalidArgumentException e) {
- // Expected exception
- }
- }
-
@Test
@SuppressWarnings("all")
public void getDataSourceTest() {
@@ -441,6 +323,45 @@ public void updateTransferConfigExceptionTest() throws Exception {
}
}
+ @Test
+ @SuppressWarnings("all")
+ public void deleteTransferConfigTest() {
+ Empty expectedResponse = Empty.newBuilder().build();
+ mockDataTransferService.addResponse(expectedResponse);
+
+ TransferConfigName name =
+ TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
+
+ client.deleteTransferConfig(name);
+
+ List actualRequests = mockDataTransferService.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ DeleteTransferConfigRequest actualRequest = (DeleteTransferConfigRequest) actualRequests.get(0);
+
+ Assert.assertEquals(name, TransferConfigName.parse(actualRequest.getName()));
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ @SuppressWarnings("all")
+ public void deleteTransferConfigExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
+ mockDataTransferService.addException(exception);
+
+ try {
+ TransferConfigName name =
+ TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
+
+ client.deleteTransferConfig(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception
+ }
+ }
+
@Test
@SuppressWarnings("all")
public void getTransferConfigTest() {
@@ -694,6 +615,45 @@ public void getTransferRunExceptionTest() throws Exception {
}
}
+ @Test
+ @SuppressWarnings("all")
+ public void deleteTransferRunTest() {
+ Empty expectedResponse = Empty.newBuilder().build();
+ mockDataTransferService.addResponse(expectedResponse);
+
+ RunName name =
+ RunName.ofProjectTransferConfigRunName("[PROJECT]", "[TRANSFER_CONFIG]", "[RUN]");
+
+ client.deleteTransferRun(name);
+
+ List actualRequests = mockDataTransferService.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ DeleteTransferRunRequest actualRequest = (DeleteTransferRunRequest) actualRequests.get(0);
+
+ Assert.assertEquals(name, RunName.parse(actualRequest.getName()));
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ @SuppressWarnings("all")
+ public void deleteTransferRunExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
+ mockDataTransferService.addException(exception);
+
+ try {
+ RunName name =
+ RunName.ofProjectTransferConfigRunName("[PROJECT]", "[TRANSFER_CONFIG]", "[RUN]");
+
+ client.deleteTransferRun(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception
+ }
+ }
+
@Test
@SuppressWarnings("all")
public void listTransferRunsTest() {
@@ -793,4 +753,44 @@ public void listTransferLogsExceptionTest() throws Exception {
// Expected exception
}
}
+
+ @Test
+ @SuppressWarnings("all")
+ public void checkValidCredsTest() {
+ boolean hasValidCreds = false;
+ CheckValidCredsResponse expectedResponse =
+ CheckValidCredsResponse.newBuilder().setHasValidCreds(hasValidCreds).build();
+ mockDataTransferService.addResponse(expectedResponse);
+
+ DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
+
+ CheckValidCredsResponse actualResponse = client.checkValidCreds(name);
+ Assert.assertEquals(expectedResponse, actualResponse);
+
+ List actualRequests = mockDataTransferService.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ CheckValidCredsRequest actualRequest = (CheckValidCredsRequest) actualRequests.get(0);
+
+ Assert.assertEquals(name, DataSourceName.parse(actualRequest.getName()));
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ @SuppressWarnings("all")
+ public void checkValidCredsExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
+ mockDataTransferService.addException(exception);
+
+ try {
+ DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
+
+ client.checkValidCreds(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception
+ }
+ }
}
diff --git a/synth.metadata b/synth.metadata
index 3958f0d3..74c4e186 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -11,15 +11,15 @@
"git": {
"name": ".",
"remote": "https://github.com/googleapis/java-bigquerydatatransfer.git",
- "sha": "3e0be16c0938ec31a40d9a11bae6b08e58e10591"
+ "sha": "4f75d090dbbba7d2cad7445107941e9f7b2c01fe"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "c4e37010d74071851ff24121f522e802231ac86e",
- "internalRef": "313460921"
+ "sha": "8dd269fb6fc7635b7edd67403b89450e0cd450c9",
+ "internalRef": "320218003"
}
},
{