
    Ng                        d dl mZmZmZmZmZmZmZ d dlm	Z	 d dl
m	Z	 d dlmZ d dlT d dlmZ  ej        d          Z edd	          Zeeeef                  Zeeeef         ef         Zd
Zde	dededefdZ	 	 	 	 	 	 ddedeeef         dedededefdZerd dlmZ  G d d          Z G d de          Z G d de          Z d
S )     )IOTYPE_CHECKINGAnyDictSetTypeVarUnion)	BaseModel)VERSION)*)modelsz2.Modelr
   )boundNmodelargskwargsreturnc                 D    t           r | j        |i |S  | j        |i |S N)PYDANTIC_V2model_dump_jsonjson)r   r   r   s      b/var/www/html/ai-engine/env/lib/python3.11/site-packages/qdrant_client/http/api/collections_api.pyto_jsonr      s9     +$u$d5f555uz4*6***    Tobjincludeby_aliasskip_defaultsexclude_unsetexclude_nonec           	          t          | d          st          | d          r$t          | |||t          |p|          |          S | S )Nr   r   )r   excluder   r    r!   )hasattrr   bool)r   r   r#   r   r   r    r!   s          r   jsonable_encoderr&      se     sF 
ws,=>> 
}=>>%
 
 
 	
 Jr   )	ApiClientc                      e Zd Zd3dZdefdZdefdZ	 	 d4deded	ej	        fd
Z
	 	 	 d5dedededej        fdZ	 	 d4dededej        fdZ	 d6dededefdZ	 d6dedefdZ	 d6dedefdZ	 	 d4dedededefdZ	 	 d4dededej        fdZ	 d6dedededefdZ	 d6dededefdZdefdZdefdZd Zd Zdededefd Zdedefd!Zdedefd"Zdefd#Z 	 	 d4deded$ej!        fd%Z"	 	 	 	 d7deded&e#d'ed(e$e%         f
d)Z&	 	 d4dededed*ej'        fd+Z(	 	 	 	 d7dededed&e#d'ed(e$e%         fd,Z)	 	 d4ded-ej*        fd.Z+	 	 d4deded/ej,        fd0Z-	 	 d4deded1ej.        fd2Z/dS )8_CollectionsApi
api_client Union[ApiClient, AsyncApiClient]c                     || _         d S r   )r*   )selfr*   s     r   __init__z_CollectionsApi.__init__4   s    $r   collection_namec                     dt          |          i}i }| j                            t          j        dd|r|nd|          S ):
        Get cluster information for a collection
        r/   GET&/collections/{collection_name}/clusterNtype_methodurlheaderspath_params)strr*   requestmInlineResponse2008r-   r/   r9   r8   s       r   "_build_for_collection_cluster_infoz2_CollectionsApi._build_for_collection_cluster_info7   Y     s?33
 &&&8&0GGD# ' 
 
 	
r   c                     dt          |          i}i }| j                            t          j        dd|r|nd|          S )[
        Returns "true" if the given collection name exists, and "false" otherwise
        r/   r2   z%/collections/{collection_name}/existsNr4   )r:   r*   r;   r<   InlineResponse2007r>   s       r   _build_for_collection_existsz,_CollectionsApi._build_for_collection_existsK   sY     s?33
 &&&7&0GGD# ' 
 
 	
r   Ntimeoutcreate_collectionc           	          dt          |          i}i }|t          |          |d<   i }t          |          }d|vrd|d<   | j                            t          j        dd|r|nd|||          S )	=
        Create new collection with given parameters
        r/   NrE   Content-Typeapplication/jsonPUT/collections/{collection_name}r5   r6   r7   r8   r9   paramscontentr:   r&   r*   r;   r<   InlineResponse200)r-   r/   rE   rF   r9   query_paramsr8   bodys           r   _build_for_create_collectionz,_CollectionsApi._build_for_create_collection_   s     s?33
 &)'llL# 122((&8GN#&&%0&0GGD# ' 
 
 	
r   waitorderingcreate_field_indexc           	      .   dt          |          i}i }|$t          |                                          |d<   |t          |          |d<   i }t          |          }d|vrd|d<   | j                            t
          j        dd|r|nd|||	          S )
6
        Create index for field in collection
        r/   NrU   rV   rI   rJ   rK   z$/collections/{collection_name}/indexrM   )r:   lowerr&   r*   r;   r<   InlineResponse2006)	r-   r/   rU   rV   rW   r9   rR   r8   rS   s	            r   _build_for_create_field_indexz-_CollectionsApi._build_for_create_field_index~   s     s?33
 #&t99??#4#4L '*8}}L$ 233((&8GN#&&&6&0GGD# ' 
 
 	
