+
    i"                       ^ RI Ht ^ RIHtHtHt ^ RIHu Ht	 ^ RI
Ht ^ RIHt ^ RIHt ^ RIHt ^ RIHt ^ R	IHt RR
 R lltRR R lltRR R lltRR R lltRR R lltRR R lltRRRRRR/R R lltRRRRRR/R R lltR# )     )annotations)AsyncIterableIterableOptionalN)protos)get_default_retriever_client)"get_default_retriever_async_client)helper_types)idecode_time)retriever_typesc          
     ,    V ^8  d   QhRRRRRRRRRR	/# )
   name
str | Nonedisplay_nameclient!glm.RetrieverServiceClient | Nonerequest_options&helper_types.RequestOptionsType | Nonereturnretriever_types.Corpus )formats   "p/Users/igloo/.openclaw/workspace/scratch/fb_ad_env/lib/python3.14/site-packages/google/generativeai/retriever.py__annotate__r      s:     ) )
)) .) <	)
 )    c                    Vf   / pVf   \        4       pV f   \        P                  ! VR7      pMk\        P                  ! V 4      '       d   \        P                  ! RV  2VR7      pM3\        \        P                  P                  \        V 4      V R7      4      h\        P                  ! VR7      pVP                  ! V3/ VB p\        V4      P                  V4      p\        VR4       \        VR4       \        P                  ! R/ VB pV# )	a  Calls the API to create a new `Corpus` by specifying either a corpus resource name as an ID or a display name, and returns the created `Corpus`.

Args:
    name: The corpus resource name (ID). The name must be alphanumeric and fewer
        than 40 characters.
    display_name: The human readable display name. The display name must be fewer
        than 128 characters. All characters, including alphanumeric, spaces, and
        dashes are supported.
    request_options: Options for the request.

Return:
    `retriever_types.Corpus` object with specified name or display name.

Raises:
    ValueError: When the name is not specified or formatted incorrectly.
r   corpora/r   r   lengthr   corpuscreate_timeupdate_timer   )r   r   Corpusr   
valid_name
ValueErrorNAME_ERROR_MSGr   lenCreateCorpusRequestcreate_corpustypeto_dictr   r   r   r   r   r$   requestresponses   &&&&   r   r-   r-      s    , ~-/|L9		#	#D	)	)htf$5LQ77>>c$iVZ>[\\((7G##G??HH~%%h/H=)=)%%11HOr   c          
     ,    V ^8  d   QhRRRRRRRRRR	/# )
r   r   r   r   r   &glm.RetrieverServiceAsyncClient | Noner   r   r   r   r   )r   s   "r   r   r   J   s:      
 3 <	
 r   c                <  "   Vf   / pVf   \        4       pV f   \        P                  ! VR7      pMk\        P                  ! V 4      '       d   \        P                  ! RV  2VR7      pM3\        \        P                  P                  \        V 4      V R7      4      h\        P                  ! VR7      pVP                  ! V3/ VB G Rj  xL
 p\        V4      P                  V4      p\        VR4       \        VR4       \        P                  ! R	/ VB pV#  LN5i)
z7This is the async version of `retriever.create_corpus`.Nr   r   r    r!   r#   r%   r&   r   )r	   r   r'   r   r(   r)   r*   r   r+   r,   r-   r.   r/   r   r0   s   &&&&   r   create_corpus_asyncr6   J   s      ~35|L9		#	#D	)	)htf$5LQ77>>c$iVZ>[\\((7G))'E_EEHH~%%h/H=)=)%%11HO Fs   ADA<DDADc               (    V ^8  d   QhRRRRRRRR/# )	r   r   strr   r   r   r   r   r   r   )r   s   "r   r   r   g   s0      
- < 	r   c                2   Vf   / pVf   \        4       pRV 9  d
   RV ,           p \        P                  ! V R7      pVP                  ! V3/ VB p\	        V4      P                  V4      p\        VR4       \        VR4       \        P                  ! R/ VB pV# )zCalls the API to fetch a `Corpus` by name and returns the `Corpus`.

Args:
    name: The `Corpus` name.
    request_options: Options for the request.

Return:
    a `retriever_types.Corpus` of interest.
