Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: Add Pub/Sub Lite Reservation APIs #156

Merged
merged 2 commits into from Jun 10, 2021
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
18 changes: 18 additions & 0 deletions google/cloud/pubsublite_v1/__init__.py
Expand Up @@ -27,25 +27,34 @@
from .services.topic_stats_service import TopicStatsServiceClient
from .services.topic_stats_service import TopicStatsServiceAsyncClient

from .types.admin import CreateReservationRequest
from .types.admin import CreateSubscriptionRequest
from .types.admin import CreateTopicRequest
from .types.admin import DeleteReservationRequest
from .types.admin import DeleteSubscriptionRequest
from .types.admin import DeleteTopicRequest
from .types.admin import GetReservationRequest
from .types.admin import GetSubscriptionRequest
from .types.admin import GetTopicPartitionsRequest
from .types.admin import GetTopicRequest
from .types.admin import ListReservationsRequest
from .types.admin import ListReservationsResponse
from .types.admin import ListReservationTopicsRequest
from .types.admin import ListReservationTopicsResponse
from .types.admin import ListSubscriptionsRequest
from .types.admin import ListSubscriptionsResponse
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 UpdateReservationRequest
from .types.admin import UpdateSubscriptionRequest
from .types.admin import UpdateTopicRequest
from .types.common import AttributeValues
from .types.common import Cursor
from .types.common import PubSubMessage
from .types.common import Reservation
from .types.common import SequencedMessage
from .types.common import Subscription
from .types.common import TimeTarget
Expand Down Expand Up @@ -103,13 +112,16 @@
"ComputeMessageStatsResponse",
"ComputeTimeCursorRequest",
"ComputeTimeCursorResponse",
"CreateReservationRequest",
"CreateSubscriptionRequest",
"CreateTopicRequest",
"Cursor",
"CursorServiceClient",
"DeleteReservationRequest",
"DeleteSubscriptionRequest",
"DeleteTopicRequest",
"FlowControlRequest",
"GetReservationRequest",
"GetSubscriptionRequest",
"GetTopicPartitionsRequest",
"GetTopicRequest",
Expand All @@ -122,6 +134,10 @@
"InitialSubscribeResponse",
"ListPartitionCursorsRequest",
"ListPartitionCursorsResponse",
"ListReservationTopicsRequest",
"ListReservationTopicsResponse",
"ListReservationsRequest",
"ListReservationsResponse",
"ListSubscriptionsRequest",
"ListSubscriptionsResponse",
"ListTopicSubscriptionsRequest",
Expand All @@ -140,6 +156,7 @@
"PublishRequest",
"PublishResponse",
"PublisherServiceClient",
"Reservation",
"SeekRequest",
"SeekResponse",
"SequencedCommitCursorRequest",
Expand All @@ -155,6 +172,7 @@
"Topic",
"TopicPartitions",
"TopicStatsServiceClient",
"UpdateReservationRequest",
"UpdateSubscriptionRequest",
"UpdateTopicRequest",
)
60 changes: 60 additions & 0 deletions google/cloud/pubsublite_v1/gapic_metadata.json
Expand Up @@ -10,6 +10,11 @@
"grpc": {
"libraryClient": "AdminServiceClient",
"rpcs": {
"CreateReservation": {
"methods": [
"create_reservation"
]
},
"CreateSubscription": {
"methods": [
"create_subscription"
Expand All @@ -20,6 +25,11 @@
"create_topic"
]
},
"DeleteReservation": {
"methods": [
"delete_reservation"
]
},
"DeleteSubscription": {
"methods": [
"delete_subscription"
Expand All @@ -30,6 +40,11 @@
"delete_topic"
]
},
"GetReservation": {
"methods": [
"get_reservation"
]
},
"GetSubscription": {
"methods": [
"get_subscription"
Expand All @@ -45,6 +60,16 @@
"get_topic_partitions"
]
},
"ListReservationTopics": {
"methods": [
"list_reservation_topics"
]
},
"ListReservations": {
"methods": [
"list_reservations"
]
},
"ListSubscriptions": {
"methods": [
"list_subscriptions"
Expand All @@ -60,6 +85,11 @@
"list_topics"
]
},
"UpdateReservation": {
"methods": [
"update_reservation"
]
},
"UpdateSubscription": {
"methods": [
"update_subscription"
Expand All @@ -75,6 +105,11 @@
"grpc-async": {
"libraryClient": "AdminServiceAsyncClient",
"rpcs": {
"CreateReservation": {
"methods": [
"create_reservation"
]
},
"CreateSubscription": {
"methods": [
"create_subscription"
Expand All @@ -85,6 +120,11 @@
"create_topic"
]
},
"DeleteReservation": {
"methods": [
"delete_reservation"
]
},
"DeleteSubscription": {
"methods": [
"delete_subscription"
Expand All @@ -95,6 +135,11 @@
"delete_topic"
]
},
"GetReservation": {
"methods": [
"get_reservation"
]
},
"GetSubscription": {
"methods": [
"get_subscription"
Expand All @@ -110,6 +155,16 @@
"get_topic_partitions"
]
},
"ListReservationTopics": {
"methods": [
"list_reservation_topics"
]
},
"ListReservations": {
"methods": [
"list_reservations"
]
},
"ListSubscriptions": {
"methods": [
"list_subscriptions"
Expand All @@ -125,6 +180,11 @@
"list_topics"
]
},
"UpdateReservation": {
"methods": [
"update_reservation"
]
},
"UpdateSubscription": {
"methods": [
"update_subscription"
Expand Down