r   create_sharding_keyc           	          dt          |          i}i }|t          |          |d<   i }t          |          }d|vrd|d<   | j                            t          j        dd|r|nd |||          S )Nr/   rE   rI   rJ   rK   z%/collections/{collection_name}/shardsrM   rP   )r-   r/   rE   r]   r9   rR   r8   rS   s           r   _build_for_create_shard_keyz+_CollectionsApi._build_for_create_shard_key   s     s?33
 &)'llL# 344((&8GN#&&%7&0GGD# ' 
 
 	
r   shard_idc                     t          |          t          |          d}i }|$t          |                                          |d<   i }| j                            t          j        dd|r|nd||          S )A
        Create new snapshot of a shard for a collection
        r/   r`   NrU   POST:/collections/{collection_name}/shards/{shard_id}/snapshotsr5   r6   r7   r8   r9   rN   r:   rZ   r*   r;   r<   InlineResponse20011)r-   r/   r`   rU   r9   rR   r8   s          r    _build_for_create_shard_snapshotz0_CollectionsApi._build_for_create_shard_snapshot   s      #?33H
 

 #&t99??#4#4L &&'L&0GGD# ' 
 
 	
r   c                     dt          |          i}i }|$t          |                                          |d<   i }| j                            t          j        dd|r|nd||          S )6
        Create new snapshot for a collection
        r/   NrU   rd   (/collections/{collection_name}/snapshotsrf   rg   )r-   r/   rU   r9   rR   r8   s         r   _build_for_create_snapshotz*_CollectionsApi._build_for_create_snapshot   s     s?33
 #&t99??#4#4L &&':&0GGD# ' 
 
 	
r   c                     dt          |          i}i }|t          |          |d<   i }| j                            t          j        dd|r|nd||          S )9
        Drop collection and all associated data
        r/   NrE   DELETErL   rf   )r:   r*   r;   r<   rQ   )r-   r/   rE   r9   rR   r8   s         r   _build_for_delete_collectionz,_CollectionsApi._build_for_delete_collection   sw     s?33
 &)'llL#&&%0&0GGD# ' 
 
 	
r   
field_namec                    t          |          t          |          d}i }|$t          |                                          |d<   |t          |          |d<   i }| j                            t          j        dd|r|nd||          S )3
        Delete field index for collection
        )r/   rr   NrU   rV   rp   z1/collections/{collection_name}/index/{field_name}rf   )r:   rZ   r*   r;   r<   r[   )r-   r/   rr   rU   rV   r9   rR   r8   s           r   _build_for_delete_field_indexz-_CollectionsApi._build_for_delete_field_index  s      #?33j//
 

 #&t99??#4#4L '*8}}L$&&&C&0GGD# ' 
 
 	
r   drop_sharding_keyc           	          dt          |          i}i }|t          |          |d<   i }t          |          }d|vrd|d<   | j                            t          j        dd|r|nd |||          S )Nr/   rE   rI   rJ   rd   z,/collections/{collection_name}/shards/deleterM   rP   )r-   r/   rE   rv   r9   rR   r8   rS   s           r   _build_for_delete_shard_keyz+_CollectionsApi._build_for_delete_shard_key+  s     s?33
 &)'llL# 122((&8GN#&&%>&0GGD# ' 
 
 	
r   snapshot_namec                    t          |          t          |          t          |          d}i }|$t          |                                          |d<   i }| j                            t          j        dd|r|nd||          S )=
        Delete snapshot of a shard for a collection
        r/   r`   ry   NrU   rp   J/collections/{collection_name}/shards/{shard_id}/snapshots/{snapshot_name}rf   r:   rZ   r*   r;   r<   rQ   )r-   r/   r`   ry   rU   r9   rR   r8   s           r    _build_for_delete_shard_snapshotz0_CollectionsApi._build_for_delete_shard_snapshotG  s      #?33H //
 
 #&t99??#4#4L &&%\&0GGD# ' 
 
 	
r   c                     t          |          t          |          d}i }|$t          |                                          |d<   i }| j                            t          j        dd|r|nd||          S )2
        Delete snapshot for a collection
        r/   ry   NrU   rp   8/collections/{collection_name}/snapshots/{snapshot_name}rf   r~   )r-   r/   ry   rU   r9   rR   r8   s          r   _build_for_delete_snapshotz*_CollectionsApi._build_for_delete_snapshote  s      #?33 //
 

 #&t99??#4#4L &&%J&0GGD# ' 
 
 	
