chore: pick up changes from googleapis (#98)

* changes without context autosynth cannot find the source of changes triggered by earlier changes in this repository, or by version upgrades to tools such as linters. * chore: migrate example/library to the Java microgenerator Committer: @miraleung PiperOrigin-RevId: 345498172 Source-Author: Google APIs <noreply@google.com> Source-Date: Thu Dec 3 11:36:52 2020 -0800 Source-Repo: googleapis/googleapis Source-Sha: 07027f95bf0a5b2451984c01a87ea86ee715c15d Source-Link: googleapis/googleapis@07027f9 * feat: migrate bigtable retry/timeout settings to gRPC's service configs Committer: @miraleung PiperOrigin-RevId: 346894665 Source-Author: Google APIs <noreply@google.com> Source-Date: Thu Dec 10 16:55:31 2020 -0800 Source-Repo: googleapis/googleapis Source-Sha: cbbd3170bcf217e36ae72f4ac522449bf861346f Source-Link: googleapis/googleapis@cbbd317 * fix: remove client recv msg limit fix: add enums to `types/__init__.py` PiperOrigin-RevId: 347055288 Source-Author: Google APIs <noreply@google.com> Source-Date: Fri Dec 11 12:44:37 2020 -0800 Source-Repo: googleapis/googleapis Source-Sha: dd372aa22ded7a8ba6f0e03a80e06358a3fa0907 Source-Link: googleapis/googleapis@dd372aa * feat: Add support for "billingAccounts" as another parent resource name for recommendations and insights APIs. PiperOrigin-RevId: 347651882 Source-Author: Google APIs <noreply@google.com> Source-Date: Tue Dec 15 11:11:56 2020 -0800 Source-Repo: googleapis/googleapis Source-Sha: e689e62a5540d4b98639f0e444a0edf5b2d94043 Source-Link: googleapis/googleapis@e689e62 * feat: Add ComputeHeadCursor RPC for Pub/Sub Lite. PiperOrigin-RevId: 347681363 Source-Author: Google APIs <noreply@google.com> Source-Date: Tue Dec 15 13:31:04 2020 -0800 Source-Repo: googleapis/googleapis Source-Sha: f967ea0c0437a269515665ff9dbb69fcf134ddd9 Source-Link: googleapis/googleapis@f967ea0 * build: add gapic yaml config and regenerate BUILD files for APIs PiperOrigin-RevId: 347695607 Source-Author: Google APIs <noreply@google.com> Source-Date: Tue Dec 15 14:40:01 2020 -0800 Source-Repo: googleapis/googleapis Source-Sha: 64f1e20354393415d5da54141ed39574a0cd1f30 Source-Link: googleapis/googleapis@64f1e20 * feat: public protos for API Gateway API PiperOrigin-RevId: 347907714 Source-Author: Google APIs <noreply@google.com> Source-Date: Wed Dec 16 15:18:35 2020 -0800 Source-Repo: googleapis/googleapis Source-Sha: 48fa7512d385dd8ea8e51aab083086858b4dbffe Source-Link: googleapis/googleapis@48fa751 * chore: upgrade gapic-generator-python to 0.39.1 feat: add 'from_service_account_info' factory to clients fix: fix sphinx identifiers PiperOrigin-RevId: 350246057 Source-Author: Google APIs <noreply@google.com> Source-Date: Tue Jan 5 16:44:11 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 520682435235d9c503983a360a2090025aa47cd1 Source-Link: googleapis/googleapis@5206824 * fix: generated package names for C#, Ruby, and PHP docs: minor cleanup, formatting and edits PiperOrigin-RevId: 351455519 Source-Author: Google APIs <noreply@google.com> Source-Date: Tue Jan 12 14:55:09 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: b71a6e53e944167cb4bcec042210d8cf2a9e40ca Source-Link: googleapis/googleapis@b71a6e5 * chore: migrate websecurityscanner to the Python microgenerator Committer: @miraleung PiperOrigin-RevId: 351457221 Source-Author: Google APIs <noreply@google.com> Source-Date: Tue Jan 12 15:03:33 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: e4a9d34833c20d6bc4836b886e8ae268d9dc9f1d Source-Link: googleapis/googleapis@e4a9d34 * feat: added expire_time and ttl fields to Secret PiperOrigin-RevId: 352563582 Source-Author: Google APIs <noreply@google.com> Source-Date: Tue Jan 19 07:29:20 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 9ecdacc9a00e1dd443b11bf10215d6e7648db8a7 Source-Link: googleapis/googleapis@9ecdacc * chore: update Go generator, rules_go, and protobuf PiperOrigin-RevId: 352816749 Source-Author: Google APIs <noreply@google.com> Source-Date: Wed Jan 20 10:06:23 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: ceaaf31b3d13badab7cf9d3b570f5639db5593d9 Source-Link: googleapis/googleapis@ceaaf31 * chore: upgrade gapic-generator-python to 0.40.5 PiperOrigin-RevId: 354996675 Source-Author: Google APIs <noreply@google.com> Source-Date: Mon Feb 1 12:11:49 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 20712b8fe95001b312f62c6c5f33e3e3ec92cfaf Source-Link: googleapis/googleapis@20712b8 * feat: Add Pub/Sub endpoints for Cloud Channel API. PiperOrigin-RevId: 355059873 Source-Author: Google APIs <noreply@google.com> Source-Date: Mon Feb 1 17:13:22 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 6ef9eaea379fc1cc0355e06a5a20b594543ee693 Source-Link: googleapis/googleapis@6ef9eae * feat: Add `ErrorReason` enum from `google.api.error_reason` for Google API and minor proto updates. PiperOrigin-RevId: 355218181 Source-Author: Google APIs <noreply@google.com> Source-Date: Tue Feb 2 11:53:01 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 2f8d204b9bc1126439565e25a456eaf6435f38f4 Source-Link: googleapis/googleapis@2f8d204 * chore: remove more unused package options in java_gapic_library rules Committer: @miraleung PiperOrigin-RevId: 355442508 Source-Author: Google APIs <noreply@google.com> Source-Date: Wed Feb 3 11:32:57 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: e038e2a5b2104dfae83edada1dfb41b319fc363f Source-Link: googleapis/googleapis@e038e2a * build: add package name to BUILD file for nodejs-access-approval PiperOrigin-RevId: 355768486 Source-Author: Google APIs <noreply@google.com> Source-Date: Thu Feb 4 20:12:35 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 53dd6b53c7af308c69581c364ad20c52aa4c6ca0 Source-Link: googleapis/googleapis@53dd6b5 * chore: re-enable python generation for dialogflow cx. PiperOrigin-RevId: 355906816 Source-Author: Google APIs <noreply@google.com> Source-Date: Fri Feb 5 12:40:52 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 254325ed3c9caa6bf6d9c8b11ce2674544ba6e7c Source-Link: googleapis/googleapis@254325e * chore: update gapic-generator-python PiperOrigin-RevId: 355923884 Source-Author: Google APIs <noreply@google.com> Source-Date: Fri Feb 5 14:04:52 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 5e3dacee19405529b841b53797df799c2383536c Source-Link: googleapis/googleapis@5e3dace * chore: remove non-existent package option in java_gapic_library rules for cloud APIs Committer: @miraleung PiperOrigin-RevId: 356328938 Source-Author: Google APIs <noreply@google.com> Source-Date: Mon Feb 8 12:39:42 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 78e0057d81c6969507bf1195b5aad8ac3e7feafd Source-Link: googleapis/googleapis@78e0057 * feat: added ApplySoftwareUpdate API docs: various clarifications, new documentation for ApplySoftwareUpdate chore: update proto annotations PiperOrigin-RevId: 356380191 Source-Author: Google APIs <noreply@google.com> Source-Date: Mon Feb 8 16:30:59 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 84cf54e45ed5970980ae868e0a1e5ad1266a8830 Source-Link: googleapis/googleapis@84cf54e * feat: Add Traffic data to the leg and step level. PiperOrigin-RevId: 357215334 Source-Author: Google APIs <noreply@google.com> Source-Date: Fri Feb 12 10:11:29 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 5a11760c9dcdf63deba111e44bc12df5a4b5cd3a Source-Link: googleapis/googleapis@5a11760 * chore: update gapic-generator-python to 0.40.11 PiperOrigin-RevId: 359562873 Source-Author: Google APIs <noreply@google.com> Source-Date: Thu Feb 25 10:52:32 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 07932bb995e7dc91b43620ea8402c6668c7d102c Source-Link: googleapis/googleapis@07932bb * chore: clean up unused gapic.legacy.yaml files Committer: @miraleung PiperOrigin-RevId: 359580699 Source-Author: Google APIs <noreply@google.com> Source-Date: Thu Feb 25 12:03:52 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: d9b32e92fa57c37e5af0dc03badfe741170c5849 Source-Link: googleapis/googleapis@d9b32e9 * build: add package name for artifact registry PiperOrigin-RevId: 359593247 Source-Author: Google APIs <noreply@google.com> Source-Date: Thu Feb 25 13:01:50 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: e69f9d4f00a558a359a55f3bb33ba582d6bfc805 Source-Link: googleapis/googleapis@e69f9d4 * chore: update protobuf v3.15.3 This release makes --experimental_allow_proto3_optional no longer necessary. PiperOrigin-RevId: 359781040 Source-Author: Google APIs <noreply@google.com> Source-Date: Fri Feb 26 09:59:49 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: f6dd7e47620566925a4b3f1ce029e74e1b2f2516 Source-Link: googleapis/googleapis@f6dd7e4 * feat: publish documentai/v1 protos PiperOrigin-RevId: 360214832 Source-Author: Google APIs <noreply@google.com> Source-Date: Mon Mar 1 09:59:41 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: be7020ff106658f75d50e14693b13d822d910325 Source-Link: googleapis/googleapis@be7020f * feat: add skip_backlog field to allow subscriptions to be created at HEAD Committer: @hannahrogers-google PiperOrigin-RevId: 360987981 Source-Author: Google APIs <noreply@google.com> Source-Date: Thu Mar 4 13:12:18 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: ead17216f9bc591177041c6aeccee751ad7df0d1 Source-Link: googleapis/googleapis@ead1721 * feat: Add CCAI API PiperOrigin-RevId: 361000862 Source-Author: Google APIs <noreply@google.com> Source-Date: Thu Mar 4 14:10:49 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 4b4e8be384ce5d3420e3af430ca50fa72c561bfd Source-Link: googleapis/googleapis@4b4e8be * feat: add PHP µ-generator build targets to googleads Committer: @aohren PiperOrigin-RevId: 361555541 Source-Author: Google APIs <noreply@google.com> Source-Date: Mon Mar 8 07:00:53 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 65d71a60baf9650404a4d9d65f29e9ba8db490d1 Source-Link: googleapis/googleapis@65d71a6 * chore: upgrade gapic-generator-python to 0.42.2 PiperOrigin-RevId: 361662015 Source-Author: Google APIs <noreply@google.com> Source-Date: Mon Mar 8 14:47:18 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 28a591963253d52ce3a25a918cafbdd9928de8cf Source-Link: googleapis/googleapis@28a5919 * build: use gapic-generator-typescript v1.2.11. Fixed IAM v1 library generation. Committer: @alexander-fenster PiperOrigin-RevId: 361676678 Source-Author: Google APIs <noreply@google.com> Source-Date: Mon Mar 8 15:51:18 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 3aeb3a70f66457a9e6b07caff841719bb9873b57 Source-Link: googleapis/googleapis@3aeb3a7 * docs: fix broken link in doc string PiperOrigin-RevId: 362183999 Source-Author: Google APIs <noreply@google.com> Source-Date: Wed Mar 10 17:50:58 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: d652c6370bf66e325da6ac9ad82989fe7ee7bb4b Source-Link: googleapis/googleapis@d652c63 * remove unwanted changes Co-authored-by: Tianzi Cai <tianzi@google.com>
googleapis · Mar 11, 2021 · 153deb5 · 153deb5
1 parent 129e70f
commit 153deb5
Show file tree

Hide file tree

Showing 49 changed files with 2,482 additions and 907 deletions.
diff --git a/google/cloud/pubsublite_v1/__init__.py b/google/cloud/pubsublite_v1/__init__.py
@@ -72,6 +72,8 @@
 from .types.subscriber import SeekResponse
 from .types.subscriber import SubscribeRequest
 from .types.subscriber import SubscribeResponse
+from .types.topic_stats import ComputeHeadCursorRequest
+from .types.topic_stats import ComputeHeadCursorResponse
 from .types.topic_stats import ComputeMessageStatsRequest
 from .types.topic_stats import ComputeMessageStatsResponse
 
@@ -81,6 +83,8 @@
     "AttributeValues",
     "CommitCursorRequest",
     "CommitCursorResponse",
+    "ComputeHeadCursorRequest",
+    "ComputeHeadCursorResponse",
     "ComputeMessageStatsRequest",
     "ComputeMessageStatsResponse",
     "CreateSubscriptionRequest",

diff --git a/google/cloud/pubsublite_v1/services/admin_service/async_client.py b/google/cloud/pubsublite_v1/services/admin_service/async_client.py
@@ -79,7 +79,36 @@ class AdminServiceAsyncClient:
         AdminServiceClient.parse_common_location_path
     )
 
