Skip to content

Commit

Permalink
feat: Add Pub/Sub Lite Reservation APIs (#156)
Browse files Browse the repository at this point in the history
* feat: Add Pub/Sub Lite Reservation APIs

PiperOrigin-RevId: 377060979

Source-Link: googleapis/googleapis@51d99df

Source-Link: googleapis/googleapis-gen@604a9d3

* 🦉 Updates from OwlBot

Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com>
  • Loading branch information
gcf-owl-bot[bot] and gcf-owl-bot[bot] committed Jun 10, 2021
1 parent 03628f2 commit edbd104
Show file tree
Hide file tree
Showing 12 changed files with 3,519 additions and 23 deletions.
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

0 comments on commit edbd104

Please sign in to comment.