diff --git a/.github/workflows/hermetic_library_generation.yaml b/.github/workflows/hermetic_library_generation.yaml index a1d9c6a9f2a0..31a38fbb06be 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/README.md b/README.md index 1e14178a732a..a6a52e055172 100644 --- a/README.md +++ b/README.md @@ -49,7 +49,7 @@ 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' ``` diff --git a/generation_config.yaml b/generation_config.yaml index d93e85c00b35..b598b536ac2c 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/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 1839c46c169a..7b14a32b6c12 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/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 c3602811f0e3..2db73a95f7b6 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 99ae3a885809..93456ac0fa8d 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/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 b348a2aed45c..cc9a36a7bfeb 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, com.google.bigtable.v2.ReadRowsRespons * */ 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, com.google.bigtable.v2.MutateRowsRespo * */ 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/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 052f8af13766..92a7f74a4335 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 676595663334..139f4d597a03 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 8cc32dba0af0..0e3f735d0583 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 000000000000..068d1b9f55cc
--- /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+ * 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
+ * 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+ * 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 000000000000..3866bedb8a9d
--- /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 6be8cc99ae3b..a02082f4e3d3 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 c2d417434bdf..93250bd24faf 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 bd29d773f87d..8b710c3c37b2 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 3dfd36055820..9bf078e6e86e 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 000000000000..357af8216baa
--- /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 076ddbd1bdf0..6eedfdf735dc 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;
}