diff --git a/.github/workflows/hermetic_library_generation.yaml b/.github/workflows/hermetic_library_generation.yaml index a1d9c6a9f2..31a38fbb06 100644 --- a/.github/workflows/hermetic_library_generation.yaml +++ b/.github/workflows/hermetic_library_generation.yaml @@ -37,7 +37,7 @@ jobs: with: fetch-depth: 0 token: ${{ secrets.CLOUD_JAVA_BOT_TOKEN }} - - uses: googleapis/sdk-platform-java/.github/scripts@v2.63.0 + - uses: googleapis/sdk-platform-java/.github/scripts@v2.64.1 if: env.SHOULD_RUN == 'true' with: base_ref: ${{ github.base_ref }} diff --git a/.github/workflows/unmanaged_dependency_check.yaml b/.github/workflows/unmanaged_dependency_check.yaml index 44c2443ed4..973ebf2f8e 100644 --- a/.github/workflows/unmanaged_dependency_check.yaml +++ b/.github/workflows/unmanaged_dependency_check.yaml @@ -14,6 +14,6 @@ jobs: shell: bash run: .kokoro/build.sh - name: Unmanaged dependency check - uses: googleapis/sdk-platform-java/java-shared-dependencies/unmanaged-dependency-check@google-cloud-shared-dependencies/v3.53.0 + uses: googleapis/sdk-platform-java/java-shared-dependencies/unmanaged-dependency-check@google-cloud-shared-dependencies/v3.54.1 with: bom-path: google-cloud-bigtable-bom/pom.xml diff --git a/CHANGELOG.md b/CHANGELOG.md index 34e052f560..25bf2b781e 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,5 +1,27 @@ # Changelog +## [2.70.0](https://github.com/googleapis/java-bigtable/compare/v2.69.0...v2.70.0) (2025-11-18) + + +### Features + +* Add PeerInfo proto in Bigtable API ([0736694](https://github.com/googleapis/java-bigtable/commit/0736694c74099a98ab9f36ecb011a31458c6d8c6)) + + +### Bug Fixes + +* **deps:** Update the Java code generator (gapic-generator-java) to 2.64.1 ([0736694](https://github.com/googleapis/java-bigtable/commit/0736694c74099a98ab9f36ecb011a31458c6d8c6)) + + +### Dependencies + +* Update shared dependencies ([#2704](https://github.com/googleapis/java-bigtable/issues/2704)) ([97a8a0e](https://github.com/googleapis/java-bigtable/commit/97a8a0e36281c3154e03e2ba74aed9af00c9a22b)) + + +### Documentation + +* Update javadoc sample for BigtableTableAdminClient.listTables ([#2308](https://github.com/googleapis/java-bigtable/issues/2308)) ([56237d7](https://github.com/googleapis/java-bigtable/commit/56237d7a8d420f526237e11c868fd85e9f256831)) + ## [2.69.0](https://github.com/googleapis/java-bigtable/compare/v2.68.0...v2.69.0) (2025-11-17) diff --git a/README.md b/README.md index 1e14178a73..92171f63a3 100644 --- a/README.md +++ b/README.md @@ -49,20 +49,20 @@ If you are using Maven without the BOM, add this to your dependencies: If you are using Gradle 5.x or later, add this to your dependencies: ```Groovy -implementation platform('com.google.cloud:libraries-bom:26.70.0') +implementation platform('com.google.cloud:libraries-bom:26.71.0') implementation 'com.google.cloud:google-cloud-bigtable' ``` If you are using Gradle without BOM, add this to your dependencies: ```Groovy -implementation 'com.google.cloud:google-cloud-bigtable:2.69.0' +implementation 'com.google.cloud:google-cloud-bigtable:2.70.0' ``` If you are using SBT, add this to your dependencies: ```Scala -libraryDependencies += "com.google.cloud" % "google-cloud-bigtable" % "2.69.0" +libraryDependencies += "com.google.cloud" % "google-cloud-bigtable" % "2.70.0" ``` ## Authentication @@ -471,7 +471,7 @@ Java is a registered trademark of Oracle and/or its affiliates. [kokoro-badge-link-5]: http://storage.googleapis.com/cloud-devrel-public/java/badges/java-bigtable/java11.html [stability-image]: https://img.shields.io/badge/stability-stable-green [maven-version-image]: https://img.shields.io/maven-central/v/com.google.cloud/google-cloud-bigtable.svg -[maven-version-link]: https://central.sonatype.com/artifact/com.google.cloud/google-cloud-bigtable/2.69.0 +[maven-version-link]: https://central.sonatype.com/artifact/com.google.cloud/google-cloud-bigtable/2.70.0 [authentication]: https://github.com/googleapis/google-cloud-java#authentication [auth-scopes]: https://developers.google.com/identity/protocols/oauth2/scopes [predefined-iam-roles]: https://cloud.google.com/iam/docs/understanding-roles#predefined_roles diff --git a/generation_config.yaml b/generation_config.yaml index d93e85c00b..b598b536ac 100644 --- a/generation_config.yaml +++ b/generation_config.yaml @@ -1,6 +1,6 @@ -gapic_generator_version: 2.63.0 -googleapis_commitish: 94ccdfe4519e0ba817bd33aa22eb9c64f88a6874 -libraries_bom_version: 26.70.0 +gapic_generator_version: 2.64.1 +googleapis_commitish: 15fa97d38ad2a38319426328c795ef76a03448bd +libraries_bom_version: 26.71.0 template_excludes: - .gitignore - .kokoro/presubmit/integration.cfg diff --git a/google-cloud-bigtable-bom/pom.xml b/google-cloud-bigtable-bom/pom.xml index f0ecc88065..c488f4904e 100644 --- a/google-cloud-bigtable-bom/pom.xml +++ b/google-cloud-bigtable-bom/pom.xml @@ -3,12 +3,12 @@ 4.0.0 com.google.cloud google-cloud-bigtable-bom - 2.69.0 + 2.70.0 pom com.google.cloud sdk-platform-java-config - 3.53.0 + 3.54.1 @@ -63,37 +63,37 @@ com.google.cloud google-cloud-bigtable - 2.69.0 + 2.70.0 com.google.cloud google-cloud-bigtable-emulator - 0.206.0 + 0.207.0 com.google.cloud google-cloud-bigtable-emulator-core - 0.206.0 + 0.207.0 com.google.api.grpc grpc-google-cloud-bigtable-admin-v2 - 2.69.0 + 2.70.0 com.google.api.grpc grpc-google-cloud-bigtable-v2 - 2.69.0 + 2.70.0 com.google.api.grpc proto-google-cloud-bigtable-admin-v2 - 2.69.0 + 2.70.0 com.google.api.grpc proto-google-cloud-bigtable-v2 - 2.69.0 + 2.70.0 diff --git a/google-cloud-bigtable-deps-bom/pom.xml b/google-cloud-bigtable-deps-bom/pom.xml index b7ba7ed212..d2d6f24b13 100644 --- a/google-cloud-bigtable-deps-bom/pom.xml +++ b/google-cloud-bigtable-deps-bom/pom.xml @@ -7,13 +7,13 @@ com.google.cloud sdk-platform-java-config - 3.53.0 + 3.54.1 com.google.cloud google-cloud-bigtable-deps-bom - 2.69.0 + 2.70.0 pom Google Cloud Bigtable Dependency BOM @@ -68,7 +68,7 @@ com.google.cloud gapic-libraries-bom - 1.72.0 + 1.74.0 pom import diff --git a/google-cloud-bigtable-emulator-core/pom.xml b/google-cloud-bigtable-emulator-core/pom.xml index 7881bab822..81b76affcf 100644 --- a/google-cloud-bigtable-emulator-core/pom.xml +++ b/google-cloud-bigtable-emulator-core/pom.xml @@ -7,12 +7,12 @@ google-cloud-bigtable-parent com.google.cloud - 2.69.0 + 2.70.0 Google Cloud Java - Bigtable Emulator Core google-cloud-bigtable-emulator-core - 0.206.0 + 0.207.0 A Java wrapper for the Cloud Bigtable emulator. diff --git a/google-cloud-bigtable-emulator/pom.xml b/google-cloud-bigtable-emulator/pom.xml index 3357543f20..0b9fed06df 100644 --- a/google-cloud-bigtable-emulator/pom.xml +++ b/google-cloud-bigtable-emulator/pom.xml @@ -5,7 +5,7 @@ 4.0.0 google-cloud-bigtable-emulator - 0.206.0 + 0.207.0 Google Cloud Java - Bigtable Emulator https://github.com/googleapis/java-bigtable @@ -14,7 +14,7 @@ com.google.cloud google-cloud-bigtable-parent - 2.69.0 + 2.70.0 scm:git:git@github.com:googleapis/java-bigtable.git @@ -81,14 +81,14 @@ com.google.cloud google-cloud-bigtable-deps-bom - 2.69.0 + 2.70.0 pom import com.google.cloud google-cloud-bigtable-bom - 2.69.0 + 2.70.0 pom import @@ -99,7 +99,7 @@ com.google.cloud google-cloud-bigtable-emulator-core - 0.206.0 + 0.207.0 diff --git a/google-cloud-bigtable/pom.xml b/google-cloud-bigtable/pom.xml index 44ff0cbc1f..6a4b3fd21c 100644 --- a/google-cloud-bigtable/pom.xml +++ b/google-cloud-bigtable/pom.xml @@ -2,7 +2,7 @@ 4.0.0 google-cloud-bigtable - 2.69.0 + 2.70.0 jar Google Cloud Bigtable https://github.com/googleapis/java-bigtable @@ -12,11 +12,11 @@ com.google.cloud google-cloud-bigtable-parent - 2.69.0 + 2.70.0 - 2.69.0 + 2.70.0 google-cloud-bigtable @@ -54,14 +54,14 @@ com.google.cloud google-cloud-bigtable-deps-bom - 2.69.0 + 2.70.0 pom import com.google.cloud google-cloud-bigtable-bom - 2.69.0 + 2.70.0 pom import @@ -204,10 +204,6 @@ io.grpc grpc-netty-shaded - - io.grpc - grpc-alts - io.grpc grpc-protobuf @@ -369,7 +365,7 @@ org.apache.maven.plugins maven-enforcer-plugin - 3.5.0 + 3.6.2 diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/Version.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/Version.java index dd58b9bcca..169e965d61 100644 --- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/Version.java +++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/Version.java @@ -20,6 +20,6 @@ @InternalApi("For internal use only") public final class Version { // {x-version-update-start:google-cloud-bigtable:current} - public static String VERSION = "2.69.0"; + public static String VERSION = "2.70.0"; // {x-version-update-end} } diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BigtableTableAdminClient.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BigtableTableAdminClient.java index 5402ef7045..ddbe637e1e 100644 --- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BigtableTableAdminClient.java +++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/admin/v2/BigtableTableAdminClient.java @@ -666,8 +666,9 @@ public Map> apply(com.google.bigtable.admin.v2.Tabl * *
{@code
    * List tableIds = client.listTables();
+   * System.out.println("Got list of tables:");
    * for(String tableId: tableIds) {
-   *   System.out.println(name.getTable());
+   *   System.out.println(tableId);
    * }
    * }
