From 34cf8d00584d342d843d5f999d586bfc82db4763 Mon Sep 17 00:00:00 2001 From: Yoshi Automation Bot Date: Mon, 30 Aug 2021 16:42:01 -0700 Subject: [PATCH] chore: Re-generated to pick up changes from googleapis (#604) * chore: release gapic-generator-java v1.0.17 Committer: @miraleung PiperOrigin-RevId: 388499329 Source-Author: Google APIs Source-Date: Tue Aug 3 11:12:29 2021 -0700 Source-Repo: googleapis/googleapis Source-Sha: bb0a090d9204110042ab5dee2ce9e06e8071ce54 Source-Link: https://github.com/googleapis/googleapis/commit/bb0a090d9204110042ab5dee2ce9e06e8071ce54 * feat!: release gapic-generator-java v2.0.0 Committer: @miraleung PiperOrigin-RevId: 388535346 Source-Author: Google APIs Source-Date: Tue Aug 3 13:48:38 2021 -0700 Source-Repo: googleapis/googleapis Source-Sha: d9eaf41de44d953458b18712a3f240bb4c564e48 Source-Link: https://github.com/googleapis/googleapis/commit/d9eaf41de44d953458b18712a3f240bb4c564e48 * chore: release gapic-generator-java v2.0.1 Committer: @miraleung PiperOrigin-RevId: 389657692 Source-Author: Google APIs Source-Date: Mon Aug 9 09:53:52 2021 -0700 Source-Repo: googleapis/googleapis Source-Sha: a739464cacb3aa6d375683aefe16b79c21da1bb0 Source-Link: https://github.com/googleapis/googleapis/commit/a739464cacb3aa6d375683aefe16b79c21da1bb0 Co-authored-by: Emily Ball --- .../datacatalog/v1/DataCatalogClient.java | 61 ++-- .../datacatalog/v1/DataCatalogSettings.java | 3 +- .../v1/PolicyTagManagerClient.java | 33 +- ...PolicyTagManagerSerializationSettings.java | 3 +- .../v1/PolicyTagManagerSettings.java | 3 +- .../v1/stub/DataCatalogStubSettings.java | 3 +- .../v1/stub/GrpcDataCatalogStub.java | 300 +++++++----------- ...GrpcPolicyTagManagerSerializationStub.java | 43 ++- .../v1/stub/GrpcPolicyTagManagerStub.java | 153 ++++----- ...cyTagManagerSerializationStubSettings.java | 3 +- .../v1/stub/PolicyTagManagerStubSettings.java | 3 +- .../v1beta1/DataCatalogClient.java | 61 ++-- .../v1beta1/DataCatalogSettings.java | 3 +- .../v1beta1/PolicyTagManagerClient.java | 33 +- ...PolicyTagManagerSerializationSettings.java | 3 +- .../v1beta1/PolicyTagManagerSettings.java | 3 +- .../v1beta1/stub/DataCatalogStubSettings.java | 3 +- .../v1beta1/stub/GrpcDataCatalogStub.java | 288 +++++++---------- ...GrpcPolicyTagManagerSerializationStub.java | 32 +- .../stub/GrpcPolicyTagManagerStub.java | 153 ++++----- ...cyTagManagerSerializationStubSettings.java | 3 +- .../stub/PolicyTagManagerStubSettings.java | 3 +- synth.metadata | 8 +- 23 files changed, 460 insertions(+), 741 deletions(-) diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/DataCatalogClient.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/DataCatalogClient.java index c38784a8..9c1ed6a6 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/DataCatalogClient.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/DataCatalogClient.java @@ -16,7 +16,6 @@ package com.google.cloud.datacatalog.v1; -import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.core.BetaApi; @@ -3526,7 +3525,7 @@ public final UnaryCallable listTagsCallable() * *
{@code
    * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) {
-   *   ResourceName resource = TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]");
+   *   ResourceName resource = EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]");
    *   Policy policy = Policy.newBuilder().build();
    *   Policy response = dataCatalogClient.setIamPolicy(resource, policy);
    * }
@@ -3569,7 +3568,8 @@ public final Policy setIamPolicy(ResourceName resource, Policy policy) {
    *
    * 
{@code
    * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) {
-   *   String resource = TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString();
+   *   String resource =
+   *       EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString();
    *   Policy policy = Policy.newBuilder().build();
    *   Policy response = dataCatalogClient.setIamPolicy(resource, policy);
    * }
@@ -3611,7 +3611,8 @@ public final Policy setIamPolicy(String resource, Policy policy) {
    * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) {
    *   SetIamPolicyRequest request =
    *       SetIamPolicyRequest.newBuilder()
-   *           .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString())
+   *           .setResource(
+   *               EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString())
    *           .setPolicy(Policy.newBuilder().build())
    *           .build();
    *   Policy response = dataCatalogClient.setIamPolicy(request);
@@ -3648,7 +3649,8 @@ public final Policy setIamPolicy(SetIamPolicyRequest request) {
    * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) {
    *   SetIamPolicyRequest request =
    *       SetIamPolicyRequest.newBuilder()
-   *           .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString())
+   *           .setResource(
+   *               EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString())
    *           .setPolicy(Policy.newBuilder().build())
    *           .build();
    *   ApiFuture future = dataCatalogClient.setIamPolicyCallable().futureCall(request);
@@ -3689,7 +3691,7 @@ public final UnaryCallable setIamPolicyCallable() {
    *
    * 
{@code
    * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) {
-   *   ResourceName resource = TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]");
+   *   ResourceName resource = EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]");
    *   Policy response = dataCatalogClient.getIamPolicy(resource);
    * }
    * }