r   c                     dt          |          i}i }| j                            t          j        dd|r|nd|          S )N
        Get detailed information about specified existing collection
        r/   r2   rL   Nr4   )r:   r*   r;   r<   InlineResponse2005r>   s       r   _build_for_get_collectionz)_CollectionsApi._build_for_get_collection  sY     s?33
 &&&0&0GGD# ' 
 
 	
r   c                     dt          |          i}i }| j                            t          j        dd|r|nd|          S ):
        Get list of all aliases for a collection
        r/   r2   z&/collections/{collection_name}/aliasesNr4   )r:   r*   r;   r<   InlineResponse2009r>   s       r   !_build_for_get_collection_aliasesz1_CollectionsApi._build_for_get_collection_aliases  r@   r   c                 ^    i }| j                             t          j        dd|r|nd          S );
        Get list name of all existing collections
        r2   z/collectionsNr5   r6   r7   r8   )r*   r;   r<   InlineResponse2004r-   r8   s     r   _build_for_get_collectionsz*_CollectionsApi._build_for_get_collections  s@     &&&&0GGD	 ' 
 
 	
r   c                 ^    i }| j                             t          j        dd|r|nd          S )>
        Get list of all existing collections aliases
        r2   z/aliasesNr   )r*   r;   r<   r   r   s     r   "_build_for_get_collections_aliasesz2_CollectionsApi._build_for_get_collections_aliases  s@     &&&&0GGD	 ' 
 
 	
r   c                     t          |          t          |          t          |          d}i }| j                            t          dd|r|nd|          S )T
        Download specified snapshot of a shard from a collection as a file
        r|   r2   r}   Nr4   r:   r*   r;   file)r-   r/   r`   ry   r9   r8   s         r   _build_for_get_shard_snapshotz-_CollectionsApi._build_for_get_shard_snapshot  sm      #?33H //
 
 &&\&0GGD# ' 
 
 	
r   c                     t          |          t          |          d}i }| j                            t          dd|r|nd|          S )I
        Download specified snapshot from a collection as a file
        r   r2   r   Nr4   r   )r-   r/   ry   r9   r8   s        r   _build_for_get_snapshotz'_CollectionsApi._build_for_get_snapshot  sd      #?33 //
 

 &&J&0GGD# ' 
 
 	
r   c                     t          |          t          |          d}i }| j                            t          j        dd|r|nd|          S )C
        Get list of snapshots for a shard of a collection
        rc   r2   re   Nr4   r:   r*   r;   r<   InlineResponse20010)r-   r/   r`   r9   r8   s        r   _build_for_list_shard_snapshotsz/_CollectionsApi._build_for_list_shard_snapshots  se      #?33H
 

 &&'L&0GGD# ' 
 
 	
r   c                     dt          |          i}i }| j                            t          j        dd|r|nd|          S )8
        Get list of snapshots for a collection
        r/   r2   rl   Nr4   r   r>   s       r   _build_for_list_snapshotsz)_CollectionsApi._build_for_list_snapshots	  sY     s?33
 &&':&0GGD# ' 
 
 	
r   snapshot_recoverc           	         dt          |          i}i }|$t          |                                          |d<   i }t          |          }d|vrd|d<   | j                            t
          j        dd|r|nd|||          S )	
        Recover local collection data from a snapshot. This will overwrite any data, stored on this node, for the collection. If collection does not exist - it will be created.
        r/   NrU   rI   rJ   rK   z0/collections/{collection_name}/snapshots/recoverrM   r:   rZ   r&   r*   r;   r<   rQ   )r-   r/   rU   r   r9   rR   r8   rS   s           r    _build_for_recover_from_snapshotz0_CollectionsApi._build_for_recover_from_snapshot  s     s?33
 #&t99??#4#4L  011((&8GN#&&%B&0GGD# ' 
 
 	
r   prioritychecksumsnapshotc           
      >   dt          |          i}i }|$t          |                                          |d<   |t          |          |d<   |t          |          |d<   i }i }	i }
|||	d<   | j                            t          j        dd|r|nd|||
|		          S )

        Recover local collection data from an uploaded snapshot. This will overwrite any data, stored on this node, for the collection. If collection does not exist - it will be created.
        r/   NrU   r   r   r   rd   z//collections/{collection_name}/snapshots/uploadr5   r6   r7   r8   r9   rN   datafilesr~   )r-   r/   rU   r   r   r   r9   rR   r8   r   r   s              r   )_build_for_recover_from_uploaded_snapshotz9_CollectionsApi._build_for_recover_from_uploaded_snapshot<  s     s?33
 #&t99??#4#4L '*8}}L$'*8}}L$$&! (E*&&%A&0GGD# ' 	
 	
 		
