feat: ComputeTimeCursor RPC for Pub/Sub Lite (#143)

* chore: upgrade gapic-generator-python to 0.46.3

PiperOrigin-RevId: 373649163

Source-Link: googleapis/googleapis@7e1b14e

Source-Link: googleapis/googleapis-gen@0a3c7d2

* 🦉 Updates from OwlBot

* Work around generator bug

* run post processor

* use latest version of post processor

* Work around generator bug

* run post processor

* Work around generator bug

* run the post processor

Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
Co-authored-by: Anthonios Partheniou <partheniou@google.com>

.github/.OwlBot.lock.yaml

@@ -1,4 +1,4 @@
 docker:
-  digest: sha256:457583330eec64daa02aeb7a72a04d33e7be2428f646671ce4045dcbc0191b1e
+  digest: sha256:4c981a6b6f2b8914a448d7b3a01688365be03e3ed26dfee399a6aa77fb112eaa
   image: gcr.io/repo-automation-bots/owlbot-python:latest  
 

.pre-commit-config.yaml

@@ -26,6 +26,6 @@ repos:
     hooks:
     - id: black
 -   repo: https://gitlab.com/pycqa/flake8
-    rev: 3.9.1
+    rev: 3.9.2
     hooks:
     - id: flake8

google/cloud/pubsublite_v1/__init__.py

@@ -1,5 +1,4 @@
 # -*- coding: utf-8 -*-
-
 # Copyright 2020 Google LLC
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
@@ -16,11 +15,18 @@
 #
 
 from .services.admin_service import AdminServiceClient
+from .services.admin_service import AdminServiceAsyncClient
 from .services.cursor_service import CursorServiceClient
+from .services.cursor_service import CursorServiceAsyncClient
 from .services.partition_assignment_service import PartitionAssignmentServiceClient
+from .services.partition_assignment_service import PartitionAssignmentServiceAsyncClient
 from .services.publisher_service import PublisherServiceClient
+from .services.publisher_service import PublisherServiceAsyncClient
 from .services.subscriber_service import SubscriberServiceClient
+from .services.subscriber_service import SubscriberServiceAsyncClient
 from .services.topic_stats_service import TopicStatsServiceClient
+from .services.topic_stats_service import TopicStatsServiceAsyncClient
+
 from .types.admin import CreateSubscriptionRequest
 from .types.admin import CreateTopicRequest
 from .types.admin import DeleteSubscriptionRequest
@@ -30,10 +36,10 @@
 from .types.admin import GetTopicRequest
 from .types.admin import ListSubscriptionsRequest
 from .types.admin import ListSubscriptionsResponse
-from .types.admin import ListTopicSubscriptionsRequest
-from .types.admin import ListTopicSubscriptionsResponse
 from .types.admin import ListTopicsRequest
 from .types.admin import ListTopicsResponse
+from .types.admin import ListTopicSubscriptionsRequest
+from .types.admin import ListTopicSubscriptionsResponse
 from .types.admin import TopicPartitions
 from .types.admin import UpdateSubscriptionRequest
 from .types.admin import UpdateTopicRequest
@@ -42,6 +48,7 @@
 from .types.common import PubSubMessage
 from .types.common import SequencedMessage
 from .types.common import Subscription
+from .types.common import TimeTarget
 from .types.common import Topic
 from .types.cursor import CommitCursorRequest
 from .types.cursor import CommitCursorResponse
@@ -76,9 +83,16 @@
 from .types.topic_stats import ComputeHeadCursorResponse
 from .types.topic_stats import ComputeMessageStatsRequest
 from .types.topic_stats import ComputeMessageStatsResponse
-
+from .types.topic_stats import ComputeTimeCursorRequest
+from .types.topic_stats import ComputeTimeCursorResponse
 
 __all__ = (
+    "AdminServiceAsyncClient",
+    "CursorServiceAsyncClient",
+    "PartitionAssignmentServiceAsyncClient",
+    "PublisherServiceAsyncClient",
+    "SubscriberServiceAsyncClient",
+    "TopicStatsServiceAsyncClient",
     "AdminServiceClient",
     "AttributeValues",
     "CommitCursorRequest",
@@ -87,6 +101,8 @@
     "ComputeHeadCursorResponse",
     "ComputeMessageStatsRequest",
     "ComputeMessageStatsResponse",
+    "ComputeTimeCursorRequest",
+    "ComputeTimeCursorResponse",
     "CreateSubscriptionRequest",
     "CreateTopicRequest",
     "Cursor",
@@ -135,9 +151,10 @@
     "SubscribeResponse",
     "SubscriberServiceClient",
     "Subscription",
+    "TimeTarget",
     "Topic",
     "TopicPartitions",
+    "TopicStatsServiceClient",
     "UpdateSubscriptionRequest",
     "UpdateTopicRequest",
-    "TopicStatsServiceClient",
 )