
    c                         S SK JrJrJr  S SKJr  S SKJr  S SKJ	r	  S SK
Jr  S SKJr  S SKJr  S SKJr  S S	KJr  S S
KJrJrJrJrJrJrJr  S SKJr  S SKJrJ r J!r!J"r"   " S S\\5      r#g)    )OptionalListUnion)ClientOptions)	Operation)Credentials)	FieldMask)AdminClientInterface)ConstructableFromServiceAccount)regional_endpoint)AdminClientImpl)CloudRegionSubscriptionPathLocationPath	TopicPathBacklogLocationPublishTime	EventTime)ReservationPath)AdminServiceClientSubscriptionTopicReservationc            
       "   \ rS rSr% Sr\\S'      S*S\S\\	   S\\
   S\\   4S	 jjrS
\4S jrS\S
\4S jrS\S
\4S jrS\S
\4S jrS\S
\\   4S jrS\S\S
\4S jrS\4S jrS\S
\\   4S jr\R:                  S4S\S\\\ \!4   S\\   S
\4S jjr"S\S
\4S jr#S\S
\\   4S jr$S\S\S
\4S jr%S\S\\\ \!4   S
\&4S jr'S\4S  jr(S!\)S
\)4S" jr*S#\+S
\)4S$ jr,S\S
\\)   4S% jr-S!\)S\S
\)4S& jr.S#\+4S' jr/S#\+S
\\   4S( jr0S)r1g)+AdminClient.   zE
An admin client for Pub/Sub Lite. Only operates on a single region.
_implNregioncredentials	transportclient_optionsc                 b    Uc  [        [        U5      S9n[        [        UUUS9U5      U l        g)a  
Create a new AdminClient.

Args:
    region: The cloud region to connect to.
    credentials: The credentials to use when connecting.
    transport: The transport to use.
    client_options: The client options to use when connecting. If used, must explicitly set `api_endpoint`.
N)api_endpoint)r!   r    r   )r   r   r   r   r   )selfr   r   r    r!   s        7lib/third_party/google/cloud/pubsublite/admin_client.py__init__AdminClient.__init__5   s<      !*8I&8QRN$-#'
 

    returnc                 6    U R                   R                  5       $ N)r   r   )r$   s    r%   r   AdminClient.regionP   s    zz  ""r(   topicc                 8    U R                   R                  U5      $ r+   )r   create_topic)r$   r-   s     r%   r/   AdminClient.create_topicS   s    zz&&u--r(   
topic_pathc                 8    U R                   R                  U5      $ r+   )r   	get_topicr$   r1   s     r%   r3   AdminClient.get_topicV   s    zz##J//r(   c                 8    U R                   R                  U5      $ r+   )r   get_topic_partition_countr4   s     r%   r7   %AdminClient.get_topic_partition_countY   s    zz33J??r(   location_pathc                 8    U R                   R                  U5      $ r+   )r   list_topicsr$   r9   s     r%   r;   AdminClient.list_topics\   s    zz%%m44r(   update_maskc                 8    U R                   R                  X5      $ r+   )r   update_topic)r$   r-   r>   s      r%   r@   AdminClient.update_topic_   s    zz&&u::r(   c                 8    U R                   R                  U5      $ r+   )r   delete_topicr4   s     r%   rC   AdminClient.delete_topicb   s    zz&&z22r(   c                 8    U R                   R                  U5      $ r+   )r   list_topic_subscriptionsr4   s     r%   rF   $AdminClient.list_topic_subscriptionse   s    zz22:>>r(   subscriptiontargetstarting_offsetc                 :    U R                   R                  XU5      $ r+   )r   create_subscription)r$   rH   rI   rJ   s       r%   rL   AdminClient.create_subscriptionh   s     zz--lOTTr(   subscription_pathc                 8    U R                   R                  U5      $ r+   )r   get_subscriptionr$   rN   s     r%   rP   AdminClient.get_subscriptionp   s    zz**+<==r(   c                 8    U R                   R                  U5      $ r+   )r   list_subscriptionsr<   s     r%   rT   AdminClient.list_subscriptionss   s    zz,,];;r(   c                 8    U R                   R                  X5      $ r+   )r   update_subscription)r$   rH   r>   s      r%   rW   AdminClient.update_subscriptionv   s     zz--lHHr(   c                 8    U R                   R                  X5      $ r+   )r   seek_subscription)r$   rN   rI   s      r%   rZ   AdminClient.seek_subscription{   s    
 zz++,=FFr(   c                 8    U R                   R                  U5      $ r+   )r   delete_subscriptionrQ   s     r%   r]   AdminClient.delete_subscription   s    zz--.?@@r(   reservationc                 8    U R                   R                  U5      $ r+   )r   create_reservation)r$   r_   s     r%   ra   AdminClient.create_reservation   s    zz,,[99r(   reservation_pathc                 8    U R                   R                  U5      $ r+   )r   get_reservationr$   rc   s     r%   re   AdminClient.get_reservation   s    zz))*:;;r(   c                 8    U R                   R                  U5      $ r+   )r   list_reservationsr<   s     r%   ri   AdminClient.list_reservations   s    zz++M::r(   c                 8    U R                   R                  X5      $ r+   )r   update_reservation)r$   r_   r>   s      r%   rl   AdminClient.update_reservation   s     zz,,[FFr(   c                 8    U R                   R                  U5      $ r+   )r   delete_reservationrf   s     r%   ro   AdminClient.delete_reservation   s    zz,,-=>>r(   c                 8    U R                   R                  U5      $ r+   )r   list_reservation_topicsrf   s     r%   rr   #AdminClient.list_reservation_topics   s     zz112BCCr(   )r   )NNN)2__name__
__module____qualname____firstlineno____doc__r
   __annotations__r   r   r   strr   r&   r   r   r/   r   r3   intr7   r   r   r;   r	   r@   rC   r   rF   r   ENDr   r   r   r   rL   rP   rT   rW   r   rZ   r]   r   ra   r   re   ri   rl   ro   rr   __static_attributes__ r(   r%   r   r   .   sV     
 .2#'26

 k*
 C=	

 !/
6# #.% .E .0I 0% 0@I @# @5 5$u+ 5;% ;i ;E ;3y 3?9 ?FVAW ? BQATAT59	U"U o{I=>U "/2	U
 
U>2B >| >< <lAS <I(I7@I	I
G+G o{I=>G 
	GA5E A:k :k :< <K <;| ;[@Q ;G&G5>G	G
?? ?D /D	iDr(   r   N)$typingr   r   r   google.api_core.client_optionsr   google.api_core.operationr   google.auth.credentialsr   'cloudsdk.google.protobuf.field_mask_pb2r	   .google.cloud.pubsublite.admin_client_interfacer
   Cgoogle.cloud.pubsublite.internal.constructable_from_service_accountr   *google.cloud.pubsublite.internal.endpointsr   7google.cloud.pubsublite.internal.wire.admin_client_implr   google.cloud.pubsublite.typesr   r   r   r   r   r   r   #google.cloud.pubsublite.types.pathsr   google.cloud.pubsublite_v1r   r   r   r   r   r~   r(   r%   <module>r      s]    ) ( 8 / / = O I S   @ kD&(G kDr(   