r   shard_snapshot_recoverc           	      "   t          |          t          |          d}i }|$t          |                                          |d<   i }t          |          }d|vrd|d<   | j                            t
          j        dd|r|nd|||          S )	
        Recover shard of a local collection data from a snapshot. This will overwrite any data, stored in this shard, for the collection.
        rc   NrU   rI   rJ   rK   zB/collections/{collection_name}/shards/{shard_id}/snapshots/recoverrM   r   )	r-   r/   r`   rU   r   r9   rR   r8   rS   s	            r   &_build_for_recover_shard_from_snapshotz6_CollectionsApi._build_for_recover_shard_from_snapshotd  s      #?33H
 

 #&t99??#4#4L  677((&8GN#&&%T&0GGD# ' 
 
 	
r   c           
      Z   t          |          t          |          d}i }|$t          |                                          |d<   |t          |          |d<   |t          |          |d<   i }	i }
i }|||
d<   | j                            t          j        dd|	r|	nd||||
	          S )

        Recover shard of a local collection from an uploaded snapshot. This will overwrite any data, stored on this node, for the collection shard.
        rc   NrU   r   r   r   rd   zA/collections/{collection_name}/shards/{shard_id}/snapshots/uploadr   r~   )r-   r/   r`   rU   r   r   r   r9   rR   r8   r   r   s               r   /_build_for_recover_shard_from_uploaded_snapshotz?_CollectionsApi._build_for_recover_shard_from_uploaded_snapshot  s      #?33H
 

 #&t99??#4#4L '*8}}L$'*8}}L$$&! (E*&&%S&0GGD# ' 	
 	
 		
r   change_aliases_operationc                     i }|t          |          |d<   i }t          |          }d|vrd|d<   | j                            t          j        dd|r|nd ||          S )NrE   rI   rJ   rd   z/collections/aliases)r5   r6   r7   r8   rN   rO   rP   )r-   rE   r   rR   r8   rS   s         r   _build_for_update_aliasesz)_CollectionsApi._build_for_update_aliases  s    
 &)'llL# 899((&8GN#&&%&&0GGD ' 
 
 	
r   update_collectionc           	          dt          |          i}i }|t          |          |d<   i }t          |          }d|vrd|d<   | j                            t          j        dd|r|nd|||          S )	>
        Update parameters of the existing collection
        r/   NrE   rI   rJ   PATCHrL   rM   rP   )r-   r/   rE   r   r9   rR   r8   rS   s           r   _build_for_update_collectionz,_CollectionsApi._build_for_update_collection  s     s?33
 &)'llL# 122((&8GN#&&%0&0GGD# ' 
 
 	
r   cluster_operationsc           	          dt          |          i}i }|t          |          |d<   i }t          |          }d|vrd|d<   | j                            t          j        dd|r|nd |||          S )Nr/   rE   rI   rJ   rd   r3   rM   rP   )r-   r/   rE   r   r9   rR   r8   rS   s           r   $_build_for_update_collection_clusterz4_CollectionsApi._build_for_update_collection_cluster  s     s?33
 &)'llL# 233((&8GN#&&%8&0GGD# ' 
 
 	
