
    'XhT                     d    d Z ddlZddlmZ  G d de      Z G d de      Zd	 Z G d
 de      Z	y)zEClient and server classes corresponding to protobuf-defined services.    N   )collections_pb2c                       e Zd ZdZd Zy)CollectionsStub8Missing associated documentation comment in .proto file.c                 n   |j                  dt        j                  j                  t        j                  j
                        | _        |j                  dt        j                  j                  t        j                  j
                        | _	        |j                  dt        j                  j                  t        j                  j
                        | _        |j                  dt        j                  j                  t        j                  j
                        | _        |j                  dt        j                  j                  t        j                  j
                        | _        |j                  dt        j"                  j                  t        j                  j
                        | _        |j                  dt        j&                  j                  t        j(                  j
                        | _        |j                  d	t        j,                  j                  t        j(                  j
                        | _        |j                  d
t        j0                  j                  t        j2                  j
                        | _        |j                  dt        j6                  j                  t        j8                  j
                        | _        |j                  dt        j<                  j                  t        j>                  j
                        | _         |j                  dt        jB                  j                  t        jD                  j
                        | _#        |j                  dt        jH                  j                  t        jJ                  j
                        | _&        y)zIConstructor.

        Args:
            channel: A grpc.Channel.
        /qdrant.Collections/Get)request_serializerresponse_deserializer/qdrant.Collections/List/qdrant.Collections/Create/qdrant.Collections/Update/qdrant.Collections/Delete!/qdrant.Collections/UpdateAliases)/qdrant.Collections/ListCollectionAliases/qdrant.Collections/ListAliases)/qdrant.Collections/CollectionClusterInfo$/qdrant.Collections/CollectionExists0/qdrant.Collections/UpdateCollectionClusterSetup"/qdrant.Collections/CreateShardKey"/qdrant.Collections/DeleteShardKeyN)'unary_unarycollections__pb2GetCollectionInfoRequestSerializeToStringGetCollectionInfoResponse
FromStringGetListCollectionsRequestListCollectionsResponseListCreateCollectionCollectionOperationResponseCreateUpdateCollectionUpdateDeleteCollectionDeleteChangeAliasesUpdateAliasesListCollectionAliasesRequestListAliasesResponseListCollectionAliasesListAliasesRequestListAliasesCollectionClusterInfoRequestCollectionClusterInfoResponseCollectionClusterInfoCollectionExistsRequestCollectionExistsResponseCollectionExists#UpdateCollectionClusterSetupRequest$UpdateCollectionClusterSetupResponseUpdateCollectionClusterSetupCreateShardKeyRequestCreateShardKeyResponseCreateShardKeyDeleteShardKeyRequestDeleteShardKeyResponseDeleteShardKey)selfchannels     Y/RAG/venv/lib/python3.12/site-packages/qdrant_client/grpc/collections_service_pb2_grpc.py__init__zCollectionsStub.__init__   s    &&)#3#L#L#^#^&6&P&P&[&[ ' 
 ''*#3#J#J#\#\&6&N&N&Y&Y ( 	
 )),#3#D#D#V#V&6&R&R&]&] * 
 )),#3#D#D#V#V&6&R&R&]&] * 
 )),#3#D#D#V#V&6&R&R&]&] * 
 %003#3#A#A#S#S&6&R&R&]&] 1 
 &-%8%8;#3#P#P#b#b&6&J&J&U&U &9 &"
 #..1#3#F#F#X#X&6&J&J&U&U / 
 &-%8%8;#3#P#P#b#b&6&T&T&_&_ &9 &"
 !( 3 36#3#K#K#]#]&6&O&O&Z&Z !4 !
 -4,?,?B#3#W#W#i#i&6&[&[&f&f -@ -)
 &114#3#I#I#[#[&6&M&M&X&X 2 
 &114#3#I#I#[#[&6&M&M&X&X 2     N)__name__
__module____qualname____doc__rB    rC   rA   r   r      s    BFrC   r   c                   ^    e Zd ZdZd Zd Zd Zd Zd Zd Z	d Z
d	 Zd
 Zd Zd Zd Zd Zy)CollectionsServicerr   c                     |j                  t        j                  j                         |j	                  d       t        d      )zN
        Get detailed information about specified existing collection
        Method not implemented!set_codegrpc