-    from_service_account_file = AdminServiceClient.from_service_account_file
+    @classmethod
+    def from_service_account_info(cls, info: dict, *args, **kwargs):
+        """Creates an instance of this client using the provided credentials info.
+
+        Args:
+            info (dict): The service account private key info.
+            args: Additional arguments to pass to the constructor.
+            kwargs: Additional arguments to pass to the constructor.
+
+        Returns:
+            AdminServiceAsyncClient: The constructed client.
+        """
+        return AdminServiceClient.from_service_account_info.__func__(AdminServiceAsyncClient, info, *args, **kwargs)  # type: ignore
+
+    @classmethod
+    def from_service_account_file(cls, filename: str, *args, **kwargs):
+        """Creates an instance of this client using the provided credentials
+        file.
+
+        Args:
+            filename (str): The path to the service account private key json
+                file.
+            args: Additional arguments to pass to the constructor.
+            kwargs: Additional arguments to pass to the constructor.
+
+        Returns:
+            AdminServiceAsyncClient: The constructed client.
+        """
+        return AdminServiceClient.from_service_account_file.__func__(AdminServiceAsyncClient, filename, *args, **kwargs)  # type: ignore
+
     from_service_account_json = from_service_account_file
 
     @property
@@ -157,18 +186,20 @@ async def create_topic(
         r"""Creates a new topic.
 
         Args:
-            request (:class:`~.admin.CreateTopicRequest`):
+            request (:class:`google.cloud.pubsublite_v1.types.CreateTopicRequest`):
                 The request object. Request for CreateTopic.
             parent (:class:`str`):
                 Required. The parent location in which to create the
                 topic. Structured like
                 ``projects/{project_number}/locations/{location}``.
+
                 This corresponds to the ``parent`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
-            topic (:class:`~.common.Topic`):
+            topic (:class:`google.cloud.pubsublite_v1.types.Topic`):
                 Required. Configuration of the topic to create. Its
                 ``name`` field is ignored.
+
                 This corresponds to the ``topic`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
@@ -177,6 +208,7 @@ async def create_topic(
                 the final component of the topic's name.
 
                 This value is structured like: ``my-topic-name``.
+
                 This corresponds to the ``topic_id`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
@@ -188,7 +220,7 @@ async def create_topic(
                 sent along with the request as metadata.
 
         Returns:
-            ~.common.Topic:
+            google.cloud.pubsublite_v1.types.Topic:
                 Metadata about a topic resource.
         """
         # Create or coerce a protobuf request object.
@@ -245,11 +277,12 @@ async def get_topic(
         r"""Returns the topic configuration.
 
         Args:
-            request (:class:`~.admin.GetTopicRequest`):
+            request (:class:`google.cloud.pubsublite_v1.types.GetTopicRequest`):
                 The request object. Request for GetTopic.
             name (:class:`str`):
                 Required. The name of the topic whose
                 configuration to return.
+
                 This corresponds to the ``name`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
@@ -261,7 +294,7 @@ async def get_topic(
                 sent along with the request as metadata.
 
         Returns:
-            ~.common.Topic:
+            google.cloud.pubsublite_v1.types.Topic:
                 Metadata about a topic resource.
         """
         # Create or coerce a protobuf request object.
@@ -315,11 +348,12 @@ async def get_topic_partitions(
         topic.
 
         Args:
-            request (:class:`~.admin.GetTopicPartitionsRequest`):
+            request (:class:`google.cloud.pubsublite_v1.types.GetTopicPartitionsRequest`):
                 The request object. Request for GetTopicPartitions.
             name (:class:`str`):
                 Required. The topic whose partition
                 information to return.
+
                 This corresponds to the ``name`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
@@ -331,7 +365,7 @@ async def get_topic_partitions(
                 sent along with the request as metadata.
 
         Returns:
-            ~.admin.TopicPartitions:
+            google.cloud.pubsublite_v1.types.TopicPartitions:
                 Response for GetTopicPartitions.
         """
         # Create or coerce a protobuf request object.
@@ -384,12 +418,13 @@ async def list_topics(
         r"""Returns the list of topics for the given project.
 
         Args:
-            request (:class:`~.admin.ListTopicsRequest`):
+            request (:class:`google.cloud.pubsublite_v1.types.ListTopicsRequest`):
                 The request object. Request for ListTopics.
             parent (:class:`str`):
                 Required. The parent whose topics are to be listed.
                 Structured like
                 ``projects/{project_number}/locations/{location}``.
+
                 This corresponds to the ``parent`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
@@ -401,7 +436,7 @@ async def list_topics(
                 sent along with the request as metadata.
 
         Returns:
-            ~.pagers.ListTopicsAsyncPager:
+            google.cloud.pubsublite_v1.services.admin_service.pagers.ListTopicsAsyncPager:
                 Response for ListTopics.
                 Iterating over this object will yield
                 results and resolve additional pages
@@ -465,17 +500,19 @@ async def update_topic(
         r"""Updates properties of the specified topic.
 
         Args:
-            request (:class:`~.admin.UpdateTopicRequest`):
+            request (:class:`google.cloud.pubsublite_v1.types.UpdateTopicRequest`):
                 The request object. Request for UpdateTopic.
-            topic (:class:`~.common.Topic`):
+            topic (:class:`google.cloud.pubsublite_v1.types.Topic`):
                 Required. The topic to update. Its ``name`` field must
                 be populated.
+
                 This corresponds to the ``topic`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
-            update_mask (:class:`~.field_mask.FieldMask`):
+            update_mask (:class:`google.protobuf.field_mask_pb2.FieldMask`):
                 Required. A mask specifying the topic
                 fields to change.
+
                 This corresponds to the ``update_mask`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
@@ -487,7 +524,7 @@ async def update_topic(
                 sent along with the request as metadata.
 
         Returns:
-            ~.common.Topic:
+            google.cloud.pubsublite_v1.types.Topic:
                 Metadata about a topic resource.
         """
         # Create or coerce a protobuf request object.
@@ -544,11 +581,12 @@ async def delete_topic(
         r"""Deletes the specified topic.
 
         Args:
-            request (:class:`~.admin.DeleteTopicRequest`):
+            request (:class:`google.cloud.pubsublite_v1.types.DeleteTopicRequest`):
                 The request object. Request for DeleteTopic.
             name (:class:`str`):
                 Required. The name of the topic to
                 delete.
+
                 This corresponds to the ``name`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
@@ -609,11 +647,12 @@ async def list_topic_subscriptions(
         topic.
 
         Args:
-            request (:class:`~.admin.ListTopicSubscriptionsRequest`):
+            request (:class:`google.cloud.pubsublite_v1.types.ListTopicSubscriptionsRequest`):
                 The request object. Request for ListTopicSubscriptions.
             name (:class:`str`):
                 Required. The name of the topic whose
                 subscriptions to list.
+
                 This corresponds to the ``name`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
@@ -625,7 +664,7 @@ async def list_topic_subscriptions(
                 sent along with the request as metadata.
 
         Returns:
-            ~.pagers.ListTopicSubscriptionsAsyncPager:
+            google.cloud.pubsublite_v1.services.admin_service.pagers.ListTopicSubscriptionsAsyncPager:
                 Response for ListTopicSubscriptions.
                 Iterating over this object will yield
                 results and resolve additional pages
@@ -690,18 +729,20 @@ async def create_subscription(
         r"""Creates a new subscription.
 
         Args:
-            request (:class:`~.admin.CreateSubscriptionRequest`):
+            request (:class:`google.cloud.pubsublite_v1.types.CreateSubscriptionRequest`):
                 The request object. Request for CreateSubscription.
             parent (:class:`str`):
                 Required. The parent location in which to create the
                 subscription. Structured like
                 ``projects/{project_number}/locations/{location}``.
+
                 This corresponds to the ``parent`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
-            subscription (:class:`~.common.Subscription`):
+            subscription (:class:`google.cloud.pubsublite_v1.types.Subscription`):
                 Required. Configuration of the subscription to create.
                 Its ``name`` field is ignored.
+
                 This corresponds to the ``subscription`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
@@ -710,6 +751,7 @@ async def create_subscription(
                 become the final component of the subscription's name.
 
                 This value is structured like: ``my-sub-name``.
+
                 This corresponds to the ``subscription_id`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
@@ -721,7 +763,7 @@ async def create_subscription(
                 sent along with the request as metadata.
 
         Returns:
-            ~.common.Subscription:
+            google.cloud.pubsublite_v1.types.Subscription:
                 Metadata about a subscription
                 resource.
 
@@ -780,12 +822,13 @@ async def get_subscription(
         r"""Returns the subscription configuration.
 
         Args:
-            request (:class:`~.admin.GetSubscriptionRequest`):
+            request (:class:`google.cloud.pubsublite_v1.types.GetSubscriptionRequest`):
                 The request object. Request for GetSubscription.
             name (:class:`str`):
                 Required. The name of the
                 subscription whose configuration to
                 return.
+
                 This corresponds to the ``name`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
@@ -797,7 +840,7 @@ async def get_subscription(
                 sent along with the request as metadata.
 
         Returns:
-            ~.common.Subscription:
+            google.cloud.pubsublite_v1.types.Subscription:
                 Metadata about a subscription
                 resource.
 
@@ -853,12 +896,13 @@ async def list_subscriptions(
         project.
 
         Args:
-            request (:class:`~.admin.ListSubscriptionsRequest`):
+            request (:class:`google.cloud.pubsublite_v1.types.ListSubscriptionsRequest`):
                 The request object. Request for ListSubscriptions.
             parent (:class:`str`):
                 Required. The parent whose subscriptions are to be
                 listed. Structured like
                 ``projects/{project_number}/locations/{location}``.
+
                 This corresponds to the ``parent`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
@@ -870,7 +914,7 @@ async def list_subscriptions(
                 sent along with the request as metadata.
 
         Returns:
-            ~.pagers.ListSubscriptionsAsyncPager:
+            google.cloud.pubsublite_v1.services.admin_service.pagers.ListSubscriptionsAsyncPager:
                 Response for ListSubscriptions.
                 Iterating over this object will yield
                 results and resolve additional pages
@@ -934,17 +978,19 @@ async def update_subscription(
         r"""Updates properties of the specified subscription.
 
         Args:
-            request (:class:`~.admin.UpdateSubscriptionRequest`):
+            request (:class:`google.cloud.pubsublite_v1.types.UpdateSubscriptionRequest`):
                 The request object. Request for UpdateSubscription.
-            subscription (:class:`~.common.Subscription`):
+            subscription (:class:`google.cloud.pubsublite_v1.types.Subscription`):
                 Required. The subscription to update. Its ``name`` field
                 must be populated. Topic field must not be populated.
+
                 This corresponds to the ``subscription`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
-            update_mask (:class:`~.field_mask.FieldMask`):
+            update_mask (:class:`google.protobuf.field_mask_pb2.FieldMask`):
                 Required. A mask specifying the
                 subscription fields to change.
+
                 This corresponds to the ``update_mask`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.
@@ -956,7 +1002,7 @@ async def update_subscription(
                 sent along with the request as metadata.
 
         Returns:
-            ~.common.Subscription:
+            google.cloud.pubsublite_v1.types.Subscription:
                 Metadata about a subscription
                 resource.
 
@@ -1015,11 +1061,12 @@ async def delete_subscription(
         r"""Deletes the specified subscription.
 
         Args:
-            request (:class:`~.admin.DeleteSubscriptionRequest`):
+            request (:class:`google.cloud.pubsublite_v1.types.DeleteSubscriptionRequest`):
                 The request object. Request for DeleteSubscription.
             name (:class:`str`):
                 Required. The name of the
                 subscription to delete.
+
                 This corresponds to the ``name`` field
                 on the ``request`` instance; if ``request`` is provided, this
                 should not be set.