feat: Publish new fields to support cluster group routing for Cloud B…

…igtable (#407) * feat: Publish new fields to support cluster group routing for Cloud Bigtable Committer: @garye PiperOrigin-RevId: 391576441 Source-Link: googleapis/googleapis@5f76113 Source-Link: googleapis/googleapis-gen@e01b342 * 🦉 Updates from OwlBot See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
googleapis · Aug 18, 2021 · 66af554 · 66af554
1 parent 32f2486
commit 66af554
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 3 deletions.
diff --git a/google/cloud/bigtable_admin_v2/types/instance.py b/google/cloud/bigtable_admin_v2/types/instance.py
@@ -181,7 +181,16 @@ class MultiClusterRoutingUseAny(proto.Message):
         available in the event of transient errors or delays. Clusters
         in a region are considered equidistant. Choosing this option
         sacrifices read-your-writes consistency to improve availability.
-            """
+
+        Attributes:
+            cluster_ids (Sequence[str]):
+                The set of clusters to route to. The order is
+                ignored; clusters will be tried in order of
+                distance. If left empty, all clusters are
+                eligible.
+        """
+
+        cluster_ids = proto.RepeatedField(proto.STRING, number=1,)
 
     class SingleClusterRouting(proto.Message):
         r"""Unconditionally routes all read/write requests to a specific

diff --git a/tests/unit/gapic/bigtable_admin_v2/test_bigtable_instance_admin.py b/tests/unit/gapic/bigtable_admin_v2/test_bigtable_instance_admin.py
@@ -2816,7 +2816,9 @@ def test_create_app_profile(
             name="name_value",
             etag="etag_value",
             description="description_value",
-            multi_cluster_routing_use_any=None,
+            multi_cluster_routing_use_any=instance.AppProfile.MultiClusterRoutingUseAny(
+                cluster_ids=["cluster_ids_value"]
+            ),
         )
         response = client.create_app_profile(request)
 
@@ -3062,7 +3064,9 @@ def test_get_app_profile(
             name="name_value",
             etag="etag_value",
             description="description_value",
-            multi_cluster_routing_use_any=None,
+            multi_cluster_routing_use_any=instance.AppProfile.MultiClusterRoutingUseAny(
+                cluster_ids=["cluster_ids_value"]
+            ),
         )
         response = client.get_app_profile(request)