r   )r*   r+   NNNNNr   NNNN)0__name__
__module____qualname__r.   r:   r?   rD   intr<   CreateCollectionrT   r%   WriteOrderingCreateFieldIndexr\   CreateShardingKeyr_   ri   rm   rq   ru   DropShardingKeyrx   r   r   r   r   r   r   r   r   r   r   SnapshotRecoverr   SnapshotPriorityr   r   r   ShardSnapshotRecoverr   r   ChangeAliasesOperationr   UpdateCollectionr   ClusterOperationsr    r   r   r)   r)   3   s       % % % %

 
 
 
(

 
 
 
. 04	
 

 
 -	
 
 
 
D "&15 
  
 
  
  	 

 . 
  
  
  
J 37	
 

 
 0	
 
 
 
@ 	
 

 
 	
 
 
 
> 
 

 
 
 
 
: 
 

 
 
 
 
< "&
 

 
 	

  
 
 
 
D /3	
 

 
 ,	
 
 
 
B 
 

 
 	

 
 
 
 
D 	
 

 
 	
 
 
 
8

 
 
 
(

 
 
 
(
 
 

 
 


 
 	
 
 
 
0

 
 
 
 
,

 
 
 
 
,

 
 
 
. .2	
 

 
 +	
 
 
 
D %) &
 &
&
 &
 #	&

 &
 S'&
 &
 &
 &
X 9=
 

 
 	

 !" 6
 
 
 
J %) (
 (
(
 (
 	(

 #(
 (
 S'(
 (
 (
 (
X =A
 

 #$":
 
 
 
2 04	
 

 
 -	
 
 
 
D 26	
 

 
 /	
 
 
 
 
 
r   r)   c                   8   e Zd Zdedej        fdZdedej        fdZ	 	 d1dede	dej
        dej        fdZ	 	 	 d2ded	ed
edej        dej        f
dZ	 	 d1dede	dej        dej        fdZ	 d3dede	d	edej        fdZ	 d3ded	edej        fdZ	 d3dede	dej        fdZ	 	 d1deded	ed
edej        f
dZ	 	 d1dede	dej        dej        fdZ	 d3dede	ded	edej        f
dZ	 d3deded	edej        fdZdedej        fdZdedej        fdZ dej!        fdZ"dej        fdZ#dede	dede$fdZ%dedede$fdZ&dede	dej'        fd Z(dedej'        fd!Z)	 	 d1ded	ed"ej*        dej        fd#Z+	 	 	 	 d4ded	ed$e,d%ed&e-e.         dej        fd'Z/	 	 d1dede	d	ed(ej0        dej        f
d)Z1	 	 	 	 d4dede	d	ed$e,d%ed&e-e.         dej        fd*Z2	 	 d1de	d+ej3        dej        fd,Z4	 	 d1dede	d-ej5        dej        fd.Z6	 	 d1dede	d/ej7        dej        fd0Z8dS )5AsyncCollectionsApir/   r   c                 >   K   |                      |           d{V S )r1   r/   Nr?   r-   r/   s     r   collection_cluster_infoz+AsyncCollectionsApi.collection_cluster_info  sF       <<+ = 
 
 
 
 
 
 
 
 	
r   c                 >   K   |                      |           d{V S )rB   r   NrD   r   s     r   collection_existsz%AsyncCollectionsApi.collection_exists  sF       66+ 7 
 
 
 
 
 
 
 
 	
r   NrE   rF   c                 B   K   |                      |||           d{V S )rH   r/   rE   rF   NrT   r-   r/   rE   rF   s       r   rF   z%AsyncCollectionsApi.create_collection  L       66+/ 7 
 
 
 
 
 
 
 
 	
r   rU   rV   rW   c                 D   K   |                      ||||           d{V S )rY   r/   rU   rV   rW   Nr\   r-   r/   rU   rV   rW   s        r   rW   z&AsyncCollectionsApi.create_field_index'  sO       77+1	 8 
 
 
 
 
 
 
 
 	
r   r]   c                 B   K   |                      |||           d {V S N)r/   rE   r]   r_   r-   r/   rE   r]   s       r   create_shard_keyz$AsyncCollectionsApi.create_shard_key8  sL       55+ 3 6 
 
 
 
 
 
 
 
 	
r   r`   c                 B   K   |                      |||           d{V S )rb   r/   r`   rU   Nri   r-   r/   r`   rU   s       r   create_shard_snapshotz)AsyncCollectionsApi.create_shard_snapshotD  sL       ::+ ; 
 
 
 
 
 
 
 
 	
r   c                 @   K   |                      ||           d{V S )rk   r/   rU   Nrm   r-   r/   rU   s      r   create_snapshotz#AsyncCollectionsApi.create_snapshotS  sI       44+ 5 
 
 
 
 
 
 
 
 	
r   c                 @   K   |                      ||           d{V S )ro   r/   rE   Nrq   r-   r/   rE   s      r   delete_collectionz%AsyncCollectionsApi.delete_collection`  sI       66+ 7 
 
 
 
 
 
 
 
 	
r   rr   c                 D   K   |                      ||||           d{V S )rt   r/   rr   rU   rV   Nru   r-   r/   rr   rU   rV   s        r   delete_field_indexz&AsyncCollectionsApi.delete_field_indexm  sO       77+!	 8 
 
 
 
 
 
 
 
 	
r   rv   c                 B   K   |                      |||           d {V S N)r/   rE   rv   rx   r-   r/   rE   rv   s       r   delete_shard_keyz$AsyncCollectionsApi.delete_shard_key~  sL       55+/ 6 
 
 
 
 
 
 
 
 	
r   ry   c                 D   K   |                      ||||           d{V S )r{   r/   r`   ry   rU   Nr   r-   r/   r`   ry   rU   s        r   delete_shard_snapshotz)AsyncCollectionsApi.delete_shard_snapshot  sO       ::+'	 ; 
 
 
 
 
 
 
 
 	
r   c                 B   K   |                      |||           d{V S )r   r/   ry   rU   Nr   r-   r/   ry   rU   s       r   delete_snapshotz#AsyncCollectionsApi.delete_snapshot  sL       44+' 5 
 
 
 
 
 
 
 
 	
r   c                 >   K   |                      |           d{V S )r   r   Nr   r   s     r   get_collectionz"AsyncCollectionsApi.get_collection  F       33+ 4 
 
 
 
 
 
 
 
 	
r   c                 >   K   |                      |           d{V S )r   r   Nr   r   s     r   get_collection_aliasesz*AsyncCollectionsApi.get_collection_aliases  sF       ;;+ < 
 
 
 
 
 
 
 
 	
r   c                 :   K   |                                   d{V S )r   Nr   r-   s    r   get_collectionsz#AsyncCollectionsApi.get_collections  s,       44666666666r   c                 :   K   |                                   d{V S )r   Nr   r  s    r   get_collections_aliasesz+AsyncCollectionsApi.get_collections_aliases  s,       <<>>>>>>>>>r   c                 B   K   |                      |||           d{V S )r   r|   Nr   r-   r/   r`   ry   s       r   get_shard_snapshotz&AsyncCollectionsApi.get_shard_snapshot  sL       77+' 8 
 
 
 
 
 
 
 
 	
r   c                 @   K   |                      ||           d{V S )r   r   Nr   r-   r/   ry   s      r   get_snapshotz AsyncCollectionsApi.get_snapshot  sI       11+' 2 
 
 
 
 
 
 
 
 	
r   c                 @   K   |                      ||           d{V S )r   rc   Nr   r-   r/   r`   s      r   list_shard_snapshotsz(AsyncCollectionsApi.list_shard_snapshots  sI       99+ : 
 
 
 
 
 
 
 
 	
r   c                 >   K   |                      |           d{V S )r   r   Nr   r   s     r   list_snapshotsz"AsyncCollectionsApi.list_snapshots  r  r   r   c                 B   K   |                      |||           d{V S )r   r/   rU   r   Nr   r-   r/   rU   r   s       r   recover_from_snapshotz)AsyncCollectionsApi.recover_from_snapshot  sL       ::+- ; 
 
 
 
 
 
 
 
 	
r   r   r   r   c                 F   K   |                      |||||           d{V S )r   r/   rU   r   r   r   Nr   r-   r/   rU   r   r   r   s         r   recover_from_uploaded_snapshotz2AsyncCollectionsApi.recover_from_uploaded_snapshot  sS       CC+ D 
 
 
 
 
 
 
 
 	
r   r   c                 D   K   |                      ||||           d{V S )r   r/   r`   rU   r   Nr   r-   r/   r`   rU   r   s        r   recover_shard_from_snapshotz/AsyncCollectionsApi.recover_shard_from_snapshot&  sP       @@+#9	 A 
 
 
 
 
 
 
 
 	
r   c                 H   K   |                      ||||||           d{V S )r   r/   r`   rU   r   r   r   Nr   r-   r/   r`   rU   r   r   r   s          r   $recover_shard_from_uploaded_snapshotz8AsyncCollectionsApi.recover_shard_from_uploaded_snapshot7  sV       II+ J 
 
 
 
 
 
 
 
 	
r   r   c                 @   K   |                      ||           d {V S N)rE   r   r   r-   rE   r   s      r   update_aliasesz"AsyncCollectionsApi.update_aliasesL  sI      
 33%= 4 
 
 
 
 
 
 
 
 	
r   r   c                 B   K   |                      |||           d{V S )r   r/   rE   r   Nr   r-   r/   rE   r   s       r   r   z%AsyncCollectionsApi.update_collectionV  r   r   r   c                 B   K   |                      |||           d {V S N)r/   rE   r   r   r-   r/   rE   r   s       r   update_collection_clusterz-AsyncCollectionsApi.update_collection_clustere  sL       >>+1 ? 
 
 
 
 
 
 
 
 	
r   r   r   r   r   9r   r   r   r:   r<   r=   r   rC   r   r   r   rQ   rF   r%   r   r   r[   rW   r   r   rh   r   r   r   r  r   r	  r  r  r   r  r   r  r   r  r!  r   r%  r)  r   r-  r0  r   r5  r   r   r   r:  r   r?  rD  r   rI  r   r   r   rR  r   r   r   r   r     s       	
	
 
		
 	
 	
 	
	
	
 
		
 	
 	
 	
 04	
 

 
 -	

 
	
 
 
 
$ "&15
 

 
  	

 .
 
	
 
 
 
( 37	

 



 

 0	


 
	

 

 

 

  	
 

 
 	

 
	
 
 
 
$ 
 

 
 
		
 
 
 
  
 

 
 
		
 
 
 
" "&
 

 
 	

  
 
	
 
 
 
( /3	

 



 

 ,	


 
	

 

 

 

" 
 

 
 	

 
 
	
 
 
 
* 	
 

 
 	

 
	
 
 
 
	
	
 
		
 	
 	
 	
	
	
 
		
 	
 	
 	
7	
	7 7 7 7?	
	? ? ? ?

 
 	

 

 
 
 


 
 
	
 
 
 


 
 
		
 
 
 
	
	
 
		
 	
 	
 	
 .2	
 

 
 +	

 
	
 
 
 
$ %) 
 

 
 #	

 
 S'
 
	
 
 
 
. 9=
 

 
 	

 !" 6
 
	
 
 
 
* %) 
 

 
 	

 #
 
 S'
 
	
 
 
 
. =A
 

 #$":
 
		
 
 
 
 04	
 

 
 -	

 
	
 
 
 
$ 26	

 



 

 /	


 
	

 

 

 

 

 

r   r   c                   8   e Zd Zdedej        fdZdedej        fdZ	 	 d1dede	dej
        dej        fdZ	 	 	 d2ded	ed
edej        dej        f
dZ	 	 d1dede	dej        dej        fdZ	 d3dede	d	edej        fdZ	 d3ded	edej        fdZ	 d3dede	dej        fdZ	 	 d1deded	ed
edej        f
dZ	 	 d1dede	dej        dej        fdZ	 d3dede	ded	edej        f
dZ	 d3deded	edej        fdZdedej        fdZdedej        fdZ dej!        fdZ"dej        fdZ#dede	dede$fdZ%dedede$fdZ&dede	dej'        fd Z(dedej'        fd!Z)	 	 d1ded	ed"ej*        dej        fd#Z+	 	 	 	 d4ded	ed$e,d%ed&e-e.         dej        fd'Z/	 	 d1dede	d	ed(ej0        dej        f
d)Z1	 	 	 	 d4dede	d	ed$e,d%ed&e-e.         dej        fd*Z2	 	 d1de	d+ej3        dej        fd,Z4	 	 d1dede	d-ej5        dej        fd.Z6	 	 d1dede	d/ej7        dej        fd0Z8dS )5SyncCollectionsApir/   r   c                 .    |                      |          S )r1   r   r   r   s     r   r   z*SyncCollectionsApi.collection_cluster_infos  s$     66+ 7 
 
 	
r   c                 .    |                      |          S )rB   r   r   r   s     r   r   z$SyncCollectionsApi.collection_exists~  s$     00+ 1 
 
 	
r   NrE   rF   c                 2    |                      |||          S )rH   r   r   r   s       r   rF   z$SyncCollectionsApi.create_collection  *     00+/ 1 
 
 	
r   rU   rV   rW   c                 4    |                      ||||          S )rY   r   r   r   s        r   rW   z%SyncCollectionsApi.create_field_index  s-     11+1	 2 
 
 	
r   r]   c                 2    |                      |||          S r   r   r   s       r   r   z#SyncCollectionsApi.create_shard_key  s*     //+ 3 0 
 
 	
r   r`   c                 2    |                      |||          S )rb   r   r   r   s       r   r   z(SyncCollectionsApi.create_shard_snapshot  s*     44+ 5 
 
 	
r   c                 0    |                      ||          S )rk   r   r   r   s      r   r   z"SyncCollectionsApi.create_snapshot  s'     ..+ / 
 
 	
r   c                 0    |                      ||          S )ro   r   r   r   s      r   r   z$SyncCollectionsApi.delete_collection  s'     00+ 1 
 
 	
r   rr   c                 4    |                      ||||          S )rt   r  r  r  s        r   r  z%SyncCollectionsApi.delete_field_index  s-     11+!	 2 
 
 	
r   rv   c                 2    |                      |||          S r  r  r  s       r   r	  z#SyncCollectionsApi.delete_shard_key  s*     //+/ 0 
 
 	
r   ry   c                 4    |                      ||||          S )r{   r  r  r  s        r   r  z(SyncCollectionsApi.delete_shard_snapshot  s-     44+'	 5 
 
 	
r   c                 2    |                      |||          S )r   r  r  r  s       r   r  z"SyncCollectionsApi.delete_snapshot  s*     ..+' / 
 
 	
r   c                 .    |                      |          S )r   r   r  r   s     r   r  z!SyncCollectionsApi.get_collection  $     --+ . 
 
 	
r   c                 .    |                      |          S )r   r   r  r   s     r   r  z)SyncCollectionsApi.get_collection_aliases&  s$     55+ 6 
 
 	
r   c                 *    |                                  S )r   r  r  s    r   r  z"SyncCollectionsApi.get_collections1  s     ..000r   c                 *    |                                  S )r   r   r  s    r   r!  z*SyncCollectionsApi.get_collections_aliases9  s     66888r   c                 2    |                      |||          S )r   r|   r#  r$  s       r   r%  z%SyncCollectionsApi.get_shard_snapshotA  s*     11+' 2 
 
 	
r   c                 0    |                      ||          S )r   r   r'  r(  s      r   r)  zSyncCollectionsApi.get_snapshotP  s'     +++' , 
 
 	
r   c                 0    |                      ||          S )r   rc   r+  r,  s      r   r-  z'SyncCollectionsApi.list_shard_snapshots]  s'     33+ 4 
 
 	
r   c                 .    |                      |          S )r   r   r/  r   s     r   r0  z!SyncCollectionsApi.list_snapshotsj  rd  r   r   c                 2    |                      |||          S )r   r2  r3  r4  s       r   r5  z(SyncCollectionsApi.recover_from_snapshotu  s*     44+- 5 
 
 	
r   r   r   r   c                 6    |                      |||||          S )r   r7  r8  r9  s         r   r:  z1SyncCollectionsApi.recover_from_uploaded_snapshot  s0     ==+ > 
 
 	
r   r   c                 4    |                      ||||          S )r   r<  r=  r>  s        r   r?  z.SyncCollectionsApi.recover_shard_from_snapshot  s-     ::+#9	 ; 
 
 	
r   c                 8    |                      ||||||          S )r   rA  rB  rC  s          r   rD  z7SyncCollectionsApi.recover_shard_from_uploaded_snapshot  s4     CC+ D 
 
 	
r   r   c                 0    |                      ||          S rF  rG  rH  s      r   rI  z!SyncCollectionsApi.update_aliases  s'    
 --%= . 
 
 	
