From 726fe752100b99c790cc407ba0095f34f9844fcc Mon Sep 17 00:00:00 2001 From: Tianzi Cai Date: Tue, 16 Nov 2021 09:51:54 -0800 Subject: [PATCH 1/4] feat: surface Reservation in types --- google/cloud/pubsublite/types/__init__.py | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/google/cloud/pubsublite/types/__init__.py b/google/cloud/pubsublite/types/__init__.py index ef4d842c..b40406d0 100644 --- a/google/cloud/pubsublite/types/__init__.py +++ b/google/cloud/pubsublite/types/__init__.py @@ -13,23 +13,26 @@ # limitations under the License. # +from pubsublite_v1.types.common import Reservation from .location import CloudRegion, CloudZone from .partition import Partition -from .paths import LocationPath, TopicPath, SubscriptionPath +from .paths import LocationPath, ReservationPath, TopicPath, SubscriptionPath from .message_metadata import MessageMetadata from .flow_control_settings import FlowControlSettings, DISABLED_FLOW_CONTROL from .backlog_location import BacklogLocation, PublishTime, EventTime __all__ = ( + "BacklogLocation", "CloudRegion", "CloudZone", + "EventTime", "FlowControlSettings", "LocationPath", - "Partition", "MessageMetadata", + "Partition", + "PublishTime", + "Reservation", + "ReservationPath", "SubscriptionPath", "TopicPath", - "BacklogLocation", - "PublishTime", - "EventTime", ) From df9a3592426c0b456ad30958e39d82d7a61e4aa5 Mon Sep 17 00:00:00 2001 From: Tianzi Cai Date: Wed, 17 Nov 2021 16:56:29 -0500 Subject: [PATCH 2/4] Update google/cloud/pubsublite/types/__init__.py Co-authored-by: Tres Seaver --- google/cloud/pubsublite/types/__init__.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/google/cloud/pubsublite/types/__init__.py b/google/cloud/pubsublite/types/__init__.py index b40406d0..0b5d6148 100644 --- a/google/cloud/pubsublite/types/__init__.py +++ b/google/cloud/pubsublite/types/__init__.py @@ -13,7 +13,7 @@ # limitations under the License. # -from pubsublite_v1.types.common import Reservation +from google.cloud.pubsublite_v1.types.common import Reservation from .location import CloudRegion, CloudZone from .partition import Partition from .paths import LocationPath, ReservationPath, TopicPath, SubscriptionPath From 49b194487912114c352fad35948083bad06f1c48 Mon Sep 17 00:00:00 2001 From: Tianzi Cai Date: Mon, 29 Nov 2021 18:27:35 -0500 Subject: [PATCH 3/4] remove reservation --- google/cloud/pubsublite/types/__init__.py | 1 - 1 file changed, 1 deletion(-) diff --git a/google/cloud/pubsublite/types/__init__.py b/google/cloud/pubsublite/types/__init__.py index 0b5d6148..98535367 100644 --- a/google/cloud/pubsublite/types/__init__.py +++ b/google/cloud/pubsublite/types/__init__.py @@ -13,7 +13,6 @@ # limitations under the License. # -from google.cloud.pubsublite_v1.types.common import Reservation from .location import CloudRegion, CloudZone from .partition import Partition from .paths import LocationPath, ReservationPath, TopicPath, SubscriptionPath From 94a3a95112da8a8cf4dda0e42506097192fea01f Mon Sep 17 00:00:00 2001 From: Tianzi Cai Date: Mon, 29 Nov 2021 15:32:16 -0800 Subject: [PATCH 4/4] add reservatin to path --- google/cloud/pubsublite/__init__.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/google/cloud/pubsublite/__init__.py b/google/cloud/pubsublite/__init__.py index 86db3807..7a064a8a 100644 --- a/google/cloud/pubsublite/__init__.py +++ b/google/cloud/pubsublite/__init__.py @@ -71,6 +71,7 @@ from google.cloud.pubsublite_v1.types.common import AttributeValues from google.cloud.pubsublite_v1.types.common import Cursor from google.cloud.pubsublite_v1.types.common import PubSubMessage +from google.cloud.pubsublite_v1.types.common import Reservation from google.cloud.pubsublite_v1.types.common import SequencedMessage from google.cloud.pubsublite_v1.types.common import Subscription from google.cloud.pubsublite_v1.types.common import TimeTarget @@ -164,6 +165,7 @@ "PublishResponse", "PublisherServiceAsyncClient", "PublisherServiceClient", + "Reservation", "SeekSubscriptionRequest", "SeekSubscriptionResponse", "SeekRequest",