chore: librarian generate pull request: 20251007T120850Z

packages/google-cloud-alloydb/google/cloud/alloydb_v1/services/alloy_db_admin/async_client.py

@@ -91,6 +91,8 @@ class AlloyDBAdminAsyncClient:
     parse_connection_info_path = staticmethod(
         AlloyDBAdminClient.parse_connection_info_path
     )
+    crypto_key_path = staticmethod(AlloyDBAdminClient.crypto_key_path)
+    parse_crypto_key_path = staticmethod(AlloyDBAdminClient.parse_crypto_key_path)
     crypto_key_version_path = staticmethod(AlloyDBAdminClient.crypto_key_version_path)
     parse_crypto_key_version_path = staticmethod(
         AlloyDBAdminClient.parse_crypto_key_version_path
@@ -101,6 +103,10 @@ class AlloyDBAdminAsyncClient:
     parse_instance_path = staticmethod(AlloyDBAdminClient.parse_instance_path)
     network_path = staticmethod(AlloyDBAdminClient.network_path)
     parse_network_path = staticmethod(AlloyDBAdminClient.parse_network_path)
+    service_attachment_path = staticmethod(AlloyDBAdminClient.service_attachment_path)
+    parse_service_attachment_path = staticmethod(
+        AlloyDBAdminClient.parse_service_attachment_path
+    )
     supported_database_flag_path = staticmethod(
         AlloyDBAdminClient.supported_database_flag_path
     )
@@ -1243,7 +1249,7 @@ async def sample_upgrade_cluster():
                 # Initialize request argument(s)
                 request = alloydb_v1.UpgradeClusterRequest(
                     name="name_value",
-                    version="POSTGRES_16",
+                    version="POSTGRES_17",
                 )
 
                 # Make the request
@@ -5142,8 +5148,7 @@ async def sample_list_databases():
 
         Args:
             request (Optional[Union[google.cloud.alloydb_v1.types.ListDatabasesRequest, dict]]):
-                The request object. Message for requesting list of
-                Databases.
+                The request object. Message for ListDatabases request.
             parent (:class:`str`):
                 Required. Parent value for
                 ListDatabasesRequest.
@@ -5161,8 +5166,8 @@ async def sample_list_databases():
 
         Returns:
             google.cloud.alloydb_v1.services.alloy_db_admin.pagers.ListDatabasesAsyncPager:
-                Message for response to listing
-                Databases.
+                Message for ListDatabases response.
+
                 Iterating over this object will yield
                 results and resolve additional pages
                 automatically.

packages/google-cloud-alloydb/google/cloud/alloydb_v1/services/alloy_db_admin/client.py

@@ -272,6 +272,30 @@ def parse_connection_info_path(path: str) -> Dict[str, str]:
         )
         return m.groupdict() if m else {}
 
+    @staticmethod
+    def crypto_key_path(
+        project: str,
+        location: str,
+        key_ring: str,
+        crypto_key: str,
+    ) -> str:
+        """Returns a fully-qualified crypto_key string."""
+        return "projects/{project}/locations/{location}/keyRings/{key_ring}/cryptoKeys/{crypto_key}".format(
+            project=project,
+            location=location,
+            key_ring=key_ring,
+            crypto_key=crypto_key,
+        )
+
+    @staticmethod
+    def parse_crypto_key_path(path: str) -> Dict[str, str]:
+        """Parses a crypto_key path into its component segments."""
+        m = re.match(
+            r"^projects/(?P<project>.+?)/locations/(?P<location>.+?)/keyRings/(?P<key_ring>.+?)/cryptoKeys/(?P<crypto_key>.+?)$",
+            path,
+        )
+        return m.groupdict() if m else {}
+
     @staticmethod
     def crypto_key_version_path(
         project: str,
@@ -365,6 +389,28 @@ def parse_network_path(path: str) -> Dict[str, str]:
         )
         return m.groupdict() if m else {}
 