r   r   c                 2    |                      |||          S )r   rK  rL  rM  s       r   r   z$SyncCollectionsApi.update_collection  rY  r   r   c                 2    |                      |||          S rO  rP  rQ  s       r   rR  z,SyncCollectionsApi.update_collection_cluster  s*     88+1 9 
 
 	
r   r   r   r   r   rS  r   r   r   rU  rU  r  s       	
	
 
		
 	
 	
 	
	
	
 
		
 	
 	
 	
 04	
 

 
 -	

 
	
 
 
 
$ "&15
 

 
  	

 .
 
	
 
 
 
( 37	

 



 

 0	


 
	

 

 

 

  	
 

 
 	

 
	
 
 
 
$ 
 

 
 
		
 
 
 
  
 

 
 
		
 
 
 
" "&
 

 
 	

  
 
	
 
 
 
( /3	

 



 

 ,	


 
	

 

 

 

" 
 

 
 	

 
 
	
 
 
 
* 	
 

 
 	

 
	
 
 
 
	
	
 
		
 	
 	
 	
	
	
 
		
 	
 	
 	
1	
	1 1 1 19	
	9 9 9 9

 
 	

 

 
 
 


 
 
	
 
 
 


 
 
		
 
 
 
	
	
 
		
 	
 	
 	
 .2	
 

 
 +	

 
	
 
 
 
$ %) 
 

 
 #	

 
 S'
 
	
 
 
 
. 9=
 

 
 	

 !" 6
 
	
 
 
 
* %) 
 

 
 	

 #
 
 S'
 
	
 
 
 
. =A
 

 #$":
 
		
 
 
 
 04	
 

 
 -	

 
	
 
 
 
$ 26	

 



 

 /	


 
	

 

 

 

 

 

r   rU  )NNTNTT)!typingr   r   r   r   r   r   r	   pydanticr
   pydantic.mainpydantic.versionr   PYDANTIC_VERSIONqdrant_client.http.modelsr   r<   
startswithr   r   r   r:   	SetIntStrDictIntStrAnyr   r   r%   r&   qdrant_client.http.api_clientr'   r)   r   rU  r   r   r   <module>r}     sA   D D D D D D D D D D D D D D D D D D       # # # # # # 8 8 8 8 8 8 ' ' ' ' 1 1 1 1 1 1))$//{+++c3h 	U38_c)*+9 +S +C +C + + + + 04 	9m+, 	
      ,  8777777K
 K
 K
 K
 K
 K
 K
 K
\n
 n
 n
 n
 n
/ n
 n
 n
bn
 n
 n
 n
 n
 n
 n
 n
 n
 n
r   