VddlmZmZddlmZmZmZddlmZddl m Z m Z m Z m Z mZmZmZddlmZddlmZmZmZddlmZGdd eZy ) )ABCabstractmethod)ListOptionalUnion) Operation) CloudRegion TopicPath LocationPathSubscriptionPathBacklogLocation PublishTime EventTime)ReservationPath)Topic Subscription Reservation) FieldMaskc veZdZdZedefdZededefdZede defdZ ede de fdZ ed e deefd Zeded edefd Zede fd Zede deefdZeej,dfdedeeeefdeedefdZededefdZed e deefdZeded edefdZededeeeefde fdZ!edefdZ"ede#de#fdZ$ede%de#fdZ&ed e dee#fdZ'ede#d ede#fdZ(ede%fd Z)ede%dee fd!Z*y)"AdminClientInterfacezM An admin client for Pub/Sub Lite. Only operates on a single region. returncy)zThe region this client is for.N)selfs Alib/third_party/google/cloud/pubsublite/admin_client_interface.pyregionzAdminClientInterface.region&topiccy)z*Create a topic, returns the created topic.Nr)rrs r create_topicz!AdminClientInterface.create_topic*rr topic_pathcy)z%Get the topic object from the server.Nrrr"s r get_topiczAdminClientInterface.get_topic.rrcy)z3Get the number of partitions in the provided topic.Nrr$s rget_topic_partition_countz.AdminClientInterface.get_topic_partition_count2rr location_pathcy)zJList the Pub/Sub lite topics that exist for a project in a given location.Nrrr(s r list_topicsz AdminClientInterface.list_topics6rr update_maskcy)z/Update the masked fields of the provided topic.Nr)rrr,s r update_topicz!AdminClientInterface.update_topic:rrcy)z+Delete a topic and all associated messages.Nrr$s r delete_topicz!AdminClientInterface.delete_topic>rrcy)z4List the subscriptions that exist for a given topic.Nrr$s rlist_topic_subscriptionsz-AdminClientInterface.list_topic_subscriptionsBrrN subscriptiontargetstarting_offsetcy)a(Create a subscription, returns the created subscription. By default a subscription will only receive messages published after the subscription was created. `starting_offset` is deprecated. Use `target` to initialize the subscription to a target location within the message backlog instead. `starting_offset` has higher precedence if `target` is also set. A seek is initiated if the target location is a publish or event time. If the seek fails, the created subscription is not deleted. Nr)rr3r4r5s rcreate_subscriptionz(AdminClientInterface.create_subscriptionFrrsubscription_pathcy)z,Get the subscription object from the server.Nrrr8s rget_subscriptionz%AdminClientInterface.get_subscriptionYrrcy)zQList the Pub/Sub lite subscriptions that exist for a project in a given location.Nrr*s rlist_subscriptionsz'AdminClientInterface.list_subscriptions]rrcy)z6Update the masked fields of the provided subscription.Nr)rr3r,s rupdate_subscriptionz(AdminClientInterface.update_subscriptionarrcy)aInitiate an out-of-band seek for a subscription to a specified target. The seek target may be timestamps or named positions within the message backlog See https://cloud.google.com/pubsub/lite/docs/seek for more information. Returns: google.api_core.operation.Operation with: result type: google.cloud.pubsublite.SeekSubscriptionResponse metadata type: google.cloud.pubsublite.OperationMetadata Nr)rr8r4s rseek_subscriptionz&AdminClientInterface.seek_subscriptiongrrcy)z2Delete a subscription and all associated messages.Nrr:s rdelete_subscriptionz(AdminClientInterface.delete_subscriptionyrr reservationcy)z6Create a reservation, returns the created reservation.Nr)rrDs rcreate_reservationz'AdminClientInterface.create_reservation}rrreservation_pathcy)z+Get the reservation object from the server.NrrrGs rget_reservationz$AdminClientInterface.get_reservationrrcy)zPList the Pub/Sub lite reservations that exist for a project in a given location.Nrr*s rlist_reservationsz&AdminClientInterface.list_reservationsrrcy)z5Update the masked fields of the provided reservation.Nr)rrDr,s rupdate_reservationz'AdminClientInterface.update_reservationrrcy)z1Delete a reservation and all associated messages.NrrIs rdelete_reservationz'AdminClientInterface.delete_reservationrrcy)z:List the subscriptions that exist for a given reservation.NrrIs rlist_reservation_topicsz,AdminClientInterface.list_reservation_topicsrr)+__name__ __module__ __qualname____doc__rr rrr!r r%intr'r rr+rr.r0r r2r ENDrrrrrr7r;r=r?rrArCrrFrrJrLrNrPrRrrrrr!sI- --9%9E994I4%44BIB#BBYY$u+YY>%>i>E>>:y::C9CFVAWCCBQATAT59  " o{I=> "/2     $;2B;|;;` `lAS``E(E7@E EE  + o{I=>     "A5EAAEkEkEE::K::_|_[@Q__D&D5>D DD @?@@I /I iIIrrN)abcrrtypingrrrgoogle.api_core.operationrgoogle.cloud.pubsublite.typesr r r r r rr#google.cloud.pubsublite.types.pathsrgoogle.cloud.pubsublite_v1rrr'cloudsdk.google.protobuf.field_mask_pb2rrrrrr`sA$((/@GG=vI3vIr