VSSKJrJr SSKJrJrJr SSKJr SSK J r J r J r J r JrJrJr SSKJr SSKJrJrJr SSKJr "SS \5rg ) )ABCabstractmethod)ListOptionalUnion) Operation) CloudRegion TopicPath LocationPathSubscriptionPathBacklogLocation PublishTime EventTime)ReservationPath)Topic Subscription Reservation) FieldMaskc \rSrSrSr\S\4Sj5r\S\S\4Sj5r \S\ S\4Sj5r \S\ S\ 4S j5r \S \S\\4S j5r\S\S \S\4S j5r\S\ 4Sj5r\S\ S\\4Sj5r\\R.S4S\S\\\\4S\\S\4Sjj5r\S\S\4Sj5r\S \S\\4Sj5r\S\S \S\4Sj5r \S\S\\\\4S\!4Sj5r"\S\4Sj5r#\S\$S\$4Sj5r%\S\&S\$4Sj5r'\S \S\\$4Sj5r(\S\$S \S\$4S j5r)\S\&4S!j5r*\S\&S\\ 4S"j5r+S#r,g)$AdminClientInterface!zE An admin client for Pub/Sub Lite. Only operates on a single region. returncg)zThe region this client is for.N)selfs Alib/third_party/google/cloud/pubsublite/admin_client_interface.pyregionAdminClientInterface.region&topiccg)z*Create a topic, returns the created topic.Nr)rr!s r create_topic!AdminClientInterface.create_topic*rr topic_pathcg)z%Get the topic object from the server.Nrrr%s r get_topicAdminClientInterface.get_topic.rr cg)z3Get the number of partitions in the provided topic.Nrr's rget_topic_partition_count.AdminClientInterface.get_topic_partition_count2rr location_pathcg)zJList the Pub/Sub lite topics that exist for a project in a given location.Nrrr-s r list_topics AdminClientInterface.list_topics6rr update_maskcg)z/Update the masked fields of the provided topic.Nr)rr!r2s r update_topic!AdminClientInterface.update_topic:rr cg)z+Delete a topic and all associated messages.Nrr's r delete_topic!AdminClientInterface.delete_topic>rr cg)z4List the subscriptions that exist for a given topic.Nrr's rlist_topic_subscriptions-AdminClientInterface.list_topic_subscriptionsBrr N subscriptiontargetstarting_offsetcg)aCreate 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)rr<r=r>s rcreate_subscription(AdminClientInterface.create_subscriptionFrr subscription_pathcg)z,Get the subscription object from the server.NrrrBs rget_subscription%AdminClientInterface.get_subscriptionYrr cg)zQList the Pub/Sub lite subscriptions that exist for a project in a given location.Nrr/s rlist_subscriptions'AdminClientInterface.list_subscriptions]rr cg)z6Update the masked fields of the provided subscription.Nr)rr<r2s rupdate_subscription(AdminClientInterface.update_subscriptionarr cg)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)rrBr=s rseek_subscription&AdminClientInterface.seek_subscriptiongrr cg)z2Delete a subscription and all associated messages.NrrDs rdelete_subscription(AdminClientInterface.delete_subscriptionyrr reservationcg)z6Create a reservation, returns the created reservation.Nr)rrSs rcreate_reservation'AdminClientInterface.create_reservation}rr reservation_pathcg)z+Get the reservation object from the server.NrrrWs rget_reservation$AdminClientInterface.get_reservationrr cg)zPList the Pub/Sub lite reservations that exist for a project in a given location.Nrr/s rlist_reservations&AdminClientInterface.list_reservationsrr cg)z5Update the masked fields of the provided reservation.Nr)rrSr2s rupdate_reservation'AdminClientInterface.update_reservationrr cg)z1Delete a reservation and all associated messages.NrrYs rdelete_reservation'AdminClientInterface.delete_reservationrr cg)z:List the subscriptions that exist for a given reservation.NrrYs rlist_reservation_topics,AdminClientInterface.list_reservation_topicsrr r)-__name__ __module__ __qualname____firstlineno____doc__rr rrr#r r(intr+r rr0rr4r7r r:r ENDrrrrrr@rErHrKrrNrQrrUrrZr]r`rcrf__static_attributes__rr rrr!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 iIIr rN)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_pb2rrrr rrwsA$((/@GG=vI3vIr