*
* try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
- * DataSource response = dataTransferServiceClient.getDataSource(name);
+ * TransferConfigName name = TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
+ * dataTransferServiceClient.deleteTransferConfig(name);
* }
*
*
@@ -159,6 +159,300 @@ 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);
- * }
- * 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());
+ * TransferConfig transferConfig = TransferConfig.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * TransferConfig response = dataTransferServiceClient.updateTransferConfig(transferConfig, updateMask);
* }
* Sample code: * *
* try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * TransferConfigName name = TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
- * DeleteTransferConfigRequest request = DeleteTransferConfigRequest.newBuilder()
- * .setName(name.toString())
+ * TransferConfig transferConfig = TransferConfig.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * UpdateTransferConfigRequest request = UpdateTransferConfigRequest.newBuilder()
+ * .setTransferConfig(transferConfig)
+ * .setUpdateMask(updateMask)
* .build();
- * dataTransferServiceClient.deleteTransferConfig(request);
+ * TransferConfig response = dataTransferServiceClient.updateTransferConfig(request);
* }
* Sample code: * *
* try (DataTransferServiceClient dataTransferServiceClient = DataTransferServiceClient.create()) {
- * TransferConfigName name = TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
- * DeleteTransferConfigRequest request = DeleteTransferConfigRequest.newBuilder()
- * .setName(name.toString())
+ * TransferConfig transferConfig = TransferConfig.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * UpdateTransferConfigRequest request = UpdateTransferConfigRequest.newBuilder()
+ * .setTransferConfig(transferConfig)
+ * .setUpdateMask(updateMask)
* .build();
- * ApiFuture<Void> future = dataTransferServiceClient.deleteTransferConfigCallable().futureCall(request);
+ * ApiFuture<TransferConfig> future = dataTransferServiceClient.updateTransferConfigCallable().futureCall(request);
* // Do something
- * future.get();
+ * TransferConfig response = 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 getDataSource to 30 seconds: + *
For example, to set the total timeout of deleteTransferConfig to 30 seconds: * *
*
* DataTransferServiceSettings.Builder dataTransferServiceSettingsBuilder =
* DataTransferServiceSettings.newBuilder();
* dataTransferServiceSettingsBuilder
- * .getDataSourceSettings()
+ * .deleteTransferConfigSettings()
* .setRetrySettings(
- * dataTransferServiceSettingsBuilder.getDataSourceSettings().getRetrySettings().toBuilder()
+ * dataTransferServiceSettingsBuilder.deleteTransferConfigSettings().getRetrySettings().toBuilder()
* .setTotalTimeout(Duration.ofSeconds(30))
* .build());
* DataTransferServiceSettings dataTransferServiceSettings = dataTransferServiceSettingsBuilder.build();
@@ -72,6 +72,22 @@
@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();
@@ -96,11 +112,6 @@ 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();
@@ -130,11 +141,6 @@ 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>
@@ -149,12 +155,6 @@ public UnaryCallSettings deleteTransferRunSetti
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,6 +252,23 @@ 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();
@@ -276,12 +293,6 @@ 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() {
@@ -315,11 +326,6 @@ 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>
@@ -334,12 +340,6 @@ public UnaryCallSettings.Builder deleteTransfer
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 5fe10fe5..3c2b7078 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()) {
- * DataSourceName name = DataSourceName.ofProjectDataSourceName("[PROJECT]", "[DATA_SOURCE]");
- * DataSource response = dataTransferServiceClient.getDataSource(name);
+ * TransferConfigName name = TransferConfigName.ofProjectTransferConfigName("[PROJECT]", "[TRANSFER_CONFIG]");
+ * dataTransferServiceClient.deleteTransferConfig(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 a9331f03..56aabbed 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,6 +60,18 @@
@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()");
}
@@ -81,10 +93,6 @@ 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()");
}
@@ -113,10 +121,6 @@ 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()");
@@ -137,10 +141,6 @@ public UnaryCallable deleteTransferRunCallable(
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 d841b7ee..f60857f0 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 getDataSource to 30 seconds:
+ *
For example, to set the total timeout of deleteTransferConfig to 30 seconds:
*
*
*
* DataTransferServiceStubSettings.Builder dataTransferServiceSettingsBuilder =
* DataTransferServiceStubSettings.newBuilder();
* dataTransferServiceSettingsBuilder
- * .getDataSourceSettings()
+ * .deleteTransferConfigSettings()
* .setRetrySettings(
- * dataTransferServiceSettingsBuilder.getDataSourceSettings().getRetrySettings().toBuilder()
+ * dataTransferServiceSettingsBuilder.deleteTransferConfigSettings().getRetrySettings().toBuilder()
* .setTotalTimeout(Duration.ofSeconds(30))
* .build());
* DataTransferServiceStubSettings dataTransferServiceSettings = dataTransferServiceSettingsBuilder.build();
@@ -116,6 +116,10 @@ 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>
@@ -124,7 +128,6 @@ public class DataTransferServiceStubSettings extends StubSettings
updateTransferConfigSettings;
- private final UnaryCallSettings deleteTransferConfigSettings;
private final UnaryCallSettings
getTransferConfigSettings;
private final PagedCallSettings<
@@ -135,15 +138,28 @@ 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;
- private final UnaryCallSettings
- checkValidCredsSettings;
+
+ /** 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;
+ }
/** Returns the object with the settings used for calls to getDataSource. */
public UnaryCallSettings getDataSourceSettings() {
@@ -169,11 +185,6 @@ 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;
@@ -203,11 +214,6 @@ 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>
@@ -222,12 +228,6 @@ public UnaryCallSettings deleteTransferRunSetti
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,6 +553,12 @@ 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>
@@ -561,8 +567,6 @@ public static class Builder
createTransferConfigSettings;
private final UnaryCallSettings.Builder
updateTransferConfigSettings;
- private final UnaryCallSettings.Builder
- deleteTransferConfigSettings;
private final UnaryCallSettings.Builder
getTransferConfigSettings;
private final PagedCallSettings.Builder<
@@ -578,16 +582,12 @@ 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;
@@ -630,6 +630,12 @@ 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);
@@ -638,8 +644,6 @@ protected Builder(ClientContext clientContext) {
updateTransferConfigSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
- deleteTransferConfigSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
-
getTransferConfigSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
listTransferConfigsSettings =
@@ -651,30 +655,26 @@ 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,
- checkValidCredsSettings);
+ listTransferLogsSettings);
initDefaults(this);
}
@@ -690,6 +690,21 @@ 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"))
@@ -710,11 +725,6 @@ private static Builder initDefaults(Builder builder) {
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
- builder
- .deleteTransferConfigSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
-
builder
.getTransferConfigSettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
@@ -740,11 +750,6 @@ private static Builder initDefaults(Builder builder) {
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
- builder
- .deleteTransferRunSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
-
builder
.listTransferRunsSettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
@@ -755,48 +760,43 @@ private static Builder initDefaults(Builder builder) {
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
- builder
- .checkValidCredsSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
-
return 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,
- checkValidCredsSettings);
+ listTransferLogsSettings);
}
// NEXT_MAJOR_VER: remove 'throws Exception'
@@ -815,6 +815,23 @@ 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;
@@ -839,12 +856,6 @@ 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() {
@@ -878,11 +889,6 @@ 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>
@@ -897,12 +903,6 @@ public UnaryCallSettings.Builder deleteTransfer
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 e140e7a4..a052c06b 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,6 +71,37 @@
@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()
@@ -112,16 +143,6 @@ 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()
@@ -177,16 +198,6 @@ 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()
@@ -209,20 +220,13 @@ 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;
@@ -232,7 +236,6 @@ public class GrpcDataTransferServiceStub extends DataTransferServiceStub {
createTransferConfigCallable;
private final UnaryCallable
updateTransferConfigCallable;
- private final UnaryCallable deleteTransferConfigCallable;
private final UnaryCallable getTransferConfigCallable;
private final UnaryCallable
listTransferConfigsCallable;
@@ -243,7 +246,6 @@ public class GrpcDataTransferServiceStub extends DataTransferServiceStub {
private final UnaryCallable
startManualTransferRunsCallable;
private final UnaryCallable getTransferRunCallable;
- private final UnaryCallable deleteTransferRunCallable;
private final UnaryCallable
listTransferRunsCallable;
private final UnaryCallable
@@ -252,8 +254,6 @@ public class GrpcDataTransferServiceStub extends DataTransferServiceStub {
listTransferLogsCallable;
private final UnaryCallable
listTransferLogsPagedCallable;
- private final UnaryCallable
- checkValidCredsCallable;
private final GrpcStubCallableFactory callableFactory;
@@ -296,6 +296,46 @@ 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)
@@ -353,19 +393,6 @@ 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)
@@ -435,19 +462,6 @@ 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()
@@ -476,21 +490,20 @@ 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);
@@ -510,11 +523,6 @@ public Map extract(CheckValidCredsRequest request) {
updateTransferConfigTransportSettings,
settings.updateTransferConfigSettings(),
clientContext);
- this.deleteTransferConfigCallable =
- callableFactory.createUnaryCallable(
- deleteTransferConfigTransportSettings,
- settings.deleteTransferConfigSettings(),
- clientContext);
this.getTransferConfigCallable =
callableFactory.createUnaryCallable(
getTransferConfigTransportSettings,
@@ -543,11 +551,6 @@ public Map extract(CheckValidCredsRequest 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);
@@ -560,13 +563,22 @@ public Map extract(CheckValidCredsRequest 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;
}
@@ -588,10 +600,6 @@ public UnaryCallable updateTransfer
return updateTransferConfigCallable;
}
- public UnaryCallable deleteTransferConfigCallable() {
- return deleteTransferConfigCallable;
- }
-
public UnaryCallable getTransferConfigCallable() {
return getTransferConfigCallable;
}
@@ -620,10 +628,6 @@ public UnaryCallable getTransferRunCallable(
return getTransferRunCallable;
}
- public UnaryCallable deleteTransferRunCallable() {
- return deleteTransferRunCallable;
- }
-
public UnaryCallable
listTransferRunsPagedCallable() {
return listTransferRunsPagedCallable;
@@ -644,10 +648,6 @@ public UnaryCallable deleteTransferRunCallable(
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 860e36ac..e7c3149a 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,6 +83,124 @@ 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() {
@@ -323,45 +441,6 @@ 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() {
@@ -615,45 +694,6 @@ 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() {
@@ -753,44 +793,4 @@ 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 956f25b2..2f3adf76 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -11,15 +11,15 @@
"git": {
"name": ".",
"remote": "https://github.com/googleapis/java-bigquerydatatransfer.git",
- "sha": "04bb54e313c85f216c81e0e83e3d953cb3c597ea"
+ "sha": "cc1b752e4a71623a1c58b3d129b70e30bb155614"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "aed11c01e52921613b9ee469c2d85f5f33175fb7",
- "internalRef": "310660461"
+ "sha": "5a90d467aa65e7f038f87585e8fbb45d74475e7c",
+ "internalRef": "312088359"
}
},
{