/r   r   r%   r&   r   )	r   r   GetCorpusRequest
get_corpusr.   r/   r   r   r'   r   r   r   r1   r2   s   &&&  r   r=   r=   g   s     ~-/
$D %%40G  <O<HH~%%h/H=)=)%%11HOr   c               (    V ^8  d   QhRRRRRRRR/# )	r   r   r8   r   r4   r   r   r   r   r   )r   s   "r   r   r      s0      
2 < 	r   c                N  "   Vf   / pVf   \        4       pRV 9  d
   RV ,           p \        P                  ! V R7      pVP                  ! V3/ VB G Rj  xL
 p\	        V4      P                  V4      p\        VR4       \        VR4       \        P                  ! R/ VB pV#  LN5i)z4This is the async version of `retriever.get_corpus`.Nr:   r   r;   r%   r&   r   )	r	   r   r<   r=   r.   r/   r   r   r'   r>   s   &&&  r   get_corpus_asyncrA      s      ~35
$D %%40G&&wB/BBHH~%%h/H=)=)%%11HO Cs   AB%B#AB%c               (    V ^8  d   QhRRRRRRRR/# )	r   r   r8   forceboolr   r   r   r   r   )r   s   "r   r   r      s0     5 5
55 .5 <	5r   c                    Vf   / pVf   \        4       pRV 9  d
   RV ,           p \        P                  ! WR7      pVP                  ! V3/ VB  R# )aN  Calls the API to remove a `Corpus` from the service, optionally deleting associated `Document`s and objects if the `force` parameter is set to true.

Args:
    name: The `Corpus` name.
    force: If set to true, any `Document`s and objects related to this `Corpus` will also be deleted.
    request_options: Options for the request.

Nr:   r   r   rC   )r   r   DeleteCorpusRequestdelete_corpusr   rC   r   r   r1   s   &&&& r   rH   rH      sP     ~-/
$D ((d@G
4O4r   c               (    V ^8  d   QhRRRRRRRR/# )	r   r   r8   rC   rD   r   r4   r   r   r   )r   s   "r   r   r      s0     ; ;
;; 3; <	;r   c                   "   Vf   / pVf   \        4       pRV 9  d
   RV ,           p \        P                  ! WR7      pVP                  ! V3/ VB G Rj  xL
  R#  L5i)z7This is the async version of `retriever.delete_corpus`.Nr:   r   rF   )r	   r   rG   rH   rI   s   &&&& r   delete_corpus_asyncrL      sY      ~35
$D ((d@G


w
:/
:::s   AAAA	page_sizer   r   c               (    V ^8  d   QhRRRRRRRR/# )	r   rM   Optional[int]r   r   r   r   r   z Iterable[retriever_types.Corpus]r   )r   s   "r   r   r      s2     / // ./ <	/
 &/r   c              #  ,  "   Vf   / pVf   \        4       p\        P                  ! V R7      pVP                  ! V3/ VB  FM  p\	        V4      P                  V4      p\        VR4       \        VR4       \        P                  ! R/ VB x  KO  	  R# 5i)a=  Calls the API to list all `Corpora` in the service and returns a list of paginated `Corpora`.

Args:
    page_size: Maximum number of `Corpora` to request.
    page_token: A page token, received from a previous ListCorpora call.
    request_options: Options for the request.

Return:
    Paginated list of `Corpora`.
NrM   r%   r&   r   )	r   r   ListCorporaRequestlist_corporar.   r/   r   r   r'   rM   r   r   r1   r$   s   $$$  r   rS   rS      s       ~-/'')<G%%gAAf%%f-V]+V]+$$.v..	 Bs   BBc               (    V ^8  d   QhRRRRRRRR/# )	r   rM   rO   r   r   r   r   r   z%AsyncIterable[retriever_types.Corpus]r   )r   s   "r   r   r      s2     / // ./ <	/
 +/r   c               R  "   Vf   / pVf   \        4       p\        P                  ! V R7      pVP                  ! V3/ VB G Rj  xL
   Rj  xL
  p\	        V4      P                  V4      p\        VR4       \        VR4       \        P                  ! R/ VB 5x  KW   L[ LTDUR# 5i)z6This is the async version of `retriever.list_corpora`.NrQ   r%   r&   r   )	r	   r   rR   rS   r.   r/   r   r   r'   rT   s   $$$  r   list_corpora_asyncrW      s      ~35'')<G$11'M_MMM / /ff%%f-V]+V]+$$.v..	 N /Ms7   AB'B B'	B$B"B$AB'"B$$B')NNNN)NN)FNN)
__future__r   typingr   r   r   google.ai.generativelanguageaigenerativelanguageglmgoogle.generativeair   google.generativeai.clientr   r	   google.generativeai.typesr
   %google.generativeai.types.model_typesr   r   r-   r6   r=   rA   rH   rL   rS   rW   r   r   r   <module>rb      s    # 5 4 * * & C I 2 > 5)X:@256;(/#/ 15/ ?C	/</#/ 15/ ?C	/ /r   