@@ -3734,7 +3736,8 @@ public final Policy getIamPolicy(ResourceName resource) { * *
{@code
    * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) {
-   *   String resource = TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString();
+   *   String resource =
+   *       EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString();
    *   Policy response = dataCatalogClient.getIamPolicy(resource);
    * }
    * }
@@ -3778,7 +3781,8 @@ public final Policy getIamPolicy(String resource) { * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) { * GetIamPolicyRequest request = * GetIamPolicyRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .setOptions(GetPolicyOptions.newBuilder().build()) * .build(); * Policy response = dataCatalogClient.getIamPolicy(request); @@ -3822,7 +3826,8 @@ public final Policy getIamPolicy(GetIamPolicyRequest request) { * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) { * GetIamPolicyRequest request = * GetIamPolicyRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .setOptions(GetPolicyOptions.newBuilder().build()) * .build(); * ApiFuture future = dataCatalogClient.getIamPolicyCallable().futureCall(request); @@ -3857,7 +3862,8 @@ public final UnaryCallable getIamPolicyCallable() { * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) { * TestIamPermissionsRequest request = * TestIamPermissionsRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .addAllPermissions(new ArrayList()) * .build(); * TestIamPermissionsResponse response = dataCatalogClient.testIamPermissions(request); @@ -3893,7 +3899,8 @@ public final TestIamPermissionsResponse testIamPermissions(TestIamPermissionsReq * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) { * TestIamPermissionsRequest request = * TestIamPermissionsRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .addAllPermissions(new ArrayList()) * .build(); * ApiFuture future = @@ -3953,12 +3960,7 @@ public static ApiFuture createAsync( SearchCatalogPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public SearchCatalogPagedResponse apply(SearchCatalogPage input) { - return new SearchCatalogPagedResponse(input); - } - }, + input -> new SearchCatalogPagedResponse(input), MoreExecutors.directExecutor()); } @@ -4034,12 +4036,7 @@ public static ApiFuture createAsync( ListEntryGroupsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListEntryGroupsPagedResponse apply(ListEntryGroupsPage input) { - return new ListEntryGroupsPagedResponse(input); - } - }, + input -> new ListEntryGroupsPagedResponse(input), MoreExecutors.directExecutor()); } @@ -4115,14 +4112,7 @@ public static ApiFuture createAsync( ApiFuture futurePage = ListEntriesPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( - futurePage, - new ApiFunction() { - @Override - public ListEntriesPagedResponse apply(ListEntriesPage input) { - return new ListEntriesPagedResponse(input); - } - }, - MoreExecutors.directExecutor()); + futurePage, input -> new ListEntriesPagedResponse(input), MoreExecutors.directExecutor()); } private ListEntriesPagedResponse(ListEntriesPage page) { @@ -4191,14 +4181,7 @@ public static ApiFuture createAsync( ApiFuture futurePage = ListTagsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( - futurePage, - new ApiFunction() { - @Override - public ListTagsPagedResponse apply(ListTagsPage input) { - return new ListTagsPagedResponse(input); - } - }, - MoreExecutors.directExecutor()); + futurePage, input -> new ListTagsPagedResponse(input), MoreExecutors.directExecutor()); } private ListTagsPagedResponse(ListTagsPage page) { diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/DataCatalogSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/DataCatalogSettings.java index 46c7af68..ab562c2b 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/DataCatalogSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/DataCatalogSettings.java @@ -311,14 +311,13 @@ public DataCatalogStubSettings.Builder getStubSettingsBuilder() { return ((DataCatalogStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/PolicyTagManagerClient.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/PolicyTagManagerClient.java index b9d59891..838ed477 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/PolicyTagManagerClient.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/PolicyTagManagerClient.java @@ -16,7 +16,6 @@ package com.google.cloud.datacatalog.v1; -import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.core.BetaApi; @@ -1209,7 +1208,8 @@ public final UnaryCallable getPolicyTagCallable( * try (PolicyTagManagerClient policyTagManagerClient = PolicyTagManagerClient.create()) { * GetIamPolicyRequest request = * GetIamPolicyRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .setOptions(GetPolicyOptions.newBuilder().build()) * .build(); * Policy response = policyTagManagerClient.getIamPolicy(request); @@ -1233,7 +1233,8 @@ public final Policy getIamPolicy(GetIamPolicyRequest request) { * try (PolicyTagManagerClient policyTagManagerClient = PolicyTagManagerClient.create()) { * GetIamPolicyRequest request = * GetIamPolicyRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .setOptions(GetPolicyOptions.newBuilder().build()) * .build(); * ApiFuture future = policyTagManagerClient.getIamPolicyCallable().futureCall(request); @@ -1256,7 +1257,8 @@ public final UnaryCallable getIamPolicyCallable() { * try (PolicyTagManagerClient policyTagManagerClient = PolicyTagManagerClient.create()) { * SetIamPolicyRequest request = * SetIamPolicyRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .setPolicy(Policy.newBuilder().build()) * .build(); * Policy response = policyTagManagerClient.setIamPolicy(request); @@ -1280,7 +1282,8 @@ public final Policy setIamPolicy(SetIamPolicyRequest request) { * try (PolicyTagManagerClient policyTagManagerClient = PolicyTagManagerClient.create()) { * SetIamPolicyRequest request = * SetIamPolicyRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .setPolicy(Policy.newBuilder().build()) * .build(); * ApiFuture future = policyTagManagerClient.setIamPolicyCallable().futureCall(request); @@ -1303,7 +1306,8 @@ public final UnaryCallable setIamPolicyCallable() { * try (PolicyTagManagerClient policyTagManagerClient = PolicyTagManagerClient.create()) { * TestIamPermissionsRequest request = * TestIamPermissionsRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .addAllPermissions(new ArrayList()) * .build(); * TestIamPermissionsResponse response = policyTagManagerClient.testIamPermissions(request); @@ -1327,7 +1331,8 @@ public final TestIamPermissionsResponse testIamPermissions(TestIamPermissionsReq * try (PolicyTagManagerClient policyTagManagerClient = PolicyTagManagerClient.create()) { * TestIamPermissionsRequest request = * TestIamPermissionsRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .addAllPermissions(new ArrayList()) * .build(); * ApiFuture future = @@ -1387,12 +1392,7 @@ public static ApiFuture createAsync( ListTaxonomiesPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListTaxonomiesPagedResponse apply(ListTaxonomiesPage input) { - return new ListTaxonomiesPagedResponse(input); - } - }, + input -> new ListTaxonomiesPagedResponse(input), MoreExecutors.directExecutor()); } @@ -1468,12 +1468,7 @@ public static ApiFuture createAsync( ListPolicyTagsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListPolicyTagsPagedResponse apply(ListPolicyTagsPage input) { - return new ListPolicyTagsPagedResponse(input); - } - }, + input -> new ListPolicyTagsPagedResponse(input), MoreExecutors.directExecutor()); } diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/PolicyTagManagerSerializationSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/PolicyTagManagerSerializationSettings.java index fca04d29..79ce51c3 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/PolicyTagManagerSerializationSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/PolicyTagManagerSerializationSettings.java @@ -174,14 +174,13 @@ public PolicyTagManagerSerializationStubSettings.Builder getStubSettingsBuilder( return ((PolicyTagManagerSerializationStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/PolicyTagManagerSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/PolicyTagManagerSettings.java index 3df9d919..2091bcf3 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/PolicyTagManagerSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/PolicyTagManagerSettings.java @@ -231,14 +231,13 @@ public PolicyTagManagerStubSettings.Builder getStubSettingsBuilder() { return ((PolicyTagManagerStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/DataCatalogStubSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/DataCatalogStubSettings.java index 5a7a03cd..c71353f3 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/DataCatalogStubSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/DataCatalogStubSettings.java @@ -1029,14 +1029,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/GrpcDataCatalogStub.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/GrpcDataCatalogStub.java index 453383d2..30d7254b 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/GrpcDataCatalogStub.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/GrpcDataCatalogStub.java @@ -26,7 +26,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.datacatalog.v1.CreateEntryGroupRequest; import com.google.cloud.datacatalog.v1.CreateEntryRequest; @@ -73,7 +72,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -441,53 +439,40 @@ protected GrpcDataCatalogStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(createEntryGroupMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateEntryGroupRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getEntryGroupTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getEntryGroupMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetEntryGroupRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updateEntryGroupTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateEntryGroupMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateEntryGroupRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put( - "entry_group.name", String.valueOf(request.getEntryGroup().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("entry_group.name", String.valueOf(request.getEntryGroup().getName())); + return params.build(); }) .build(); GrpcCallSettings deleteEntryGroupTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteEntryGroupMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteEntryGroupRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -495,65 +480,50 @@ public Map extract(DeleteEntryGroupRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(listEntryGroupsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListEntryGroupsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings createEntryTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(createEntryMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateEntryRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings updateEntryTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateEntryMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateEntryRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("entry.name", String.valueOf(request.getEntry().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("entry.name", String.valueOf(request.getEntry().getName())); + return params.build(); }) .build(); GrpcCallSettings deleteEntryTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteEntryMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteEntryRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings getEntryTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getEntryMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetEntryRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings lookupEntryTransportSettings = @@ -564,66 +534,51 @@ public Map extract(GetEntryRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(listEntriesMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListEntriesRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings createTagTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(createTagTemplateMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateTagTemplateRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getTagTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getTagTemplateMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetTagTemplateRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updateTagTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateTagTemplateMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateTagTemplateRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put( - "tag_template.name", String.valueOf(request.getTagTemplate().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put( + "tag_template.name", String.valueOf(request.getTagTemplate().getName())); + return params.build(); }) .build(); GrpcCallSettings deleteTagTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteTagTemplateMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteTagTemplateRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -631,13 +586,10 @@ public Map extract(DeleteTagTemplateRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(createTagTemplateFieldMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateTagTemplateFieldRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings @@ -645,13 +597,10 @@ public Map extract(CreateTagTemplateFieldRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(updateTagTemplateFieldMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateTagTemplateFieldRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -659,13 +608,10 @@ public Map extract(UpdateTagTemplateFieldRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(renameTagTemplateFieldMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(RenameTagTemplateFieldRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -673,105 +619,80 @@ public Map extract(RenameTagTemplateFieldRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(renameTagTemplateFieldEnumValueMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract( - RenameTagTemplateFieldEnumValueRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings deleteTagTemplateFieldTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteTagTemplateFieldMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteTagTemplateFieldRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings createTagTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(createTagMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateTagRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings updateTagTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateTagMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateTagRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("tag.name", String.valueOf(request.getTag().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("tag.name", String.valueOf(request.getTag().getName())); + return params.build(); }) .build(); GrpcCallSettings deleteTagTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteTagMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteTagRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings listTagsTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(listTagsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListTagsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings setIamPolicyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(setIamPolicyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(SetIamPolicyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("resource", String.valueOf(request.getResource())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("resource", String.valueOf(request.getResource())); + return params.build(); }) .build(); GrpcCallSettings getIamPolicyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getIamPolicyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetIamPolicyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("resource", String.valueOf(request.getResource())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("resource", String.valueOf(request.getResource())); + return params.build(); }) .build(); GrpcCallSettings @@ -779,13 +700,10 @@ public Map extract(GetIamPolicyRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(testIamPermissionsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(TestIamPermissionsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("resource", String.valueOf(request.getResource())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("resource", String.valueOf(request.getResource())); + return params.build(); }) .build(); @@ -1081,7 +999,13 @@ public UnaryCallable getIamPolicyCallable() { @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/GrpcPolicyTagManagerSerializationStub.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/GrpcPolicyTagManagerSerializationStub.java index 77b75cf4..4c198bb6 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/GrpcPolicyTagManagerSerializationStub.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/GrpcPolicyTagManagerSerializationStub.java @@ -21,7 +21,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.datacatalog.v1.ExportTaxonomiesRequest; import com.google.cloud.datacatalog.v1.ExportTaxonomiesResponse; @@ -34,7 +33,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -138,13 +136,10 @@ protected GrpcPolicyTagManagerSerializationStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(replaceTaxonomyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ReplaceTaxonomyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -152,13 +147,10 @@ public Map extract(ReplaceTaxonomyRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(importTaxonomiesMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ImportTaxonomiesRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings @@ -166,13 +158,10 @@ public Map extract(ImportTaxonomiesRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(exportTaxonomiesMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ExportTaxonomiesRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); @@ -213,7 +202,13 @@ public UnaryCallable replaceTaxonomyCallable() @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/GrpcPolicyTagManagerStub.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/GrpcPolicyTagManagerStub.java index 5ce77a94..a2e6643c 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/GrpcPolicyTagManagerStub.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/GrpcPolicyTagManagerStub.java @@ -24,7 +24,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.datacatalog.v1.CreatePolicyTagRequest; import com.google.cloud.datacatalog.v1.CreateTaxonomyRequest; @@ -51,7 +50,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -256,39 +254,30 @@ protected GrpcPolicyTagManagerStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(createTaxonomyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateTaxonomyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings deleteTaxonomyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteTaxonomyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteTaxonomyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updateTaxonomyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateTaxonomyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateTaxonomyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("taxonomy.name", String.valueOf(request.getTaxonomy().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("taxonomy.name", String.valueOf(request.getTaxonomy().getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -296,65 +285,50 @@ public Map extract(UpdateTaxonomyRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(listTaxonomiesMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListTaxonomiesRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getTaxonomyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getTaxonomyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetTaxonomyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings createPolicyTagTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(createPolicyTagMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreatePolicyTagRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings deletePolicyTagTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deletePolicyTagMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeletePolicyTagRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updatePolicyTagTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updatePolicyTagMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdatePolicyTagRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("policy_tag.name", String.valueOf(request.getPolicyTag().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("policy_tag.name", String.valueOf(request.getPolicyTag().getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -362,52 +336,40 @@ public Map extract(UpdatePolicyTagRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(listPolicyTagsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListPolicyTagsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getPolicyTagTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getPolicyTagMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetPolicyTagRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings getIamPolicyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getIamPolicyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetIamPolicyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("resource", String.valueOf(request.getResource())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("resource", String.valueOf(request.getResource())); + return params.build(); }) .build(); GrpcCallSettings setIamPolicyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(setIamPolicyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(SetIamPolicyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("resource", String.valueOf(request.getResource())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("resource", String.valueOf(request.getResource())); + return params.build(); }) .build(); GrpcCallSettings @@ -415,13 +377,10 @@ public Map extract(SetIamPolicyRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(testIamPermissionsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(TestIamPermissionsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("resource", String.valueOf(request.getResource())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("resource", String.valueOf(request.getResource())); + return params.build(); }) .build(); @@ -561,7 +520,13 @@ public UnaryCallable setIamPolicyCallable() { @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/PolicyTagManagerSerializationStubSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/PolicyTagManagerSerializationStubSettings.java index 79bb101d..3eb48724 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/PolicyTagManagerSerializationStubSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/PolicyTagManagerSerializationStubSettings.java @@ -287,14 +287,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/PolicyTagManagerStubSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/PolicyTagManagerStubSettings.java index cac0d3de..1f8cb47f 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/PolicyTagManagerStubSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1/stub/PolicyTagManagerStubSettings.java @@ -599,14 +599,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/DataCatalogClient.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/DataCatalogClient.java index c61b76ab..a7b928d2 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/DataCatalogClient.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/DataCatalogClient.java @@ -16,7 +16,6 @@ package com.google.cloud.datacatalog.v1beta1; -import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.core.BetaApi; @@ -3248,7 +3247,7 @@ public final UnaryCallable listTagsCallable() * *

{@code
    * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) {
-   *   ResourceName resource = TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]");
+   *   ResourceName resource = EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]");
    *   Policy policy = Policy.newBuilder().build();
    *   Policy response = dataCatalogClient.setIamPolicy(resource, policy);
    * }
@@ -3285,7 +3284,8 @@ public final Policy setIamPolicy(ResourceName resource, Policy policy) {
    *
    * 
{@code
    * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) {
-   *   String resource = TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString();
+   *   String resource =
+   *       EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString();
    *   Policy policy = Policy.newBuilder().build();
    *   Policy response = dataCatalogClient.setIamPolicy(resource, policy);
    * }
@@ -3321,7 +3321,8 @@ public final Policy setIamPolicy(String resource, Policy policy) {
    * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) {
    *   SetIamPolicyRequest request =
    *       SetIamPolicyRequest.newBuilder()
-   *           .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString())
+   *           .setResource(
+   *               EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString())
    *           .setPolicy(Policy.newBuilder().build())
    *           .build();
    *   Policy response = dataCatalogClient.setIamPolicy(request);
@@ -3352,7 +3353,8 @@ public final Policy setIamPolicy(SetIamPolicyRequest request) {
    * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) {
    *   SetIamPolicyRequest request =
    *       SetIamPolicyRequest.newBuilder()
-   *           .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString())
+   *           .setResource(
+   *               EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString())
    *           .setPolicy(Policy.newBuilder().build())
    *           .build();
    *   ApiFuture future = dataCatalogClient.setIamPolicyCallable().futureCall(request);
@@ -3383,7 +3385,7 @@ public final UnaryCallable setIamPolicyCallable() {
    *
    * 
{@code
    * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) {
-   *   ResourceName resource = TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]");
+   *   ResourceName resource = EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]");
    *   Policy response = dataCatalogClient.getIamPolicy(resource);
    * }
    * }
@@ -3418,7 +3420,8 @@ public final Policy getIamPolicy(ResourceName resource) { * *
{@code
    * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) {
-   *   String resource = TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString();
+   *   String resource =
+   *       EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString();
    *   Policy response = dataCatalogClient.getIamPolicy(resource);
    * }
    * }
@@ -3452,7 +3455,8 @@ public final Policy getIamPolicy(String resource) { * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) { * GetIamPolicyRequest request = * GetIamPolicyRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .setOptions(GetPolicyOptions.newBuilder().build()) * .build(); * Policy response = dataCatalogClient.getIamPolicy(request); @@ -3486,7 +3490,8 @@ public final Policy getIamPolicy(GetIamPolicyRequest request) { * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) { * GetIamPolicyRequest request = * GetIamPolicyRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .setOptions(GetPolicyOptions.newBuilder().build()) * .build(); * ApiFuture future = dataCatalogClient.getIamPolicyCallable().futureCall(request); @@ -3516,7 +3521,8 @@ public final UnaryCallable getIamPolicyCallable() { * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) { * TestIamPermissionsRequest request = * TestIamPermissionsRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .addAllPermissions(new ArrayList()) * .build(); * TestIamPermissionsResponse response = dataCatalogClient.testIamPermissions(request); @@ -3547,7 +3553,8 @@ public final TestIamPermissionsResponse testIamPermissions(TestIamPermissionsReq * try (DataCatalogClient dataCatalogClient = DataCatalogClient.create()) { * TestIamPermissionsRequest request = * TestIamPermissionsRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .addAllPermissions(new ArrayList()) * .build(); * ApiFuture future = @@ -3607,12 +3614,7 @@ public static ApiFuture createAsync( SearchCatalogPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public SearchCatalogPagedResponse apply(SearchCatalogPage input) { - return new SearchCatalogPagedResponse(input); - } - }, + input -> new SearchCatalogPagedResponse(input), MoreExecutors.directExecutor()); } @@ -3688,12 +3690,7 @@ public static ApiFuture createAsync( ListEntryGroupsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListEntryGroupsPagedResponse apply(ListEntryGroupsPage input) { - return new ListEntryGroupsPagedResponse(input); - } - }, + input -> new ListEntryGroupsPagedResponse(input), MoreExecutors.directExecutor()); } @@ -3769,14 +3766,7 @@ public static ApiFuture createAsync( ApiFuture futurePage = ListEntriesPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( - futurePage, - new ApiFunction() { - @Override - public ListEntriesPagedResponse apply(ListEntriesPage input) { - return new ListEntriesPagedResponse(input); - } - }, - MoreExecutors.directExecutor()); + futurePage, input -> new ListEntriesPagedResponse(input), MoreExecutors.directExecutor()); } private ListEntriesPagedResponse(ListEntriesPage page) { @@ -3845,14 +3835,7 @@ public static ApiFuture createAsync( ApiFuture futurePage = ListTagsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( - futurePage, - new ApiFunction() { - @Override - public ListTagsPagedResponse apply(ListTagsPage input) { - return new ListTagsPagedResponse(input); - } - }, - MoreExecutors.directExecutor()); + futurePage, input -> new ListTagsPagedResponse(input), MoreExecutors.directExecutor()); } private ListTagsPagedResponse(ListTagsPage page) { diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/DataCatalogSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/DataCatalogSettings.java index e73c048b..8271da85 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/DataCatalogSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/DataCatalogSettings.java @@ -306,14 +306,13 @@ public DataCatalogStubSettings.Builder getStubSettingsBuilder() { return ((DataCatalogStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerClient.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerClient.java index adddd8ae..4131823a 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerClient.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerClient.java @@ -16,7 +16,6 @@ package com.google.cloud.datacatalog.v1beta1; -import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.ApiFutures; import com.google.api.core.BetaApi; @@ -1178,7 +1177,8 @@ public final UnaryCallable getPolicyTagCallable( * try (PolicyTagManagerClient policyTagManagerClient = PolicyTagManagerClient.create()) { * GetIamPolicyRequest request = * GetIamPolicyRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .setOptions(GetPolicyOptions.newBuilder().build()) * .build(); * Policy response = policyTagManagerClient.getIamPolicy(request); @@ -1202,7 +1202,8 @@ public final Policy getIamPolicy(GetIamPolicyRequest request) { * try (PolicyTagManagerClient policyTagManagerClient = PolicyTagManagerClient.create()) { * GetIamPolicyRequest request = * GetIamPolicyRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .setOptions(GetPolicyOptions.newBuilder().build()) * .build(); * ApiFuture future = policyTagManagerClient.getIamPolicyCallable().futureCall(request); @@ -1225,7 +1226,8 @@ public final UnaryCallable getIamPolicyCallable() { * try (PolicyTagManagerClient policyTagManagerClient = PolicyTagManagerClient.create()) { * SetIamPolicyRequest request = * SetIamPolicyRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .setPolicy(Policy.newBuilder().build()) * .build(); * Policy response = policyTagManagerClient.setIamPolicy(request); @@ -1249,7 +1251,8 @@ public final Policy setIamPolicy(SetIamPolicyRequest request) { * try (PolicyTagManagerClient policyTagManagerClient = PolicyTagManagerClient.create()) { * SetIamPolicyRequest request = * SetIamPolicyRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .setPolicy(Policy.newBuilder().build()) * .build(); * ApiFuture future = policyTagManagerClient.setIamPolicyCallable().futureCall(request); @@ -1272,7 +1275,8 @@ public final UnaryCallable setIamPolicyCallable() { * try (PolicyTagManagerClient policyTagManagerClient = PolicyTagManagerClient.create()) { * TestIamPermissionsRequest request = * TestIamPermissionsRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .addAllPermissions(new ArrayList()) * .build(); * TestIamPermissionsResponse response = policyTagManagerClient.testIamPermissions(request); @@ -1296,7 +1300,8 @@ public final TestIamPermissionsResponse testIamPermissions(TestIamPermissionsReq * try (PolicyTagManagerClient policyTagManagerClient = PolicyTagManagerClient.create()) { * TestIamPermissionsRequest request = * TestIamPermissionsRequest.newBuilder() - * .setResource(TaxonomyName.of("[PROJECT]", "[LOCATION]", "[TAXONOMY]").toString()) + * .setResource( + * EntryName.of("[PROJECT]", "[LOCATION]", "[ENTRY_GROUP]", "[ENTRY]").toString()) * .addAllPermissions(new ArrayList()) * .build(); * ApiFuture future = @@ -1356,12 +1361,7 @@ public static ApiFuture createAsync( ListTaxonomiesPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListTaxonomiesPagedResponse apply(ListTaxonomiesPage input) { - return new ListTaxonomiesPagedResponse(input); - } - }, + input -> new ListTaxonomiesPagedResponse(input), MoreExecutors.directExecutor()); } @@ -1437,12 +1437,7 @@ public static ApiFuture createAsync( ListPolicyTagsPage.createEmptyPage().createPageAsync(context, futureResponse); return ApiFutures.transform( futurePage, - new ApiFunction() { - @Override - public ListPolicyTagsPagedResponse apply(ListPolicyTagsPage input) { - return new ListPolicyTagsPagedResponse(input); - } - }, + input -> new ListPolicyTagsPagedResponse(input), MoreExecutors.directExecutor()); } diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSerializationSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSerializationSettings.java index 1ec55066..420fcf37 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSerializationSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSerializationSettings.java @@ -169,14 +169,13 @@ public PolicyTagManagerSerializationStubSettings.Builder getStubSettingsBuilder( return ((PolicyTagManagerSerializationStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSettings.java index 08f9779c..2c2581a4 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/PolicyTagManagerSettings.java @@ -232,14 +232,13 @@ public PolicyTagManagerStubSettings.Builder getStubSettingsBuilder() { return ((PolicyTagManagerStubSettings.Builder) getStubSettings()); } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods( getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater); return this; diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/DataCatalogStubSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/DataCatalogStubSettings.java index 1343e87a..e47db449 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/DataCatalogStubSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/DataCatalogStubSettings.java @@ -1008,14 +1008,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/GrpcDataCatalogStub.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/GrpcDataCatalogStub.java index 8ed395a8..7da73575 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/GrpcDataCatalogStub.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/GrpcDataCatalogStub.java @@ -27,7 +27,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.datacatalog.v1beta1.CreateEntryGroupRequest; import com.google.cloud.datacatalog.v1beta1.CreateEntryRequest; @@ -73,7 +72,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -432,53 +430,40 @@ protected GrpcDataCatalogStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(createEntryGroupMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateEntryGroupRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings updateEntryGroupTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateEntryGroupMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateEntryGroupRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put( - "entry_group.name", String.valueOf(request.getEntryGroup().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("entry_group.name", String.valueOf(request.getEntryGroup().getName())); + return params.build(); }) .build(); GrpcCallSettings getEntryGroupTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getEntryGroupMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetEntryGroupRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings deleteEntryGroupTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteEntryGroupMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteEntryGroupRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -486,65 +471,50 @@ public Map extract(DeleteEntryGroupRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(listEntryGroupsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListEntryGroupsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings createEntryTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(createEntryMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateEntryRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings updateEntryTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateEntryMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateEntryRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("entry.name", String.valueOf(request.getEntry().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("entry.name", String.valueOf(request.getEntry().getName())); + return params.build(); }) .build(); GrpcCallSettings deleteEntryTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteEntryMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteEntryRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings getEntryTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getEntryMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetEntryRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings lookupEntryTransportSettings = @@ -555,66 +525,51 @@ public Map extract(GetEntryRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(listEntriesMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListEntriesRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings createTagTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(createTagTemplateMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateTagTemplateRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getTagTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getTagTemplateMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetTagTemplateRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updateTagTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateTagTemplateMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateTagTemplateRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put( - "tag_template.name", String.valueOf(request.getTagTemplate().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put( + "tag_template.name", String.valueOf(request.getTagTemplate().getName())); + return params.build(); }) .build(); GrpcCallSettings deleteTagTemplateTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteTagTemplateMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteTagTemplateRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -622,13 +577,10 @@ public Map extract(DeleteTagTemplateRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(createTagTemplateFieldMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateTagTemplateFieldRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings @@ -636,13 +588,10 @@ public Map extract(CreateTagTemplateFieldRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(updateTagTemplateFieldMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateTagTemplateFieldRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -650,104 +599,80 @@ public Map extract(UpdateTagTemplateFieldRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(renameTagTemplateFieldMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(RenameTagTemplateFieldRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings deleteTagTemplateFieldTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteTagTemplateFieldMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteTagTemplateFieldRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings createTagTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(createTagMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateTagRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings updateTagTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateTagMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateTagRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("tag.name", String.valueOf(request.getTag().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("tag.name", String.valueOf(request.getTag().getName())); + return params.build(); }) .build(); GrpcCallSettings deleteTagTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteTagMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteTagRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings listTagsTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(listTagsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListTagsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings setIamPolicyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(setIamPolicyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(SetIamPolicyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("resource", String.valueOf(request.getResource())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("resource", String.valueOf(request.getResource())); + return params.build(); }) .build(); GrpcCallSettings getIamPolicyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getIamPolicyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetIamPolicyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("resource", String.valueOf(request.getResource())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("resource", String.valueOf(request.getResource())); + return params.build(); }) .build(); GrpcCallSettings @@ -755,13 +680,10 @@ public Map extract(GetIamPolicyRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(testIamPermissionsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(TestIamPermissionsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("resource", String.valueOf(request.getResource())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("resource", String.valueOf(request.getResource())); + return params.build(); }) .build(); @@ -1046,7 +968,13 @@ public UnaryCallable getIamPolicyCallable() { @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/GrpcPolicyTagManagerSerializationStub.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/GrpcPolicyTagManagerSerializationStub.java index 29a2e1c4..c7eff486 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/GrpcPolicyTagManagerSerializationStub.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/GrpcPolicyTagManagerSerializationStub.java @@ -22,7 +22,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.datacatalog.v1beta1.ExportTaxonomiesRequest; import com.google.cloud.datacatalog.v1beta1.ExportTaxonomiesResponse; @@ -33,7 +32,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -127,13 +125,10 @@ protected GrpcPolicyTagManagerSerializationStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(importTaxonomiesMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ImportTaxonomiesRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings @@ -141,13 +136,10 @@ public Map extract(ImportTaxonomiesRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(exportTaxonomiesMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ExportTaxonomiesRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); @@ -180,7 +172,13 @@ public GrpcOperationsStub getOperationsStub() { @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/GrpcPolicyTagManagerStub.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/GrpcPolicyTagManagerStub.java index 27c40e79..4f8c6aef 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/GrpcPolicyTagManagerStub.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/GrpcPolicyTagManagerStub.java @@ -25,7 +25,6 @@ import com.google.api.gax.grpc.GrpcCallSettings; import com.google.api.gax.grpc.GrpcStubCallableFactory; import com.google.api.gax.rpc.ClientContext; -import com.google.api.gax.rpc.RequestParamsExtractor; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.datacatalog.v1beta1.CreatePolicyTagRequest; import com.google.cloud.datacatalog.v1beta1.CreateTaxonomyRequest; @@ -52,7 +51,6 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; -import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -262,39 +260,30 @@ protected GrpcPolicyTagManagerStub( GrpcCallSettings.newBuilder() .setMethodDescriptor(createTaxonomyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreateTaxonomyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings deleteTaxonomyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deleteTaxonomyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeleteTaxonomyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updateTaxonomyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updateTaxonomyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdateTaxonomyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("taxonomy.name", String.valueOf(request.getTaxonomy().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("taxonomy.name", String.valueOf(request.getTaxonomy().getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -302,65 +291,50 @@ public Map extract(UpdateTaxonomyRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(listTaxonomiesMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListTaxonomiesRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getTaxonomyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getTaxonomyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetTaxonomyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings createPolicyTagTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(createPolicyTagMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(CreatePolicyTagRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings deletePolicyTagTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(deletePolicyTagMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(DeletePolicyTagRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings updatePolicyTagTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(updatePolicyTagMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(UpdatePolicyTagRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("policy_tag.name", String.valueOf(request.getPolicyTag().getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("policy_tag.name", String.valueOf(request.getPolicyTag().getName())); + return params.build(); }) .build(); GrpcCallSettings @@ -368,52 +342,40 @@ public Map extract(UpdatePolicyTagRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(listPolicyTagsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(ListPolicyTagsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("parent", String.valueOf(request.getParent())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("parent", String.valueOf(request.getParent())); + return params.build(); }) .build(); GrpcCallSettings getPolicyTagTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getPolicyTagMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetPolicyTagRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("name", String.valueOf(request.getName())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("name", String.valueOf(request.getName())); + return params.build(); }) .build(); GrpcCallSettings getIamPolicyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(getIamPolicyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(GetIamPolicyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("resource", String.valueOf(request.getResource())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("resource", String.valueOf(request.getResource())); + return params.build(); }) .build(); GrpcCallSettings setIamPolicyTransportSettings = GrpcCallSettings.newBuilder() .setMethodDescriptor(setIamPolicyMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(SetIamPolicyRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("resource", String.valueOf(request.getResource())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("resource", String.valueOf(request.getResource())); + return params.build(); }) .build(); GrpcCallSettings @@ -421,13 +383,10 @@ public Map extract(SetIamPolicyRequest request) { GrpcCallSettings.newBuilder() .setMethodDescriptor(testIamPermissionsMethodDescriptor) .setParamsExtractor( - new RequestParamsExtractor() { - @Override - public Map extract(TestIamPermissionsRequest request) { - ImmutableMap.Builder params = ImmutableMap.builder(); - params.put("resource", String.valueOf(request.getResource())); - return params.build(); - } + request -> { + ImmutableMap.Builder params = ImmutableMap.builder(); + params.put("resource", String.valueOf(request.getResource())); + return params.build(); }) .build(); @@ -567,7 +526,13 @@ public UnaryCallable setIamPolicyCallable() { @Override public final void close() { - shutdown(); + try { + backgroundResources.close(); + } catch (RuntimeException e) { + throw e; + } catch (Exception e) { + throw new IllegalStateException("Failed to close resource", e); + } } @Override diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerSerializationStubSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerSerializationStubSettings.java index c8d01d38..a08a05f4 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerSerializationStubSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerSerializationStubSettings.java @@ -262,14 +262,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerStubSettings.java b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerStubSettings.java index ede0c10d..d4eace58 100644 --- a/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerStubSettings.java +++ b/google-cloud-datacatalog/src/main/java/com/google/cloud/datacatalog/v1beta1/stub/PolicyTagManagerStubSettings.java @@ -592,14 +592,13 @@ private static Builder initDefaults(Builder builder) { return builder; } - // NEXT_MAJOR_VER: remove 'throws Exception'. /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( - ApiFunction, Void> settingsUpdater) throws Exception { + ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } diff --git a/synth.metadata b/synth.metadata index 28976e75..d2e24c61 100644 --- a/synth.metadata +++ b/synth.metadata @@ -11,16 +11,16 @@ "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "5b1f7cf1d2e2f8ab028a7090d0981fc774028906", - "internalRef": "387350333" + "sha": "a739464cacb3aa6d375683aefe16b79c21da1bb0", + "internalRef": "389657692" } }, { "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "5b1f7cf1d2e2f8ab028a7090d0981fc774028906", - "internalRef": "387350333" + "sha": "a739464cacb3aa6d375683aefe16b79c21da1bb0", + "internalRef": "389657692" } }, {