*/ diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/gaxx/grpc/BigtableChannelPool.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/gaxx/grpc/BigtableChannelPool.java index 9fcc0ee151..5f1f1677ef 100644 --- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/gaxx/grpc/BigtableChannelPool.java +++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/gaxx/grpc/BigtableChannelPool.java @@ -30,7 +30,6 @@ import io.grpc.Metadata; import io.grpc.MethodDescriptor; import io.grpc.Status; -import io.grpc.alts.AltsContextUtil; import java.io.IOException; import java.time.Clock; import java.util.ArrayList; @@ -566,8 +565,9 @@ static class Entry implements BigtableChannelObserver { } void checkAndSetIsAlts(ClientCall call) { - boolean currentIsAlts = AltsContextUtil.check(call); - isAltsHolder.set(currentIsAlts); + // TODO(populate ALTS holder) + boolean result = false; + isAltsHolder.compareAndSet(null, result); } ManagedChannel getManagedChannel() { diff --git a/google-cloud-bigtable/src/main/resources/META-INF/native-image/com.google.cloud.bigtable.data.v2/reflect-config.json b/google-cloud-bigtable/src/main/resources/META-INF/native-image/com.google.cloud.bigtable.data.v2/reflect-config.json index 1839c46c16..7b14a32b6c 100644 --- a/google-cloud-bigtable/src/main/resources/META-INF/native-image/com.google.cloud.bigtable.data.v2/reflect-config.json +++ b/google-cloud-bigtable/src/main/resources/META-INF/native-image/com.google.cloud.bigtable.data.v2/reflect-config.json @@ -971,6 +971,33 @@ "allDeclaredClasses": true, "allPublicClasses": true }, + { + "name": "com.google.bigtable.v2.PeerInfo", + "queryAllDeclaredConstructors": true, + "queryAllPublicConstructors": true, + "queryAllDeclaredMethods": true, + "allPublicMethods": true, + "allDeclaredClasses": true, + "allPublicClasses": true + }, + { + "name": "com.google.bigtable.v2.PeerInfo$Builder", + "queryAllDeclaredConstructors": true, + "queryAllPublicConstructors": true, + "queryAllDeclaredMethods": true, + "allPublicMethods": true, + "allDeclaredClasses": true, + "allPublicClasses": true + }, + { + "name": "com.google.bigtable.v2.PeerInfo$TransportType", + "queryAllDeclaredConstructors": true, + "queryAllPublicConstructors": true, + "queryAllDeclaredMethods": true, + "allPublicMethods": true, + "allDeclaredClasses": true, + "allPublicClasses": true + }, { "name": "com.google.bigtable.v2.PingAndWarmRequest", "queryAllDeclaredConstructors": true, diff --git a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/it/BigtableMaterializedViewIT.java b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/it/BigtableMaterializedViewIT.java index c12d9332b2..b339ad1d64 100644 --- a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/it/BigtableMaterializedViewIT.java +++ b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/admin/v2/it/BigtableMaterializedViewIT.java @@ -24,11 +24,9 @@ import com.google.api.gax.rpc.NotFoundException; import com.google.cloud.bigtable.admin.v2.BigtableInstanceAdminClient; import com.google.cloud.bigtable.admin.v2.BigtableTableAdminClient; -import com.google.cloud.bigtable.admin.v2.models.CreateInstanceRequest; import com.google.cloud.bigtable.admin.v2.models.CreateMaterializedViewRequest; import com.google.cloud.bigtable.admin.v2.models.CreateTableRequest; import com.google.cloud.bigtable.admin.v2.models.MaterializedView; -import com.google.cloud.bigtable.admin.v2.models.StorageType; import com.google.cloud.bigtable.admin.v2.models.Table; import com.google.cloud.bigtable.admin.v2.models.UpdateMaterializedViewRequest; import com.google.cloud.bigtable.test_helpers.env.EmulatorEnv; @@ -38,7 +36,6 @@ import java.io.IOException; import java.util.List; import java.util.logging.Logger; -import org.junit.After; import org.junit.Before; import org.junit.BeforeClass; import org.junit.ClassRule; @@ -55,9 +52,8 @@ public class BigtableMaterializedViewIT { private static final int[] BACKOFF_DURATION = {2, 4, 8, 16, 32, 64, 128, 256, 512, 1024}; private BigtableInstanceAdminClient client; - private BigtableTableAdminClient tableAdminClient; private Table testTable; - private String instanceId = ""; + private String instanceId = testEnvRule.env().getInstanceId(); // TODO: Update this test once emulator supports InstanceAdmin operation // https://github.com/googleapis/google-cloud-go/issues/1069 @@ -72,23 +68,7 @@ public static void validatePlatform() throws IOException { @Before public void setUp() throws InterruptedException, IOException { client = testEnvRule.env().getInstanceAdminClient(); - - instanceId = new PrefixGenerator().newPrefix(); - client.createInstance( - CreateInstanceRequest.of(instanceId) - .setDisplayName("BigtableMaterializedViewIT") - .addCluster( - instanceId + "-c1", testEnvRule.env().getPrimaryZone(), 1, StorageType.SSD)); - tableAdminClient = testEnvRule.env().getTableAdminClientForInstance(instanceId); - - testTable = createTestTable(tableAdminClient); - } - - @After - public void deleteInstance() { - if (!instanceId.isEmpty()) { - client.deleteInstance(instanceId); - } + testTable = createTestTable(testEnvRule.env().getTableAdminClient()); } @Test diff --git a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/it/ExecuteQueryIT.java b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/it/ExecuteQueryIT.java index 90bbd65fd5..fc56035c02 100644 --- a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/it/ExecuteQueryIT.java +++ b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/it/ExecuteQueryIT.java @@ -232,8 +232,11 @@ public void allTypes() throws Exception { assertThat(rs.getProtoEnum("enumCol", Genre::forNumber)).isEqualTo(Genre.JAZZ); assertThat(rs.getProtoEnum(12, Genre::forNumber)).isEqualTo(Genre.JAZZ); assertThat(rs.next()).isFalse(); + } catch (AssertionError e) { + throw e; + } finally { + deleteTestSchemaBundle(); } - deleteTestSchemaBundle(); } @Test diff --git a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/gaxx/grpc/BigtableChannelPoolTest.java b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/gaxx/grpc/BigtableChannelPoolTest.java index caed478e0a..d1059c0362 100644 --- a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/gaxx/grpc/BigtableChannelPoolTest.java +++ b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/gaxx/grpc/BigtableChannelPoolTest.java @@ -21,7 +21,6 @@ import com.google.api.gax.grpc.ChannelFactory; import com.google.common.collect.Iterables; -import io.grpc.Attributes; import io.grpc.CallOptions; import io.grpc.ClientCall; import io.grpc.ManagedChannel; @@ -113,8 +112,6 @@ public void setUp() throws IOException { // Capture the listener when start is called // Configure mockClientCall.start to capture the listener doNothing().when(mockClientCall).start(listenerCaptor.capture(), any(Metadata.class)); - // Default to no ALTS context - when(mockClientCall.getAttributes()).thenReturn(Attributes.EMPTY); } private BigtableChannelPool.Entry getSingleEntry() { @@ -236,16 +233,4 @@ public void testMixedRpcs() { assertThat(entry.getAndResetErrorCount()).isEqualTo(1); // The last failure assertThat(entry.totalOutstandingRpcs()).isEqualTo(0); } - - @Test - public void testNonAltsChannelReturnsFalse() { - // empty attributes - // cannot test true value as logic is complicated. - // alts check looks at attributes.get(AltsProtocolNegotiator.AUTH_CONTEXT_KEY); - when(mockClientCall.getAttributes()).thenReturn(Attributes.EMPTY); - BigtableChannelPool.Entry entry = getSingleEntry(); - assertThat(entry.isAltsHolder.get()).isNull(); - startCall(unaryMethodDescriptor); - assertThat(entry.isAltsChannel()).isFalse(); - } } diff --git a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/test_helpers/env/TestEnvRule.java b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/test_helpers/env/TestEnvRule.java index 86fc88adff..0f3d5e3ef3 100644 --- a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/test_helpers/env/TestEnvRule.java +++ b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/test_helpers/env/TestEnvRule.java @@ -24,8 +24,12 @@ import com.google.cloud.bigtable.admin.v2.models.AppProfile; import com.google.cloud.bigtable.admin.v2.models.Cluster; import com.google.cloud.bigtable.admin.v2.models.Instance; +import com.google.cloud.bigtable.admin.v2.models.LogicalView; +import com.google.cloud.bigtable.admin.v2.models.MaterializedView; import com.google.cloud.bigtable.admin.v2.models.Table; import com.google.cloud.bigtable.admin.v2.models.UpdateAuthorizedViewRequest; +import com.google.cloud.bigtable.admin.v2.models.UpdateLogicalViewRequest; +import com.google.cloud.bigtable.admin.v2.models.UpdateMaterializedViewRequest; import com.google.cloud.bigtable.admin.v2.models.UpdateTableRequest; import com.google.common.collect.ImmutableSet; import java.io.IOException; @@ -161,8 +165,6 @@ void cleanUpStale() throws ExecutionException, InterruptedException, IOException /** * Clean up AppProfile that were dynamically created in the default instance that have been * orphaned. - * - * @param stalePrefix */ private void cleanupStaleTables(String stalePrefix) { LOGGER.info("Start cleaning up stale tables with stalePrefix=" + stalePrefix); @@ -213,8 +215,6 @@ private void prepTableForDelete(String tableId) { /** * Clean up AppProfile that were dynamically created in the default instance that have been * orphaned. - * - * @param stalePrefix */ private void cleanUpStaleAppProfile(String stalePrefix) { for (AppProfile appProfile : @@ -239,8 +239,6 @@ private void cleanUpStaleAppProfile(String stalePrefix) { /** * Clean up clusters that were dynamically created in the default instance that have been * orphaned. - * - * @param stalePrefix */ private void cleanUpStaleClusters(String stalePrefix) throws ExecutionException, InterruptedException { @@ -264,11 +262,36 @@ private void cleanUpStaleClusters(String stalePrefix) } } - /** - * Clean up dynamically created (non-default) instances that have been orphaned. - * - * @param stalePrefix - */ + private void prepInstanceForDelete(String instanceId) { + if (env() instanceof EmulatorEnv) { + return; + } + // Unprotected MaterializedViews. + for (MaterializedView materializedView : + env().getInstanceAdminClient().listMaterializedViews(instanceId)) { + try { + env() + .getInstanceAdminClient() + .updateMaterializedView( + UpdateMaterializedViewRequest.of(instanceId, materializedView.getId()) + .setDeletionProtection(false)); + } catch (NotFoundException ignored) { + } + } + // Unprotected LogicalViews. + for (LogicalView logicalView : env().getInstanceAdminClient().listLogicalViews(instanceId)) { + try { + env() + .getInstanceAdminClient() + .updateLogicalView( + UpdateLogicalViewRequest.of(instanceId, logicalView.getId()) + .setDeletionProtection(false)); + } catch (NotFoundException ignored) { + } + } + } + + /** Clean up dynamically created (non-default) instances that have been orphaned. */ private void cleanUpStaleInstances(String stalePrefix) throws IOException, ExecutionException, InterruptedException { for (Instance instance : env().getInstanceAdminClient().listInstances()) { @@ -279,6 +302,7 @@ private void cleanUpStaleInstances(String stalePrefix) if (isNewerThanStale) { continue; } + prepInstanceForDelete(instance.getId()); try { deleteInstance(instance.getId()); } catch (NotFoundException ignored) { diff --git a/grpc-google-cloud-bigtable-admin-v2/pom.xml b/grpc-google-cloud-bigtable-admin-v2/pom.xml index 6ae06f900e..bb452b01c0 100644 --- a/grpc-google-cloud-bigtable-admin-v2/pom.xml +++ b/grpc-google-cloud-bigtable-admin-v2/pom.xml @@ -4,13 +4,13 @@ 4.0.0 com.google.api.grpc grpc-google-cloud-bigtable-admin-v2 - 2.69.0 + 2.70.0 grpc-google-cloud-bigtable-admin-v2 GRPC library for grpc-google-cloud-bigtable-admin-v2 com.google.cloud google-cloud-bigtable-parent - 2.69.0 + 2.70.0 @@ -18,14 +18,14 @@ com.google.cloud google-cloud-bigtable-deps-bom - 2.69.0 + 2.70.0 pom import com.google.cloud google-cloud-bigtable-bom - 2.69.0 + 2.70.0 pom import diff --git a/grpc-google-cloud-bigtable-admin-v2/src/main/java/com/google/bigtable/admin/v2/BigtableInstanceAdminGrpc.java b/grpc-google-cloud-bigtable-admin-v2/src/main/java/com/google/bigtable/admin/v2/BigtableInstanceAdminGrpc.java index c3602811f0..2db73a95f7 100644 --- a/grpc-google-cloud-bigtable-admin-v2/src/main/java/com/google/bigtable/admin/v2/BigtableInstanceAdminGrpc.java +++ b/grpc-google-cloud-bigtable-admin-v2/src/main/java/com/google/bigtable/admin/v2/BigtableInstanceAdminGrpc.java @@ -26,9 +26,6 @@ * tables' metadata or data stored in those tables. * */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/bigtable/admin/v2/bigtable_instance_admin.proto") @io.grpc.stub.annotations.GrpcGenerated public final class BigtableInstanceAdminGrpc { @@ -2593,8 +2590,8 @@ protected BigtableInstanceAdminBlockingV2Stub build( * */ public com.google.longrunning.Operation createInstance( - com.google.bigtable.admin.v2.CreateInstanceRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.CreateInstanceRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateInstanceMethod(), getCallOptions(), request); } @@ -2606,8 +2603,8 @@ public com.google.longrunning.Operation createInstance( * */ public com.google.bigtable.admin.v2.Instance getInstance( - com.google.bigtable.admin.v2.GetInstanceRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.GetInstanceRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetInstanceMethod(), getCallOptions(), request); } @@ -2619,8 +2616,8 @@ public com.google.bigtable.admin.v2.Instance getInstance( * */ public com.google.bigtable.admin.v2.ListInstancesResponse listInstances( - com.google.bigtable.admin.v2.ListInstancesRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.ListInstancesRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListInstancesMethod(), getCallOptions(), request); } @@ -2634,8 +2631,8 @@ public com.google.bigtable.admin.v2.ListInstancesResponse listInstances( * */ public com.google.bigtable.admin.v2.Instance updateInstance( - com.google.bigtable.admin.v2.Instance request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.Instance request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getUpdateInstanceMethod(), getCallOptions(), request); } @@ -2648,8 +2645,9 @@ public com.google.bigtable.admin.v2.Instance updateInstance( * */ public com.google.longrunning.Operation partialUpdateInstance( - com.google.bigtable.admin.v2.PartialUpdateInstanceRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.PartialUpdateInstanceRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getPartialUpdateInstanceMethod(), getCallOptions(), request); } @@ -2661,8 +2659,8 @@ public com.google.longrunning.Operation partialUpdateInstance( * */ public com.google.protobuf.Empty deleteInstance( - com.google.bigtable.admin.v2.DeleteInstanceRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.DeleteInstanceRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteInstanceMethod(), getCallOptions(), request); } @@ -2679,8 +2677,8 @@ public com.google.protobuf.Empty deleteInstance( * */ public com.google.longrunning.Operation createCluster( - com.google.bigtable.admin.v2.CreateClusterRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.CreateClusterRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateClusterMethod(), getCallOptions(), request); } @@ -2692,8 +2690,8 @@ public com.google.longrunning.Operation createCluster( * */ public com.google.bigtable.admin.v2.Cluster getCluster( - com.google.bigtable.admin.v2.GetClusterRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.GetClusterRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetClusterMethod(), getCallOptions(), request); } @@ -2705,8 +2703,8 @@ public com.google.bigtable.admin.v2.Cluster getCluster( * */ public com.google.bigtable.admin.v2.ListClustersResponse listClusters( - com.google.bigtable.admin.v2.ListClustersRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.ListClustersRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListClustersMethod(), getCallOptions(), request); } @@ -2721,8 +2719,8 @@ public com.google.bigtable.admin.v2.ListClustersResponse listClusters( * */ public com.google.longrunning.Operation updateCluster( - com.google.bigtable.admin.v2.Cluster request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.Cluster request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getUpdateClusterMethod(), getCallOptions(), request); } @@ -2743,8 +2741,9 @@ public com.google.longrunning.Operation updateCluster( * */ public com.google.longrunning.Operation partialUpdateCluster( - com.google.bigtable.admin.v2.PartialUpdateClusterRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.PartialUpdateClusterRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getPartialUpdateClusterMethod(), getCallOptions(), request); } @@ -2756,8 +2755,8 @@ public com.google.longrunning.Operation partialUpdateCluster( * */ public com.google.protobuf.Empty deleteCluster( - com.google.bigtable.admin.v2.DeleteClusterRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.DeleteClusterRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteClusterMethod(), getCallOptions(), request); } @@ -2769,8 +2768,9 @@ public com.google.protobuf.Empty deleteCluster( * */ public com.google.bigtable.admin.v2.AppProfile createAppProfile( - com.google.bigtable.admin.v2.CreateAppProfileRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.CreateAppProfileRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateAppProfileMethod(), getCallOptions(), request); } @@ -2782,8 +2782,8 @@ public com.google.bigtable.admin.v2.AppProfile createAppProfile( * */ public com.google.bigtable.admin.v2.AppProfile getAppProfile( - com.google.bigtable.admin.v2.GetAppProfileRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.GetAppProfileRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetAppProfileMethod(), getCallOptions(), request); } @@ -2795,8 +2795,9 @@ public com.google.bigtable.admin.v2.AppProfile getAppProfile( * */ public com.google.bigtable.admin.v2.ListAppProfilesResponse listAppProfiles( - com.google.bigtable.admin.v2.ListAppProfilesRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.ListAppProfilesRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListAppProfilesMethod(), getCallOptions(), request); } @@ -2808,8 +2809,9 @@ public com.google.bigtable.admin.v2.ListAppProfilesResponse listAppProfiles( * */ public com.google.longrunning.Operation updateAppProfile( - com.google.bigtable.admin.v2.UpdateAppProfileRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.UpdateAppProfileRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getUpdateAppProfileMethod(), getCallOptions(), request); } @@ -2821,8 +2823,9 @@ public com.google.longrunning.Operation updateAppProfile( * */ public com.google.protobuf.Empty deleteAppProfile( - com.google.bigtable.admin.v2.DeleteAppProfileRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.DeleteAppProfileRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteAppProfileMethod(), getCallOptions(), request); } @@ -2834,8 +2837,9 @@ public com.google.protobuf.Empty deleteAppProfile( * policy if an instance exists but does not have a policy set. * */ - public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetIamPolicyMethod(), getCallOptions(), request); } @@ -2847,8 +2851,9 @@ public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyReque * existing policy. * */ - public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getSetIamPolicyMethod(), getCallOptions(), request); } @@ -2860,8 +2865,8 @@ public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyReque * */ public com.google.iam.v1.TestIamPermissionsResponse testIamPermissions( - com.google.iam.v1.TestIamPermissionsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.iam.v1.TestIamPermissionsRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getTestIamPermissionsMethod(), getCallOptions(), request); } @@ -2874,8 +2879,8 @@ public com.google.iam.v1.TestIamPermissionsResponse testIamPermissions( * */ public com.google.bigtable.admin.v2.ListHotTabletsResponse listHotTablets( - com.google.bigtable.admin.v2.ListHotTabletsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.ListHotTabletsRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListHotTabletsMethod(), getCallOptions(), request); } @@ -2887,8 +2892,9 @@ public com.google.bigtable.admin.v2.ListHotTabletsResponse listHotTablets( * */ public com.google.longrunning.Operation createLogicalView( - com.google.bigtable.admin.v2.CreateLogicalViewRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.CreateLogicalViewRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateLogicalViewMethod(), getCallOptions(), request); } @@ -2900,8 +2906,8 @@ public com.google.longrunning.Operation createLogicalView( * */ public com.google.bigtable.admin.v2.LogicalView getLogicalView( - com.google.bigtable.admin.v2.GetLogicalViewRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.GetLogicalViewRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetLogicalViewMethod(), getCallOptions(), request); } @@ -2913,8 +2919,9 @@ public com.google.bigtable.admin.v2.LogicalView getLogicalView( * */ public com.google.bigtable.admin.v2.ListLogicalViewsResponse listLogicalViews( - com.google.bigtable.admin.v2.ListLogicalViewsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.ListLogicalViewsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListLogicalViewsMethod(), getCallOptions(), request); } @@ -2926,8 +2933,9 @@ public com.google.bigtable.admin.v2.ListLogicalViewsResponse listLogicalViews( * */ public com.google.longrunning.Operation updateLogicalView( - com.google.bigtable.admin.v2.UpdateLogicalViewRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.UpdateLogicalViewRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getUpdateLogicalViewMethod(), getCallOptions(), request); } @@ -2939,8 +2947,9 @@ public com.google.longrunning.Operation updateLogicalView( * */ public com.google.protobuf.Empty deleteLogicalView( - com.google.bigtable.admin.v2.DeleteLogicalViewRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.DeleteLogicalViewRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteLogicalViewMethod(), getCallOptions(), request); } @@ -2952,8 +2961,9 @@ public com.google.protobuf.Empty deleteLogicalView( * */ public com.google.longrunning.Operation createMaterializedView( - com.google.bigtable.admin.v2.CreateMaterializedViewRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.CreateMaterializedViewRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateMaterializedViewMethod(), getCallOptions(), request); } @@ -2965,8 +2975,9 @@ public com.google.longrunning.Operation createMaterializedView( * */ public com.google.bigtable.admin.v2.MaterializedView getMaterializedView( - com.google.bigtable.admin.v2.GetMaterializedViewRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.GetMaterializedViewRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetMaterializedViewMethod(), getCallOptions(), request); } @@ -2978,8 +2989,9 @@ public com.google.bigtable.admin.v2.MaterializedView getMaterializedView( * */ public com.google.bigtable.admin.v2.ListMaterializedViewsResponse listMaterializedViews( - com.google.bigtable.admin.v2.ListMaterializedViewsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.ListMaterializedViewsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListMaterializedViewsMethod(), getCallOptions(), request); } @@ -2991,8 +3003,9 @@ public com.google.bigtable.admin.v2.ListMaterializedViewsResponse listMaterializ * */ public com.google.longrunning.Operation updateMaterializedView( - com.google.bigtable.admin.v2.UpdateMaterializedViewRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.UpdateMaterializedViewRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getUpdateMaterializedViewMethod(), getCallOptions(), request); } @@ -3004,8 +3017,9 @@ public com.google.longrunning.Operation updateMaterializedView( * */ public com.google.protobuf.Empty deleteMaterializedView( - com.google.bigtable.admin.v2.DeleteMaterializedViewRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.DeleteMaterializedViewRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteMaterializedViewMethod(), getCallOptions(), request); } } diff --git a/grpc-google-cloud-bigtable-admin-v2/src/main/java/com/google/bigtable/admin/v2/BigtableTableAdminGrpc.java b/grpc-google-cloud-bigtable-admin-v2/src/main/java/com/google/bigtable/admin/v2/BigtableTableAdminGrpc.java index 99ae3a8858..93456ac0fa 100644 --- a/grpc-google-cloud-bigtable-admin-v2/src/main/java/com/google/bigtable/admin/v2/BigtableTableAdminGrpc.java +++ b/grpc-google-cloud-bigtable-admin-v2/src/main/java/com/google/bigtable/admin/v2/BigtableTableAdminGrpc.java @@ -26,9 +26,6 @@ * the tables. * */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/bigtable/admin/v2/bigtable_table_admin.proto") @io.grpc.stub.annotations.GrpcGenerated public final class BigtableTableAdminGrpc { @@ -2913,8 +2910,8 @@ protected BigtableTableAdminBlockingV2Stub build( * */ public com.google.bigtable.admin.v2.Table createTable( - com.google.bigtable.admin.v2.CreateTableRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.CreateTableRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateTableMethod(), getCallOptions(), request); } @@ -2932,8 +2929,9 @@ public com.google.bigtable.admin.v2.Table createTable( * */ public com.google.longrunning.Operation createTableFromSnapshot( - com.google.bigtable.admin.v2.CreateTableFromSnapshotRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.CreateTableFromSnapshotRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateTableFromSnapshotMethod(), getCallOptions(), request); } @@ -2945,8 +2943,8 @@ public com.google.longrunning.Operation createTableFromSnapshot( * */ public com.google.bigtable.admin.v2.ListTablesResponse listTables( - com.google.bigtable.admin.v2.ListTablesRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.ListTablesRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListTablesMethod(), getCallOptions(), request); } @@ -2958,8 +2956,8 @@ public com.google.bigtable.admin.v2.ListTablesResponse listTables( * */ public com.google.bigtable.admin.v2.Table getTable( - com.google.bigtable.admin.v2.GetTableRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.GetTableRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetTableMethod(), getCallOptions(), request); } @@ -2971,8 +2969,8 @@ public com.google.bigtable.admin.v2.Table getTable( * */ public com.google.longrunning.Operation updateTable( - com.google.bigtable.admin.v2.UpdateTableRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.UpdateTableRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getUpdateTableMethod(), getCallOptions(), request); } @@ -2984,8 +2982,8 @@ public com.google.longrunning.Operation updateTable( * */ public com.google.protobuf.Empty deleteTable( - com.google.bigtable.admin.v2.DeleteTableRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.DeleteTableRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteTableMethod(), getCallOptions(), request); } @@ -2997,8 +2995,8 @@ public com.google.protobuf.Empty deleteTable( * */ public com.google.longrunning.Operation undeleteTable( - com.google.bigtable.admin.v2.UndeleteTableRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.UndeleteTableRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getUndeleteTableMethod(), getCallOptions(), request); } @@ -3010,8 +3008,9 @@ public com.google.longrunning.Operation undeleteTable( * */ public com.google.longrunning.Operation createAuthorizedView( - com.google.bigtable.admin.v2.CreateAuthorizedViewRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.CreateAuthorizedViewRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateAuthorizedViewMethod(), getCallOptions(), request); } @@ -3023,8 +3022,9 @@ public com.google.longrunning.Operation createAuthorizedView( * */ public com.google.bigtable.admin.v2.ListAuthorizedViewsResponse listAuthorizedViews( - com.google.bigtable.admin.v2.ListAuthorizedViewsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.ListAuthorizedViewsRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListAuthorizedViewsMethod(), getCallOptions(), request); } @@ -3036,8 +3036,9 @@ public com.google.bigtable.admin.v2.ListAuthorizedViewsResponse listAuthorizedVi * */ public com.google.bigtable.admin.v2.AuthorizedView getAuthorizedView( - com.google.bigtable.admin.v2.GetAuthorizedViewRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.GetAuthorizedViewRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetAuthorizedViewMethod(), getCallOptions(), request); } @@ -3049,8 +3050,9 @@ public com.google.bigtable.admin.v2.AuthorizedView getAuthorizedView( * */ public com.google.longrunning.Operation updateAuthorizedView( - com.google.bigtable.admin.v2.UpdateAuthorizedViewRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.UpdateAuthorizedViewRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getUpdateAuthorizedViewMethod(), getCallOptions(), request); } @@ -3062,8 +3064,9 @@ public com.google.longrunning.Operation updateAuthorizedView( * */ public com.google.protobuf.Empty deleteAuthorizedView( - com.google.bigtable.admin.v2.DeleteAuthorizedViewRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.DeleteAuthorizedViewRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteAuthorizedViewMethod(), getCallOptions(), request); } @@ -3078,8 +3081,9 @@ public com.google.protobuf.Empty deleteAuthorizedView( * */ public com.google.bigtable.admin.v2.Table modifyColumnFamilies( - com.google.bigtable.admin.v2.ModifyColumnFamiliesRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.ModifyColumnFamiliesRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getModifyColumnFamiliesMethod(), getCallOptions(), request); } @@ -3093,8 +3097,8 @@ public com.google.bigtable.admin.v2.Table modifyColumnFamilies( * */ public com.google.protobuf.Empty dropRowRange( - com.google.bigtable.admin.v2.DropRowRangeRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.DropRowRangeRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDropRowRangeMethod(), getCallOptions(), request); } @@ -3109,8 +3113,9 @@ public com.google.protobuf.Empty dropRowRange( * */ public com.google.bigtable.admin.v2.GenerateConsistencyTokenResponse generateConsistencyToken( - com.google.bigtable.admin.v2.GenerateConsistencyTokenRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.GenerateConsistencyTokenRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGenerateConsistencyTokenMethod(), getCallOptions(), request); } @@ -3124,8 +3129,9 @@ public com.google.bigtable.admin.v2.GenerateConsistencyTokenResponse generateCon * */ public com.google.bigtable.admin.v2.CheckConsistencyResponse checkConsistency( - com.google.bigtable.admin.v2.CheckConsistencyRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.CheckConsistencyRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCheckConsistencyMethod(), getCallOptions(), request); } @@ -3143,8 +3149,8 @@ public com.google.bigtable.admin.v2.CheckConsistencyResponse checkConsistency( * */ public com.google.longrunning.Operation snapshotTable( - com.google.bigtable.admin.v2.SnapshotTableRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.SnapshotTableRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getSnapshotTableMethod(), getCallOptions(), request); } @@ -3161,8 +3167,8 @@ public com.google.longrunning.Operation snapshotTable( * */ public com.google.bigtable.admin.v2.Snapshot getSnapshot( - com.google.bigtable.admin.v2.GetSnapshotRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.GetSnapshotRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetSnapshotMethod(), getCallOptions(), request); } @@ -3179,8 +3185,8 @@ public com.google.bigtable.admin.v2.Snapshot getSnapshot( * */ public com.google.bigtable.admin.v2.ListSnapshotsResponse listSnapshots( - com.google.bigtable.admin.v2.ListSnapshotsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.ListSnapshotsRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListSnapshotsMethod(), getCallOptions(), request); } @@ -3197,8 +3203,8 @@ public com.google.bigtable.admin.v2.ListSnapshotsResponse listSnapshots( * */ public com.google.protobuf.Empty deleteSnapshot( - com.google.bigtable.admin.v2.DeleteSnapshotRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.DeleteSnapshotRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteSnapshotMethod(), getCallOptions(), request); } @@ -3217,8 +3223,8 @@ public com.google.protobuf.Empty deleteSnapshot( * */ public com.google.longrunning.Operation createBackup( - com.google.bigtable.admin.v2.CreateBackupRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.CreateBackupRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateBackupMethod(), getCallOptions(), request); } @@ -3230,8 +3236,8 @@ public com.google.longrunning.Operation createBackup( * */ public com.google.bigtable.admin.v2.Backup getBackup( - com.google.bigtable.admin.v2.GetBackupRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.GetBackupRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetBackupMethod(), getCallOptions(), request); } @@ -3243,8 +3249,8 @@ public com.google.bigtable.admin.v2.Backup getBackup( * */ public com.google.bigtable.admin.v2.Backup updateBackup( - com.google.bigtable.admin.v2.UpdateBackupRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.UpdateBackupRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getUpdateBackupMethod(), getCallOptions(), request); } @@ -3256,8 +3262,8 @@ public com.google.bigtable.admin.v2.Backup updateBackup( * */ public com.google.protobuf.Empty deleteBackup( - com.google.bigtable.admin.v2.DeleteBackupRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.DeleteBackupRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteBackupMethod(), getCallOptions(), request); } @@ -3270,8 +3276,8 @@ public com.google.protobuf.Empty deleteBackup( * */ public com.google.bigtable.admin.v2.ListBackupsResponse listBackups( - com.google.bigtable.admin.v2.ListBackupsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.ListBackupsRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListBackupsMethod(), getCallOptions(), request); } @@ -3289,8 +3295,8 @@ public com.google.bigtable.admin.v2.ListBackupsResponse listBackups( * */ public com.google.longrunning.Operation restoreTable( - com.google.bigtable.admin.v2.RestoreTableRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.RestoreTableRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getRestoreTableMethod(), getCallOptions(), request); } @@ -3303,8 +3309,8 @@ public com.google.longrunning.Operation restoreTable( * */ public com.google.longrunning.Operation copyBackup( - com.google.bigtable.admin.v2.CopyBackupRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.CopyBackupRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCopyBackupMethod(), getCallOptions(), request); } @@ -3317,8 +3323,9 @@ public com.google.longrunning.Operation copyBackup( * set. * */ - public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetIamPolicyMethod(), getCallOptions(), request); } @@ -3330,8 +3337,9 @@ public com.google.iam.v1.Policy getIamPolicy(com.google.iam.v1.GetIamPolicyReque * Replaces any existing policy. * */ - public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getSetIamPolicyMethod(), getCallOptions(), request); } @@ -3344,8 +3352,8 @@ public com.google.iam.v1.Policy setIamPolicy(com.google.iam.v1.SetIamPolicyReque * */ public com.google.iam.v1.TestIamPermissionsResponse testIamPermissions( - com.google.iam.v1.TestIamPermissionsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.iam.v1.TestIamPermissionsRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getTestIamPermissionsMethod(), getCallOptions(), request); } @@ -3357,8 +3365,9 @@ public com.google.iam.v1.TestIamPermissionsResponse testIamPermissions( * */ public com.google.longrunning.Operation createSchemaBundle( - com.google.bigtable.admin.v2.CreateSchemaBundleRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.CreateSchemaBundleRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateSchemaBundleMethod(), getCallOptions(), request); } @@ -3370,8 +3379,9 @@ public com.google.longrunning.Operation createSchemaBundle( * */ public com.google.longrunning.Operation updateSchemaBundle( - com.google.bigtable.admin.v2.UpdateSchemaBundleRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.UpdateSchemaBundleRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getUpdateSchemaBundleMethod(), getCallOptions(), request); } @@ -3383,8 +3393,9 @@ public com.google.longrunning.Operation updateSchemaBundle( * */ public com.google.bigtable.admin.v2.SchemaBundle getSchemaBundle( - com.google.bigtable.admin.v2.GetSchemaBundleRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.GetSchemaBundleRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetSchemaBundleMethod(), getCallOptions(), request); } @@ -3396,8 +3407,9 @@ public com.google.bigtable.admin.v2.SchemaBundle getSchemaBundle( * */ public com.google.bigtable.admin.v2.ListSchemaBundlesResponse listSchemaBundles( - com.google.bigtable.admin.v2.ListSchemaBundlesRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.ListSchemaBundlesRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListSchemaBundlesMethod(), getCallOptions(), request); } @@ -3409,8 +3421,9 @@ public com.google.bigtable.admin.v2.ListSchemaBundlesResponse listSchemaBundles( * */ public com.google.protobuf.Empty deleteSchemaBundle( - com.google.bigtable.admin.v2.DeleteSchemaBundleRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.admin.v2.DeleteSchemaBundleRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteSchemaBundleMethod(), getCallOptions(), request); } } diff --git a/grpc-google-cloud-bigtable-v2/pom.xml b/grpc-google-cloud-bigtable-v2/pom.xml index 79f0e79334..b78d5e5ea3 100644 --- a/grpc-google-cloud-bigtable-v2/pom.xml +++ b/grpc-google-cloud-bigtable-v2/pom.xml @@ -4,13 +4,13 @@ 4.0.0 com.google.api.grpc grpc-google-cloud-bigtable-v2 - 2.69.0 + 2.70.0 grpc-google-cloud-bigtable-v2 GRPC library for grpc-google-cloud-bigtable-v2 com.google.cloud google-cloud-bigtable-parent - 2.69.0 + 2.70.0 @@ -18,14 +18,14 @@ com.google.cloud google-cloud-bigtable-deps-bom - 2.69.0 + 2.70.0 pom import com.google.cloud google-cloud-bigtable-bom - 2.69.0 + 2.70.0 pom import diff --git a/grpc-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/BigtableGrpc.java b/grpc-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/BigtableGrpc.java index b348a2aed4..cc9a36a7bf 100644 --- a/grpc-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/BigtableGrpc.java +++ b/grpc-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/BigtableGrpc.java @@ -24,9 +24,6 @@ * Service for reading from and writing to existing Bigtable tables. * */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/bigtable/v2/bigtable.proto") @io.grpc.stub.annotations.GrpcGenerated public final class BigtableGrpc { @@ -1048,8 +1045,8 @@ public io.grpc.stub.BlockingClientCall */ public com.google.bigtable.v2.MutateRowResponse mutateRow( - com.google.bigtable.v2.MutateRowRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.v2.MutateRowRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getMutateRowMethod(), getCallOptions(), request); } @@ -1077,8 +1074,8 @@ public io.grpc.stub.BlockingClientCall */ public com.google.bigtable.v2.CheckAndMutateRowResponse checkAndMutateRow( - com.google.bigtable.v2.CheckAndMutateRowRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.v2.CheckAndMutateRowRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCheckAndMutateRowMethod(), getCallOptions(), request); } @@ -1091,8 +1088,8 @@ public com.google.bigtable.v2.CheckAndMutateRowResponse checkAndMutateRow( * */ public com.google.bigtable.v2.PingAndWarmResponse pingAndWarm( - com.google.bigtable.v2.PingAndWarmRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.v2.PingAndWarmRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getPingAndWarmMethod(), getCallOptions(), request); } @@ -1108,8 +1105,8 @@ public com.google.bigtable.v2.PingAndWarmResponse pingAndWarm( * */ public com.google.bigtable.v2.ReadModifyWriteRowResponse readModifyWriteRow( - com.google.bigtable.v2.ReadModifyWriteRowRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.v2.ReadModifyWriteRowRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getReadModifyWriteRowMethod(), getCallOptions(), request); } @@ -1160,8 +1157,8 @@ public com.google.bigtable.v2.ReadModifyWriteRowResponse readModifyWriteRow( * */ public com.google.bigtable.v2.PrepareQueryResponse prepareQuery( - com.google.bigtable.v2.PrepareQueryRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.bigtable.v2.PrepareQueryRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getPrepareQueryMethod(), getCallOptions(), request); } diff --git a/pom.xml b/pom.xml index b91f4c1d2f..3fcd706262 100644 --- a/pom.xml +++ b/pom.xml @@ -4,7 +4,7 @@ google-cloud-bigtable-parent pom - 2.69.0 + 2.70.0 Google Cloud Bigtable Parent https://github.com/googleapis/java-bigtable @@ -14,7 +14,7 @@ com.google.cloud sdk-platform-java-config - 3.53.0 + 3.54.1 @@ -156,27 +156,27 @@ com.google.api.grpc proto-google-cloud-bigtable-v2 - 2.69.0 + 2.70.0 com.google.api.grpc proto-google-cloud-bigtable-admin-v2 - 2.69.0 + 2.70.0 com.google.api.grpc grpc-google-cloud-bigtable-v2 - 2.69.0 + 2.70.0 com.google.api.grpc grpc-google-cloud-bigtable-admin-v2 - 2.69.0 + 2.70.0 com.google.cloud google-cloud-bigtable - 2.69.0 + 2.70.0 diff --git a/proto-google-cloud-bigtable-admin-v2/pom.xml b/proto-google-cloud-bigtable-admin-v2/pom.xml index 524cb4ecfd..fa309c627b 100644 --- a/proto-google-cloud-bigtable-admin-v2/pom.xml +++ b/proto-google-cloud-bigtable-admin-v2/pom.xml @@ -4,13 +4,13 @@ 4.0.0 com.google.api.grpc proto-google-cloud-bigtable-admin-v2 - 2.69.0 + 2.70.0 proto-google-cloud-bigtable-admin-v2 PROTO library for proto-google-cloud-bigtable-admin-v2 com.google.cloud google-cloud-bigtable-parent - 2.69.0 + 2.70.0 @@ -18,14 +18,14 @@ com.google.cloud google-cloud-bigtable-deps-bom - 2.69.0 + 2.70.0 pom import com.google.cloud google-cloud-bigtable-bom - 2.69.0 + 2.70.0 pom import diff --git a/proto-google-cloud-bigtable-v2/pom.xml b/proto-google-cloud-bigtable-v2/pom.xml index 080f08d68c..1e747d0995 100644 --- a/proto-google-cloud-bigtable-v2/pom.xml +++ b/proto-google-cloud-bigtable-v2/pom.xml @@ -4,13 +4,13 @@ 4.0.0 com.google.api.grpc proto-google-cloud-bigtable-v2 - 2.69.0 + 2.70.0 proto-google-cloud-bigtable-v2 PROTO library for proto-google-cloud-bigtable-v2 com.google.cloud google-cloud-bigtable-parent - 2.69.0 + 2.70.0 @@ -18,14 +18,14 @@ com.google.cloud google-cloud-bigtable-deps-bom - 2.69.0 + 2.70.0 pom import com.google.cloud google-cloud-bigtable-bom - 2.69.0 + 2.70.0 pom import diff --git a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/FeatureFlags.java b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/FeatureFlags.java index 052f8af137..92a7f74a43 100644 --- a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/FeatureFlags.java +++ b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/FeatureFlags.java @@ -248,6 +248,25 @@ public boolean getDirectAccessRequested() { return directAccessRequested_; } + public static final int PEER_INFO_FIELD_NUMBER = 11; + private boolean peerInfo_ = false; + + /** + * + * + *
+   * If the client can support using BigtablePeerInfo.
+   * 
+ * + * bool peer_info = 11; + * + * @return The peerInfo. + */ + @java.lang.Override + public boolean getPeerInfo() { + return peerInfo_; + } + private byte memoizedIsInitialized = -1; @java.lang.Override @@ -289,6 +308,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io if (directAccessRequested_ != false) { output.writeBool(10, directAccessRequested_); } + if (peerInfo_ != false) { + output.writeBool(11, peerInfo_); + } getUnknownFields().writeTo(output); } @@ -325,6 +347,9 @@ public int getSerializedSize() { if (directAccessRequested_ != false) { size += com.google.protobuf.CodedOutputStream.computeBoolSize(10, directAccessRequested_); } + if (peerInfo_ != false) { + size += com.google.protobuf.CodedOutputStream.computeBoolSize(11, peerInfo_); + } size += getUnknownFields().getSerializedSize(); memoizedSize = size; return size; @@ -349,6 +374,7 @@ public boolean equals(final java.lang.Object obj) { if (getClientSideMetricsEnabled() != other.getClientSideMetricsEnabled()) return false; if (getTrafficDirectorEnabled() != other.getTrafficDirectorEnabled()) return false; if (getDirectAccessRequested() != other.getDirectAccessRequested()) return false; + if (getPeerInfo() != other.getPeerInfo()) return false; if (!getUnknownFields().equals(other.getUnknownFields())) return false; return true; } @@ -378,6 +404,8 @@ public int hashCode() { hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(getTrafficDirectorEnabled()); hash = (37 * hash) + DIRECT_ACCESS_REQUESTED_FIELD_NUMBER; hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(getDirectAccessRequested()); + hash = (37 * hash) + PEER_INFO_FIELD_NUMBER; + hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(getPeerInfo()); hash = (29 * hash) + getUnknownFields().hashCode(); memoizedHashCode = hash; return hash; @@ -533,6 +561,7 @@ public Builder clear() { clientSideMetricsEnabled_ = false; trafficDirectorEnabled_ = false; directAccessRequested_ = false; + peerInfo_ = false; return this; } @@ -595,6 +624,9 @@ private void buildPartial0(com.google.bigtable.v2.FeatureFlags result) { if (((from_bitField0_ & 0x00000100) != 0)) { result.directAccessRequested_ = directAccessRequested_; } + if (((from_bitField0_ & 0x00000200) != 0)) { + result.peerInfo_ = peerInfo_; + } } @java.lang.Override @@ -669,6 +701,9 @@ public Builder mergeFrom(com.google.bigtable.v2.FeatureFlags other) { if (other.getDirectAccessRequested() != false) { setDirectAccessRequested(other.getDirectAccessRequested()); } + if (other.getPeerInfo() != false) { + setPeerInfo(other.getPeerInfo()); + } this.mergeUnknownFields(other.getUnknownFields()); onChanged(); return this; @@ -749,6 +784,12 @@ public Builder mergeFrom( bitField0_ |= 0x00000100; break; } // case 80 + case 88: + { + peerInfo_ = input.readBool(); + bitField0_ |= 0x00000200; + break; + } // case 88 default: { if (!super.parseUnknownField(input, extensionRegistry, tag)) { @@ -1296,6 +1337,62 @@ public Builder clearDirectAccessRequested() { return this; } + private boolean peerInfo_; + + /** + * + * + *
+     * If the client can support using BigtablePeerInfo.
+     * 
+ * + * bool peer_info = 11; + * + * @return The peerInfo. + */ + @java.lang.Override + public boolean getPeerInfo() { + return peerInfo_; + } + + /** + * + * + *
+     * If the client can support using BigtablePeerInfo.
+     * 
+ * + * bool peer_info = 11; + * + * @param value The peerInfo to set. + * @return This builder for chaining. + */ + public Builder setPeerInfo(boolean value) { + + peerInfo_ = value; + bitField0_ |= 0x00000200; + onChanged(); + return this; + } + + /** + * + * + *
+     * If the client can support using BigtablePeerInfo.
+     * 
+ * + * bool peer_info = 11; + * + * @return This builder for chaining. + */ + public Builder clearPeerInfo() { + bitField0_ = (bitField0_ & ~0x00000200); + peerInfo_ = false; + onChanged(); + return this; + } + @java.lang.Override public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) { return super.setUnknownFields(unknownFields); diff --git a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/FeatureFlagsOrBuilder.java b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/FeatureFlagsOrBuilder.java index 6765956633..139f4d597a 100644 --- a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/FeatureFlagsOrBuilder.java +++ b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/FeatureFlagsOrBuilder.java @@ -148,4 +148,17 @@ public interface FeatureFlagsOrBuilder * @return The directAccessRequested. */ boolean getDirectAccessRequested(); + + /** + * + * + *
+   * If the client can support using BigtablePeerInfo.
+   * 
+ * + * bool peer_info = 11; + * + * @return The peerInfo. + */ + boolean getPeerInfo(); } diff --git a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/FeatureFlagsProto.java b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/FeatureFlagsProto.java index 8cc32dba0a..0e3f735d05 100644 --- a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/FeatureFlagsProto.java +++ b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/FeatureFlagsProto.java @@ -42,19 +42,20 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { static { java.lang.String[] descriptorData = { "\n&google/bigtable/v2/feature_flags.proto" - + "\022\022google.bigtable.v2\"\236\002\n\014FeatureFlags\022\025\n" + + "\022\022google.bigtable.v2\"\261\002\n\014FeatureFlags\022\025\n" + "\rreverse_scans\030\001 \001(\010\022\036\n\026mutate_rows_rate" + "_limit\030\003 \001(\010\022\037\n\027mutate_rows_rate_limit2\030" + "\005 \001(\010\022\"\n\032last_scanned_row_responses\030\004 \001(" + "\010\022\026\n\016routing_cookie\030\006 \001(\010\022\022\n\nretry_info\030" + "\007 \001(\010\022#\n\033client_side_metrics_enabled\030\010 \001" + "(\010\022 \n\030traffic_director_enabled\030\t \001(\010\022\037\n\027" - + "direct_access_requested\030\n \001(\010B\273\001\n\026com.go" - + "ogle.bigtable.v2B\021FeatureFlagsProtoP\001Z8c" - + "loud.google.com/go/bigtable/apiv2/bigtab" - + "lepb;bigtablepb\252\002\030Google.Cloud.Bigtable." - + "V2\312\002\030Google\\Cloud\\Bigtable\\V2\352\002\033Google::" - + "Cloud::Bigtable::V2b\006proto3" + + "direct_access_requested\030\n \001(\010\022\021\n\tpeer_in" + + "fo\030\013 \001(\010B\273\001\n\026com.google.bigtable.v2B\021Fea" + + "tureFlagsProtoP\001Z8cloud.google.com/go/bi" + + "gtable/apiv2/bigtablepb;bigtablepb\252\002\030Goo" + + "gle.Cloud.Bigtable.V2\312\002\030Google\\Cloud\\Big" + + "table\\V2\352\002\033Google::Cloud::Bigtable::V2b\006" + + "proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom( @@ -74,6 +75,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "ClientSideMetricsEnabled", "TrafficDirectorEnabled", "DirectAccessRequested", + "PeerInfo", }); } diff --git a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/PeerInfo.java b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/PeerInfo.java new file mode 100644 index 0000000000..068d1b9f55 --- /dev/null +++ b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/PeerInfo.java @@ -0,0 +1,1427 @@ +/* + * Copyright 2025 Google LLC + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: google/bigtable/v2/peer_info.proto + +// Protobuf Java Version: 3.25.8 +package com.google.bigtable.v2; + +/** + * + * + *
+ * PeerInfo contains information about the peer that the client is
+ * connecting to.
+ * 
+ * + * Protobuf type {@code google.bigtable.v2.PeerInfo} + */ +public final class PeerInfo extends com.google.protobuf.GeneratedMessageV3 + implements + // @@protoc_insertion_point(message_implements:google.bigtable.v2.PeerInfo) + PeerInfoOrBuilder { + private static final long serialVersionUID = 0L; + + // Use PeerInfo.newBuilder() to construct. + private PeerInfo(com.google.protobuf.GeneratedMessageV3.Builder builder) { + super(builder); + } + + private PeerInfo() { + applicationFrontendZone_ = ""; + applicationFrontendSubzone_ = ""; + transportType_ = 0; + } + + @java.lang.Override + @SuppressWarnings({"unused"}) + protected java.lang.Object newInstance(UnusedPrivateParameter unused) { + return new PeerInfo(); + } + + public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() { + return com.google.bigtable.v2.PeerInfoProto + .internal_static_google_bigtable_v2_PeerInfo_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return com.google.bigtable.v2.PeerInfoProto + .internal_static_google_bigtable_v2_PeerInfo_fieldAccessorTable + .ensureFieldAccessorsInitialized( + com.google.bigtable.v2.PeerInfo.class, com.google.bigtable.v2.PeerInfo.Builder.class); + } + + /** + * + * + *
+   * The transport type that the client used to connect to this peer.
+   * 
+ * + * Protobuf enum {@code google.bigtable.v2.PeerInfo.TransportType} + */ + public enum TransportType implements com.google.protobuf.ProtocolMessageEnum { + /** + * + * + *
+     * The transport type is unknown.
+     * 
+ * + * TRANSPORT_TYPE_UNKNOWN = 0; + */ + TRANSPORT_TYPE_UNKNOWN(0), + /** + * + * + *
+     * The client connected to this peer via an external network
+     * (e.g. outside Google Coud).
+     * 
+ * + * TRANSPORT_TYPE_EXTERNAL = 1; + */ + TRANSPORT_TYPE_EXTERNAL(1), + /** + * + * + *
+     * The client connected to this peer via CloudPath.
+     * 
+ * + * TRANSPORT_TYPE_CLOUD_PATH = 2; + */ + TRANSPORT_TYPE_CLOUD_PATH(2), + /** + * + * + *
+     * The client connected to this peer via DirectAccess.
+     * 
+ * + * TRANSPORT_TYPE_DIRECT_ACCESS = 3; + */ + TRANSPORT_TYPE_DIRECT_ACCESS(3), + /** + * + * + *
+     * The client connected to this peer via Bigtable Sessions using an unknown
+     * transport type.
+     * 
+ * + * TRANSPORT_TYPE_SESSION_UNKNOWN = 4; + */ + TRANSPORT_TYPE_SESSION_UNKNOWN(4), + /** + * + * + *
+     * The client connected to this peer via Bigtable Sessions on an external
+     * network (e.g. outside Google Cloud).
+     * 
+ * + * TRANSPORT_TYPE_SESSION_EXTERNAL = 5; + */ + TRANSPORT_TYPE_SESSION_EXTERNAL(5), + /** + * + * + *
+     * The client connected to this peer via Bigtable Sessions using CloudPath.
+     * 
+ * + * TRANSPORT_TYPE_SESSION_CLOUD_PATH = 6; + */ + TRANSPORT_TYPE_SESSION_CLOUD_PATH(6), + /** + * + * + *
+     * The client connected to this peer via Bigtable Sessions using
+     * DirectAccess.
+     * 
+ * + * TRANSPORT_TYPE_SESSION_DIRECT_ACCESS = 7; + */ + TRANSPORT_TYPE_SESSION_DIRECT_ACCESS(7), + UNRECOGNIZED(-1), + ; + + /** + * + * + *
+     * The transport type is unknown.
+     * 
+ * + * TRANSPORT_TYPE_UNKNOWN = 0; + */ + public static final int TRANSPORT_TYPE_UNKNOWN_VALUE = 0; + + /** + * + * + *
+     * The client connected to this peer via an external network
+     * (e.g. outside Google Coud).
+     * 
+ * + * TRANSPORT_TYPE_EXTERNAL = 1; + */ + public static final int TRANSPORT_TYPE_EXTERNAL_VALUE = 1; + + /** + * + * + *
+     * The client connected to this peer via CloudPath.
+     * 
+ * + * TRANSPORT_TYPE_CLOUD_PATH = 2; + */ + public static final int TRANSPORT_TYPE_CLOUD_PATH_VALUE = 2; + + /** + * + * + *
+     * The client connected to this peer via DirectAccess.
+     * 
+ * + * TRANSPORT_TYPE_DIRECT_ACCESS = 3; + */ + public static final int TRANSPORT_TYPE_DIRECT_ACCESS_VALUE = 3; + + /** + * + * + *
+     * The client connected to this peer via Bigtable Sessions using an unknown
+     * transport type.
+     * 
+ * + * TRANSPORT_TYPE_SESSION_UNKNOWN = 4; + */ + public static final int TRANSPORT_TYPE_SESSION_UNKNOWN_VALUE = 4; + + /** + * + * + *
+     * The client connected to this peer via Bigtable Sessions on an external
+     * network (e.g. outside Google Cloud).
+     * 
+ * + * TRANSPORT_TYPE_SESSION_EXTERNAL = 5; + */ + public static final int TRANSPORT_TYPE_SESSION_EXTERNAL_VALUE = 5; + + /** + * + * + *
+     * The client connected to this peer via Bigtable Sessions using CloudPath.
+     * 
+ * + * TRANSPORT_TYPE_SESSION_CLOUD_PATH = 6; + */ + public static final int TRANSPORT_TYPE_SESSION_CLOUD_PATH_VALUE = 6; + + /** + * + * + *
+     * The client connected to this peer via Bigtable Sessions using
+     * DirectAccess.
+     * 
+ * + * TRANSPORT_TYPE_SESSION_DIRECT_ACCESS = 7; + */ + public static final int TRANSPORT_TYPE_SESSION_DIRECT_ACCESS_VALUE = 7; + + public final int getNumber() { + if (this == UNRECOGNIZED) { + throw new java.lang.IllegalArgumentException( + "Can't get the number of an unknown enum value."); + } + return value; + } + + /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. + * @deprecated Use {@link #forNumber(int)} instead. + */ + @java.lang.Deprecated + public static TransportType valueOf(int value) { + return forNumber(value); + } + + /** + * @param value The numeric wire value of the corresponding enum entry. + * @return The enum associated with the given numeric wire value. + */ + public static TransportType forNumber(int value) { + switch (value) { + case 0: + return TRANSPORT_TYPE_UNKNOWN; + case 1: + return TRANSPORT_TYPE_EXTERNAL; + case 2: + return TRANSPORT_TYPE_CLOUD_PATH; + case 3: + return TRANSPORT_TYPE_DIRECT_ACCESS; + case 4: + return TRANSPORT_TYPE_SESSION_UNKNOWN; + case 5: + return TRANSPORT_TYPE_SESSION_EXTERNAL; + case 6: + return TRANSPORT_TYPE_SESSION_CLOUD_PATH; + case 7: + return TRANSPORT_TYPE_SESSION_DIRECT_ACCESS; + default: + return null; + } + } + + public static com.google.protobuf.Internal.EnumLiteMap internalGetValueMap() { + return internalValueMap; + } + + private static final com.google.protobuf.Internal.EnumLiteMap internalValueMap = + new com.google.protobuf.Internal.EnumLiteMap() { + public TransportType findValueByNumber(int number) { + return TransportType.forNumber(number); + } + }; + + public final com.google.protobuf.Descriptors.EnumValueDescriptor getValueDescriptor() { + if (this == UNRECOGNIZED) { + throw new java.lang.IllegalStateException( + "Can't get the descriptor of an unrecognized enum value."); + } + return getDescriptor().getValues().get(ordinal()); + } + + public final com.google.protobuf.Descriptors.EnumDescriptor getDescriptorForType() { + return getDescriptor(); + } + + public static final com.google.protobuf.Descriptors.EnumDescriptor getDescriptor() { + return com.google.bigtable.v2.PeerInfo.getDescriptor().getEnumTypes().get(0); + } + + private static final TransportType[] VALUES = values(); + + public static TransportType valueOf(com.google.protobuf.Descriptors.EnumValueDescriptor desc) { + if (desc.getType() != getDescriptor()) { + throw new java.lang.IllegalArgumentException("EnumValueDescriptor is not for this type."); + } + if (desc.getIndex() == -1) { + return UNRECOGNIZED; + } + return VALUES[desc.getIndex()]; + } + + private final int value; + + private TransportType(int value) { + this.value = value; + } + + // @@protoc_insertion_point(enum_scope:google.bigtable.v2.PeerInfo.TransportType) + } + + public static final int GOOGLE_FRONTEND_ID_FIELD_NUMBER = 1; + private long googleFrontendId_ = 0L; + + /** + * + * + *
+   * An opaque identifier for the Google Frontend which serviced this request.
+   * Only set when not using DirectAccess.
+   * 
+ * + * int64 google_frontend_id = 1; + * + * @return The googleFrontendId. + */ + @java.lang.Override + public long getGoogleFrontendId() { + return googleFrontendId_; + } + + public static final int APPLICATION_FRONTEND_ID_FIELD_NUMBER = 2; + private long applicationFrontendId_ = 0L; + + /** + * + * + *
+   * An opaque identifier for the application frontend which serviced this
+   * request.
+   * 
+ * + * int64 application_frontend_id = 2; + * + * @return The applicationFrontendId. + */ + @java.lang.Override + public long getApplicationFrontendId() { + return applicationFrontendId_; + } + + public static final int APPLICATION_FRONTEND_ZONE_FIELD_NUMBER = 3; + + @SuppressWarnings("serial") + private volatile java.lang.Object applicationFrontendZone_ = ""; + + /** + * + * + *
+   * The Cloud zone of the application frontend that served this request.
+   * 
+ * + * string application_frontend_zone = 3; + * + * @return The applicationFrontendZone. + */ + @java.lang.Override + public java.lang.String getApplicationFrontendZone() { + java.lang.Object ref = applicationFrontendZone_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + applicationFrontendZone_ = s; + return s; + } + } + + /** + * + * + *
+   * The Cloud zone of the application frontend that served this request.
+   * 
+ * + * string application_frontend_zone = 3; + * + * @return The bytes for applicationFrontendZone. + */ + @java.lang.Override + public com.google.protobuf.ByteString getApplicationFrontendZoneBytes() { + java.lang.Object ref = applicationFrontendZone_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref); + applicationFrontendZone_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int APPLICATION_FRONTEND_SUBZONE_FIELD_NUMBER = 4; + + @SuppressWarnings("serial") + private volatile java.lang.Object applicationFrontendSubzone_ = ""; + + /** + * + * + *
+   * The subzone of the application frontend that served this request, e.g. an
+   * identifier for where within the zone the application frontend is.
+   * 
+ * + * string application_frontend_subzone = 4; + * + * @return The applicationFrontendSubzone. + */ + @java.lang.Override + public java.lang.String getApplicationFrontendSubzone() { + java.lang.Object ref = applicationFrontendSubzone_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + applicationFrontendSubzone_ = s; + return s; + } + } + + /** + * + * + *
+   * The subzone of the application frontend that served this request, e.g. an
+   * identifier for where within the zone the application frontend is.
+   * 
+ * + * string application_frontend_subzone = 4; + * + * @return The bytes for applicationFrontendSubzone. + */ + @java.lang.Override + public com.google.protobuf.ByteString getApplicationFrontendSubzoneBytes() { + java.lang.Object ref = applicationFrontendSubzone_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref); + applicationFrontendSubzone_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + public static final int TRANSPORT_TYPE_FIELD_NUMBER = 5; + private int transportType_ = 0; + + /** + * .google.bigtable.v2.PeerInfo.TransportType transport_type = 5; + * + * @return The enum numeric value on the wire for transportType. + */ + @java.lang.Override + public int getTransportTypeValue() { + return transportType_; + } + + /** + * .google.bigtable.v2.PeerInfo.TransportType transport_type = 5; + * + * @return The transportType. + */ + @java.lang.Override + public com.google.bigtable.v2.PeerInfo.TransportType getTransportType() { + com.google.bigtable.v2.PeerInfo.TransportType result = + com.google.bigtable.v2.PeerInfo.TransportType.forNumber(transportType_); + return result == null ? com.google.bigtable.v2.PeerInfo.TransportType.UNRECOGNIZED : result; + } + + private byte memoizedIsInitialized = -1; + + @java.lang.Override + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + @java.lang.Override + public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException { + if (googleFrontendId_ != 0L) { + output.writeInt64(1, googleFrontendId_); + } + if (applicationFrontendId_ != 0L) { + output.writeInt64(2, applicationFrontendId_); + } + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(applicationFrontendZone_)) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 3, applicationFrontendZone_); + } + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(applicationFrontendSubzone_)) { + com.google.protobuf.GeneratedMessageV3.writeString(output, 4, applicationFrontendSubzone_); + } + if (transportType_ + != com.google.bigtable.v2.PeerInfo.TransportType.TRANSPORT_TYPE_UNKNOWN.getNumber()) { + output.writeEnum(5, transportType_); + } + getUnknownFields().writeTo(output); + } + + @java.lang.Override + public int getSerializedSize() { + int size = memoizedSize; + if (size != -1) return size; + + size = 0; + if (googleFrontendId_ != 0L) { + size += com.google.protobuf.CodedOutputStream.computeInt64Size(1, googleFrontendId_); + } + if (applicationFrontendId_ != 0L) { + size += com.google.protobuf.CodedOutputStream.computeInt64Size(2, applicationFrontendId_); + } + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(applicationFrontendZone_)) { + size += com.google.protobuf.GeneratedMessageV3.computeStringSize(3, applicationFrontendZone_); + } + if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(applicationFrontendSubzone_)) { + size += + com.google.protobuf.GeneratedMessageV3.computeStringSize(4, applicationFrontendSubzone_); + } + if (transportType_ + != com.google.bigtable.v2.PeerInfo.TransportType.TRANSPORT_TYPE_UNKNOWN.getNumber()) { + size += com.google.protobuf.CodedOutputStream.computeEnumSize(5, transportType_); + } + size += getUnknownFields().getSerializedSize(); + memoizedSize = size; + return size; + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof com.google.bigtable.v2.PeerInfo)) { + return super.equals(obj); + } + com.google.bigtable.v2.PeerInfo other = (com.google.bigtable.v2.PeerInfo) obj; + + if (getGoogleFrontendId() != other.getGoogleFrontendId()) return false; + if (getApplicationFrontendId() != other.getApplicationFrontendId()) return false; + if (!getApplicationFrontendZone().equals(other.getApplicationFrontendZone())) return false; + if (!getApplicationFrontendSubzone().equals(other.getApplicationFrontendSubzone())) + return false; + if (transportType_ != other.transportType_) return false; + if (!getUnknownFields().equals(other.getUnknownFields())) return false; + return true; + } + + @java.lang.Override + public int hashCode() { + if (memoizedHashCode != 0) { + return memoizedHashCode; + } + int hash = 41; + hash = (19 * hash) + getDescriptor().hashCode(); + hash = (37 * hash) + GOOGLE_FRONTEND_ID_FIELD_NUMBER; + hash = (53 * hash) + com.google.protobuf.Internal.hashLong(getGoogleFrontendId()); + hash = (37 * hash) + APPLICATION_FRONTEND_ID_FIELD_NUMBER; + hash = (53 * hash) + com.google.protobuf.Internal.hashLong(getApplicationFrontendId()); + hash = (37 * hash) + APPLICATION_FRONTEND_ZONE_FIELD_NUMBER; + hash = (53 * hash) + getApplicationFrontendZone().hashCode(); + hash = (37 * hash) + APPLICATION_FRONTEND_SUBZONE_FIELD_NUMBER; + hash = (53 * hash) + getApplicationFrontendSubzone().hashCode(); + hash = (37 * hash) + TRANSPORT_TYPE_FIELD_NUMBER; + hash = (53 * hash) + transportType_; + hash = (29 * hash) + getUnknownFields().hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static com.google.bigtable.v2.PeerInfo parseFrom(java.nio.ByteBuffer data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + + public static com.google.bigtable.v2.PeerInfo parseFrom( + java.nio.ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + + public static com.google.bigtable.v2.PeerInfo parseFrom(com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + + public static com.google.bigtable.v2.PeerInfo parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + + public static com.google.bigtable.v2.PeerInfo parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + + public static com.google.bigtable.v2.PeerInfo parseFrom( + byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + + public static com.google.bigtable.v2.PeerInfo parseFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input); + } + + public static com.google.bigtable.v2.PeerInfo parseFrom( + java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3.parseWithIOException( + PARSER, input, extensionRegistry); + } + + public static com.google.bigtable.v2.PeerInfo parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException(PARSER, input); + } + + public static com.google.bigtable.v2.PeerInfo parseDelimitedFrom( + java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3.parseDelimitedWithIOException( + PARSER, input, extensionRegistry); + } + + public static com.google.bigtable.v2.PeerInfo parseFrom( + com.google.protobuf.CodedInputStream input) throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3.parseWithIOException(PARSER, input); + } + + public static com.google.bigtable.v2.PeerInfo parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return com.google.protobuf.GeneratedMessageV3.parseWithIOException( + PARSER, input, extensionRegistry); + } + + @java.lang.Override + public Builder newBuilderForType() { + return newBuilder(); + } + + public static Builder newBuilder() { + return DEFAULT_INSTANCE.toBuilder(); + } + + public static Builder newBuilder(com.google.bigtable.v2.PeerInfo prototype) { + return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); + } + + @java.lang.Override + public Builder toBuilder() { + return this == DEFAULT_INSTANCE ? new Builder() : new Builder().mergeFrom(this); + } + + @java.lang.Override + protected Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + + /** + * + * + *
+   * PeerInfo contains information about the peer that the client is
+   * connecting to.
+   * 
+ * + * Protobuf type {@code google.bigtable.v2.PeerInfo} + */ + public static final class Builder extends com.google.protobuf.GeneratedMessageV3.Builder + implements + // @@protoc_insertion_point(builder_implements:google.bigtable.v2.PeerInfo) + com.google.bigtable.v2.PeerInfoOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() { + return com.google.bigtable.v2.PeerInfoProto + .internal_static_google_bigtable_v2_PeerInfo_descriptor; + } + + @java.lang.Override + protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internalGetFieldAccessorTable() { + return com.google.bigtable.v2.PeerInfoProto + .internal_static_google_bigtable_v2_PeerInfo_fieldAccessorTable + .ensureFieldAccessorsInitialized( + com.google.bigtable.v2.PeerInfo.class, com.google.bigtable.v2.PeerInfo.Builder.class); + } + + // Construct using com.google.bigtable.v2.PeerInfo.newBuilder() + private Builder() {} + + private Builder(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) { + super(parent); + } + + @java.lang.Override + public Builder clear() { + super.clear(); + bitField0_ = 0; + googleFrontendId_ = 0L; + applicationFrontendId_ = 0L; + applicationFrontendZone_ = ""; + applicationFrontendSubzone_ = ""; + transportType_ = 0; + return this; + } + + @java.lang.Override + public com.google.protobuf.Descriptors.Descriptor getDescriptorForType() { + return com.google.bigtable.v2.PeerInfoProto + .internal_static_google_bigtable_v2_PeerInfo_descriptor; + } + + @java.lang.Override + public com.google.bigtable.v2.PeerInfo getDefaultInstanceForType() { + return com.google.bigtable.v2.PeerInfo.getDefaultInstance(); + } + + @java.lang.Override + public com.google.bigtable.v2.PeerInfo build() { + com.google.bigtable.v2.PeerInfo result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + @java.lang.Override + public com.google.bigtable.v2.PeerInfo buildPartial() { + com.google.bigtable.v2.PeerInfo result = new com.google.bigtable.v2.PeerInfo(this); + if (bitField0_ != 0) { + buildPartial0(result); + } + onBuilt(); + return result; + } + + private void buildPartial0(com.google.bigtable.v2.PeerInfo result) { + int from_bitField0_ = bitField0_; + if (((from_bitField0_ & 0x00000001) != 0)) { + result.googleFrontendId_ = googleFrontendId_; + } + if (((from_bitField0_ & 0x00000002) != 0)) { + result.applicationFrontendId_ = applicationFrontendId_; + } + if (((from_bitField0_ & 0x00000004) != 0)) { + result.applicationFrontendZone_ = applicationFrontendZone_; + } + if (((from_bitField0_ & 0x00000008) != 0)) { + result.applicationFrontendSubzone_ = applicationFrontendSubzone_; + } + if (((from_bitField0_ & 0x00000010) != 0)) { + result.transportType_ = transportType_; + } + } + + @java.lang.Override + public Builder clone() { + return super.clone(); + } + + @java.lang.Override + public Builder setField( + com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) { + return super.setField(field, value); + } + + @java.lang.Override + public Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field) { + return super.clearField(field); + } + + @java.lang.Override + public Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) { + return super.clearOneof(oneof); + } + + @java.lang.Override + public Builder setRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, int index, java.lang.Object value) { + return super.setRepeatedField(field, index, value); + } + + @java.lang.Override + public Builder addRepeatedField( + com.google.protobuf.Descriptors.FieldDescriptor field, java.lang.Object value) { + return super.addRepeatedField(field, value); + } + + @java.lang.Override + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof com.google.bigtable.v2.PeerInfo) { + return mergeFrom((com.google.bigtable.v2.PeerInfo) other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(com.google.bigtable.v2.PeerInfo other) { + if (other == com.google.bigtable.v2.PeerInfo.getDefaultInstance()) return this; + if (other.getGoogleFrontendId() != 0L) { + setGoogleFrontendId(other.getGoogleFrontendId()); + } + if (other.getApplicationFrontendId() != 0L) { + setApplicationFrontendId(other.getApplicationFrontendId()); + } + if (!other.getApplicationFrontendZone().isEmpty()) { + applicationFrontendZone_ = other.applicationFrontendZone_; + bitField0_ |= 0x00000004; + onChanged(); + } + if (!other.getApplicationFrontendSubzone().isEmpty()) { + applicationFrontendSubzone_ = other.applicationFrontendSubzone_; + bitField0_ |= 0x00000008; + onChanged(); + } + if (other.transportType_ != 0) { + setTransportTypeValue(other.getTransportTypeValue()); + } + this.mergeUnknownFields(other.getUnknownFields()); + onChanged(); + return this; + } + + @java.lang.Override + public final boolean isInitialized() { + return true; + } + + @java.lang.Override + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + if (extensionRegistry == null) { + throw new java.lang.NullPointerException(); + } + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + case 8: + { + googleFrontendId_ = input.readInt64(); + bitField0_ |= 0x00000001; + break; + } // case 8 + case 16: + { + applicationFrontendId_ = input.readInt64(); + bitField0_ |= 0x00000002; + break; + } // case 16 + case 26: + { + applicationFrontendZone_ = input.readStringRequireUtf8(); + bitField0_ |= 0x00000004; + break; + } // case 26 + case 34: + { + applicationFrontendSubzone_ = input.readStringRequireUtf8(); + bitField0_ |= 0x00000008; + break; + } // case 34 + case 40: + { + transportType_ = input.readEnum(); + bitField0_ |= 0x00000010; + break; + } // case 40 + default: + { + if (!super.parseUnknownField(input, extensionRegistry, tag)) { + done = true; // was an endgroup tag + } + break; + } // default: + } // switch (tag) + } // while (!done) + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.unwrapIOException(); + } finally { + onChanged(); + } // finally + return this; + } + + private int bitField0_; + + private long googleFrontendId_; + + /** + * + * + *
+     * An opaque identifier for the Google Frontend which serviced this request.
+     * Only set when not using DirectAccess.
+     * 
+ * + * int64 google_frontend_id = 1; + * + * @return The googleFrontendId. + */ + @java.lang.Override + public long getGoogleFrontendId() { + return googleFrontendId_; + } + + /** + * + * + *
+     * An opaque identifier for the Google Frontend which serviced this request.
+     * Only set when not using DirectAccess.
+     * 
+ * + * int64 google_frontend_id = 1; + * + * @param value The googleFrontendId to set. + * @return This builder for chaining. + */ + public Builder setGoogleFrontendId(long value) { + + googleFrontendId_ = value; + bitField0_ |= 0x00000001; + onChanged(); + return this; + } + + /** + * + * + *
+     * An opaque identifier for the Google Frontend which serviced this request.
+     * Only set when not using DirectAccess.
+     * 
+ * + * int64 google_frontend_id = 1; + * + * @return This builder for chaining. + */ + public Builder clearGoogleFrontendId() { + bitField0_ = (bitField0_ & ~0x00000001); + googleFrontendId_ = 0L; + onChanged(); + return this; + } + + private long applicationFrontendId_; + + /** + * + * + *
+     * An opaque identifier for the application frontend which serviced this
+     * request.
+     * 
+ * + * int64 application_frontend_id = 2; + * + * @return The applicationFrontendId. + */ + @java.lang.Override + public long getApplicationFrontendId() { + return applicationFrontendId_; + } + + /** + * + * + *
+     * An opaque identifier for the application frontend which serviced this
+     * request.
+     * 
+ * + * int64 application_frontend_id = 2; + * + * @param value The applicationFrontendId to set. + * @return This builder for chaining. + */ + public Builder setApplicationFrontendId(long value) { + + applicationFrontendId_ = value; + bitField0_ |= 0x00000002; + onChanged(); + return this; + } + + /** + * + * + *
+     * An opaque identifier for the application frontend which serviced this
+     * request.
+     * 
+ * + * int64 application_frontend_id = 2; + * + * @return This builder for chaining. + */ + public Builder clearApplicationFrontendId() { + bitField0_ = (bitField0_ & ~0x00000002); + applicationFrontendId_ = 0L; + onChanged(); + return this; + } + + private java.lang.Object applicationFrontendZone_ = ""; + + /** + * + * + *
+     * The Cloud zone of the application frontend that served this request.
+     * 
+ * + * string application_frontend_zone = 3; + * + * @return The applicationFrontendZone. + */ + public java.lang.String getApplicationFrontendZone() { + java.lang.Object ref = applicationFrontendZone_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + applicationFrontendZone_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + + /** + * + * + *
+     * The Cloud zone of the application frontend that served this request.
+     * 
+ * + * string application_frontend_zone = 3; + * + * @return The bytes for applicationFrontendZone. + */ + public com.google.protobuf.ByteString getApplicationFrontendZoneBytes() { + java.lang.Object ref = applicationFrontendZone_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref); + applicationFrontendZone_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + /** + * + * + *
+     * The Cloud zone of the application frontend that served this request.
+     * 
+ * + * string application_frontend_zone = 3; + * + * @param value The applicationFrontendZone to set. + * @return This builder for chaining. + */ + public Builder setApplicationFrontendZone(java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + applicationFrontendZone_ = value; + bitField0_ |= 0x00000004; + onChanged(); + return this; + } + + /** + * + * + *
+     * The Cloud zone of the application frontend that served this request.
+     * 
+ * + * string application_frontend_zone = 3; + * + * @return This builder for chaining. + */ + public Builder clearApplicationFrontendZone() { + applicationFrontendZone_ = getDefaultInstance().getApplicationFrontendZone(); + bitField0_ = (bitField0_ & ~0x00000004); + onChanged(); + return this; + } + + /** + * + * + *
+     * The Cloud zone of the application frontend that served this request.
+     * 
+ * + * string application_frontend_zone = 3; + * + * @param value The bytes for applicationFrontendZone to set. + * @return This builder for chaining. + */ + public Builder setApplicationFrontendZoneBytes(com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + checkByteStringIsUtf8(value); + applicationFrontendZone_ = value; + bitField0_ |= 0x00000004; + onChanged(); + return this; + } + + private java.lang.Object applicationFrontendSubzone_ = ""; + + /** + * + * + *
+     * The subzone of the application frontend that served this request, e.g. an
+     * identifier for where within the zone the application frontend is.
+     * 
+ * + * string application_frontend_subzone = 4; + * + * @return The applicationFrontendSubzone. + */ + public java.lang.String getApplicationFrontendSubzone() { + java.lang.Object ref = applicationFrontendSubzone_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + applicationFrontendSubzone_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + + /** + * + * + *
+     * The subzone of the application frontend that served this request, e.g. an
+     * identifier for where within the zone the application frontend is.
+     * 
+ * + * string application_frontend_subzone = 4; + * + * @return The bytes for applicationFrontendSubzone. + */ + public com.google.protobuf.ByteString getApplicationFrontendSubzoneBytes() { + java.lang.Object ref = applicationFrontendSubzone_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8((java.lang.String) ref); + applicationFrontendSubzone_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + /** + * + * + *
+     * The subzone of the application frontend that served this request, e.g. an
+     * identifier for where within the zone the application frontend is.
+     * 
+ * + * string application_frontend_subzone = 4; + * + * @param value The applicationFrontendSubzone to set. + * @return This builder for chaining. + */ + public Builder setApplicationFrontendSubzone(java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + applicationFrontendSubzone_ = value; + bitField0_ |= 0x00000008; + onChanged(); + return this; + } + + /** + * + * + *
+     * The subzone of the application frontend that served this request, e.g. an
+     * identifier for where within the zone the application frontend is.
+     * 
+ * + * string application_frontend_subzone = 4; + * + * @return This builder for chaining. + */ + public Builder clearApplicationFrontendSubzone() { + applicationFrontendSubzone_ = getDefaultInstance().getApplicationFrontendSubzone(); + bitField0_ = (bitField0_ & ~0x00000008); + onChanged(); + return this; + } + + /** + * + * + *
+     * The subzone of the application frontend that served this request, e.g. an
+     * identifier for where within the zone the application frontend is.
+     * 
+ * + * string application_frontend_subzone = 4; + * + * @param value The bytes for applicationFrontendSubzone to set. + * @return This builder for chaining. + */ + public Builder setApplicationFrontendSubzoneBytes(com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + checkByteStringIsUtf8(value); + applicationFrontendSubzone_ = value; + bitField0_ |= 0x00000008; + onChanged(); + return this; + } + + private int transportType_ = 0; + + /** + * .google.bigtable.v2.PeerInfo.TransportType transport_type = 5; + * + * @return The enum numeric value on the wire for transportType. + */ + @java.lang.Override + public int getTransportTypeValue() { + return transportType_; + } + + /** + * .google.bigtable.v2.PeerInfo.TransportType transport_type = 5; + * + * @param value The enum numeric value on the wire for transportType to set. + * @return This builder for chaining. + */ + public Builder setTransportTypeValue(int value) { + transportType_ = value; + bitField0_ |= 0x00000010; + onChanged(); + return this; + } + + /** + * .google.bigtable.v2.PeerInfo.TransportType transport_type = 5; + * + * @return The transportType. + */ + @java.lang.Override + public com.google.bigtable.v2.PeerInfo.TransportType getTransportType() { + com.google.bigtable.v2.PeerInfo.TransportType result = + com.google.bigtable.v2.PeerInfo.TransportType.forNumber(transportType_); + return result == null ? com.google.bigtable.v2.PeerInfo.TransportType.UNRECOGNIZED : result; + } + + /** + * .google.bigtable.v2.PeerInfo.TransportType transport_type = 5; + * + * @param value The transportType to set. + * @return This builder for chaining. + */ + public Builder setTransportType(com.google.bigtable.v2.PeerInfo.TransportType value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000010; + transportType_ = value.getNumber(); + onChanged(); + return this; + } + + /** + * .google.bigtable.v2.PeerInfo.TransportType transport_type = 5; + * + * @return This builder for chaining. + */ + public Builder clearTransportType() { + bitField0_ = (bitField0_ & ~0x00000010); + transportType_ = 0; + onChanged(); + return this; + } + + @java.lang.Override + public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.setUnknownFields(unknownFields); + } + + @java.lang.Override + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return super.mergeUnknownFields(unknownFields); + } + + // @@protoc_insertion_point(builder_scope:google.bigtable.v2.PeerInfo) + } + + // @@protoc_insertion_point(class_scope:google.bigtable.v2.PeerInfo) + private static final com.google.bigtable.v2.PeerInfo DEFAULT_INSTANCE; + + static { + DEFAULT_INSTANCE = new com.google.bigtable.v2.PeerInfo(); + } + + public static com.google.bigtable.v2.PeerInfo getDefaultInstance() { + return DEFAULT_INSTANCE; + } + + private static final com.google.protobuf.Parser PARSER = + new com.google.protobuf.AbstractParser() { + @java.lang.Override + public PeerInfo parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + Builder builder = newBuilder(); + try { + builder.mergeFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(builder.buildPartial()); + } catch (com.google.protobuf.UninitializedMessageException e) { + throw e.asInvalidProtocolBufferException().setUnfinishedMessage(builder.buildPartial()); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException(e) + .setUnfinishedMessage(builder.buildPartial()); + } + return builder.buildPartial(); + } + }; + + public static com.google.protobuf.Parser parser() { + return PARSER; + } + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + @java.lang.Override + public com.google.bigtable.v2.PeerInfo getDefaultInstanceForType() { + return DEFAULT_INSTANCE; + } +} diff --git a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/PeerInfoOrBuilder.java b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/PeerInfoOrBuilder.java new file mode 100644 index 0000000000..b3eebfd0cc --- /dev/null +++ b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/PeerInfoOrBuilder.java @@ -0,0 +1,122 @@ +/* + * Copyright 2025 Google LLC + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: google/bigtable/v2/peer_info.proto + +// Protobuf Java Version: 3.25.8 +package com.google.bigtable.v2; + +public interface PeerInfoOrBuilder + extends + // @@protoc_insertion_point(interface_extends:google.bigtable.v2.PeerInfo) + com.google.protobuf.MessageOrBuilder { + + /** + * + * + *
+   * An opaque identifier for the Google Frontend which serviced this request.
+   * Only set when not using DirectAccess.
+   * 
+ * + * int64 google_frontend_id = 1; + * + * @return The googleFrontendId. + */ + long getGoogleFrontendId(); + + /** + * + * + *
+   * An opaque identifier for the application frontend which serviced this
+   * request.
+   * 
+ * + * int64 application_frontend_id = 2; + * + * @return The applicationFrontendId. + */ + long getApplicationFrontendId(); + + /** + * + * + *
+   * The Cloud zone of the application frontend that served this request.
+   * 
+ * + * string application_frontend_zone = 3; + * + * @return The applicationFrontendZone. + */ + java.lang.String getApplicationFrontendZone(); + + /** + * + * + *
+   * The Cloud zone of the application frontend that served this request.
+   * 
+ * + * string application_frontend_zone = 3; + * + * @return The bytes for applicationFrontendZone. + */ + com.google.protobuf.ByteString getApplicationFrontendZoneBytes(); + + /** + * + * + *
+   * The subzone of the application frontend that served this request, e.g. an
+   * identifier for where within the zone the application frontend is.
+   * 
+ * + * string application_frontend_subzone = 4; + * + * @return The applicationFrontendSubzone. + */ + java.lang.String getApplicationFrontendSubzone(); + + /** + * + * + *
+   * The subzone of the application frontend that served this request, e.g. an
+   * identifier for where within the zone the application frontend is.
+   * 
+ * + * string application_frontend_subzone = 4; + * + * @return The bytes for applicationFrontendSubzone. + */ + com.google.protobuf.ByteString getApplicationFrontendSubzoneBytes(); + + /** + * .google.bigtable.v2.PeerInfo.TransportType transport_type = 5; + * + * @return The enum numeric value on the wire for transportType. + */ + int getTransportTypeValue(); + + /** + * .google.bigtable.v2.PeerInfo.TransportType transport_type = 5; + * + * @return The transportType. + */ + com.google.bigtable.v2.PeerInfo.TransportType getTransportType(); +} diff --git a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/PeerInfoProto.java b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/PeerInfoProto.java new file mode 100644 index 0000000000..3866bedb8a --- /dev/null +++ b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/PeerInfoProto.java @@ -0,0 +1,82 @@ +/* + * Copyright 2025 Google LLC + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +// Generated by the protocol buffer compiler. DO NOT EDIT! +// source: google/bigtable/v2/peer_info.proto + +// Protobuf Java Version: 3.25.8 +package com.google.bigtable.v2; + +public final class PeerInfoProto { + private PeerInfoProto() {} + + public static void registerAllExtensions(com.google.protobuf.ExtensionRegistryLite registry) {} + + public static void registerAllExtensions(com.google.protobuf.ExtensionRegistry registry) { + registerAllExtensions((com.google.protobuf.ExtensionRegistryLite) registry); + } + + static final com.google.protobuf.Descriptors.Descriptor + internal_static_google_bigtable_v2_PeerInfo_descriptor; + static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_google_bigtable_v2_PeerInfo_fieldAccessorTable; + + public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + return descriptor; + } + + private static com.google.protobuf.Descriptors.FileDescriptor descriptor; + + static { + java.lang.String[] descriptorData = { + "\n\"google/bigtable/v2/peer_info.proto\022\022go" + + "ogle.bigtable.v2\"\372\003\n\010PeerInfo\022\032\n\022google_" + + "frontend_id\030\001 \001(\003\022\037\n\027application_fronten" + + "d_id\030\002 \001(\003\022!\n\031application_frontend_zone\030" + + "\003 \001(\t\022$\n\034application_frontend_subzone\030\004 " + + "\001(\t\022B\n\016transport_type\030\005 \001(\0162*.google.big" + + "table.v2.PeerInfo.TransportType\"\243\002\n\rTran" + + "sportType\022\032\n\026TRANSPORT_TYPE_UNKNOWN\020\000\022\033\n" + + "\027TRANSPORT_TYPE_EXTERNAL\020\001\022\035\n\031TRANSPORT_" + + "TYPE_CLOUD_PATH\020\002\022 \n\034TRANSPORT_TYPE_DIRE" + + "CT_ACCESS\020\003\022\"\n\036TRANSPORT_TYPE_SESSION_UN" + + "KNOWN\020\004\022#\n\037TRANSPORT_TYPE_SESSION_EXTERN" + + "AL\020\005\022%\n!TRANSPORT_TYPE_SESSION_CLOUD_PAT" + + "H\020\006\022(\n$TRANSPORT_TYPE_SESSION_DIRECT_ACC" + + "ESS\020\007B\267\001\n\026com.google.bigtable.v2B\rPeerIn" + + "foProtoP\001Z8cloud.google.com/go/bigtable/" + + "apiv2/bigtablepb;bigtablepb\252\002\030Google.Clo" + + "ud.Bigtable.V2\312\002\030Google\\Cloud\\Bigtable\\V" + + "2\352\002\033Google::Cloud::Bigtable::V2b\006proto3" + }; + descriptor = + com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom( + descriptorData, new com.google.protobuf.Descriptors.FileDescriptor[] {}); + internal_static_google_bigtable_v2_PeerInfo_descriptor = + getDescriptor().getMessageTypes().get(0); + internal_static_google_bigtable_v2_PeerInfo_fieldAccessorTable = + new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_google_bigtable_v2_PeerInfo_descriptor, + new java.lang.String[] { + "GoogleFrontendId", + "ApplicationFrontendId", + "ApplicationFrontendZone", + "ApplicationFrontendSubzone", + "TransportType", + }); + } + + // @@protoc_insertion_point(outer_class_scope) +} diff --git a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/ResponseParams.java b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/ResponseParams.java index 6be8cc99ae..a02082f4e3 100644 --- a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/ResponseParams.java +++ b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/ResponseParams.java @@ -207,6 +207,41 @@ public com.google.protobuf.ByteString getClusterIdBytes() { } } + public static final int AFE_ID_FIELD_NUMBER = 3; + private long afeId_ = 0L; + + /** + * + * + *
+   * The AFE ID for the AFE that is served this request.
+   * 
+ * + * optional int64 afe_id = 3; + * + * @return Whether the afeId field is set. + */ + @java.lang.Override + public boolean hasAfeId() { + return ((bitField0_ & 0x00000004) != 0); + } + + /** + * + * + *
+   * The AFE ID for the AFE that is served this request.
+   * 
+ * + * optional int64 afe_id = 3; + * + * @return The afeId. + */ + @java.lang.Override + public long getAfeId() { + return afeId_; + } + private byte memoizedIsInitialized = -1; @java.lang.Override @@ -227,6 +262,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io if (((bitField0_ & 0x00000002) != 0)) { com.google.protobuf.GeneratedMessageV3.writeString(output, 2, clusterId_); } + if (((bitField0_ & 0x00000004) != 0)) { + output.writeInt64(3, afeId_); + } getUnknownFields().writeTo(output); } @@ -242,6 +280,9 @@ public int getSerializedSize() { if (((bitField0_ & 0x00000002) != 0)) { size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, clusterId_); } + if (((bitField0_ & 0x00000004) != 0)) { + size += com.google.protobuf.CodedOutputStream.computeInt64Size(3, afeId_); + } size += getUnknownFields().getSerializedSize(); memoizedSize = size; return size; @@ -265,6 +306,10 @@ public boolean equals(final java.lang.Object obj) { if (hasClusterId()) { if (!getClusterId().equals(other.getClusterId())) return false; } + if (hasAfeId() != other.hasAfeId()) return false; + if (hasAfeId()) { + if (getAfeId() != other.getAfeId()) return false; + } if (!getUnknownFields().equals(other.getUnknownFields())) return false; return true; } @@ -284,6 +329,10 @@ public int hashCode() { hash = (37 * hash) + CLUSTER_ID_FIELD_NUMBER; hash = (53 * hash) + getClusterId().hashCode(); } + if (hasAfeId()) { + hash = (37 * hash) + AFE_ID_FIELD_NUMBER; + hash = (53 * hash) + com.google.protobuf.Internal.hashLong(getAfeId()); + } hash = (29 * hash) + getUnknownFields().hashCode(); memoizedHashCode = hash; return hash; @@ -425,6 +474,7 @@ public Builder clear() { bitField0_ = 0; zoneId_ = ""; clusterId_ = ""; + afeId_ = 0L; return this; } @@ -470,6 +520,10 @@ private void buildPartial0(com.google.bigtable.v2.ResponseParams result) { result.clusterId_ = clusterId_; to_bitField0_ |= 0x00000002; } + if (((from_bitField0_ & 0x00000004) != 0)) { + result.afeId_ = afeId_; + to_bitField0_ |= 0x00000004; + } result.bitField0_ |= to_bitField0_; } @@ -528,6 +582,9 @@ public Builder mergeFrom(com.google.bigtable.v2.ResponseParams other) { bitField0_ |= 0x00000002; onChanged(); } + if (other.hasAfeId()) { + setAfeId(other.getAfeId()); + } this.mergeUnknownFields(other.getUnknownFields()); onChanged(); return this; @@ -566,6 +623,12 @@ public Builder mergeFrom( bitField0_ |= 0x00000002; break; } // case 18 + case 24: + { + afeId_ = input.readInt64(); + bitField0_ |= 0x00000004; + break; + } // case 24 default: { if (!super.parseUnknownField(input, extensionRegistry, tag)) { @@ -843,6 +906,78 @@ public Builder setClusterIdBytes(com.google.protobuf.ByteString value) { return this; } + private long afeId_; + + /** + * + * + *
+     * The AFE ID for the AFE that is served this request.
+     * 
+ * + * optional int64 afe_id = 3; + * + * @return Whether the afeId field is set. + */ + @java.lang.Override + public boolean hasAfeId() { + return ((bitField0_ & 0x00000004) != 0); + } + + /** + * + * + *
+     * The AFE ID for the AFE that is served this request.
+     * 
+ * + * optional int64 afe_id = 3; + * + * @return The afeId. + */ + @java.lang.Override + public long getAfeId() { + return afeId_; + } + + /** + * + * + *
+     * The AFE ID for the AFE that is served this request.
+     * 
+ * + * optional int64 afe_id = 3; + * + * @param value The afeId to set. + * @return This builder for chaining. + */ + public Builder setAfeId(long value) { + + afeId_ = value; + bitField0_ |= 0x00000004; + onChanged(); + return this; + } + + /** + * + * + *
+     * The AFE ID for the AFE that is served this request.
+     * 
+ * + * optional int64 afe_id = 3; + * + * @return This builder for chaining. + */ + public Builder clearAfeId() { + bitField0_ = (bitField0_ & ~0x00000004); + afeId_ = 0L; + onChanged(); + return this; + } + @java.lang.Override public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) { return super.setUnknownFields(unknownFields); diff --git a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/ResponseParamsOrBuilder.java b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/ResponseParamsOrBuilder.java index c2d417434b..93250bd24f 100644 --- a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/ResponseParamsOrBuilder.java +++ b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/ResponseParamsOrBuilder.java @@ -104,4 +104,30 @@ public interface ResponseParamsOrBuilder * @return The bytes for clusterId. */ com.google.protobuf.ByteString getClusterIdBytes(); + + /** + * + * + *
+   * The AFE ID for the AFE that is served this request.
+   * 
+ * + * optional int64 afe_id = 3; + * + * @return Whether the afeId field is set. + */ + boolean hasAfeId(); + + /** + * + * + *
+   * The AFE ID for the AFE that is served this request.
+   * 
+ * + * optional int64 afe_id = 3; + * + * @return The afeId. + */ + long getAfeId(); } diff --git a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/ResponseParamsProto.java b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/ResponseParamsProto.java index bd29d773f8..8b710c3c37 100644 --- a/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/ResponseParamsProto.java +++ b/proto-google-cloud-bigtable-v2/src/main/java/com/google/bigtable/v2/ResponseParamsProto.java @@ -42,17 +42,19 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { static { java.lang.String[] descriptorData = { "\n" - + "(google/bigtable/v2/response_params.proto\022\022google.bigtable.v2\"Z\n" + + "(google/bigtable/v2/response_params.proto\022\022google.bigtable.v2\"z\n" + "\016ResponseParams\022\024\n" + "\007zone_id\030\001 \001(\tH\000\210\001\001\022\027\n\n" - + "cluster_id\030\002 \001(\tH\001\210\001\001B\n\n" + + "cluster_id\030\002 \001(\tH\001\210\001\001\022\023\n" + + "\006afe_id\030\003 \001(\003H\002\210\001\001B\n\n" + "\010_zone_idB\r\n" - + "\013_cluster_idB\275\001\n" - + "\026com.google.bigtable.v2B\023ResponseParamsPro" - + "toP\001Z8cloud.google.com/go/bigtable/apiv2" - + "/bigtablepb;bigtablepb\252\002\030Google.Cloud.Bi" - + "gtable.V2\312\002\030Google\\Cloud\\Bigtable\\V2\352\002\033G" - + "oogle::Cloud::Bigtable::V2b\006proto3" + + "\013_cluster_idB\t\n" + + "\007_afe_idB\275\001\n" + + "\026com.google.bigtable.v2B\023ResponseParamsProtoP\001Z8cl" + + "oud.google.com/go/bigtable/apiv2/bigtabl" + + "epb;bigtablepb\252\002\030Google.Cloud.Bigtable.V" + + "2\312\002\030Google\\Cloud\\Bigtable\\V2\352\002\033Google::C" + + "loud::Bigtable::V2b\006proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom( @@ -63,7 +65,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_google_bigtable_v2_ResponseParams_descriptor, new java.lang.String[] { - "ZoneId", "ClusterId", + "ZoneId", "ClusterId", "AfeId", }); } diff --git a/proto-google-cloud-bigtable-v2/src/main/proto/google/bigtable/v2/feature_flags.proto b/proto-google-cloud-bigtable-v2/src/main/proto/google/bigtable/v2/feature_flags.proto index 3dfd360558..9bf078e6e8 100644 --- a/proto-google-cloud-bigtable-v2/src/main/proto/google/bigtable/v2/feature_flags.proto +++ b/proto-google-cloud-bigtable-v2/src/main/proto/google/bigtable/v2/feature_flags.proto @@ -67,4 +67,7 @@ message FeatureFlags { // Notify the server that the client explicitly opted in for Direct Access. bool direct_access_requested = 10; + + // If the client can support using BigtablePeerInfo. + bool peer_info = 11; } diff --git a/proto-google-cloud-bigtable-v2/src/main/proto/google/bigtable/v2/peer_info.proto b/proto-google-cloud-bigtable-v2/src/main/proto/google/bigtable/v2/peer_info.proto new file mode 100644 index 0000000000..357af8216b --- /dev/null +++ b/proto-google-cloud-bigtable-v2/src/main/proto/google/bigtable/v2/peer_info.proto @@ -0,0 +1,77 @@ +// Copyright 2025 Google LLC +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +syntax = "proto3"; + +package google.bigtable.v2; + +option csharp_namespace = "Google.Cloud.Bigtable.V2"; +option go_package = "cloud.google.com/go/bigtable/apiv2/bigtablepb;bigtablepb"; +option java_multiple_files = true; +option java_outer_classname = "PeerInfoProto"; +option java_package = "com.google.bigtable.v2"; +option php_namespace = "Google\\Cloud\\Bigtable\\V2"; +option ruby_package = "Google::Cloud::Bigtable::V2"; + +// PeerInfo contains information about the peer that the client is +// connecting to. +message PeerInfo { + // The transport type that the client used to connect to this peer. + enum TransportType { + // The transport type is unknown. + TRANSPORT_TYPE_UNKNOWN = 0; + + // The client connected to this peer via an external network + // (e.g. outside Google Coud). + TRANSPORT_TYPE_EXTERNAL = 1; + + // The client connected to this peer via CloudPath. + TRANSPORT_TYPE_CLOUD_PATH = 2; + + // The client connected to this peer via DirectAccess. + TRANSPORT_TYPE_DIRECT_ACCESS = 3; + + // The client connected to this peer via Bigtable Sessions using an unknown + // transport type. + TRANSPORT_TYPE_SESSION_UNKNOWN = 4; + + // The client connected to this peer via Bigtable Sessions on an external + // network (e.g. outside Google Cloud). + TRANSPORT_TYPE_SESSION_EXTERNAL = 5; + + // The client connected to this peer via Bigtable Sessions using CloudPath. + TRANSPORT_TYPE_SESSION_CLOUD_PATH = 6; + + // The client connected to this peer via Bigtable Sessions using + // DirectAccess. + TRANSPORT_TYPE_SESSION_DIRECT_ACCESS = 7; + } + + // An opaque identifier for the Google Frontend which serviced this request. + // Only set when not using DirectAccess. + int64 google_frontend_id = 1; + + // An opaque identifier for the application frontend which serviced this + // request. + int64 application_frontend_id = 2; + + // The Cloud zone of the application frontend that served this request. + string application_frontend_zone = 3; + + // The subzone of the application frontend that served this request, e.g. an + // identifier for where within the zone the application frontend is. + string application_frontend_subzone = 4; + + TransportType transport_type = 5; +} diff --git a/proto-google-cloud-bigtable-v2/src/main/proto/google/bigtable/v2/response_params.proto b/proto-google-cloud-bigtable-v2/src/main/proto/google/bigtable/v2/response_params.proto index 076ddbd1bd..6eedfdf735 100644 --- a/proto-google-cloud-bigtable-v2/src/main/proto/google/bigtable/v2/response_params.proto +++ b/proto-google-cloud-bigtable-v2/src/main/proto/google/bigtable/v2/response_params.proto @@ -32,4 +32,7 @@ message ResponseParams { // Identifier for a cluster that represents set of // bigtable resources. optional string cluster_id = 2; + + // The AFE ID for the AFE that is served this request. + optional int64 afe_id = 3; } diff --git a/samples/install-without-bom/pom.xml b/samples/install-without-bom/pom.xml index a1637b3c6b..3abc0a6617 100644 --- a/samples/install-without-bom/pom.xml +++ b/samples/install-without-bom/pom.xml @@ -14,7 +14,7 @@ com.google.cloud.samples shared-configuration - 1.2.0 + 1.2.2 diff --git a/samples/pom.xml b/samples/pom.xml index 785a96f581..624ab90266 100644 --- a/samples/pom.xml +++ b/samples/pom.xml @@ -18,7 +18,7 @@ com.google.cloud.samples shared-configuration - 1.2.0 + 1.2.2 @@ -38,7 +38,7 @@ org.apache.maven.plugins maven-deploy-plugin - 3.1.3 + 3.1.4 true diff --git a/samples/snapshot/pom.xml b/samples/snapshot/pom.xml index f700183283..67a4886439 100644 --- a/samples/snapshot/pom.xml +++ b/samples/snapshot/pom.xml @@ -14,7 +14,7 @@ com.google.cloud.samples shared-configuration - 1.2.0 + 1.2.2 @@ -28,7 +28,7 @@ com.google.cloud google-cloud-bigtable - 2.69.0 + 2.70.0 diff --git a/samples/snippets/pom.xml b/samples/snippets/pom.xml index 83938c31f3..41b35ec41d 100644 --- a/samples/snippets/pom.xml +++ b/samples/snippets/pom.xml @@ -16,7 +16,7 @@ com.google.cloud.samples shared-configuration - 1.2.0 + 1.2.2 diff --git a/test-proxy/pom.xml b/test-proxy/pom.xml index 28dbae19a8..41c9934ee3 100644 --- a/test-proxy/pom.xml +++ b/test-proxy/pom.xml @@ -12,11 +12,11 @@ google-cloud-bigtable-parent com.google.cloud - 2.69.0 + 2.70.0 - 2.69.0 + 2.70.0 diff --git a/versions.txt b/versions.txt index cf92827dfc..6504a55414 100644 --- a/versions.txt +++ b/versions.txt @@ -1,10 +1,10 @@ # Format: # module:released-version:current-version -google-cloud-bigtable:2.69.0:2.69.0 -grpc-google-cloud-bigtable-admin-v2:2.69.0:2.69.0 -grpc-google-cloud-bigtable-v2:2.69.0:2.69.0 -proto-google-cloud-bigtable-admin-v2:2.69.0:2.69.0 -proto-google-cloud-bigtable-v2:2.69.0:2.69.0 -google-cloud-bigtable-emulator:0.206.0:0.206.0 -google-cloud-bigtable-emulator-core:0.206.0:0.206.0 +google-cloud-bigtable:2.70.0:2.70.0 +grpc-google-cloud-bigtable-admin-v2:2.70.0:2.70.0 +grpc-google-cloud-bigtable-v2:2.70.0:2.70.0 +proto-google-cloud-bigtable-admin-v2:2.70.0:2.70.0 +proto-google-cloud-bigtable-v2:2.70.0:2.70.0 +google-cloud-bigtable-emulator:0.207.0:0.207.0 +google-cloud-bigtable-emulator-core:0.207.0:0.207.0