StatusCodeUNIMPLEMENTEDset_detailsNotImplementedErrorr?   requestcontexts      rA   r   zCollectionsServicer.GetW   7     	66756!";<<rC   c                     |j                  t        j                  j                         |j	                  d       t        d      )z;
        Get list name of all existing collections
        rL   rM   rT   s      rA   r!   zCollectionsServicer.List_   rW   rC   c                     |j                  t        j                  j                         |j	                  d       t        d      )z=
        Create new collection with given parameters
        rL   rM   rT   s      rA   r$   zCollectionsServicer.Createg   rW   rC   c                     |j                  t        j                  j                         |j	                  d       t        d      )z>
        Update parameters of the existing collection
        rL   rM   rT   s      rA   r&   zCollectionsServicer.Updateo   rW   rC   c                     |j                  t        j                  j                         |j	                  d       t        d      )z9
        Drop collection and all associated data
        rL   rM   rT   s      rA   r(   zCollectionsServicer.Deletew   rW   rC   c                     |j                  t        j                  j                         |j	                  d       t        d      )z;
        Update Aliases of the existing collection
        rL   rM   rT   s      rA   r*   z!CollectionsServicer.UpdateAliases   rW   rC   c                     |j                  t        j                  j                         |j	                  d       t        d      )z:
        Get list of all aliases for a collection
        rL   rM   rT   s      rA   r-   z)CollectionsServicer.ListCollectionAliases   rW   rC   c                     |j                  t        j                  j                         |j	                  d       t        d      )zF
        Get list of all aliases for all existing collections
        rL   rM   rT   s      rA   r/   zCollectionsServicer.ListAliases   rW   rC   c                     |j                  t        j                  j                         |j	                  d       t        d      )z:
        Get cluster information for a collection
        rL   rM   rT   s      rA   r2   z)CollectionsServicer.CollectionClusterInfo   rW   rC   c                     |j                  t        j                  j                         |j	                  d       t        d      )z5
        Check the existence of a collection
        rL   rM   rT   s      rA   r5   z$CollectionsServicer.CollectionExists   rW   rC   c                     |j                  t        j                  j                         |j	                  d       t        d      )z7
        Update cluster setup for a collection
        rL   rM   rT   s      rA   r8   z0CollectionsServicer.UpdateCollectionClusterSetup   rW   rC   c                     |j                  t        j                  j                         |j	                  d       t        d      )z"
        Create shard key
        rL   rM   rT   s      rA   r;   z"CollectionsServicer.CreateShardKey   rW   rC   c                     |j                  t        j                  j                         |j	                  d       t        d      )z"
        Delete shard key
        rL   rM   rT   s      rA   r>   z"CollectionsServicer.DeleteShardKey   rW   rC   N)rD   rE   rF   rG   r   r!   r$   r&   r(   r*   r-   r/   r2   r5   r8   r;   r>   rH   rC   rA   rJ   rJ   T   sF    B=============rC   rJ   c                    t        j                  | j                  t        j                  j
                  t        j                  j                        t        j                  | j                  t        j                  j
                  t        j                  j                        t        j                  | j                  t        j                  j
                  t        j                  j                        t        j                  | j                  t        j                  j
                  t        j                  j                        t        j                  | j                   t        j"                  j
                  t        j                  j                        t        j                  | j$                  t        j&                  j
                  t        j                  j                        t        j                  | j(                  t        j*                  j
                  t        j,                  j                        t        j                  | j.                  t        j0                  j
                  t        j,                  j                        t        j                  | j2                  t        j4                  j
                  t        j6                  j                        t        j                  | j8                  t        j:                  j
                  t        j<                  j                        t        j                  | j>                  t        j@                  j
                  t        jB                  j                        t        j                  | jD                  t        jF                  j
                  t        jH                  j                        t        j                  | jJ                  t        jL                  j
                  t        jN                  j                        d}t        jP                  d|      }|jS                  |f       y )N)request_deserializerresponse_serializer)r   r!   r$   r&   r(   r*   r-   r/   r2   r5   r8   r;   r>   zqdrant.Collections)*rO   unary_unary_rpc_method_handlerr   r   r   r   r   r   r!   r   r    r$   r"   r#   r&   r%   r(   r'   r*   r)   r-   r+   r,   r/   r.   r2   r0   r1   r5   r3   r4   r8   r6   r7   r;   r9   r:   r>   r<   r=   method_handlers_generic_handleradd_generic_rpc_handlers)servicerserverrpc_method_handlersgeneric_handlers       rA   !add_CollectionsServicer_to_serverrn      s   66LL)9)R)R)])](8(R(R(d(d
 77MM)9)P)P)[)[(8(P(P(b(b
 99OO)9)J)J)U)U(8(T(T(f(f
 99OO)9)J)J)U)U(8(T(T(f(f
 99OO)9)J)J)U)U(8(T(T(f(f
 "@@**)9)G)G)R)R(8(T(T(f(f
 &*%H%H22)9)V)V)a)a(8(L(L(^(^&
  >>(()9)L)L)W)W(8(L(L(^(^
 &*%H%H22)9)V)V)a)a(8(V(V(h(h&
 !% C C--)9)Q)Q)\)\(8(Q(Q(c(c!
 -1,O,O99)9)])])h)h(8(](](o(o-
 #AA++)9)O)O)Z)Z(8(O(O(a(a
 #AA++)9)O)O)Z)Z(8(O(O(a(a{BF :: "57O
##_$67rC   c                      e Zd ZdZe	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Z	e	 	 	 	 	 	 	 	 dd       Z
e	 	 	 	 	 	 	 	 dd	       Ze	 	 	 	 	 	 	 	 dd
       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Ze	 	 	 	 	 	 	 	 dd       Zy)Collectionsr   Nc
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr	   )rO   experimentalr   r   r   r   r   r   
rU   targetoptionschannel_credentialscall_credentialsinsecurecompressionwait_for_readytimeoutmetadatas
             rA   r   zCollections.Get  sX       ,,Wf>W55GG66AA(&^Wh	X 	XrC   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )rO   rr   r   r   r   r   r    r   rs   s
             rA   r!   zCollections.List  sX       ,,Wf>X33EE44??(&^Wh	X 	XrC   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )rO   rr   r   r   r"   r   r#   r   rs   s
             rA   r$   zCollections.Create/  X       ,,Wf>Z--??88CC(&^Wh	X 	XrC   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )rO   rr   r   r   r%   r   r#   r   rs   s
             rA   r&   zCollections.Update@  r   rC   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )rO   rr   r   r   r'   r   r#   r   rs   s
             rA   r(   zCollections.DeleteQ  r   rC   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )rO   rr   r   r   r)   r   r#   r   rs   s
             rA   r*   zCollections.UpdateAliasesb  sX       ,,Wf>a**<<88CC(&^Wh	X 	XrC   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )rO   rr   r   r   r+   r   r,   r   rs   s
             rA   r-   z!Collections.ListCollectionAliasess  sX       ,,Wf>i99KK00;;(&^Wh	X 	XrC   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )rO   rr   r   r   r.   r   r,   r   rs   s
             rA   r/   zCollections.ListAliases  sX       ,,Wf>_//AA00;;(&^Wh	X 	XrC   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )rO   rr   r   r   r0   r   r1   r   rs   s
             rA   r2   z!Collections.CollectionClusterInfo  sX       ,,Wf>i99KK::EE(&^Wh	X 	XrC   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )rO   rr   r   r   r3   r   r4   r   rs   s
             rA   r5   zCollections.CollectionExists  sX       ,,Wf>d44FF55@@(&^Wh	X 	XrC   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )rO   rr   r   r   r6   r   r7   r   rs   s
             rA   r8   z(Collections.UpdateCollectionClusterSetup  sX       ,,Wf>p@@RRAALL(&^Wh	X 	XrC   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )rO   rr   r   r   r9   r   r:   r   rs   s
             rA   r;   zCollections.CreateShardKey  X       ,,Wf>b22DD33>>(&^Wh	X 	XrC   c
                     t         j                  j                  | |dt        j                  j
                  t        j                  j                  ||||||||	      S )Nr   )rO   rr   r   r   r<   r   r=   r   rs   s
             rA   r>   zCollections.DeleteShardKey  r   rC   )rH   NNFNNNN)rD   rE   rF   rG   staticmethodr   r!   r$   r&   r(   r*   r-   r/   r2   r5   r8   r;   r>   rH   rC   rA   rp   rp   
  ss   B  $!X X    $!X X    $!X X    $!X X    $!X X    $!X X    $!X X    $!X X    $!X X    $!X X    $!X X    $!X X    $!X XrC   rp   )
rG   rO    r   r   objectr   rJ   rn   rp   rH   rC   rA   <module>r      sC    K  1If IXi=& i=XF8T^X& ^XrC   