+    @staticmethod
+    def service_attachment_path(
+        project: str,
+        region: str,
+        service_attachment: str,
+    ) -> str:
+        """Returns a fully-qualified service_attachment string."""
+        return "projects/{project}/regions/{region}/serviceAttachments/{service_attachment}".format(
+            project=project,
+            region=region,
+            service_attachment=service_attachment,
+        )
+
+    @staticmethod
+    def parse_service_attachment_path(path: str) -> Dict[str, str]:
+        """Parses a service_attachment path into its component segments."""
+        m = re.match(
+            r"^projects/(?P<project>.+?)/regions/(?P<region>.+?)/serviceAttachments/(?P<service_attachment>.+?)$",
+            path,
+        )
+        return m.groupdict() if m else {}
+
     @staticmethod
     def supported_database_flag_path(
         project: str,
@@ -1808,7 +1854,7 @@ def sample_upgrade_cluster():
                 # Initialize request argument(s)
                 request = alloydb_v1.UpgradeClusterRequest(
                     name="name_value",
-                    version="POSTGRES_16",
+                    version="POSTGRES_17",
                 )
 
                 # Make the request
@@ -5627,8 +5673,7 @@ def sample_list_databases():
 
         Args:
             request (Union[google.cloud.alloydb_v1.types.ListDatabasesRequest, dict]):
-                The request object. Message for requesting list of
-                Databases.
+                The request object. Message for ListDatabases request.
             parent (str):
                 Required. Parent value for
                 ListDatabasesRequest.
@@ -5646,8 +5691,8 @@ def sample_list_databases():
 
         Returns:
             google.cloud.alloydb_v1.services.alloy_db_admin.pagers.ListDatabasesPager:
-                Message for response to listing
-                Databases.
+                Message for ListDatabases response.
+
                 Iterating over this object will yield
                 results and resolve additional pages
                 automatically.

packages/google-cloud-alloydb/google/cloud/alloydb_v1/services/alloy_db_admin/transports/rest.py

@@ -5985,8 +5985,7 @@ def __call__(
 
             Args:
                 request (~.service.ListDatabasesRequest):
-                    The request object. Message for requesting list of
-                Databases.
+                    The request object. Message for ListDatabases request.
                 retry (google.api_core.retry.Retry): Designation of what errors, if any,
                     should be retried.
                 timeout (float): The timeout for this request.
@@ -5997,9 +5996,7 @@ def __call__(
 
             Returns:
                 ~.service.ListDatabasesResponse:
-                    Message for response to listing
-                Databases.
-
+                    Message for ListDatabases response.
             """
 
             http_options = (

packages/google-cloud-alloydb/google/cloud/alloydb_v1/services/alloy_dbcsql_admin/async_client.py

@@ -83,6 +83,8 @@ class AlloyDBCSQLAdminAsyncClient:
     parse_backup_path = staticmethod(AlloyDBCSQLAdminClient.parse_backup_path)
     cluster_path = staticmethod(AlloyDBCSQLAdminClient.cluster_path)
     parse_cluster_path = staticmethod(AlloyDBCSQLAdminClient.parse_cluster_path)
+    crypto_key_path = staticmethod(AlloyDBCSQLAdminClient.crypto_key_path)
+    parse_crypto_key_path = staticmethod(AlloyDBCSQLAdminClient.parse_crypto_key_path)
     crypto_key_version_path = staticmethod(
         AlloyDBCSQLAdminClient.crypto_key_version_path
     )

packages/google-cloud-alloydb/google/cloud/alloydb_v1/services/alloy_dbcsql_admin/client.py

@@ -246,6 +246,30 @@ def parse_cluster_path(path: str) -> Dict[str, str]:
         )
         return m.groupdict() if m else {}
 
+    @staticmethod
+    def crypto_key_path(
+        project: str,
+        location: str,
+        key_ring: str,
+        crypto_key: str,
+    ) -> str:
+        """Returns a fully-qualified crypto_key string."""
+        return "projects/{project}/locations/{location}/keyRings/{key_ring}/cryptoKeys/{crypto_key}".format(
+            project=project,
+            location=location,
+            key_ring=key_ring,
+            crypto_key=crypto_key,
+        )
+
+    @staticmethod
+    def parse_crypto_key_path(path: str) -> Dict[str, str]:
+        """Parses a crypto_key path into its component segments."""
+        m = re.match(
+            r"^projects/(?P<project>.+?)/locations/(?P<location>.+?)/keyRings/(?P<key_ring>.+?)/cryptoKeys/(?P<crypto_key>.+?)$",
+            path,
+        )
+        return m.groupdict() if m else {}
+
     @staticmethod
     def crypto_key_version_path(
         project: str,

packages/google-cloud-alloydb/google/cloud/alloydb_v1/types/resources.py

@@ -119,12 +119,15 @@ class DatabaseVersion(proto.Enum):
             The database version is Postgres 15.
         POSTGRES_16 (4):
             The database version is Postgres 16.
+        POSTGRES_17 (5):
+            The database version is Postgres 17.
     """
     DATABASE_VERSION_UNSPECIFIED = 0
     POSTGRES_13 = 1
     POSTGRES_14 = 2
     POSTGRES_15 = 3
     POSTGRES_16 = 4
+    POSTGRES_17 = 5
 
 
 class SubscriptionType(proto.Enum):
@@ -939,14 +942,9 @@ class State(proto.Enum):
             READY (1):
                 The cluster is active and running.
             STOPPED (2):
-                The cluster is stopped. All instances in the
-                cluster are stopped. Customers can start a
-                stopped cluster at any point and all their
-                instances will come back to life with same names
-                and IP resources. In this state, customer pays
-                for storage.
-                Associated backups could also be present in a
-                stopped cluster.
+                This is unused. Even when all instances in
+                the cluster are stopped, the cluster remains in
+                READY state.
             EMPTY (3):
                 The cluster is empty and has no associated
                 resources. All instances, associated storage and
@@ -1427,6 +1425,9 @@ class Instance(proto.Message):
             can/cannot be activated (for example, a read pool instance
             should be stopped before stopping primary etc.). Please
             refer to the API documentation for more details.
+        connection_pool_config (google.cloud.alloydb_v1.types.Instance.ConnectionPoolConfig):
+            Optional. The configuration for Managed
+            Connection Pool (MCP).
     """
 
     class State(proto.Enum):
@@ -1994,6 +1995,35 @@ class AuthorizedNetwork(proto.Message):
             number=5,
         )
 
+    class ConnectionPoolConfig(proto.Message):
+        r"""Configuration for Managed Connection Pool (MCP).
+
+        Attributes:
+            enabled (bool):
+                Optional. Whether to enable Managed
+                Connection Pool (MCP).
+            flags (MutableMapping[str, str]):
+                Optional. Connection Pool flags, as a list of
+                "key": "value" pairs.
+            pooler_count (int):
+                Output only. The number of running poolers
+                per instance.
+        """
+
+        enabled: bool = proto.Field(
+            proto.BOOL,
+            number=12,
+        )
+        flags: MutableMapping[str, str] = proto.MapField(
+            proto.STRING,
+            proto.STRING,
+            number=13,
+        )
+        pooler_count: int = proto.Field(
+            proto.INT32,
+            number=14,
+        )
+
     name: str = proto.Field(
         proto.STRING,
         number=1,
@@ -2129,6 +2159,11 @@ class AuthorizedNetwork(proto.Message):
         number=35,
         enum=ActivationPolicy,
     )
+    connection_pool_config: ConnectionPoolConfig = proto.Field(
+        proto.MESSAGE,
+        number=37,
+        message=ConnectionPoolConfig,
+    )
 
 
 class ConnectionInfo(proto.Message):
@@ -2729,19 +2764,31 @@ class UserType(proto.Enum):
 class Database(proto.Message):
     r"""Message describing Database object.
 
+    .. _oneof: https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields
+
     Attributes:
         name (str):
             Identifier. Name of the resource in the form of
             ``projects/{project}/locations/{location}/clusters/{cluster}/databases/{database}``.
         charset (str):
-            Optional. Charset for the database. This field can contain
-            any PostgreSQL supported charset name. Example values
-            include "UTF8", "SQL_ASCII", etc.
+            Optional. Immutable. Charset for the database. This field
+            can contain any PostgreSQL supported charset name. Example
+            values include "UTF8", "SQL_ASCII", etc.
         collation (str):
-            Optional. Collation for the database.
-            Name of the custom or native collation for
-            postgres. Example values include "C", "POSIX",
-            etc
+            Optional. Immutable. lc_collate for the database. String
+            sort order. Example values include "C", "POSIX", etc.
+        character_type (str):
+            Optional. Immutable. lc_ctype for the database. Character
+            classification (What is a letter? The upper-case
+            equivalent?). Example values include "C", "POSIX", etc.
+        database_template (str):
+            Input only. Immutable. Template of the
+            database to be used for creating a new database.
+        is_template_database (bool):
+            Optional. Whether the database is a template
+            database.
+
+            This field is a member of `oneof`_ ``_is_template_database``.
     """
 
     name: str = proto.Field(
@@ -2756,6 +2803,19 @@ class Database(proto.Message):
         proto.STRING,
         number=3,
     )
+    character_type: str = proto.Field(
+        proto.STRING,
+        number=4,
+    )
+    database_template: str = proto.Field(
+        proto.STRING,
+        number=6,
+    )
+    is_template_database: bool = proto.Field(
+        proto.BOOL,
+        number=7,
+        optional=True,
+    )
 
 
 __all__ = tuple(sorted(__protobuf__.manifest))