
    NgJ                       d dl mZm Z mZ d dlmZmZ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 n# e$ r Y nw xY wd dlmZ d dlmZmZmZmZ d dlmZ d d	lmZm Z  d d
l!m"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e#ef         dee#ef         fdZ(dee#ef         dee#ef         fdZ)dej*        dej+        fdZ,dej+        dej*        fdZ- G d d          Z. G d d          Z/dS )    )datedatetimetimezone)	AnyDictListMappingOptionalSequenceTupleUnionget_args)MessageToDict)	Timestamp)MessageMapContainer)grpc)	ListValue	NullValueStructValue)models)	constructto_jsonable_python)get_args_subscribedmessagefieldreturnc                     	 |                      |          S # t          $ r2 t          d |                                 D                       }||v cY S w xY w)a  
    Same as protobuf HasField, but also works for primitive values
    (https://stackoverflow.com/questions/51918871/check-if-a-field-has-been-set-in-protocol-buffer-3)

    Args:
        message (Any): protobuf message
        field (str): name of the field
    c                 "    g | ]\  }}|j         S  name).0
descriptor_values      `/var/www/html/ai-engine/env/lib/python3.11/site-packages/qdrant_client/conversions/conversion.py
<listcomp>zhas_field.<locals>.<listcomp>   s    YYY.@j&*/YYY    )HasField
ValueErrorset
ListFields)r   r   
all_fieldss      r&   	has_fieldr.      so    #&&& # # #YYGDVDVDXDXYYYZZ

""""#s    9AApayloadc           	      T   | t          t          j                  S t          | t                    rt          |           S t          | t
                    rt          |           S t          | t                    rt          |           S t          | t                    rt          |           S t          | t          t          f          r(t          t          d | D                                 S t          | t                    rGt          t          t          d	 |                                 D                       
                    S t          | t                    st          | t                    rt          t!          |                     S t#          d|            )N)
null_value)
bool_valueinteger_value)double_valuestring_valuec                 ,    g | ]}t          |          S r    json_to_value)r#   vs     r&   r'   z!json_to_value.<locals>.<listcomp>/   s     1T1T1Tq-2B2B1T1T1Tr(   )values)
list_valuec              3   >   K   | ]\  }}|t          |          fV  d S Nr9   )r#   kr;   s      r&   	<genexpr>z json_to_value.<locals>.<genexpr>2   s3      +^+^daQa0@0@,A+^+^+^+^+^+^r(   fields)struct_valuezNot supported json value: )r   r   
NULL_VALUE
isinstanceboolintfloatstrlisttupler   dictr   itemsr   r   r   r*   r/   s    r&   r:   r:   #   s   	 45555'4   )(((('3 ,7++++'5!! +'****'3 +'****'D%=)) W	1T1TG1T1T1T U U UVVVV'4   
t+^+^gmmoo+^+^+^'^'^___
 
 
 	
 '8$$ ?
7D(A(A ?"4W"="=>>>>
;';;
<
<<r(   valuec                    t          | t                    rt          | d          }n| }d|v rt          |d                   S d|v r|d         S d|v r|d         S d|v r|d         S d|v rCd|d         vri S t	          d	 |d         d                                         D                       S d
|v r1d|d
         v r%t          d |d
         d         D                       S g S d|v rd S t          d|           )NF)preserving_proto_field_nameintegerValuedoubleValuestringValue	boolValuestructValuerC   c              3   >   K   | ]\  }}|t          |          fV  d S r?   value_to_jsonr#   keyvals      r&   rA   z value_to_json.<locals>.<genexpr>L   sD       
 
*2#sS-$$%
 
 
 
 
 
r(   	listValuer<   c              3   4   K   | ]}t          |          V  d S r?   rY   )r#   r]   s     r&   rA   z value_to_json.<locals>.<genexpr>Q   s*      TTsc**TTTTTTr(   	nullValuezNot supported value: )rF   r   r   rH   rM   rN   rK   r*   )rP   value_s     r&   rZ   rZ   9   sc   % u%HHH 6.)***m$$m$$fk""6-000I 
 
6<]6KH6U6[6[6]6]
 
 
 
 
 	
 fvk***TTf[6I(6STTTTTTIft
5V55
6
66r(   c                 X    t          d |                                 D                       S )Nc              3   >   K   | ]\  }}|t          |          fV  d S r?   r9   r[   s      r&   rA   z"payload_to_grpc.<locals>.<genexpr>Z   s3      JJhc3mC(()JJJJJJr(   rM   rN   rO   s    r&   payload_to_grpcre   Y   s'    JJ'--//JJJJJJr(   grpc_c                 X    t          d |                                 D                       S )Nc              3   >   K   | ]\  }}|t          |          fV  d S r?   rY   r[   s      r&   rA   z"grpc_to_payload.<locals>.<genexpr>^   s3      HHhc3mC(()HHHHHHr(   rd   )rf   s    r&   grpc_to_payloadri   ]   s'    HH%++--HHHHHHr(   modelc                    | t           j        j        k    rt           j        j        S | t           j        j        k    rt           j        j        S | t           j        j        k    rt           j        j        S | t           j        j	        k    rt           j        j
        S | t           j        j        k    rt           j        j        S | t           j        j        k    rt           j        j        S | t           j        j        k    rt           j        j        S | t           j        j        k    rt           j        j        S t'          d|            Nz!invalid PayloadSchemaType model: )r   PayloadSchemaTypeKeyword	FieldTypeFieldTypeKeywordIntegerFieldTypeIntegerFloatFieldTypeFloatBoolFieldTypeBoolGeoFieldTypeGeoTextFieldTypeTextDatetimeFieldTypeDatetimeUuidFieldTypeUuidr*   rj   s    r&   !grpc_payload_schema_to_field_typer   a   s    &...~..&...~..&,,,~,,&+++~++&***~**&+++~++&///~//&+++~++
@@@
A
AAr(   c                    | t           j        j        k    rt           j        j        S | t           j        j        k    rt           j        j        S | t           j        j        k    rt           j        j        S | t           j        j	        k    rt           j        j
        S | t           j        j        k    rt           j        j        S | t           j        j        k    rt           j        j        S | t           j        j        k    rt           j        j        S | t           j        j        k    rt           j        j        S t'          d|            )Nzinvalid FieldType model: )r   ro   rp   rm   rn   rr   rq   rt   rs   rv   ru   rx   rw   rz   ry   r|   r{   r~   r}   r*   r   s    r&   !grpc_field_type_to_payload_schemar   v   s    ///%--///%-----%++,,,%**+++%)),,,%**000%..,,,%**
888
9
99r(   c            	          e Zd Zedej        dej        fd            Zedej        dej        fd            Z	edej
        dej
        fd            Zededefd            Zedej        dej        fd            Zedej        dej        fd            Zedej        dej        fd	            Zedej        dej        fd
            Zedej        dej        fd            Zedej        dej        fd            Zedej        dej        fd            Zedej        dej        fd            Zedej         dej!        fd            Z"edej#        dej#        fd            Z$edej%        dej&        fd            Z'ede(e)ej*        f         de(e)ej+        f         fd            Z,edej*        dej+        fd            Z-edej.        dej/        fd            Z0edej1        dej1        fd            Z2edej3        dej3        fd            Z4edej5        dej5        fd            Z6edej7        dej7        fd            Z8edej9        dej9        fd            Z:edej;        dej<        fd            Z=edej>        dej>        fd            Z?edej@        dej@        fd            ZAedejB        dejB        fd            ZCedejD        dejD        fd            ZEedejF        dejF        fd            ZGedejH        dejH        fd             ZIedejJ        dejJ        fd!            ZKedejL        dejL        fd"            ZMedejN        dejN        fd#            ZOedd$dejP        fd%            ZQedejR        dejR        fd&            ZSedejT        dejT        fd'            ZUedejV        dejV        fd(            ZWedejX        dejX        fd)            ZYedejZ        dejZ        fd*            Z[edej%        dej%        fd+            Z\edej]        dej]        fd,            Z^edej         dej         fd-            Z_edej`        dej`        fd.            Zaedejb        dejb        fd/            Zcedejd        dejd        fd0            Zeedejf        dejf        fd1            Zge	 ddejh        d3eiejj                 dejh        fd4            Zkedejl        dejm        fd5            Znedejl        dejm        fd6            Zoedejp        dejq        fd7            Zredejp        dejq        fd8            Zsedejt        dejt        fd9            Zuedejv        dejv        fd:            Zwedejx        dejx        fd;            Zyedejz        dejz        fd<            Z{edej|        dej|        fd=            Z}edej~        dej~        fd>            Zedej        dej        fd?            Zedej        deee         eee                  ej        f         fd@            Zedej        de(e)ej        f         fdA            Zedej        dej        fdB            Zedej        dee         fdC            Zedej        dej        fdD            Zedej        deee                  fdE            Zedej        dej        fdF            Zedej        dej        fdG            Zedej        dej        fdH            Zedej        dej        fdI            Zedej        dej        fdJ            Zedej        dej        fdK            Zedej        dej        fdL            Zedej        dej        fdM            Zedej        dej        fdN            Zedej        dee)         fdO            Zedej        dej        fdP            Zedej        dej        fdQ            Zedej        dej        fdR            Zedej        dej        fdS            Zedej        dej        fdT            Zedej        dej        fdU            Zedej        dej        fdV            Zedej        dej        fdW            Zedej        dej        fdX            Zedej        dej        fdY            Zedej        dej        fdZ            Zedej        dej        fd[            Zedej        dej        fd\            Zedej        dej        fd]            Zed^ej        dej        fd_            Zedej        dej        fd`            Zedej        dej        fda            Zedej        dej        fdb            Zedej        dej        fdc            Zedej        dej        fdd            Zedej        dej        fde            Zedej        dej        fdf            Zedej        dej        fdg            Zedej        dej        fdh            Zedej        dej        fdi            Zedej        dej        fdj            Zedej        dej        fdk            Zedej        dej        fdl            Zedej        dej        fdm            Zedej        dej        fdn            Zedej        dej        fdo            Zedej        dej        fdp            Zedej        dej        fdq            Zedej        dej        fdr            Zedej        dej        fds            Zedej        dej        fdt            Zedej        dej        fdu            Zede)dej        fdv            Zedej        dej        fdw            Zedej         dej        fdx            Zedej        dej        fdy            Zedej        dej        fdz            Zedej        de(e)ej        f         fd{            Zedej	        dej	        fd|            Z
edejj        dejj        fd}            Zedej        dej        fd~            Zedej        dej        fd            Zedej        dej        fd            Zedej        dej        fd            Zedej        dej        fd            Zedej        dej        fd            Zedej        dej        fd            Zedej        dej        fd            Zedej        dej        fd            Z edej!        dej"        fd            Z#d2S )
GrpcToRestrj   r   c                    |                     d          }|t          d|           t          ||          }|dk    r|                     |          S |dk    r|                     |          S |dk    r|                     |          S |dk    r|                     |          S |dk    r|                     |          S |dk    r|                     |          S t          d|           )	Ncondition_one_ofinvalid Condition model: r   filterhas_idis_emptyis_nullnested)	
WhichOneofr*   getattrconvert_field_conditionconvert_filterconvert_has_id_conditionconvert_is_empty_conditionconvert_is_null_conditionconvert_nested_conditionclsrj   r"   r]   s       r&   convert_conditionzGrpcToRest.convert_condition   s    233<@@@AAAeT""7??..s3338%%c***8//444:11#6669005558//444<U<<===r(   c           	      0    t          j         fd|j        D              fd|j        D              fd|j        D             |                    d          r6t          j         fd|j        j        D             |j        j	                  nd           S )Nc                 :    g | ]}                     |          S r    r   r#   	conditionr   s     r&   r'   z-GrpcToRest.convert_filter.<locals>.<listcomp>   s'    OOOy#''	22OOOr(   c                 :    g | ]}                     |          S r    r   r   s     r&   r'   z-GrpcToRest.convert_filter.<locals>.<listcomp>   s'    SSSC)))44SSSr(   c                 :    g | ]}                     |          S r    r   r   s     r&   r'   z-GrpcToRest.convert_filter.<locals>.<listcomp>   s'    WWW9c++I66WWWr(   
min_shouldc                 :    g | ]}                     |          S r    r   r   s     r&   r'   z-GrpcToRest.convert_filter.<locals>.<listcomp>   s7          % --i88     r(   
conditions	min_count)mustshouldmust_notr   )
restFilterr   r   r   r)   	MinShouldr   r   r   r   rj   s   ` r&   r   zGrpcToRest.convert_filter   s    {OOOOEJOOOSSSSelSSSWWWWWWW >>,//       ).)9)D      $.8    
 
 
 	
r(   c                    t          j        |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd           S Ngtgteltlte)r   r   r   r   )r   Ranger)   r   r   r   r   r   s     r&   convert_rangezGrpcToRest.convert_range   s    z >>$//9uxxT"^^E22<		 >>$//9uxxT"^^E22<			
 
 
 	
r(   c                 B    |                     t          j                  S )N)tzinfo)
ToDatetimer   utcr   s     r&   convert_timestampzGrpcToRest.convert_timestamp   s    x|444r(   c                    t          j        |                    d          r|                     |j                  nd |                    d          r|                     |j                  nd |                    d          r|                     |j                  nd |                    d          r|                     |j                  nd           S r   )r   DatetimeRanger)   r   r   r   r   r   r   s     r&   convert_datetime_rangez!GrpcToRest.convert_datetime_range   s    !27..2F2FPs$$UX...D49NN54I4IS%%ei000t27..2F2FPs$$UX...D49NN54I4IS%%ei000t	
 
 
 	
r(   c                 h    t          j        |                     |j                  |j                  S N)centerradius)r   	GeoRadiusconvert_geo_pointr   r   r   s     r&   convert_geo_radiuszGrpcToRest.convert_geo_radius   +    ~S%:%:5<%H%HQVQ]^^^^r(   c                 6    t          j        |j                  S Nr!   )r   CollectionDescriptionr"   r   s     r&   convert_collection_descriptionz)GrpcToRest.convert_collection_description        )uz::::r(   c           
      T   t          j        |                     |j                  |                     |j                  |                     |j                  |j        | 	                    |j
                  |                    d          r|j        nd |j        |j        pd          S )Nvectors_countr   )configoptimizer_statuspayload_schemasegments_countstatusr   points_countindexed_vectors_count)r   CollectionInfoconvert_collection_configr   convert_optimizer_statusr   convert_payload_schemar   r   convert_collection_statusr   r)   r   r   r   r   s     r&   convert_collection_infoz"GrpcToRest.convert_collection_info   s    "00>> 99%:PQQ55e6JKK /00>>161P1PZ%--VZ+"'"="B	
 	
 	
 		
r(   c                 f    |j         rt          j        j        S t          j        |j                  S )N)error)okr   OptimizersStatusOneOfOKOptimizersStatusOneOf1r   r   s     r&   r   z#GrpcToRest.convert_optimizer_status   s/    8 	B-00.U[AAAAr(   c           	      R   t          j        |                     |j                  |                     |j                  |                     |j                  |                     |j	                  |
                    d          r|                     |j                  nd           S )Nquantization_config)hnsw_configoptimizer_configparams
wal_configr   )r   CollectionConfigconvert_hnsw_configr   convert_optimizer_configr   convert_collection_paramsr   convert_wal_configr   r)   convert_quantization_configr   r   s     r&   r   z$GrpcToRest.convert_collection_config   s    $//0ABB 99%:PQQ00>>--e.>?? >>"788//0IJJJ

 

 

 
	
r(   c           
         t          j        |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd           S Nef_constructmfull_scan_thresholdmax_indexing_threadson_disk	payload_m)r   r   r   r   r   r   )	r   HnswConfigDiffr)   r   r   r   r   r   r   r   s     r&   convert_hnsw_config_diffz#GrpcToRest.convert_hnsw_config_diff   s    "/4~~n/M/MW++SW,,6egg$-2^^<Q-R-R\))X\ /4nn=S.T.T^**Z^%*^^I%>%>HEMMD).)D)DNeoo$
 
 
 	
r(   c           
         t          j        |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd           S r   )	r   
HnswConfigr)   r   r   r   r   r   r   r   s     r&   r   zGrpcToRest.convert_hnsw_config  s    /4~~n/M/MW++SW,,6egg$-2^^<Q-R-R\))X\ /4nn=S.T.T^**Z^%*^^I%>%>HEMMD).)D)DNeoo$
 
 
 	
r(   c                    t          j        |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j	        nd |                    d          r|j
        nd 	          S 
Ndefault_segment_numberdeleted_thresholdflush_interval_secindexing_thresholdmax_optimization_threadsmax_segment_sizememmap_thresholdvacuum_min_vector_numberr   r   r   r   r   r   r   r   )r   OptimizersConfigr)   r   r   r   r   r   r   r   r   r   s     r&   r   z#GrpcToRest.convert_optimizer_config  s   $05?W0X0Xb,,^b ,1>>:M+N+NX''TX -2NN;O,P,PZ((VZ -2NN;O,P,PZ((VZ >>"<==.. +0..9K*L*LV&&RV +0..9K*L*LV&&RV >>"<==..7
 
 
 	
r(   c                 V   |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j	        k    rt          j        j
        S t          d|           Nzinvalid Distance model: )r   DistanceCosiner   COSINEEuclidEUCLID	Manhattan	MANHATTANDotDOTr*   r   s     r&   convert_distancezGrpcToRest.convert_distance6  s    DM(((=''dm***=''dm---=**dm'''=$$???@@@r(   c                     t          j        |                    d          r|j        nd |                    d          r|j        nd           S Nwal_capacity_mbwal_segments_aheadr  r  )r   	WalConfigr)   r  r  r   s     r&   r   zGrpcToRest.convert_wal_configC  sW    ~5:^^DU5V5V`E11\`,1NN;O,P,PZ((VZ
 
 
 	
r(   c                 D      fd|                                 D             S )Nc                 B    i | ]\  }}|                     |          S r    )convert_payload_schema_info)r#   r\   infor   s      r&   
<dictcomp>z5GrpcToRest.convert_payload_schema.<locals>.<dictcomp>P  s-    ZZZysDS44T::ZZZr(   )rN   r   s   ` r&   r   z!GrpcToRest.convert_payload_schemaL  s(     [ZZZEKKMMZZZZr(   c                     t          j        |                     |j                  |                    d          r|                     |j                  nd |j                  S )Nr   	data_typer   points)r   PayloadIndexInfoconvert_payload_schema_typer  r)   convert_payload_schema_paramsr   r  r   s     r&   r  z&GrpcToRest.convert_payload_schema_infoR  sb    $55eoFF >>(++11%,???<
 
 
 	
r(   c                 6   |                     d          r|j        }|                     |          S |                     d          r|j        }|                     |          S |                     d          r|j        }|                     |          S |                     d          r|j        }|                     |          S |                     d          r|j	        }| 
                    |          S |                     d          r|j        }|                     |          S |                     d          r|j        }|                     |          S |                     d          r|j        }	|                     |	          S t#          d	|           )
Ntext_index_paramsinteger_index_paramskeyword_index_paramsfloat_index_paramsgeo_index_paramsbool_index_paramsdatetime_index_paramsuuid_index_paramsz"invalid PayloadIndexParams model: )r)   r   convert_text_index_paramsr!  convert_integer_index_paramsr"  convert_keyword_index_paramsr#  convert_float_index_paramsr$  convert_geo_index_paramsr%  convert_bool_index_paramsr&  convert_datetime_index_paramsr'  convert_uuid_index_paramsr*   )
r   rj   r   r!  r"  r#  r$  r%  r&  r'  s
             r&   r  z(GrpcToRest.convert_payload_schema_params^  s    >>-.. 	D % 7001BCCC>>011 	J#(#= 334HIII>>011 	J#(#= 334HIII>>.// 	F!&!9112DEEE>>,-- 	B$5//0@AAA>>-.. 	D % 7001BCCC>>122 	L$)$?!445JKKK>>-.. 	D % 7001BCCCEeEEFFFr(   c                    |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j	        k    rt          j        j
        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S t'          d|           rl   )r   rm   rs   r   FLOATrw   GEOrq   INTEGERrn   KEYWORDru   BOOLry   TEXTr{   DATETIMEr}   UUIDr*   r   s     r&   r  z&GrpcToRest.convert_payload_schema_type}  s   D*000)//d,000)--d,444)11d,444)11d,111)..d,111)..d,555)22d,111)..HHHIIIr(   c                 V   |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j	        k    rt          j        j
        S t          d|           Nz invalid CollectionStatus model: )r   CollectionStatusGreenr   GREENYellowYELLOWRedREDGreyGREYr*   r   s     r&   r   z$GrpcToRest.convert_collection_status  s    D)///(..d+222(//d+///(,,d+000(--CECCDDDr(   c                 h    t          j        |j        |                     |j                            S N)operation_idr   )r   UpdateResultrF  convert_update_statusr   r   s     r&   convert_update_resultz GrpcToRest.convert_update_result  s5     +,,U\::
 
 
 	
r(   c                     |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S t          d|           Nzinvalid UpdateStatus model: )r   UpdateStatusAcknowledgedr   ACKNOWLEDGED	Completed	COMPLETEDr*   r   s     r&   rH  z GrpcToRest.convert_update_status  sS    D%222$11d'111$..CECCDDDr(   c                 P     t          j         fd|j        D                       S )Nc                 :    g | ]}                     |          S r    convert_point_idr#   idxr   s     r&   r'   z7GrpcToRest.convert_has_id_condition.<locals>.<listcomp>  s'    *]*]*]3+?+?+D+D*]*]*]r(   r   )r   HasIdConditionr   r   s   ` r&   r   z#GrpcToRest.convert_has_id_condition  s0    "*]*]*]*]PUP\*]*]*]^^^^r(   c                     |                     d          }|dk    r|j        S |dk    r|j        S t          d|           )Npoint_id_optionsnumuuidzinvalid PointId model: )r   r[  r\  r*   )r   rj   r"   s      r&   rT  zGrpcToRest.convert_point_id  sO     2335==96>>::5::;;;r(   c                 6    t          j        |j                  S N)
alias_name)r   DeleteAliasr_  r   s     r&   convert_delete_aliaszGrpcToRest.convert_delete_alias      5+;<<<<r(   c                 B    t          j        |j        |j                  S N)old_alias_namenew_alias_name)r   RenameAliasre  rf  r   s     r&   convert_rename_aliaszGrpcToRest.convert_rename_alias  '     /@T
 
 
 	
r(   c                 \    t          j        t          j        |j                            S )Nr\   r   )r   IsEmptyConditionPayloadFieldr\   r   s     r&   r   z%GrpcToRest.convert_is_empty_condition  s&    $d.?EI.N.N.NOOOOr(   c                 \    t          j        t          j        |j                            S )Nrk  r   )r   IsNullConditionrn  r\   r   s     r&   r   z$GrpcToRest.convert_is_null_condition  s&    #D,=%),L,L,LMMMMr(   c                     t          j        t          j        |j        |                     |j                                      S )Nr\   r   r   )r   NestedConditionNestedr\   r   r   r   s     r&   r   z#GrpcToRest.convert_nested_condition  sH    #;I))%,77  
 
 
 	
r(   c                 8   t          j        |                    d          r|j        nd |                    d          r|j        nd |                    d          r|                     |j                  nd |                    d          r|j        nd           S )Nhnsw_efexactquantizationindexed_onlyrx  ry  rz  r{  )r   SearchParamsr)   rx  ry  "convert_quantization_search_paramsrz  r{  r   s     r&   convert_search_paramsz GrpcToRest.convert_search_params  s     %*^^I%>%>HEMMD!&!8!8B%++d >>.1166u7IJJJ/4~~n/M/MW++SW	
 	
 	
 		
r(   c                 B    t          j        |j        |j                  S N)collection_namer_  )r   CreateAliasr  r_  r   s     r&   convert_create_aliaszGrpcToRest.convert_create_alias      0ERWRbccccr(   c                     |                     d          }|t          d|           t          ||          }|dk    r|S |dk    r|S t          d|           )Nvariantinvalid OrderValue model: rH   rI   r   r*   r   r   s       r&   convert_order_valuezGrpcToRest.convert_order_value  ss    	**<A%AABBBeT""5==J7??J=e==>>>r(   c                    t          t          j        |                     |j                  t          |d          r|                     |j                  nd |j        |	                    d          r| 
                    |j                  nd |j        |	                    d          r|                     |j                  nd |	                    d          r|                     |j                  nd           S )Nr/   vectors	shard_keyorder_value)idr/   scorevectorversionr  r  )r   r   ScoredPointrT  r  r.   convert_payloadr/   r  r)   convert_vectorsr  r  convert_shard_keyr  r  r  r   s     r&   convert_scored_pointzGrpcToRest.convert_scored_point  s    ##EH--:CE9:U:U_C''666[_+9>	9R9R\3&&u}555X\M:?..:U:U_%%eo666[_ >>-00''(9:::
 
 
 	
r(   r   c                 :    t          fdD                       S )Nc              3   F   K   | ]}|t          |                   fV  d S r?   rY   )r#   r\   rj   s     r&   rA   z-GrpcToRest.convert_payload.<locals>.<genexpr>  s4      FFS-c
334FFFFFFr(   )rM   r   s    `r&   r  zGrpcToRest.convert_payload  s&    FFFFFFFFFFr(   c                    t          j        |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd           S r   )r   ValuesCountr)   r   r   r   r   r   s     r&   convert_values_countzGrpcToRest.convert_values_count  s     >>$//9uxxT"^^E22<		 >>$//9uxxT"^^E22<			
 
 
 	
r(   c                     t          j        |                     |j                  |                     |j                            S )N)bottom_righttop_left)r   GeoBoundingBoxr   r  r  r   s     r&   convert_geo_bounding_boxz#GrpcToRest.convert_geo_bounding_box  sC    "..u/ABB**5>::
 
 
 	
r(   c                     t          j        |                     |j                  |                     |j                  |                    d          r|                     |j                  nd           S )Nr  )r  r/   r  )	r   PointStructrT  r  r  r/   r)   r  r  r   s     r&   convert_point_structzGrpcToRest.convert_point_struct  sl    ##EH--''669>	9R9R\3&&u}555X\
 
 
 	
r(   c                    |                     d          r|                     |j                  nd }|                     d          r|                     |j                  nd }|                     d          r|                     |j                  nd }d }|                     d          r|                     |j                  }n/|                     d          r| 	                    |j
                  }|                     d          r|                     |j                  nd }t          j        |j        |||||          S )Ngeo_bounding_box
geo_radiusmatchrangedatetime_rangevalues_count)r\   r  r  r  r  r  )r)   r  r  r   r  convert_matchr  r   r  r   r  r  r  r   FieldConditionr\   )r   rj   r  r  r  range_r  s          r&   r   z"GrpcToRest.convert_field_condition'  sW    ~~011C(()?@@@ 	 9>|8T8T^C""5#3444Z^ 	 38..2I2IS!!%+...t04>>'"" 	F&&u{33FF^^,-- 	F//0DEEF ~~n--C$$U%7888 	 "	-!%
 
 
 	
r(   c                    |                     d          }|t          d|           t          ||          }|dk    rt          j        |          S |dk    rt          j        |          S |dk    rt          j        |          S |dk    rt          j        |          S |d	k    r't          j        t          |j                  
          S |dk    r't          j        t          |j	                  
          S |dk    r%t          j
        di dt          |j                  iS |dk    r%t          j
        di dt          |j	                  iS t          d|           )Nmatch_valueinvalid Match model: integer)rP   booleankeywordtextr  keywords)anyintegersexcept_keywordsexceptexcept_integersr    )r   r*   r   r   
MatchValue	MatchTextMatchAnyrK   stringsr  MatchExceptr   s       r&   r  zGrpcToRest.convert_matchJ  s   ..<<U<<===eT""9?----9?----9?----6>>>s++++:=T#+%6%67777:=T#,%7%78888$$$#DDxck1B1B&CDDD$$$#EExcl1C1C&DEEE888999r(   c                     t          j        |                    d          r|j        nd |                    d          r|j        nd           S r  )r   WalConfigDiffr)   r  r  r   s     r&   convert_wal_config_diffz"GrpcToRest.convert_wal_config_diffc  sX    !5:^^DU5V5V`E11\`,1NN;O,P,PZ((VZ
 
 
 	
r(   c                    t          j        |                    d          r|                     |j                  nd |j        |j        |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j	        nd |                    d          r| 
                    |j                  nd |                    d          r|                     |j                  nd           S )Nvectors_configreplication_factorread_fan_out_factorwrite_consistency_factorsparse_vectors_configsharding_method)r  shard_numberon_disk_payloadr  r  r  sparse_vectorsr  )r   CollectionParamsr)   convert_vectors_configr  r  r  r  r  r  convert_sparse_vector_configr  convert_sharding_methodr  r   s     r&   r   z$GrpcToRest.convert_collection_paramsl  s   $ >>"233**5+?@@@+!1,1NN;O,P,PZ((VZ .3^^<Q-R-R\))X\ >>"<==.. ~~5663;;E<WXXX~~/00C778MNNN1
 
 
 	
r(   c                    t          j        |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j	        nd |                    d          r|j
        nd 	          S r   )r   OptimizersConfigDiffr)   r   r   r   r   r   r   r   r   r   s     r&   convert_optimizers_config_diffz)GrpcToRest.convert_optimizers_config_diff  s     (05?W0X0Xb,,^b ,1>>:M+N+NX''TX -2NN;O,P,PZ((VZ -2NN;O,P,PZ((VZ >>"<==.. +0..9K*L*LV&&RV +0..9K*L*LV&&RV >>"<==..7
 
 
 	
r(   c           	      
   t          j        |                    d          r|                     |j                  nd |                    d          r|                     |j                  nd |                    d          r|                     |j                  nd |                    d          r| 	                    |j
                  nd |                    d          r|                     |j                  nd           S )Nr  optimizers_configr   r   r   )r  r  r   r   r   )r   UpdateCollectionr)   convert_vectors_config_diffr  r  r  convert_collection_params_diffr   r   r    convert_quantization_config_diffr   r   s     r&   convert_update_collectionz$GrpcToRest.convert_update_collection  s	   $ >>"233//0DEEE >>"5662253JKKK >>(++225<@@@ >>-00,,U->??? >>"78844U5NOOO1
 
 
 	
r(   c                 B    t          j        |j        |j                  S )N)latlon)r   GeoPointr  r  r   s     r&   r   zGrpcToRest.convert_geo_point  s%    }		
 
 
 	
r(   c                    |                     d          }|t          d|           t          ||          }|dk    r(t          j        |                     |                    S |dk    r(t          j        |                     |                    S |dk    r(t          j        | 	                    |                    S t          d|           )	Nactioninvalid AliasOperations model: rename_aliasr  create_aliasr  delete_aliasr  )
r   r*   r   r   RenameAliasOperationrh  CreateAliasOperationr  DeleteAliasOperationra  r   s       r&   convert_alias_operationsz#GrpcToRest.convert_alias_operations  s    ))<FuFFGGGeT"">!!,#:R:RSV:W:WXXXX>!!,#:R:RSV:W:WXXXX>!!,#:R:RSV:W:WXXXXB5BBCCCr(   c                 B    t          j        |j        |j                  S N)r_  r  )r   AliasDescriptionr_  r  r   s     r&   convert_alias_descriptionz$GrpcToRest.convert_alias_description  (    $'!1
 
 
 	
r(   Nshard_key_selectorc                 R    |                     d          }|t          d|           t          ||          }|dk    r't          j         fd|j        D             |          S |dk    r)t          j                             |          |          S t          d|           )Npoints_selector_one_ofinvalid PointsSelector model: r  c                 :    g | ]}                     |          S r    rS  r#   pointr   s     r&   r'   z6GrpcToRest.convert_points_selector.<locals>.<listcomp>  s'    III,,U33IIIr(   r  r  r   )r   r  )r   r*   r   r   PointIdsListidsFilterSelectorr   )r   rj   r  r"   r]   s   `    r&   convert_points_selectorz"GrpcToRest.convert_points_selector  s      899<EeEEFFFeT""8$IIIIIII,    8&))#..,    A%AABBBr(   c                 6   |                     d          }|t          d|           t          ||          }|dk    r|S |dk    rt          |j                  S |dk    r't          j        t          |j                            S t          d|           )Nselector_optionsz#invalid WithPayloadSelector model: enableincludeexcluder  )r   r*   r   rK   rC   r   PayloadSelectorExcluder   s       r&   convert_with_payload_selectorz(GrpcToRest.convert_with_payload_selector  s      233<J5JJKKKeT""8J9
###9.tCJ7G7GHHHHFuFFGGGr(   c                 ,    |                      |          S r?   )r  r   s     r&   convert_with_payload_interfacez)GrpcToRest.convert_with_payload_interface  s     00777r(   c           	         t          j        |                     |j                  |                     |j                  |                    d          r|                     |j                  nd |                    d          r| 	                    |j
                  nd |                    d          r|                     |j                  nd           S )Nr  r  r  )r  r/   r  r  r  )r   RecordrT  r  r  r/   r)   r  r  r  r  r  r  r   s     r&   convert_retrieved_pointz"GrpcToRest.convert_retrieved_point  s    {##EH--''669>	9R9R\3&&u}555X\:?..:U:U_%%eo666[_ >>-00''(9:::
 
 
 	
r(   c                 ,    |                      |          S r?   )r  r   s     r&   convert_recordzGrpcToRest.convert_record%  s    **5111r(   c                 6    t          j        |j                  S N)count)r   CountResultr  r   s     r&   convert_count_resultzGrpcToRest.convert_count_result)      ek2222r(   c                     t          j        |j        |                    d          r+|j                                                                        nd |j                  S )Ncreation_timer"   r  size)r   SnapshotDescriptionr"   r)   r  r   	isoformatr  r   s     r&   convert_snapshot_descriptionz'GrpcToRest.convert_snapshot_description-  sa     ' >>/22#..00::<<<
 
 
 	
r(   c                 
   |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S t          d|           Nzinvalid Datatype model: )
r   DatatypeFloat32r   FLOAT32Uint8UINT8Float16FLOAT16r*   r   s     r&   convert_datatypezGrpcToRest.convert_datatype;  sj    DM)))=((dm)))=&&dm+++=((???@@@r(   c                 "   t          j        |j        |                     |j                  |                    d          r|                     |j                  nd |                    d          r|                     |j	                  nd |                    d          r|j
        nd |                    d          r|                     |j                  nd |                    d          r|                     |j                  nd           S )Nr   r   r   datatypemultivector_configr  distancer   r   r   r&  r'  )r   VectorParamsr  r  r)  r)   r   r   r   r   r   r$  r&  convert_multivector_configr'  r   s     r&   convert_vector_paramsz GrpcToRest.convert_vector_paramsF  s    ))%.99 >>-00,,U->??? >>"788//0IJJJ%*^^I%>%>HEMMD=B^^J=W=WaS))%.999]a >>"677..u/GHHH%
 
 
 	
r(   c                 \    t          j        |                     |j                            S N)
comparator)r   MultiVectorConfigconvert_multivector_comparatorr/  r   s     r&   r+  z%GrpcToRest.convert_multivector_config^  0    %99%:JKK
 
 
 	
r(   c                 r    |t           j        j        k    rt          j        j        S t          d|           Nz%invalid MultiVectorComparator model: )r   MultiVectorComparatorMaxSimr   MAX_SIMr*   r   s     r&   r1  z)GrpcToRest.convert_multivector_comparatord  s8     D.555-55HHHIIIr(   c                 @    |                     d          }|t          d|           t          ||          }|dk    r                     |          S |dk    r2t	           fd|j                                        D                       S t          d|           )Nr   invalid VectorsConfig model: r   
params_mapc              3   L   K   | ]\  }}|                     |          fV  d S r?   r,  r#   r\   
vec_paramsr   s      r&   rA   z4GrpcToRest.convert_vectors_config.<locals>.<genexpr>w  sK        APjc//
;;<     r(   )r   r*   r   r,  rM   maprN   r   s   `   r&   r  z!GrpcToRest.convert_vectors_configm  s    ))<DUDDEEEeT""8,,S111<    TWT[TaTaTcTc      @@@AAAr(   c                 x   |                     d          r5t          j        |j        j        d d          |j        d d                    S |                     d          rK|j        }|j        t                    |z  fdt          dt                              D             S |j        d d          S )NindicesrA  r<   r   c                 *    g | ]}||z            S r    r    )r#   istepr  s     r&   r'   z-GrpcToRest.convert_vector.<locals>.<listcomp>  s&    PPPaGADL)PPPr(   r   )r)   r   SparseVectorrA  datar   lenr  )r   rj   r   rE  r  s      @@r&   convert_vectorzGrpcToRest.convert_vector|  s     >>)$$ 	Z$U]-?-B5:VWVWVW=YYYY>>/** 	Q!/MjGw<<=0DPPPPP5CLL$3O3OPPPPz!!!}r(   c                 x    i }|j                                         D ]\  }}|                     |          ||<   |S r?   )r  rN   rI  )r   rj   r  r"   r  s        r&   convert_named_vectorsz GrpcToRest.convert_named_vectors  sF    !M//11 	7 	7LD&..v66GDMMr(   c                    |                     d          }|t          d|           t          ||          }|dk    r|                     |          S |dk    r|                     |          S t          d|           )Nvectors_optionszinvalid Vectors model: r  r  )r   r*   r   rI  rK  r   s       r&   r  zGrpcToRest.convert_vectors  s     122<>u>>???eT""8%%c***9,,S111:5::;;;r(   c                      |j         d d          S r?   rG  r   s     r&   convert_dense_vectorzGrpcToRest.convert_dense_vector  s    z!!!}r(   c                 b    t          j        |j        d d          |j        d d                    S )NrB  )r   rF  rA  r<   r   s     r&   convert_sparse_vectorz GrpcToRest.convert_sparse_vector  s-     qqq)9%,qqq/RRRRr(   c                 *      fd|j         D             S )Nc                 :    g | ]}                     |          S r    rP  r#   r  r   s     r&   r'   z9GrpcToRest.convert_multi_dense_vector.<locals>.<listcomp>  s'    MMMV((00MMMr(   r  r   s   ` r&   convert_multi_dense_vectorz%GrpcToRest.convert_multi_dense_vector  s    MMMMu}MMMMr(   c                 p   |                     d          }|t          d|           t          ||          }|dk    r|                     |          S |dk    r|                     |          S |dk    r|                     |          S |dk    r|                     |          S t          d|           )Nr  invalid VectorInput model: r  densesparsemulti_dense)r   r*   r   rT  rP  rR  rX  r   s       r&   convert_vector_inputzGrpcToRest.convert_vector_input  s    	**<B5BBCCCeT""4<<'',,,7??++C0008,,S111=  11#666>u>>???r(   c                      t          j         fd|j        D              fd|j        D             |                    d          r                     |j                  nd           S )Nc                 :    g | ]}                     |          S r    r^  rV  s     r&   r'   z6GrpcToRest.convert_recommend_input.<locals>.<listcomp>  '    TTT6c..v66TTTr(   c                 :    g | ]}                     |          S r    ra  rV  s     r&   r'   z6GrpcToRest.convert_recommend_input.<locals>.<listcomp>  rb  r(   strategypositivenegativerd  )r   RecommendInputrf  rg  r)   convert_recommend_strategyrd  r   s   ` r&   convert_recommend_inputz"GrpcToRest.convert_recommend_input  s{    "TTTTU^TTTTTTTU^TTT~~j))S33ENCCC
 
 
 	
r(   c                     t          j        |                     |j                  |                     |j                            S N)rf  rg  )r   ContextPairr^  rf  rg  r   s     r&   convert_context_input_pairz%GrpcToRest.convert_context_input_pair  sB    --en==--en==
 
 
 	
r(   c                 *      fd|j         D             S )Nc                 :    g | ]}                     |          S r    rn  r#   pairr   s     r&   r'   z4GrpcToRest.convert_context_input.<locals>.<listcomp>  s'    MMM..t44MMMr(   pairsr   s   ` r&   convert_context_inputz GrpcToRest.convert_context_input  s    MMMMMMMMr(   c                     t          j        |                     |j                  |                     |j                            S N)targetcontext)r   DiscoverInputr^  ry  rv  rz  r   s     r&   convert_discover_inputz!GrpcToRest.convert_discover_input  B    !++EL99--em<<
 
 
 	
r(   c                     |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S t          d|           Nzinvalid Fusion model: )r   FusionRRFr   DBSFr*   r   s     r&   convert_fusionzGrpcToRest.convert_fusion  M    DKO##;?"DK$$$;##9%99:::r(   c                 r    |t           j        j        k    rt          j        j        S t          d|           Nzinvalid Sample model: )r   SampleRandomr   RANDOMr*   r   s     r&   convert_samplezGrpcToRest.convert_sample  4    DK&&&;%%9%99:::r(   c                    |                     d          }|t          d|           t          ||          }|dk    r(t          j        |                     |                    S |dk    r(t          j        |                     |                    S |dk    r(t          j        | 	                    |                    S |d	k    r(t          j
        |                     |          
          S |dk    r(t          j        |                     |                    S |dk    r(t          j        |                     |                    S |dk    r(t          j        |                     |                    S t          d|           )Nr  invalid Query model: nearestr  	recommendr  discoverr  rz  rz  order_byr  fusionr  sampler  )r   r*   r   r   NearestQueryr^  RecommendQueryrj  DiscoverQueryr|  ContextQueryrv  OrderByQueryconvert_order_byFusionQueryr  SampleQueryr  r   s       r&   convert_queryzGrpcToRest.convert_query  s   	**<<U<<===eT""9$S-E-Ec-J-JKKKK;&1L1LS1Q1QRRRR:%s/I/I#/N/NOOOO9$S-F-Fs-K-KLLLL:$c.B.B3.G.GHHHH8#3+=+=c+B+BCCCC8#3+=+=c+B+BCCCC888999r(   c                     t          j        t          |j                  dk    r fd|j        D             nd |                    d          r                     |j                  nd |                    d          r|j        nd |                    d          r                     |j	                  nd |                    d          r 
                    |j                  nd |                    d          r|j        nd |                    d          r|j        nd |                    d	          r                     |j                  nd 
          S )Nr   c                 :    g | ]}                     |          S r    convert_prefetch_queryr#   prefetchr   s     r&   r'   z5GrpcToRest.convert_prefetch_query.<locals>.<listcomp>	  '    ZZZxc00::ZZZr(   queryusingr   r   score_thresholdlimitlookup_fromr  r  r  r   r   r  r  r  )r   PrefetchrH  r  r)   r  r  r  r   r   r  r   r  r  convert_lookup_locationr  r   s   ` r&   r  z!GrpcToRest.convert_prefetch_query  sP   }5>""a'' [ZZZ5>ZZZZ49NN74K4KU###EK000QU!&!8!8B%++d7<~~h7O7OY3%%el333UY>CnnX>V>V`3,,U\:::\`5:^^DU5V5V`E11\`!&!8!8B%++d~~m,,33E4EFFF
 
 
 	
r(   c                      |j         d d          S r?   namesr   s     r&   convert_vectors_selectorz#GrpcToRest.convert_vectors_selector  s    {111~r(   c                     |                     d          }|t          d|           t          ||          }|dk    r|S |dk    r|                     |          S t          d|           )Nr   z#invalid WithVectorsSelector model: r  r  )r   r*   r   r  r   s       r&   convert_with_vectors_selectorz(GrpcToRest.convert_with_vectors_selector  s     233<J5JJKKKeT""8J9//444FuFFGGGr(   c                    t          j        t          j        |j        |j        d d                    |                    d          r|                     |j                  nd |j        |                    d          r| 	                    |j
                  nd |                    d          r|                     |j                  nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|                     |j                  nd |                    d          r|                     |j                  nd 		  	        S )
N)r"   r  r   with_payloadr   r  offsetwith_vectorsr  )	r  r   r  r  r   r  r  with_vectorr  )r   SearchRequestNamedVectorvector_namer  r)   r   r   r  r  r  r  r   r  r  r  r  convert_shard_key_selectorr  r   s     r&   convert_search_pointsz GrpcToRest.convert_search_points(  s^   !#):5<PQPQPQ?SSS7<~~h7O7OY3%%el333UY+ >>.112253EFFF>CnnX>V>V`3,,U\:::\`5:^^DU5V5V`E11\`#(>>(#;#;E5<< >>.1111%2DEEE >>"677..u/GHHH)
 
 
 	
r(   c                     t          j        |                    d          r                     |j                  nd t          |j                  dk    r fd|j        D             nd |                    d          r                     |j                  nd |                    d          r|j	        nd |                    d          r 
                    |j                  nd |                    d          r                     |j                  nd |                    d          r|j        nd |                    d	          r|j        nd |                    d
          r|j        nd |                    d          r                     |j                  nd |                    d          r                     |j                  nd |                    d          r                     |j                  nd           S )Nr  r   c                 :    g | ]}                     |          S r    r  r  s     r&   r'   z3GrpcToRest.convert_query_points.<locals>.<listcomp>J  r  r(   r  r  r   r   r  r  r  r  r  r  )r  r  r  r  r   r   r  r  r  r  r  r  )r   QueryRequestr)   r  r  rH  r  r  r  r  r   r   r  r   r  r  r  r  r  r  r  r  r  r   s   ` r&   convert_query_pointszGrpcToRest.convert_query_pointsB  s     >>"677..u/GHHH 5>""a'' [ZZZ5>ZZZZ49NN74K4KU###EK000QU!&!8!8B%++d7<~~h7O7OY3%%el333UY>CnnX>V>V`3,,U\:::\`5:^^DU5V5V`E11\`!&!8!8B%++d#(>>(#;#;E5<< >>.1111%2DEEE >>.112253EFFF >>-00++E,=>>>;
 
 
 	
r(   c                       fd|j         D             } fd|j        D             } fd|j        D             } fd|j        D             }t	          j        ||z   ||z   |                    d          r                     |j                  nd |j	        |                    d          r 
                    |j                  nd |                    d          r                     |j                  nd |                    d          r|j        nd |                    d	          r|j        nd |                    d
          r                     |j                  nd |j        |                    d          r                     |j                  nd |                    d          r                     |j                  nd |                    d          r                     |j                  nd           S )Nc                 :    g | ]}                     |          S r    rS  r#   point_idr   s     r&   r'   z7GrpcToRest.convert_recommend_points.<locals>.<listcomp>g  '    VVV8,,X66VVVr(   c                 :    g | ]}                     |          S r    rS  r  s     r&   r'   z7GrpcToRest.convert_recommend_points.<locals>.<listcomp>h  r  r(   c                 :    g | ]}                     |          S r    rI  rV  s     r&   r'   z7GrpcToRest.convert_recommend_points.<locals>.<listcomp>j  '    \\\6C..v66\\\r(   c                 :    g | ]}                     |          S r    r  rV  s     r&   r'   z7GrpcToRest.convert_recommend_points.<locals>.<listcomp>k  r  r(   r   r  r   r  r  r  r  rd  r  )rf  rg  r   r  r  r   r  r  r  r  r  rd  r  )rf  rg  positive_vectorsnegative_vectorsr   RecommendRequestr)   r   r   r  r  r  r  r   r  r  r  r  r  r  r  ri  rd  r  r  )r   rj   positive_idsnegative_idsr  r  s   `     r&   convert_recommend_pointsz#GrpcToRest.convert_recommend_pointse  s!   VVVVu~VVVVVVVu~VVV\\\\UE[\\\\\\\UE[\\\$!$44!$447<~~h7O7OY3%%el333UY+ >>.112253EFFF>CnnX>V>V`3,,U\:::\`5:^^DU5V5V`E11\`#(>>(#;#;E5<< >>.1111%2DEEE+ >>-00++E,=>>> >>*--..u~>>> >>"677..u/GHHHA"
 "
 "
 "	
r(   c                 J    |                     d          r                     |j                  nd } fd|j        D             }t	          j        |||                     d          r                     |j                  nd |j        |                     d          r 	                    |j
                  nd |                     d          r                     |j                  nd |                     d          r|j        nd |                     d          r                     |j                  nd |j        |                     d          r                     |j                  nd |                     d	          r                     |j                  nd 
          S )Nry  c                 :    g | ]}                     |          S r    convert_context_example_pairrr  s     r&   r'   z6GrpcToRest.convert_discover_points.<locals>.<listcomp>  s'    TTTd333D99TTTr(   r   r  r   r  r  r  r  )ry  rz  r   r  r  r   r  r  r  r  r  )r)   convert_target_vectorry  rz  r   DiscoverRequestr   r   r  r  r  r  r   r  r  r  r  r  r  r  r  )r   rj   ry  rz  s   `   r&   convert_discover_pointsz"GrpcToRest.convert_discover_points  s   <ANN8<T<T^**5<888Z^TTTTemTTT#7<~~h7O7OY3%%el333UY+ >>.112253EFFF>CnnX>V>V`3,,U\:::\`#(>>(#;#;E5<< >>.1111%2DEEE+ >>-00++E,=>>> >>"677..u/GHHH5
 
 
 	
r(   c                     |                     d          r|                     |j                  S |                     d          r|                     |j                  S t          d|           )Nr  r  zinvalid VectorExample model: )r)   rI  r  rT  r  r*   r   s     r&   convert_vector_examplez!GrpcToRest.convert_vector_example  sm    >>(## 	4%%el333>>$ 	2''111@@@AAAr(   c                     |                     d          r|                     |j                  S t          d|           )Nsinglezinvalid TargetVector model: )r)   r  r  r*   r   s     r&   r  z GrpcToRest.convert_target_vector  sC    >>(## 	<--el;;;???@@@r(   c                     t          j        |                     |j                  |                     |j                            S rl  )r   ContextExamplePairr  rf  rg  r   s     r&   r  z'GrpcToRest.convert_context_example_pair  sD     &//??//??
 
 
 	
r(   c                 .   |t           j        k    rt          j        j        S |t           j        k    rt          j        j        S |t           j        k    rt          j        j        S |t           j	        k    rt          j        j
        S t          d|           Nzinvalid TokenizerType model: )r   Prefixr   TokenizerTypePREFIX
Whitespace
WHITESPACEWordWORDMultilingualMULTILINGUALr*   r   s     r&   convert_tokenizer_typez!GrpcToRest.convert_tokenizer_type  s~    DK%,,DO##%00DI%**D%%%%22@@@AAAr(   c           	         t          j        d|                     |j                  |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd           S )Nr  min_token_lenmax_token_len	lowercase)type	tokenizerr  r  r  )r   TextIndexParamsr  r  r)   r  r  r  r   s     r&   r(  z$GrpcToRest.convert_text_index_params  s    #00AA161P1PZ%--VZ161P1PZ%--VZ).)D)DNeoo$
 
 
 	
r(   c           	          t          j        t           j        j        |j        |j        |                    d          r|j        nd |                    d          r|j        nd           S )Nis_principalr   )r  r  lookupr  r   )	r   IntegerIndexParamsIntegerIndexTyper3  r  r  r)   r  r   r   s     r&   r)  z'GrpcToRest.convert_integer_index_params  sh     &&.+</4~~n/M/MW++SW%*^^I%>%>HEMMD
 
 
 	
r(   c                     t          j        t           j        j        |                    d          r|j        nd |                    d          r|j        nd           S N	is_tenantr   )r  r  r   )r   KeywordIndexParamsKeywordIndexTyper4  r)   r  r   r   s     r&   r*  z'GrpcToRest.convert_keyword_index_params  s[     &&.).)D)DNeoo$%*^^I%>%>HEMMD
 
 
 	
r(   c                     t          j        t           j        j        |                    d          r|j        nd |                    d          r|j        nd           S Nr  r   )r  r  r   )r   FloatIndexParamsFloatIndexTyper1  r)   r  r   r   s     r&   r+  z%GrpcToRest.convert_float_index_params  s\    $$*/4~~n/M/MW++SW%*^^I%>%>HEMMD
 
 
 	
r(   c                     t          j        t           j        j        |                    d          r|j        nd           S )Nr   )r  r   )r   GeoIndexParamsGeoIndexTyper2  r)   r   r   s     r&   r,  z#GrpcToRest.convert_geo_index_params   s?    ""&%*^^I%>%>HEMMD
 
 
 	
r(   _c                 J    t          j        t           j        j                  S )Nr  )r   BoolIndexParamsBoolIndexTyper5  r   r  s     r&   r-  z$GrpcToRest.convert_bool_index_params  s%    ##(
 
 
 	
r(   c                     t          j        t           j        j        |                    d          r|j        nd |                    d          r|j        nd           S r  )r   DatetimeIndexParamsDatetimeIndexTyper7  r)   r  r   r   s     r&   r.  z(GrpcToRest.convert_datetime_index_params  s^     ''0/4~~n/M/MW++SW%*^^I%>%>HEMMD
 
 
 	
r(   c                     t          j        t           j        j        |                    d          r|j        nd |                    d          r|j        nd           S r  )r   UuidIndexParamsUuidIndexTyper8  r)   r  r   r   s     r&   r/  z$GrpcToRest.convert_uuid_index_params  sY    ##().)D)DNeoo$%*^^I%>%>HEMMD
 
 
 	
r(   c                    t          j        |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd           S )Nr  r  r  r  )r  r  r  r  )r   CollectionParamsDiffr)   r  r  r  r  r   s     r&   r  z)GrpcToRest.convert_collection_params_diff  s     (,1NN;O,P,PZ((VZ >>"<==.. .3^^<Q-R-R\))X\5:^^DU5V5V`E11\`
 
 
 	
r(   c                 p    t          j        |j        |                    d          r|j        nd           S )Nr  )
collectionr  )r   LookupLocationr  r)   r  r   s     r&   r  z"GrpcToRest.convert_lookup_location2  s>    ",(-}(E(EO5$$4
 
 
 	
r(   c                 (   |j         t          j        j        k    rt          j        j        S |j         t          j        j        k    rt          j        j        S |j         t          j        j	        k    rt          j        j
        S t          d|           )Ninvalid WriteOrdering model: )r  r   WriteOrderingTypeWeakr   WriteOrderingWEAKMediumMEDIUMStrongSTRONGr*   r   s     r&   convert_write_orderingz!GrpcToRest.convert_write_ordering9  sv    :/444%**:/666%,,:/666%,,@@@AAAr(   c                     |                     d          }|t          d|           t          ||          }|dk    r|S |dk    r|                     |          S t          d|           )NrP   invalid ReadConsistency model: factorr  )r   r*   r   convert_read_consistency_typer   s       r&   convert_read_consistencyz#GrpcToRest.convert_read_consistencyC  s    ((<FuFFGGGeT""8J6>>44S999B5BBCCCr(   c                     |t           j        k    rt          j        j        S |t           j        k    rt          j        j        S |t           j        k    rt          j        j        S t          d|           Nz#invalid ReadConsistencyType model: )
r   Allr   ReadConsistencyTypeALLMajorityMAJORITYQuorumQUORUMr*   r   s     r&   r'  z(GrpcToRest.convert_read_consistency_typeO  sf     DH+//DM!!+44DK+22FuFFGGGr(   c                     t          j        t           j        j        |                    d          r|j        nd |                    d          r|j        nd           S )Nquantile
always_ramr  r3  r4  )r   ScalarQuantizationConfig
ScalarTypeINT8r)   r3  r4  r   s     r&   "convert_scalar_quantization_configz-GrpcToRest.convert_scalar_quantization_config[  s\     ,%',~~j'A'AKU^^t+0>>,+G+GQu''T
 
 
 	
r(   c                     t          j        |                     |j                  |                    d          r|j        nd           S )Nr4  compressionr4  )r   ProductQuantizationConfigconvert_compression_ratior<  r)   r4  r   s     r&   #convert_product_quantization_configz.GrpcToRest.convert_product_quantization_confige  sN     -55e6GHH+0>>,+G+GQu''T
 
 
 	
r(   c                 d    t          j        |                    d          r|j        nd           S )Nr4  r4  )r   BinaryQuantizationConfigr)   r4  r   s     r&   "convert_binary_quantization_configz-GrpcToRest.convert_binary_quantization_confign  s:     ,+0>>,+G+GQu''T
 
 
 	
r(   c                 p   |t           j        k    rt          j        j        S |t           j        k    rt          j        j        S |t           j        k    rt          j        j        S |t           j	        k    rt          j        j
        S |t           j        k    rt          j        j        S t          d|           Nz invalid CompressionRatio model: )r   x4r   CompressionRatioX4x8X8x16X16x32X32x64X64r*   r   s     r&   r>  z$GrpcToRest.convert_compression_ratiov  s    DG(++DG(++DH(,,DH(,,DH(,,CECCDDDr(   c                    |                     d          }|t          d|           t          ||          }|dk    r(t          j        |                     |                    S |dk    r(t          j        |                     |                    S |dk    r(t          j        | 	                    |                    S t          d|           )	Nrz  "invalid QuantizationConfig model: scalarrS  productrU  binaryrW  )
r   r*   r   r   ScalarQuantizationr9  ProductQuantizationr?  BinaryQuantizationrC  r   s       r&   r   z&GrpcToRest.convert_quantization_config  s     //<I%IIJJJeT""8*#2X2XY\2]2]^^^^9+C4[4[\_4`4`aaaa8*#2X2XY\2]2]^^^^EeEEFFFr(   c                     t          j        |                    d          r|j        nd |                    d          r|j        nd |                    d          r|j        nd           S )Nignorerescoreoversamplingr]  r^  r_  )r   QuantizationSearchParamsr)   r]  r^  r_  r   s     r&   r~  z-GrpcToRest.convert_quantization_search_params  so     ,#(>>(#;#;E5<<%*^^I%>%>HEMMD/4~~n/M/MW++SW
 
 
 	
r(   c                     t          j        |                     |j                  |                     |j                            S )N)r  r  )r   PointVectorsrT  r  r  r  r   s     r&   convert_point_vectorsz GrpcToRest.convert_point_vectors  sB     ##EH--&&u}55
 
 
 	
r(   c                 P     t          j         fd|j        D                       S )Nc                 :    g | ]}                     |          S r    convert_point_groupr#   groupr   s     r&   r'   z4GrpcToRest.convert_groups_result.<locals>.<listcomp>  '    MMMuC++E22MMMr(   groups)r   GroupsResultrm  r   s   ` r&   convert_groups_resultz GrpcToRest.convert_groups_result  6     MMMMMMM
 
 
 	
r(   c                      t          j                             |j                   fd|j        D             |                    d          r                     |j                  nd           S )Nc                 :    g | ]}                     |          S r    r  )r#   hitr   s     r&   r'   z2GrpcToRest.convert_point_group.<locals>.<listcomp>  s'    FFFC#**3//FFFr(   r  r  hitsr  )r   
PointGroupconvert_group_idr  rv  r)   r  r  r   s   ` r&   rh  zGrpcToRest.convert_point_group  sr    ##EH--FFFF5:FFF7<~~h7O7OY3%%el333UY
 
 
 	
r(   c                 x    |                     d          }|t          d|           t          ||          }|S )Nkindinvalid GroupId model: r  r   s       r&   rx  zGrpcToRest.convert_group_id  sE    ''<>u>>???eT""
r(   c                     t          j        |j        |                    d          r|                     |j                  nd |                    d          r|                     |j                  nd           S )Nr  r  )r  r  r  )r   
WithLookupr  r)   r  r  r  r  r   s     r&   convert_with_lookupzGrpcToRest.convert_with_lookup  s    ' >>.1111%2DEEE >>.1111%2DEEE
 
 
 	
r(   c                    |                     d          }|t          d|           t          ||          }|dk    r(t          j        |                     |                    S |dk    r(t          j        |                     |                    S |dk    r(t          j        | 	                    |                    S |d	k    rt          j
        j        S t          d|           )
Nrz  &invalid QuantizationConfigDiff model: rS  rT  rU  rV  rW  rX  disabled)r   r*   r   r   rY  r9  rZ  r?  r[  rC  DisabledDISABLEDr   s       r&   r  z+GrpcToRest.convert_quantization_config_diff  s     //<MeMMNNNeT""8*#2X2XY\2]2]^^^^9+C4[4[\_4`4`aaaa8*#2X2XY\2]2]^^^^:=))I%IIJJJr(   c                 $   t          j        |                    d          r|                     |j                  nd |                    d          r|                     |j                  nd |                    d          r|j        nd           S )Nr   r   r   r   r   r   )r   VectorParamsDiffr)   r   r   r  r   r   r   s     r&   convert_vector_params_diffz%GrpcToRest.convert_vector_params_diff  s    $ >>-00,,U->??? >>"78844U5NOOO%*^^I%>%>HEMMD
 
 
 	
r(   c                 D    |                     d          }|t          d|           t          ||          }|dk    rd                     |          iS |dk    r2t	           fd|j                                        D                       S t          d|           )Nr   !invalid VectorsConfigDiff model: r    r:  c              3   L   K   | ]\  }}|                     |          fV  d S r?   r  r=  s      r&   rA   z9GrpcToRest.convert_vectors_config_diff.<locals>.<genexpr>  sN        #C c44Z@@A     r(   )r   r*   r   r  rM   r?  rN   r   s   `   r&   r  z&GrpcToRest.convert_vectors_config_diff  s    ))<HHHIIIeT""866s;;<<<    '*w}}      DUDDEEEr(   c                 x
    |                     d          }|t          d|           t          ||          }|dk    rk|                    d          r                     |j                  nd }t          j        t          j         fd|j	        D             |                    S |dk    rO|                    d          r|j        nd } 
                    |j	        |	          }t          j        |
          S |dk    r|                    d          r|j        nd } 
                    |j        |	          }d }d }t          |t          j                  r|j	        }n4t          |t          j                  r|j        }nt          d|           t          j        t          j                             |j                  ||                    S |dk    r|                    d          r|j        nd } 
                    |j        |	          }d }d }t          |t          j                  r|j	        }n4t          |t          j                  r|j        }nt          d|           t          j        t          j                             |j                  ||                    S |dk    r|                    d          r|j        nd } 
                    |j        |	          }d }d }t          |t          j                  r|j	        }n4t          |t          j                  r|j        }nt          d|           t          j        t          j        d |j        D             ||                    S |dk    rO|                    d          r|j        nd } 
                    |j	        |	          }t          j        |          S |dk    rk|                    d          r                     |j                  nd }t          j        t          j         fd|j	        D             |                    S |dk    r|                    d          r|j        nd } 
                    |j        |	          }d }d }t          |t          j                  r|j	        }n4t          |t          j                  r|j        }nt          d|           t          j        t          j        d |j        j        D             ||                    S t          d|           )N	operationz%invalid PointsUpdateOperation model: upsertr  c                 :    g | ]}                     |          S r    r  r  s     r&   r'   z>GrpcToRest.convert_points_update_operation.<locals>.<listcomp>  s'    TTTC44U;;TTTr(   r  r  delete_points)r  )deleteset_payloadr  )r/   r  r   r  overwrite_payloadr  delete_payloadc                     g | ]}|S r    r    )r#   r\   s     r&   r'   z>GrpcToRest.convert_points_update_operation.<locals>.<listcomp>`  s    222##222r(   )keysr  r   r  clear_payloadr  update_vectorsc                 :    g | ]}                     |          S r    rd  r  s     r&   r'   z>GrpcToRest.convert_points_update_operation.<locals>.<listcomp>u  s'    UUUC55e<<UUUr(   r  delete_vectorsc                     g | ]}|S r    r    )r#   r"   s     r&   r'   z>GrpcToRest.convert_points_update_operation.<locals>.<listcomp>  s    ???TD???r(   )r  r  r   r  invalid UpdateOperation model: ) r   r*   r   r)   r  r  r   UpsertOperation
PointsListr  r  DeleteOperationpoints_selectorrF   r  r  r   SetPayloadOperation
SetPayloadr  r/   OverwritePayloadOperationDeletePayloadOperationDeletePayloadr  ClearPayloadOperationUpdateVectorsOperationUpdateVectorsDeleteVectorsOperationDeleteVectorsr  r  )r   rj   r"   r]   r  r  r  filter_s   `       r&   convert_points_update_operationz*GrpcToRest.convert_points_update_operation  sd    ,,<LULLMMMeT""8 << 455%%c&<=== 
 'TTTTTTT0      _$$*-,,7K*L*LV&&RV  "99
/A :  O '????]""*-,,7K*L*LV&&RV  "99#8J :  O FG/4+<== (/OT-@AA )0 F_FF   + O//<<!"      (((*-,,7K*L*LV&&RV  "99#8J :  O FG/4+<== (/OT-@AA )0 F_FF   1"&///<<!"# # #    %%%*-,,7K*L*LV&&RV  "99#8J :  O FG/4+<== (/OT-@AA )0 F_FF   .#122222!"         _$$*-,,7K*L*LV&&RV  "99
/A :  O -OLLLL%%% << 455%%c&<=== 
 .#1UUUU#*UUU0         %%%*-,,7K*L*LV&&RV  "99#8J :  O FG/4+<== (/OT-@AA )0 F_FF   .#1??S[->???!"         FuFFGGGr(   c                 z    t          |t                    rt          j        |          S t	          d|           )N)r  zInvalid InitFrom model: )rF   rJ   r   InitFromr*   r   s     r&   convert_init_fromzGrpcToRest.convert_init_from  s>    eS!! 	3=E2222;E;;<<<r(   c                     |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S t          d|           Nz!invalid RecommendStrategy model: )r   RecommendStrategyAverageVectorr   AVERAGE_VECTOR	BestScore
BEST_SCOREr*   r   s     r&   ri  z%GrpcToRest.convert_recommend_strategy  sS    D*888)88D*444)44DUDDEEEr(   c                     t          j        |                    d          r|j        nd |                    d          r|j        nd |                    d          r|                     |j                  nd           S )Nr   r   r&  r   r   r&  )r   SparseIndexParamsr)   r   r   r$  r&  r   s     r&   convert_sparse_index_configz&GrpcToRest.convert_sparse_index_config  s~    %-2^^<Q-R-R\))X\%*^^I%>%>HEMMD=B^^J=W=WaS))%.999]a
 
 
 	
r(   c                     |t           j        j        k    rt          j        j        S |t          t           j        d          k    rt          j        j        S t          d|           NNonezinvalid Modifier model: )r   ModifierIdfr   IDFr   NONEr*   r   s     r&   convert_modifierzGrpcToRest.convert_modifier  sV    DM%%%=$$GDM62222=%%;E;;<<<r(   c                     t          j        |                    d          |                     |j                  nd |                    d          r|                     |j                  nd           S )Nindexmodifierr  r  )r   SparseVectorParamsr)   r  r  r  r  r   s     r&   convert_sparse_vector_paramsz'GrpcToRest.convert_sparse_vector_params  sy     & >>'**6 //<<< 9>z8R8R\$$U^444X\	
 	
 	
 		
r(   c                 h     t           fd|j                                        D                       S )Nc              3   L   K   | ]\  }}|                     |          fV  d S r?   r  r#   r\   r]   r   s      r&   rA   z:GrpcToRest.convert_sparse_vector_config.<locals>.<genexpr>  s:      ccXS#S#::3??@ccccccr(   )rM   r?  rN   r   s   ` r&   r  z'GrpcToRest.convert_sparse_vector_config  s8     ccccQVQZQ`Q`QbQbccccccr(   c                 x    |                     d          }|t          d|           t          ||          }|S )Nr\   invalid ShardKey model: r  r   s       r&   r  zGrpcToRest.convert_shard_key  sE    &&<???@@@eT""
r(   c                      t          |j                  dk    r                      |j        d                   S  fd|j        D             S )N   r   c                 :    g | ]}                     |          S r    r  )r#   r  r   s     r&   r'   z9GrpcToRest.convert_shard_key_selector.<locals>.<listcomp>  s'    SSSY%%i00SSSr(   )rH  
shard_keysr  r   s   ` r&   r  z%GrpcToRest.convert_shard_key_selector  sR    u  A%%(()9!)<===SSSS%BRSSSSr(   c                     |t           j        k    rt          j        j        S |t           j        k    rt          j        j        S t          d|           Nzinvalid ShardingMethod model: )r   Autor   ShardingMethodAUTOCustomCUSTOMr*   r   s     r&   r  z"GrpcToRest.convert_sharding_method  sK    DI&++DK&--A%AABBBr(   c                     |t           j        k    rt          j        j        S |t           j        k    rt          j        j        S t          d|           Nzinvalid Direction model: )r   Ascr   	DirectionASCDescDESCr*   r   s     r&   convert_directionzGrpcToRest.convert_direction  sI    DH>%%DI>&&<U<<===r(   c                    |                     d          r|j        S |                     d          r|j        S |                     d          r|                     |j                  }|S |                     d          r|j        S d S )Nr  rI   	timestampr   )r)   r  rI   r   r  r   )r   rj   dts      r&   convert_start_fromzGrpcToRest.convert_start_from  s    >>)$$ 	!= >>'"" 	;>>+&& 	&&u77BI>>*%% 	">!	" 	"r(   c                     t          j        |j        |                    d          r|                     |j                  nd |                    d          r|                     |j                  nd           S )N	direction
start_fromr\   r  r  )r   OrderByr\   r)   r  r  r  r  r   s     r&   r  zGrpcToRest.convert_order_by  sx    |	:?..:U:U_%%eo666[_ =BNN<<X<Xb&&u'7888^b
 
 
 	
r(   c                 x    |                     d          }|t          d|           t          ||          }|S )Nr  invalid FacetValue model: r  r   s       r&   convert_facet_valuezGrpcToRest.convert_facet_value   sE    	**<A%AABBBeT""
r(   c                 h    t          j        |                     |j                  |j                  S N)rP   r  )r   FacetValueHitr  rP   r  r   s     r&   convert_facet_value_hitz"GrpcToRest.convert_facet_value_hit	  s4    !))%+66+
 
 
 	
r(   c                 |    t          j        |j        |j        |                    d          r|j        nd           S )Ncommittitler  r  )r   VersionInfor   r  r)   r  r   s     r&   convert_health_check_replyz%GrpcToRest.convert_health_check_reply  s@    +M#(>>(#;#;E5<<
 
 
 	
r(   c                     t          j        |                     |j                  |                     |j                  |j                  S N)abr  )r   SearchMatrixPairrT  r  r  r  r   s     r&   convert_search_matrix_pairz%GrpcToRest.convert_search_matrix_pair  sG    $""57++""57+++
 
 
 	
r(   c                 P     t          j         fd|j        D                       S )Nc                 :    g | ]}                     |          S r    r  rr  s     r&   r'   z:GrpcToRest.convert_search_matrix_pairs.<locals>.<listcomp>%  '    PPPD311$77PPPr(   rt  )r   SearchMatrixPairsResponseru  r   s   ` r&   convert_search_matrix_pairsz&GrpcToRest.convert_search_matrix_pairs   s8     -PPPPEKPPP
 
 
 	
r(   c                      t          j        t          |j                  t          |j                  t          |j                   fd|j        D                       S )Nc                 :    g | ]}                     |          S r    rS  r#   p_idr   s     r&   r'   z<GrpcToRest.convert_search_matrix_offsets.<locals>.<listcomp>0  s'    BBB%%d++BBBr(   offsets_rowoffsets_colscoresr  )r   SearchMatrixOffsetsResponserK   r  r  r  r  r   s   ` r&   convert_search_matrix_offsetsz(GrpcToRest.convert_search_matrix_offsets(  sa     /U.//U.//%%BBBB	BBB	
 
 
 	
r(   r?   ($  __name__
__module____qualname__classmethodr   	Conditionr   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   OptimizerStatusOptimizersStatusr   r   r   r   r   r   r   r  r   r   r  r  r  r  r   r   rJ   PayloadSchemaInfor  r   r  PayloadIndexParamsPayloadSchemaParamsr  rm   r  r;  r   rG  rI  rL  rH  rX  r   PointIdExtendedPointIdrT  r`  ra  rg  rh  rm  r   rq  r   ru  r   r}  r  r  r  
OrderValuer  r  r  Payloadr  r  r  r  r  r  r  r  r   Matchr  r  r  r   r  r  r  r  r   AliasOperationsr  r  r  PointsSelectorr
   ShardKeySelectorr  WithPayloadSelectorWithPayloadInterfacer  r  RetrievedPointr
  r  r  r  r  r  r  r  r$  r*  r,  r0  r+  r5  r1  VectorsConfigr  Vectorr   r   rI   rF  rI  NamedVectorsrK  VectorsVectorStructr  DenseVectorrP  rR  MultiDenseVectorrX  VectorInputr^  rh  rj  ContextInputPairrm  rn  ContextInputrv  r{  r|  r  r  r  r  Queryr  PrefetchQueryr  r  VectorsSelectorr  WithVectorsSelector
WithVectorr  SearchPointsr  r  QueryPointsr  r  RecommendPointsr  r  DiscoverPointsr  r  VectorExampleRecommendExampler  TargetVectorr  r  r  r  r  r  r(  r  r)  r  r*  r  r+  r  r,  r  r-  r  r.  r  r/  r  r  r  r  r  r#  ReadConsistencyr(  r,  r'  rY  r6  r9  rZ  r=  r?  r[  rB  rC  rG  r>  QuantizationConfigr   ra  r~  rc  rd  rn  ro  rw  rh  GroupIdrx  r}  r~  QuantizationConfigDiffr  r  r  VectorsConfigDiffr  PointsUpdateOperationUpdateOperationr  r  r  r  ri  SparseIndexConfigr  r  r  r  r  r  SparseVectorConfigr  ShardKeyr  r  r  r  r  r  	StartFromr  r  r  
FacetValuer  FacetHitr  r  HealthCheckReplyr  r  r  r  SearchMatrixPairsr  r  SearchMatrixOffsetsr  r  r    r(   r&   r   r      s       >dn > > > > [>* 
4; 
4; 
 
 
 [
$ 
$* 
 
 
 
 [
 5i 5H 5 5 5 [5 
4+= 
$BT 
 
 
 [
 _t~ _$. _ _ _ [_ ;.;		#; ; ; [;
 

D,? 

DDW 

 

 

 [

 BT-A BdF[ B B B [B 
d.C 
H] 
 
 
 [
 
T-@ 
TEX 
 
 
 [
 
(; 
 
 
 
 [
 
T-F 
4K` 
 
 
 [
@ 
AT] 
At} 
A 
A 
A [
A 
t'9 
dn 
 
 
 [
 [d445[	c4((	)[ [ [ [[
 	
0F 	
4K` 	
 	
 	
 [	
 G+G		!G G G [G< J0F J4Ka J J J [J( 
Ed.C 
EH] 
E 
E 
E [
E 
$*; 
@Q 
 
 
 [
 E$*; E@Q E E E [E _T-@ _TEX _ _ _ [_ <T\ <d6J < < < [< =)9 =d>N = = = [= 
)9 
d>N 
 
 
 [

 Pt/D PI^ P P P [P Nd.B NtG[ N N N [N 
T-A 
dFZ 
 
 
 [
 

$*; 

@Q 

 

 

 [

 d)9 dd>N d d d [d ? ?DO ? ? ? [? 
)9 
d>N 
 
 
 [
$ G$9 Gdl G G G [G 
)9 
d>N 
 
 
 [
 
T-@ 
TEX 
 
 
 [
 
)9 
d>N 
 
 
 [
  
D,?  
DDW  
  
  
 [ 
D :$* : : : : [:0 
D,> 
4CU 
 
 
 [
 
d.C 
H] 
 
 
 [
8  
- 
		" 
  
  
 [ 
D 
d.C 
H] 
 
 
 [
: 
dm 
 
 
 
 [
 DT-A DdFZ D D D [D 
d.C 
H] 
 
 
 [
 _cC C'C=EdF[=\C		C C C [C( H,H		"H H H [H" 8,8		"8 8 8 [8
 
D,? 
DK 
 
 
 [
 24#6 24; 2 2 2 [2 3)9 3d>N 3 3 3 [3 
,
		!
 
 
 [
 AT] At} A A A [A 
$*; 
@Q 
 
 
 [
. 
t/E 
$J` 
 
 
 [

 J.J		#J J J [J B4+= B$BT B B B [B 
K
	tE{De-t/@@	A
 
 
 [
 $*; S$+EU@V    [ 
<DL 
<T5F 
< 
< 
< [
< )9 d5k    [ S$*; S@Q S S S [S Nt/D NdSXkIZ N N N [N @)9 @d>N @ @ @ [@  
D,? 
DDW 
 
 
 [
 
t/D 
IY 
 
 
 [
 N$*; N@Q N N N [N 
4+= 
$BT 
 
 
 [
 ;4; ;4; ; ; ; [; ;4; ;4; ; ; ; [; :$* : : : : [:: 
4+= 
$- 
 
 
 [
  T-A d3i    [ 
H$2J 
Ht 
H 
H 
H [
H 
$*; 
@R 
 
 
 [
2  
)9  
d>O  
  
  
 [ 
D )
T-A )
dF[ )
 )
 )
 [)
V 
D,? 
DDX 
 
 
 [
B B4+= B$BW B B B [B A$*; A@U A A A [A 
+
		 
 
 
 [
 	B4+= 	B$BT 	B 	B 	B [	B 
d.B 
tG[ 
 
 
 [
 	
+	
		 	
 	
 	
 [	
 
+
		 
 
 
 [
 
t/D 
I^ 
 
 
 [
 
T-@ 
TEX 
 
 
 [
 
$*> 
4CW 
 
 
 [

 
,
		!
 
 
 [
 
d.B 
tG[ 
 
 
 [
 
-
		"
 
 
 [
$ 
D,? 
DDW 
 
 
 [
 B4+= B$BT B B B [B 	DT-A 	DdFZ 	D 	D 	D [	D 	H,	H		!	H 	H 	H [	H 
+
		&
 
 
 [
 
,
		'
 
 
 [
 
+
		&
 
 
 [
 Ed.C EH] E E E [E G+G		 G G G [G 
1
		&
 
 
 [
 
$*; 
@Q 
 
 
 [
 
$*; 
@Q 
 
 
 [

 
 
DO 
 
 
 [
 T\ dl    [ 
 
DO 
 
 
 [
 K/K		$K K K [K" 
t/D 
I^ 
 
 
 [
 F0F F4Ka F F F [F UH.UH		UH UH UH [UHn =c =dm = = = [=
 Ft/E F$J` F F F [F 
0F 
4Ka 
 
 
 [
 =T] =t} = = = [= 
+
		 
 
 
 [
 d+d	c4**	+d d d [d
 dm     [ Tt/D TI^ T T T [T
 CD,? CDDW C C C [C >dn > > > > [> 	"t~ 	"$. 	" 	" 	" [	" 	
T\ 	
dl 	
 	
 	
 [	
  DO    [ 
DM 
d>P 
 
 
 [
 
t/D 
IY 
 
 
 [
 
t/D 
I^ 
 
 
 [
 
*
		'
 
 
 [
 
,
		)
 
 
 [
 
 
r(   r   c            	       :   e Zd Zedej        dej        fd            Zedej        dej        fd            Z	ede
eef         defd            Zedej        dej        fd            Zedej        dej        fd            Zedej        dej        fd            Zedej        dej        fd	            Zedej        dej        fd
            Zedej        dej        fd            Zedeeej        f         deeej        f         fd            Z edej        dej        fd            Z!edej"        dej#        fd            Z$edej%        dej%        fd            Z&edej'        dej'        fd            Z(edej)        dej)        fd            Z*edej+        dej+        fd            Z,edej-        dej-        fd            Z.edej/        dej/        fd            Z0edej1        dej1        fd            Z2edej3        dej3        fd            Z4edej5        dej5        fd            Z6edej7        dej7        fd            Z8edej9        dej9        fd            Z:edej;        dej;        fd            Z<edej=        dej=        fd            Z>edej?        dej?        fd            Z@edejA        dejA        fd            ZBedejC        dejC        fd            ZDedejE        deeejF        f         fd            ZGedejH        dejH        fd             ZIedejJ        dejJ        fd!            ZKedejL        dejL        fd"            ZMedejN        dejN        fd#            ZOedejP        dejH        fd$            ZQedejR        dejL        fd%            ZSedejT        dejT        fd&            ZUedejV        dejV        fd'            ZWedejX        dejY        fd(            ZZedejY        dejY        fd)            Z[edej\        d*edej\        fd+            Z]edej^        dej^        fd,            Z_edej`        dej`        fd-            Zaedejb        dejb        fd.            Zcedejd        dejd        fd/            Zeed0efejg                 deheji                 fd1            Zjed0efejg                 dehejk                 fd2            Zledejg        dejm        fd3            Znedejg        dejm        fd4            Zoedejp        dejk        fd5            Zqedejg        dejr        fd6            Zsedejt        dejt        fd7            Zuedejv        deji        fd8            Zwedejx        dejx        fd9            Zyedejz        dejz        fd:            Z{edej|        dej}        fd;            Z~edej|        dej}        fd<            Zedej        dej}        fd=            Zedej        dej        fd>            Zedej        dej        fd?            Zedej        dej        fd@            Zedej        dej        fdA            Zedej        dej        fdB            Zedej        dej        fdC            Zedej        dej        fdD            Zedej        dej        fdE            Zedej        dej        fdF            Zedej        dej        fdG            Zedej        dej        fdH            Zedej        dej        fdI            Zedej        dej        fdJ            Zedej        dej        fdK            Zedej        dej        fdL            Zedej        dej        fdM            Zedej        dej        fdN            Zedej        dOedehej                 fdP            Zedej        deehe         eej                 ee         f         fdQ            Zedehe         dej        fdR            Zedejp        dejp        fdS            Zedehehe                  dej        fdT            Zedej        dej        fdU            Zedej        dej        fdV            Zedej        dej        fdW            Zedej        dej        fdX            Zedej        dej        fdY            Zedej        dej        fdZ            Zedej        dej        fd[            Zedej        dej        fd\            Zedej        dej        fd]            Zedej        dej        fd^            Zedej        d*edej        fd_            Zedej        d*edej        fd`            Zedej        d*edej        fda            Zedej        d*edej        fdb            Zedej        d*edej        fdc            Zedej        d*edej        fdd            Zedej        d*edej        fde            Zedej        d*edej        fdf            Zedej        dej        fdg            Zedej        dej        fdh            Zedej        dej        fdi            Zedej        dej        fdj            Zedej        dej        fdk            Zedej        dej        fdl            Zedmej        dej        fdn            Zedej        dej        fdo            Zedej        dej        fdp            Zedej        dej        fdq            Zedej        dej        fdr            Zedej        dej        fds            Zedej        dej        fdt            Zedej        dej        fdu            Zedej        dej        fdv            Zedej        dej        fdw            Zedej        dej        fdx            Zedej         dej         fdy            Zedej        dej        fdz            Zedej        dej        fd{            Zedej        dej        fd|            Zedej        dej        fd}            Z	edej
        dej
        fd~            Zedej        dej        fd            Zedej        dej        fd            Zedej        dej        fd            Zedej        dej        fd            Zedej        dej        fd            Zedej        dehejC                 fd            Zedej        dej        fd            Zedej        dej        fd            Zedej        defd            Zedej        dej        fd            Zedej         dej!        fd            Z"edej#        dej#        fd            Z$edej%        dej%        fd            Z&ede'eej%        f         dej(        fd            Z)edej*        dej*        fd            Z+edej,        dej,        fd            Z-edej.        dej.        fd            Z/edej0        dej1        fd            Z2edej3        dej3        fd            Z4edej5        dej6        fd            Z7edej8        dej9        fd            Z:dS )
RestToGrpcrj   r   c           
          dt           t          t          j                 t          j        f         dt          t          j                 f fd}t	          j        |j         ||j                  nd |j         ||j                  nd |j         ||j                  nd |j	        3t	          j
         ||j	        j                  |j	        j                  nd           S )Nr   r   c                 P    t          | t                    s| g} fd| D             S )Nc                 :    g | ]}                     |          S r    r   r   s     r&   r'   zIRestToGrpc.convert_filter.<locals>.convert_conditions.<locals>.<listcomp>C  s'    QQQC)))44QQQr(   )rF   r   )r   r   s    r&   convert_conditionsz5RestToGrpc.convert_filter.<locals>.convert_conditions>  s8     j$// *(\
QQQQjQQQQr(   r   )r   r   r   r   )r   r   r   r  r   r   r   r   r   r   r   r   r   )r   rj   rY  s   `  r&   r   zRestToGrpc.convert_filter<  s   	Rd4>2DNBC	R$.!	R 	R 	R 	R 	R 	R {49J4J$$UZ000PT<AN<V((888\`8=8P&&u|444VZ #/	 11%2B2MNN#.8   
 
 
 
 	
r(   c                 Z    t          j        |j        |j        |j        |j                  S N)r   r   r   r   )r   r   r   r   r   r   r   s     r&   r   zRestToGrpc.convert_rangeS  s/    zxx			
 
 
 	
r(   c                    t          |t                    rFt          |t                    s1t          j        |t          j                                                  }t                      }|                    |           |S r?   )rF   r   r   combinemintimer   FromDatetimer   rj   tss      r&   convert_datetimezRestToGrpc.convert_datetime\  sg    eT"" 	A:eX+F+F 	A$UHL,=,=,?,?@@E[[
	r(   c                 :   t          j        |j        |                     |j                  nd |j        |                     |j                  nd |j        |                     |j                  nd |j        |                     |j                  nd           S r[  )r   r   r   rc  r   r   r   r   s     r&   r   z!RestToGrpc.convert_datetime_ranged  s    !161Es##EH---4161Es##EH---43893H$$UY///d3893H$$UY///d	
 
 
 	
r(   c                 h    t          j        |                     |j                  |j                  S r   )r   r   r   r   r   r   s     r&   r   zRestToGrpc.convert_geo_radiusm  r   r(   c                 6    t          j        |j                  S r   )r   r   r"   r   s     r&   r   z)RestToGrpc.convert_collection_descriptionq  r   r(   c           	      L   t          j        |j        r|                     |j                  nd |                     |j                  |j        |                     |j                  nd |j        | 	                    |j
                  |j        |j        nd |j                  S )N)r   r   r   r   r   r   r   )r   r   r   r   r   r   r   r   r   r   r   r   r   r   s     r&   r   z"RestToGrpc.convert_collection_infow  s    "BG,X300>>>TX 99%:PQQ '3 **5+?@@@ /00>>161D1P%--VZ+
 
 
 	
r(   c                 V   |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j	        k    rt          j        j
        S t          d|           r:  )r   r;  rA  r   r@  r?  r>  r=  r<  rC  rB  r*   r   s     r&   r   z$RestToGrpc.convert_collection_status  s    D)---(,,D)000(//D)///(..D)...(--CECCDDDr(   c                     t          |t          j                  rt          j        d          S t          |t          j                  rt          j        d|j                  S t          d|           )NT)r   F)r   r   z invalid OptimizersStatus model: )rF   r   r   r   r  r   r   r*   r   s     r&   r   z#RestToGrpc.convert_optimizer_status  s{    eT788 	'    eT899 	E'5DDDDCECCDDDr(   c                 ^     t           fd|                                D                       S )Nc              3   L   K   | ]\  }}|                     |          fV  d S r?   )convert_payload_index_infor  s      r&   rA   z4RestToGrpc.convert_payload_schema.<locals>.<genexpr>  s:      ]]83S#88==>]]]]]]r(   rd   r   s   ` r&   r   z!RestToGrpc.convert_payload_schema  s0     ]]]]u{{}}]]]]]]r(   c                     |j         }t          j        |                     |j                  ||                     |          nd |j                  S )Nr  )r   r   r   r  r  r  r  )r   rj   r   s      r&   rl  z%RestToGrpc.convert_payload_index_info  sW    %55eoFF@F@R344V<<<X\<
 
 
 	
r(   c                 F   t          |t          j                  r(t          j        |                     |                    S t          |t          j                  r(t          j        |                     |                    S t          |t          j                  r(t          j        | 	                    |                    S t          |t          j
                  r(t          j        |                     |                    S t          |t          j                  r(t          j        |                     |                    S t          |t          j                  r(t          j        |                     |                    S t          |t          j                  r(t          j        |                     |                    S t          |t          j                  r(t          j        |                     |                    S t)          d	|           )
N)r   )r!  )r"  )r#  )r$  )r%  )r&  )r'  z#invalid PayloadSchemaParams model: )rF   r   r  r   r!  r(  r  r)  r  r*  r  r+  r  r,  r  r-  r  r.  r  r/  r*   r   s     r&   r  z(RestToGrpc.convert_payload_schema_params  s    eT122 	c*S=Z=Z[`=a=abbbbeT455 	*%(%E%Ee%L%L    eT455 	*%(%E%Ee%L%L    eT233 	*#&#A#A%#H#H    eT011 	a*C<X<XY^<_<_````eT122 	c*S=Z=Z[`=a=abbbbeT566 	*&)&G&G&N&N    eT122 	c*S=Z=Z[`=a=abbbbFuFFGGGr(   c                    |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j	        k    rt          j        j
        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S t'          d|           rl   )r   rm   r4  r   rn   r3  rq   r1  rs   r5  ru   r2  rw   r6  ry   r7  r{   r8  r}   r*   r   s     r&   r  z&RestToGrpc.convert_payload_schema_type  s   D*222)11D*222)11D*000)//D*///)..D*...)--D*///)..D*333)22D*///)..DUDDEEEr(   c                 h    t          j        |j        |                     |j                            S rE  )r   rG  rF  convert_update_statsr   r   s     r&   rI  z RestToGrpc.convert_update_result  s5     +++EL99
 
 
 	
r(   c                     |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S t          d|           rK  )r   rL  rP  r   rO  rN  rM  r*   r   s     r&   rq  zRestToGrpc.convert_update_stats  sS    D%///$..D%222$11???@@@r(   c                 P     t          j         fd|j        D                       S )Nc                 :    g | ]}                     |          S r    convert_extended_point_idrU  s     r&   r'   z7RestToGrpc.convert_has_id_condition.<locals>.<listcomp>  s'    OOO3C11#66OOOr(   rW  )r   rX  r   r   s   ` r&   r   z#RestToGrpc.convert_has_id_condition  s6    "OOOO%,OOO
 
 
 	
r(   c                 6    t          j        |j                  S r^  )r   r`  r_  r   s     r&   ra  zRestToGrpc.convert_delete_alias  rb  r(   c                 B    t          j        |j        |j                  S rd  )r   rg  re  rf  r   s     r&   rh  zRestToGrpc.convert_rename_alias  ri  r(   c                 @    t          j        |j        j                  S Nrk  )r   rm  r   r\   r   s     r&   r   z%RestToGrpc.convert_is_empty_condition  s    $);<<<<r(   c                 @    t          j        |j        j                  S rz  )r   rq  r   r\   r   s     r&   r   z$RestToGrpc.convert_is_null_condition  s    #(9::::r(   c                 |    t          j        |j        j        |                     |j        j                            S )Nrs  )r   ru  r   r\   r   r   r   s     r&   r   z#RestToGrpc.convert_nested_condition  s:    # %%el&9::
 
 
 	
r(   c                     t          j        |j        |j        |j        |                     |j                  nd |j                  S )Nr|  )r   r}  rx  ry  rz  r~  r{  r   s     r&   r  z RestToGrpc.convert_search_params  sS     M+ %1 66u7IJJJ+	
 	
 	
 		
r(   c                 B    t          j        |j        |j                  S r  )r   r  r  r_  r   s     r&   r  zRestToGrpc.convert_create_alias$  r  r(   c                     t          |t                    rt          j        |          S t          |t                    rt          j        |          S t          d|           )N)rH   rI   r  )rF   rH   r   r%  rI   r*   r   s     r&   r  zRestToGrpc.convert_order_value(  sc    eS!! 	.?u----eU## 	0?////=e==>>>r(   c                    t          j        |                     |j                  |j        |                     |j                  nd |j        |j        |                     |j                  nd |j	        |j
        r|                     |j
                  nd |j        r|                     |j                  nd           S )N)r  r/   r  r  r  r  r  )r   r  rv  r  r/   r  r  r  convert_vector_structr  r  r  r  r  r   s     r&   r  zRestToGrpc.convert_scored_point0  s    ,,UX66:?-:SC''666Y]+?D|?WC--el;;;]aM@EYc++EO<<<UYFKFWa//0ABBB]a
 
 
 	
r(   c                 Z    t          j        |j        |j        |j        |j                  S r[  )r   r  r   r   r   r   r   s     r&   r  zRestToGrpc.convert_values_count<  s0    xx			
 
 
 	
r(   c                     t          j        |                     |j                  |                     |j                            S )N)r  r  )r   r  r   r  r  r   s     r&   r  z#RestToGrpc.convert_geo_bounding_boxE  sC    "**5>::..u/ABB
 
 
 	
r(   c                     t          j        |                     |j                  |                     |j                  |j        |                     |j                  nd           S N)r  r  r/   )r   r  rv  r  r  r  r/   r  r   s     r&   r  zRestToGrpc.convert_point_structL  sb    ,,UX66--el;;:?-:SC''666Y]
 
 
 	
r(   c                 X    t          d |                                D                       S )Nc              3   >   K   | ]\  }}|t          |          fV  d S r?   r9   r[   s      r&   rA   z-RestToGrpc.convert_payload.<locals>.<genexpr>V  s3      LL(#sS-,,-LLLLLLr(   rd   r   s     r&   r  zRestToGrpc.convert_payloadT  s'    LLekkmmLLLLLLr(   c                 r    t          j        |j        |j        |j        |j        |j        |j                  S N)r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   s     r&   r   z#RestToGrpc.convert_hnsw_config_diffX  =    "+ % 9g!&!;Mo
 
 
 	
r(   c                 L   |j         r3t          j        |j        |                     |j                             S |j        rt          |j        t          j                  r3t          j        |j        | 	                    |j                            S t          |j        t          j
                  r3t          j        |j        |                     |j                            S |j        r3t          j        |j        |                     |j                            S |j        r3t          j        |j        |                     |j                            S |j        r3t          j        |j        |                     |j                            S t%          d|           )N)r\   r  )r\   r  )r\   r  )r\   r  )r\   r  )r\   r  zinvalid FieldCondition model: )r  r   r  r\   r  r  rF   r   r   r   r   r   r  r  r  r   r  r  r*   r   s     r&   r   z"RestToGrpc.convert_field_conditionc  s   ; 	\&59C<M<Mek<Z<Z[[[[; 	%+tz22 `*uy@Q@QRWR]@^@^____%+t'9:: *	#2L2LU[2Y2Y    ! 	&I!$!=!=e>T!U!U     	&I#*@*@AQ*R*R     	&IC,D,DUEW,X,X    A%AABBBr(   c                 B    t          j        |j        |j                  S Nr  r   r  r  r  r   s     r&   r  z"RestToGrpc.convert_wal_config_diff}  (    !!1$7
 
 
 	
r(   c           	      6   t          j        |                     |j                  |                     |j                  |                     |j                  |                     |j	                  |j
        |                     |j
                  nd           S )N)r   r   r   r   r   )r   r   r   r   r   r   convert_optimizers_configr   r   r   r   r   r   s     r&   r   z$RestToGrpc.convert_collection_config  s    $00>>//0ABB ::5;QRR--e.>?? ,8 //0IJJJ

 

 

 
	
r(   c                 r    t          j        |j        |j        |j        |j        |j        |j                  S r  r  r   s     r&   r   zRestToGrpc.convert_hnsw_config  r  r(   c                 B    t          j        |j        |j                  S r  r  r   s     r&   r   zRestToGrpc.convert_wal_config  r  r(   c                 V   |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j	        k    rt          j        j
        S t          d|           r  )r   r  r  r   r
  r  r  r  r  r	  r  r*   r   s     r&   r  zRestToGrpc.convert_distance  s    DM%%%=$$DM(((=''DM(((=''DM+++=**;E;;<<<r(   c                 6   t          j        |j        |                     |j                  nd |j        |j        pd|j        |j        |j        |j	        | 
                    |j	                  nd |j        |                     |j                  nd           S )NF)r  r  r  r  r  r  r  r  )r   r  r  r  r  r  r  r  r  r  r  r  r  r   s     r&   r   z$RestToGrpc.convert_collection_params  s    $=B]=V**5=999\`+!1:U%*%C$7 % 9 '3 001EFFF (4 ++E,ABBB#
 
 
 	
r(   c           
          t          j        |j        |j        |j        |j        |j        |j        |j        |j	                  S Nr   
r   r  r   r   r   r   r   r   r   r   r   s     r&   r  z$RestToGrpc.convert_optimizers_config  sL    (#(#?#5$7$7%*%C"3"3%*%C	
 	
 	
 		
r(   c           
          t          j        |j        |j        |j        |j        |j        |j        |j        |j	                  S r  r  r   s     r&   r  z)RestToGrpc.convert_optimizers_config_diff  sN     (#(#?#5$7$7%*%C"3"3%*%C	
 	
 	
 		
r(   r  c           
         t          j        ||j        |                     |j                  nd |j        |                     |j                  nd |j        |                     |j                  nd |j        | 	                    |j                  nd |j
        |                     |j
                  nd           S )N)r  r  r  r   r   r   )r   r  r  r  r  r  r   r  r   r   r   r  r   rj   r  s      r&   r  z$RestToGrpc.convert_update_collection  s     $+ *6 2253JKKK =, //>>> <+ 225<@@@ $0 ,,U->??? ,8 44U5NOOO3
 
 
 	
r(   c                 B    t          j        |j        |j                  S )N)r  r  )r   r  r  r  r   s     r&   r   zRestToGrpc.convert_geo_point	  s    }	::::r(   c                    t          |t          j                  rt          |j        t                    rt          j        |j                  S t          |j        t                    rt          j        |j                  S t          |j        t                    rt          j        |j                  S t          |t          j	                  rt          j        |j
                  S t          |t          j                  rt          |j                  dk    r(t          j        t          j        g                     S t          |j        d         t                    r-t          j        t          j        |j                            S t          |j        d         t                    r-t          j        t          j        |j                            S t!          d	|           t          |t          j                  rt          |j                  dk    r(t          j        t          j        g           
          S t          |j        d         t                    r-t          j        t          j        |j                  
          S t          |j        d         t                    r-t          j        t          j        |j                            S t!          d|           t!          d|           )N)r  r  r  r  r   )r  )r  )r  zinvalid MatchAny model: )r  )r  zinvalid MatchExcept model: r  )rF   r   r  rP   rG   r   r'  rH   rJ   r  r  r  rH  r  RepeatedStringsRepeatedIntegersr*   r  except_r   s     r&   r  zRestToGrpc.convert_match		  s   eT_-- 	7%+t,, 7z%+6666%+s++ 7z%+6666%+s++ 7z%+6666eT^,, 	/:5:....eT]++ 	A59~~""z4+?+K+K+KLLLL%)A,,, Tz4+?	+R+R+RSSSS%)A,,, Vz4+@%)+T+T+TUUUU???@@@eT-.. 	D5=!!Q&&z$2Fr2R2R2RSSSS%-*C00 _z$2Fu}2]2]2]^^^^%-*C00 az$2GQVQ^2_2_2_````B5BBCCC888999r(   c                    t          |t          j                  r-t          j        |                     |j                            S t          |t          j                  r-t          j        |                     |j	                            S t          |t          j
                  r-t          j        |                     |j                            S t          d|           )Nr  r  r  r  )rF   r   r  r   r(  r  r  r  ra  r  r  rh  r  r*   r   s     r&   r  z#RestToGrpc.convert_alias_operations'	  s    eT677 	c'S5M5MeN`5a5abbbbeT677 	c'S5M5MeN`5a5abbbbeT677 	c'S5M5MeN`5a5abbbbB5BBCCCr(   c                 B    t          j        |j        |j                  S r  )r   r  r_  r  r   s     r&   r  z$RestToGrpc.convert_alias_description2	  r  r(   examplesc                     g }|D ]r}t          |t          t          j                            r|                     |          }nt          |t
          j                  r|}n]|                    |           s|S r?   )rF   r   r   r$  rv  r   r#  append)r   r  r  exampleid_s        r&   !convert_recommend_examples_to_idsz,RestToGrpc.convert_recommend_examples_to_ids9	  s     #% 	 	G'#6t7K#L#LMM 33G<<GT\22 JJsOOOO
r(   c                 0   g }|D ]}t          |t          j                  r|}n\t          |t                    rt          j        |          }n1t          |t          j                  r|                     |          }n{|                    |           |S NrO  )rF   r   r/  rK   r   rF  convert_sparse_vector_to_vectorr  )r   r  r  r  r  s        r&   %convert_recommend_examples_to_vectorsz0RestToGrpc.convert_recommend_examples_to_vectorsJ	  s     &( 
	# 
	#G'4;//  GT** '222GT%677 <<WEENN6""""r(   c                 ,    |                      |          S r?   )convert_recommend_exampler   s     r&   r  z!RestToGrpc.convert_vector_example]	  s    ,,U333r(   c                    t          |t          t          j                            r(t	          j        |                     |                    S t          |t          j                  r(t	          j        |                     |                    S t          |t                    r(t	          j        t	          j
        |                    S t          d|           )Nr  r  rO  z Invalid RecommendExample model: )rF   r   r   r$  r   rA  rv  rF  r  rK   r/  r*   r   s     r&   r  z$RestToGrpc.convert_recommend_examplea	  s    e01EFFGG 	O%)F)Fu)M)MNNNNeT.// 	Y%S-P-PQV-W-WXXXXeT"" 	F%T[e-D-D-DEEEECECCDDDr(   c                 h    t          j        |j        t          j        |j                            S )NrO  )rG  rA  )r   r/  r<   SparseIndicesrA  r   s     r&   r  z*RestToGrpc.convert_sparse_vector_to_vectorl	  s3    {&EM:::
 
 
 	
r(   c                 R    t          j        |                     |                    S )N)r  )r   rC  r  r   s     r&   r  z RestToGrpc.convert_target_vectors	  s$     (E(Ee(L(LMMMMr(   c                     t          j        |                     |j                  |                     |j                            S rl  )r   r  r  rf  rg  r   s     r&   r  z'RestToGrpc.convert_context_example_pairw	  sD    
 &225>BB225>BB
 
 
 	
r(   c                     t          |t                    rt          j        |          S t          |t                    rt          j        |          S t          d|           )N)r[  )r\  zinvalid ExtendedPointId model: )rF   rH   r   r#  rJ   r*   r   s     r&   rv  z$RestToGrpc.convert_extended_point_id	  sc    eS!! 	+<E****eS!! 	,<U++++B5BBCCCr(   c                 \    t          |t          j                  r9t          j        t          j         fd|j        D                                 S t          |t          j                  r-t          j                             |j	                            S t          d|           )Nc                 :    g | ]}                     |          S r    ru  r  s     r&   r'   z6RestToGrpc.convert_points_selector.<locals>.<listcomp>	  s'    XXX%66u==XXXr(   )r  r  r   r  )rF   r   r  r   r)  PointsIdsListr  r  r   r   r*   r   s   ` r&   r  z"RestToGrpc.convert_points_selector	  s    eT.// 	&)XXXX5<XXX     
 eT011 	P&c.@.@.N.NOOOOA%AABBBr(   c                 >   t          |t          j                  r(t          j        |                     |                    S t          |t          j                  r(t          j        |                     |                    S t          |t          j                  r(t          j        | 	                    |                    S t          |t          j
                  r(t          j        |                     |                    S t          |t          j                  r(t          j        |                     |                    S t          |t          j                  r(t          j        |                     |                    S t!          d|           )N)r   rl  rp  rW  r  rt  r   )rF   r   r  r   r  r   rm  r   rq  r   rX  r   r   r   ru  r   r*   r   s     r&   r   zRestToGrpc.convert_condition	  sb   eT011 	L>(C(CE(J(JKKKKeT233 	R>3+I+I%+P+PQQQQeT122 	P>#*G*G*N*NOOOOeT011 	N>)E)Ee)L)LMMMMeT[)) 	D>););E)B)BCCCCeT122 	N>)E)Ee)L)LMMMM<U<<===r(   c                 B   t          |t          j                  r-t          j        t          j        |j                            S t          |t          j                  r-t          j        t          j        |j	                            S t          d|           )NrB   r  r  zinvalid PayloadSelector model: )rF   r   PayloadSelectorIncluder   r+  PayloadIncludeSelectorr  r  PayloadExcludeSelectorr  r*   r   s     r&   convert_payload_selectorz#RestToGrpc.convert_payload_selector	  s    eT899 	+35=III    eT899 	+35=III    B5BBCCCr(   c                 ,    |                      |          S r?   )r  r   s     r&   r  z(RestToGrpc.convert_with_payload_selector	  s     11%888r(   c                 l   t          |t                    rt          j        |          S t          |t                    r(t          j        t          j        |                    S t          |t          t          j                            r| 	                    |          S t          d|           )Nr  rB   r  z$invalid WithPayloadInterface model: )rF   rG   r   r+  rK   r  r   r   PayloadSelectorr  r*   r   s     r&   r  z)RestToGrpc.convert_with_payload_interface	  s     eT"" 	7+59999t$$ 	7+D4OW\4]4]4]^^^^x(<==>> 	7//666GGGHHHr(   c                    t          |t                    rt          j        |          S t          |t                    rt          j        |          S t          |t
                    r*|                     |          }t          j        |          S t          |t                    rt          j        |          S t          d|           )Nr  r  )r  )r   zinvalid StartFrom model: )	rF   rH   r   rN  rI   r   rc  rJ   r*   ra  s      r&   r  zRestToGrpc.convert_start_from	  s    eS!! 	1>%0000eU## 	/>....eX&& 	0%%e,,B>B////eS!! 	2>51111<U<<===r(   c                     |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S t          d|           r  )r   r  r  r   r  r  r  r*   r   s     r&   r  zRestToGrpc.convert_direction	  sO    DN&&&>%%DN'''>&&<U<<===r(   c                     t          j        |j        |j        |                     |j                  nd |j        |                     |j                  nd           S )Nr  )r   r  r\   r  r  r  r  r   s     r&   r  zRestToGrpc.convert_order_by	  se    |	:?/:U%%eo666[_ =B<L<X&&u'7888^b
 
 
 	
r(   c                     t          |t                    rt          j        |          S t          |t          j                  r|                     |          S t          d|           )Nrk  z invalid OrderByInterface model: )rF   rJ   r   r  r   r  r*   r   s     r&   convert_order_by_interfacez%RestToGrpc.convert_order_by_interface	  sh    
 eS!! 	+<E****eT\** 	/''...CECCDDDr(   c                     t          |t                    rt          j        |          S t          |t                    rt          j        |          S t          d|           )Nr6   r3   r  )rF   rJ   r   rO  rH   r*   r   s     r&   r  zRestToGrpc.convert_facet_value	  sc    eS!! 	7?6666eS!! 	8?7777=e==>>>r(   c                 h    t          j        |                     |j                  |j                  S r  )r   rP  r  rP   r  r   s     r&   r  z"RestToGrpc.convert_facet_value_hit	  s3    }))%+66+
 
 
 	
r(   c           	      Z   t          j        |                     |j                  |                     |j                  |j        |                     |j                  nd |j        r| 	                    |j                  nd |j
        r|                     |j
                  nd           S )N)r  r/   r  r  r  )r   r-  rv  r  r  r/   r  r  r  r  r  r  r   s     r&   r  zRestToGrpc.convert_record
  s    ",,UX66''66?D|?WC--el;;;]a@EYc++EO<<<UYFKFWa//0ABBB]a
 
 
 	
r(   c                 ,    |                      |          S r?   )r  r   s     r&   r  z"RestToGrpc.convert_retrieved_point
  s    !!%(((r(   c                 6    t          j        |j                  S r  )r   r  r  r   s     r&   r  zRestToGrpc.convert_count_result
  r  r(   c                     t                      }|                    t          j        |j                             t          j        |j        ||j                  S )Nr  )	r   r`  r   fromisoformatr  r   r  r"   r  )r   rj   r  s      r&   r  z'RestToGrpc.convert_snapshot_description
  sV     KK	x5e6IJJKKK'#
 
 
 	
r(   c                 
   |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S t          d|           r  )
r   r  r  r   r  r!  r   r#  r"  r*   r   s     r&   r$  zRestToGrpc.convert_datatype!
  sj    DM)))=((DM'''=&&DM)))=((;E;;<<<r(   c                    t          j        |j        |                     |j                  |j        |                     |j                  nd |j        |                     |j                  nd |j	        |j
        |                     |j
                  nd |j        |                     |j                  nd           S )Nr(  )r   r*  r  r  r)  r   r   r   r   r   r&  r$  r'  r+  r   s     r&   r,  z RestToGrpc.convert_vector_params,
  s     ))%.99 $0 ,,U->??? ,8 //0IJJJM=B^=WS))%.999]a +7 ..u/GHHH%
 
 
 	
r(   c                 \    t          j        |                     |j                            S r.  )r   r0  r1  r/  r   s     r&   r+  z%RestToGrpc.convert_multivector_configD
  r2  r(   c                 r    |t           j        j        k    rt          j        j        S t          d|           r4  )r   r5  r7  r   r6  r*   r   s     r&   r1  z)RestToGrpc.convert_multivector_comparatorJ
  s8     D.666-44HHHIIIr(   c           	      |    t          |t          j                  r(t          j                             |                    S t          |t                    rSt          j        t          j        t           fd|                                D                                           S t          d|           )Nr   c              3   L   K   | ]\  }}|                     |          fV  d S r?   r<  r  s      r&   rA   z4RestToGrpc.convert_vectors_config.<locals>.<genexpr>Z
  s:      aaxsCc3#<#<S#A#ABaaaaaar(   r?  r:  r9  )
rF   r   r*  r   r.  r,  rM   VectorParamsMaprN   r*   r   s   ` r&   r  z!RestToGrpc.convert_vectors_configS
  s    eT.// 		F%S-F-Fu-M-MNNNNt$$ 	F%/aaaaSXS^S^S`S`aaaaa      DUDDEEEr(   c                    dt           t          t                   t          t          t                            f         dt          j        fd}t          |t                    rt          j         ||                    S t          |t                    ri }|	                                D ]\  }}t          |t                    r!|
                    | ||          i           ;t          |t          j                  r*|
                    ||                     |          i           t          j        t          j        |                    S t          d|           )Nr  r   c                     t          |           dk    rHt          | d         t                    r-t          j        d | D             t          |                     S t          j        |           S )Nr   c                     g | ]	}|D ]}|
S r    r    )r#   multi_vectorinner_vectors      r&   r'   zLRestToGrpc.convert_vector_struct.<locals>.convert_vector.<locals>.<listcomp>g
  s?       (,8  ) %   r(   )rG  r   rO  )rH  rF   rK   r   r/  r  s    r&   rI  z8RestToGrpc.convert_vector_struct.<locals>.convert_vectorb
  s    6{{aJq	4% % { ,2  
 #&f++    ;F++++r(   r  rW  zinvalid VectorStruct model: )r   r   rI   r   r/  rF   rK   r1  rM   rN   updater   rF  r  r0  r*   )r   rj   rI  r  r\   r]   s         r&   r  z RestToGrpc.convert_vector_struct`
  sO   	,5ed4;6G)G#H 	,T[ 	, 	, 	, 	, eT"" 	E<~~e'<'<====t$$ 		EG!KKMM T TSc4(( TNNC)<)<#=>>>>T%677 TNNC)L)LS)Q)Q#RSSS<(9'(J(J(JKKKKCECCDDDr(   c                     t          |t                    rt          j        |          S t          |t                    r(t          j        t          j        |                    S t          d|           )Nr  r  r  zinvalid WithVectors model: )rF   rG   r   r;  rK   r:  r*   r   s     r&   convert_with_vectorszRestToGrpc.convert_with_vectors}
  su    eT"" 	D+59999t$$ 	D+D4Hu4U4U4UVVVVB5BBCCCr(   num_recordsc                 Z    t          |t                    r fd|D             S t          |t                    rad t          |          D             }|                                D ]%\  }}t          |          D ]\  }}|||         |<   & fd|D             S t          d|           )Nc                 :    g | ]}                     |          S r    r  r#   itemr   s     r&   r'   z:RestToGrpc.convert_batch_vector_struct.<locals>.<listcomp>
  s'    FFFC--d33FFFr(   c                     g | ]}i S r    r    )r#   r  s     r&   r'   z:RestToGrpc.convert_batch_vector_struct.<locals>.<listcomp>
  s    !A!A!A"!A!A!Ar(   c                 :    g | ]}                     |          S r    r  r  s     r&   r'   z:RestToGrpc.convert_batch_vector_struct.<locals>.<listcomp>
  s'    GGGC--d33GGGr(   z!invalid BatchVectorStruct model: )rF   rK   rM   r  rN   	enumerater*   )r   rj   r  resultr\   r]   rD  r  s   `       r&   convert_batch_vector_structz&RestToGrpc.convert_batch_vector_struct
  s     eT"" 		JFFFFFFFFt$$ 	J!A!AeK.@.@!A!A!AF!KKMM * *S(~~ * *GAt%)F1IcNN*GGGGGGGGHHHIIIr(   c                 B   t          |t                    r|d d fS t          |t          j                  r|j        d |j        fS t          |t          j                  r1|j        j        t          j	        |j        j
                  |j        fS t          d|           )NrO  z!invalid NamedVectorStruct model: )rF   rK   r   r  r  r"   NamedSparseVectorr<   r   r  rA  r*   r   s     r&   convert_named_vector_structz&RestToGrpc.convert_named_vector_struct
  s     eT"" 	J$$$t/00 	J<uz11t566 	J<&(:@T(U(U(UW\WaaaHHHIIIr(   c                 ,    t          j        |          S r  )r   r3  r   s     r&   rP  zRestToGrpc.convert_dense_vector
  s    U++++r(   c                 B    t          j        |j        |j                  S )N)r<   rA  )r   rF  r<   rA  r   s     r&   rR  z RestToGrpc.convert_sparse_vector
  s     emLLLLr(   c                 F     t          j         fd|D                       S )Nc                 :    g | ]}                     |          S r    rU  rV  s     r&   r'   z9RestToGrpc.convert_multi_dense_vector.<locals>.<listcomp>
  s'    JJJ&S--f55JJJr(   rW  )r   r4  r   s   ` r&   rX  z%RestToGrpc.convert_multi_dense_vector
  s4    $JJJJEJJJ
 
 
 	
r(   c                 n   t          |t                    r~t          |          dk    rCt          |d         t                    r(t          j        |                     |                    S t          j        |                     |                    S t          |t          j                  r(t          j        | 	                    |                    S t          |t          t          j                            r(t          j        |                     |                    S t          d|           )Nr   )r]  )r[  )r\  r  rZ  )rF   rK   rH  r   r5  rX  rP  r   rF  rR  r   r$  rv  r*   r   s     r&   r^  zRestToGrpc.convert_vector_input
  s   eT"" 	K5zzQ:a$$ $ 'C4R4RSX4Y4YZZZZ##*B*B5*I*IJJJJeT.// 	M#3+D+DU+K+KLLLLe01EFFGG 	M#s'D'DU'K'KLLLL>u>>???r(   c                      t          j        |j         fd|j        D             nd |j         fd|j        D             nd |j                             |j                  nd           S )Nc                 :    g | ]}                     |          S r    ra  rV  s     r&   r'   z6RestToGrpc.convert_recommend_input.<locals>.<listcomp>
  rb  r(   c                 :    g | ]}                     |          S r    ra  rV  s     r&   r'   z6RestToGrpc.convert_recommend_input.<locals>.<listcomp>
  rb  r(   re  )r   rh  rf  rg  rd  ri  r   s   ` r&   rj  z"RestToGrpc.convert_recommend_input
  s    "~) UTTTU^TTTT~) UTTTU^TTTT~) 33ENCCC

 

 

 
	
r(   c                     t          j        |                     |j                  |                     |j                            S rl  )r   r6  r^  rf  rg  r   s     r&   rn  z%RestToGrpc.convert_context_input_pair
  sB    $--en==--en==
 
 
 	
r(   c                     t          |t                    r!t          j         fd|D                       S t          |t          j                  r)t          j                             |          g          S t          d|           )Nc                 :    g | ]}                     |          S r    rq  rr  s     r&   r'   z4RestToGrpc.convert_context_input.<locals>.<listcomp>
  s'    NNNs55d;;NNNr(   rt  zinvalid ContextInput model: )rF   rK   r   r7  r   rm  rn  r*   r   s   ` r&   rv  z RestToGrpc.convert_context_input
  s    eT"" 	$NNNNNNN    eT-.. 	T$C,J,J5,Q,Q+RSSSS???@@@r(   c                     t          j        |                     |j                  |                     |j                            S rx  )r   r{  r^  ry  rv  rz  r   s     r&   r|  z!RestToGrpc.convert_discover_input
  r}  r(   c                     |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S t          d|           r  )r   r  r  r   r  r*   r   s     r&   r  zRestToGrpc.convert_fusion
  r  r(   c                 r    |t           j        j        k    rt          j        j        S t          d|           r  )r   r  r  r   r  r*   r   s     r&   r  zRestToGrpc.convert_sample
  r  r(   c                    t          |t          j                  r-t          j        |                     |j                            S t          |t          j                  r-t          j        |                     |j	                            S t          |t          j
                  r-t          j        |                     |j                            S t          |t          j                  r-t          j        |                     |j                            S t          |t          j                  r-t          j        |                     |j                            S t          |t          j                  r-t          j        |                     |j                            S t          |t          j                  r-t          j        |                     |j                            S t3          d|           )	Nr  r  r  r  r  r  r  r  )rF   r   r  r   r8  r^  r  r  rj  r  r  r|  r  r  rv  rz  r  r  r  r  r  r  r  r  r  r*   r   s     r&   r  zRestToGrpc.convert_query
  s   eT.// 	O:c&>&>u}&M&MNNNNeT011 	V:(C(CEO(T(TUUUUeT/00 	S:s'A'A%.'Q'QRRRReT.// 	P:c&?&?&N&NOOOOeT.// 	W:s'E'Een'U'UVVVVeT-.. 	G:S%7%7%E%EFFFFeT-.. 	G:S%7%7%E%EFFFF888999r(   c                 <   t          |t          t          j                            r(t	          j        |                     |                    S t          |t          t          j                            r|                     |          S t          d|           )Nr  zinvalid QueryInterface: )
rF   r   r   r5  r   r8  r^  r   r  r*   r   s     r&   convert_query_interfacez"RestToGrpc.convert_query_interface  s    e01ABBCC 	G:c&>&>u&E&EFFFFeXdj1122 	,$$U+++;E;;<<<r(   c                 Z    d }t          |j        t          j                  r                     |j                  g}n-t          |j        t
                    r fd|j        D             }t          j        ||j         	                    |j                  nd |j
        |j
        nd |j                             |j                  nd |j                             |j                  nd |j        |j        |j        nd |j                             |j                  nd           S )Nc                 :    g | ]}                     |          S r    r  r  s     r&   r'   z5RestToGrpc.convert_prefetch_query.<locals>.<listcomp>   s'    \\\228<<\\\r(   r  )rF   r  r   r  r  r   r   r9  r  r  r  r   r   r   r  r  r  r  r  )r   rj   r  s   `  r&   r  z!RestToGrpc.convert_prefetch_query  s1   endm44 	]225>BBCHH-- 	]\\\\U^\\\H!>Ck>U#--ek:::[_!&!8%++d7<|7O3%%el333UY>Cl>V3,,U\:::\`!1!&!8%++d , 33E4EFFF
 
 
 	
r(   c                    |                      |j                  \  }}}t          j        ||||j        |                     |j                  nd |j        |j        |                     |j                  nd |j	        | 
                    |j	                  nd |j        |j        ||j        |                     |j                  nd |j        r|                     |j                  nd           S )N)r  r  sparse_indicesr   r  r  r   r  r  r  r  r  )r  r  r   r=  r   r   r  r  r  r   r  r  r  r  r  r  r  )r   rj   r  r  r  r"   s         r&   convert_search_requestz!RestToGrpc.convert_search_request/  s    (+'F'Fu|'T'T$ +)7<|7O3%%el333UY+ %1 2253EFFF>Cl>V3,,U\:::\`!1< $0 (():;;; DI?\..u???X\+
 
 
 	
r(   c                 .    |                      ||          S r?   )r  r  s      r&   r  z RestToGrpc.convert_search_pointsN  s     ))%AAAr(   c                     t          |j        t          j                  r|j        gn|j        }t	          j        ||j         fd|D             nd |j                             |j                  nd |j        |j	         
                    |j	                  nd |j                             |j                  nd |j        |j        |j        |j                             |j                  nd |j                             |j                  nd |j                             |j                  nd |j                             |j                  nd           S )Nc                 :    g | ]}                     |          S r    r  )r#   pr   s     r&   r'   z4RestToGrpc.convert_query_request.<locals>.<listcomp>]  s'    FFFc0033FFFr(   )r  r  r  r  r   r   r  r  r  r  r  r  r  )rF   r  r   r  r   r>  r  r  r  r   r   r   r  r  r  r  r  r  r  r  r  r  r  r  )r   rj   r  r  s   `   r&   convert_query_requestz RestToGrpc.convert_query_requestT  s   
 !+5>4= I I]U^u~ 	 +~) GFFFXFFFF>Ck>U#--ek:::[_+7<|7O3%%el333UY>Cl>V3,,U\:::\`!1+< , 11%2CDDD %1 2253EFFF ?. ..u???  , 33E4EFFF7
 
 
 	
r(   c                 .    |                      ||          S r?   )r  r  s      r&   r  zRestToGrpc.convert_query_pointsy  s     ((@@@r(   c                 F   |                      |j                  }|                      |j                  }|                     |j                  }|                     |j                  }t	          j        di d|d|d|d|j        |                     |j                  nd d|j        d|j	        | 
                    |j	                  nd d|j        |                     |j                  nd d|j        d	|j        d
|j        |                     |j                  nd d|j        d|j        |                     |j                  nd d|j        |                     |j                  nd d|d|d|j        r|                     |j                  nd S )Nr  rf  rg  r   r  r  r   r  r  r  r  r  rd  r  r  r  r    )r  rf  rg  r  r   r?  r   r   r  r  r  r   r  r  r  r  r  r  r  r  rd  ri  r  r  )r   rj   r  r  r  r  r  s          r&   convert_recommend_requestz$RestToGrpc.convert_recommend_request  s    <<U^LL<<U^LLDDU^TTDDU^TT# #
 #
 #
+O#
!\#
 "\#
 8=|7O3%%el333UY	#

 ++#
 %1 2253EFFF#
 ?Dl>V3,,U\:::\`#
 "11#
 <<#
  $0 (():;;;##
& ++'#
, $0 ++E,=>>>/#
6 >- ..u~>>>9#
< .-=#
> .-?#
B DI?\..u???X\C#
 #	
r(   c                 .    |                      ||          S r?   )convert_discover_requestr  s      r&   r  z"RestToGrpc.convert_discover_points  s     ++E?CCCr(   c                     |j                              |j                   nd }|j         fd|j        D             nd }|j        d n                     |j                  }|j        d n                     |j                  }|j        d n                     |j                  }|j	        d n 
                    |j	                  }|j        d n                     |j                  }	|j        d n                     |j                  }
t          j        |||||j        |j        ||||j        |	|
          S )Nc                 :    g | ]}                     |          S r    r  rr  s     r&   r'   z7RestToGrpc.convert_discover_request.<locals>.<listcomp>  s'    NNNS--d33NNNr(   r   )r  ry  rz  r   r  r  r  r  r   r  r  r  )ry  r  rz  r   r   r   r  r  r  r  r  r  r  r  r  r   r@  r  r  r  )r   rj   r  ry  rz  query_filtersearch_paramsr  r  r  r  s   `          r&   r  z#RestToGrpc.convert_discover_request  s    =BL<T**5<888Z^ }( ONNNNNNN 	  %|3tt9K9KRWR^9K9_9_ % 4#:S:STYT`:a:a !) D33E4FGG 	 %-DD33K3KEL]3^3^ 	
 %-DD33N3NuO`3a3a 	
 O+DD1O1OPUP_1`1` 	 "++<%% +#1
 
 
 	
r(   c                 .    |                      ||          S r?   )r  r  s      r&   r  z#RestToGrpc.convert_recommend_points  s     ,,UODDDr(   c                 V   |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j	        k    rt          j        j
        S t          d|           r  )r   r  r  r   r  r  r  r  r  r  r  r*   r   s     r&   r  z!RestToGrpc.convert_tokenizer_type  s    D&+++%**d(333%00d(///%,,d(555%22DUDDEEEr(   c                     t          j        |j        |                     |j                  nd |j        |j        |j                  S )N)r  r  r  r  )r   r  r  r  r  r  r  r   s     r&   r(  z$RestToGrpc.convert_text_index_params  sR    # ?. **5?;;;o--	
 	
 	
 		
r(   c                 Z    t          j        |j        |j        |j        |j                  S )N)r  r  r  r   )r   r  r  r  r  r   r   s     r&   r)  z'RestToGrpc.convert_integer_index_params  s3     &<++M	
 
 
 	
r(   c                 B    t          j        |j        |j                  S N)r  r   )r   r  r  r   r   s     r&   r*  z'RestToGrpc.convert_keyword_index_params  s     &%-XXXXr(   c                 B    t          j        |j        |j                  S N)r  r   )r   r  r  r   r   s     r&   r+  z%RestToGrpc.convert_float_index_params  s    $%2Dem\\\\r(   c                 6    t          j        |j                  S )N)r   )r   r  r   r   s     r&   r,  z#RestToGrpc.convert_geo_index_params  s    "5=9999r(   r  c                 (    t          j                    S r?   )r   r  r  s     r&   r-  z$RestToGrpc.convert_bool_index_params  s    #%%%r(   c                 B    t          j        |j        |j                  S r"  )r   r  r  r   r   s     r&   r.  z(RestToGrpc.convert_datetime_index_params"  s!     'U5GQVQ^____r(   c                 B    t          j        |j        |j                  S r   )r   r  r  r   r   s     r&   r/  z$RestToGrpc.convert_uuid_index_params(  s    #eou}UUUUr(   c                 Z    t          j        |j        |j        |j        |j                  S )N)r  r  r  r  )r   r  r  r  r  r  r   s     r&   r  z)RestToGrpc.convert_collection_params_diff,  s6     ($7%*%C!1 % 9	
 
 
 	
r(   c                 B    t          j        |j        |j                  S )N)r  r  )r   r  r  r  r   s     r&   r  z"RestToGrpc.convert_lookup_location7  s'    "!,
 
 
 	
r(   c                     t          |t                    rt          j        |          S t          |t          j                  r(t          j        |                     |                    S t          d|           )N)r&  r
  r%  )rF   rH   r   rD  r   r,  r'  r*   r   s     r&   r(  z#RestToGrpc.convert_read_consistency>  s    eS!! 		H'    t788 	H'66u==    FuFFGGGr(   c                 
   |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S t          d|           r*  )
r   r,  r/  r   r.  r-  r+  r1  r0  r*   r   s     r&   r'  z(RestToGrpc.convert_read_consistency_typeK  sr     D,555+44d.222+//d.555+22J5JJKKKr(   c                 |   |t           j        j        k    r$t          j        t          j        j                  S |t           j        j        k    r$t          j        t          j        j                  S |t           j        j        k    r$t          j        t          j        j	                  S t          d|           )Nr
  r  )r   r  r  r   r  r  r   r  r"  r!  r*   r   s     r&   r#  z!RestToGrpc.convert_write_orderingX  s    D&+++%4+A+FGGGGd(///%4+A+HIIIId(///%4+A+HIIIIDUDDEEEr(   c                 b    t          j        t           j        j        |j        |j                  S )Nr5  )r   rY  QuantizationTypeInt8r3  r4  r   s     r&   r9  z-RestToGrpc.convert_scalar_quantization_configc  s2     &&+^'
 
 
 	
r(   c                 h    t          j        |                     |j                  |j                  S )Nr;  )r   rZ  r>  r<  r4  r   s     r&   r?  z.RestToGrpc.convert_product_quantization_configm  s8     '55e6GHH'
 
 
 	
r(   c                 6    t          j        |j                  S )NrA  )r   r[  r4  r   s     r&   rC  z-RestToGrpc.convert_binary_quantization_configv  s$     &'
 
 
 	
r(   c                    |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S |t           j        j	        k    rt          j        j
        S |t           j        j        k    rt          j        j        S t          d|           rE  )r   rG  rH  r   rF  rJ  rI  rL  rK  rN  rM  rP  rO  r*   r   s     r&   r>  z$RestToGrpc.convert_compression_ratio~  s    D),,,(++d+...(++d+///(,,d+///(,,d+///(,,GGGHHHr(   c                    t          |t          j                  r-t          j        |                     |j                            S t          |t          j                  r-t          j        |                     |j	                            S t          |t          j
                  r-t          j        |                     |j                            S t          d|           )NrT  rV  rX  rR  )rF   r   rY  r   rE  r9  rS  rZ  r?  rU  r[  rC  rW  r*   r   s     r&   r   z&RestToGrpc.convert_quantization_config  s     eT455 	*==elKK    eT566 	*??NN    eT455 	K*==elKK    I%IIJJJr(   c                 N    t          j        |j        |j        |j                  S )Nr`  )r   ra  r]  r^  r_  r   s     r&   r~  z-RestToGrpc.convert_quantization_search_params  s.     ,<M+
 
 
 	
r(   c                     t          j        |                     |j                  |                     |j                            S )N)r  r  )r   rc  rv  r  r  r  r   s     r&   rd  z RestToGrpc.convert_point_vectors  sB     ,,UX66--el;;
 
 
 	
r(   c                 P     t          j         fd|j        D                       S )Nc                 :    g | ]}                     |          S r    rg  ri  s     r&   r'   z4RestToGrpc.convert_groups_result.<locals>.<listcomp>  rk  r(   rl  )r   rn  rm  r   s   ` r&   ro  z RestToGrpc.convert_groups_result  rp  r(   c                      t          j                             |j                   fd|j        D             |j                             |j                  nd           S )Nc                 :    g | ]}                     |          S r    rs  r  s     r&   r'   z2RestToGrpc.convert_point_group.<locals>.<listcomp>  s'    JJJe#**511JJJr(   ru  )r   rw  rx  r  rv  r  r  r   s   ` r&   rh  zRestToGrpc.convert_point_group  sh    ##EH--JJJJuzJJJ7<|7O3%%el333UY
 
 
 	
r(   c                    t          |t                    rt          j        |          S t          |t                    r0|dk    rt          j        |          S t          j        |          S t          d|           )Nr6   r   )unsigned_valuer3   r{  )rF   rJ   r   rF  rH   r*   r   s     r&   rx  zRestToGrpc.convert_group_id  s    eS!! 	@<"    s## 
	@zz|#(    |"'    >u>>???r(   c                     t          j        |j        |j        |                     |j                  nd |j        |                     |j                  nd           S )N)r  r  r  )r   r}  r  r  r  r  r  r   s     r&   r~  zRestToGrpc.convert_with_lookup  so    ' %1 (();<<< %1 2253EFFF
 
 
 	
r(   c                 F   t          |t          j                  r-t          j        |                     |j                            S t          |t          j                  r-t          j        |                     |j	                            S t          |t          j
                  r-t          j        |                     |j                            S |t          j        j        k    r&t          j        t          j                              S t          d|           )NrT  rV  rX  )r  r  )rF   r   rY  r   rG  r9  rS  rZ  r?  rU  r[  rC  rW  r  r  r*   r   s     r&   r  z+RestToGrpc.convert_quantization_config_diff  s    eT455 	.==elKK    eT566 	.??NN    eT455 	.==elKK    DM***.    MeMMNNNr(   c                     t          j        |j        |                     |j                  nd |j        |                     |j                  nd |j                  S )Nr  )r   r  r   r   r   r  r   r   s     r&   r  z%RestToGrpc.convert_vector_params_diff  so    $ $0 ,,U->??? ,8 44U5NOOOM
 
 
 	
r(   c           	          t          |t                    rEt          |          dk    r2d|v r.t          j                             |d                             S t          |t                    rSt          j        t          j        t           fd|                                D                                           S t          d|           )Nr  r  r  c              3   L   K   | ]\  }}|                     |          fV  d S r?   r  r  s      r&   rA   z9RestToGrpc.convert_vectors_config_diff.<locals>.<genexpr>  sK        GOsCc<<SAAB     r(   r  r  r  )	rF   rM   rH  r   rH  r  VectorParamsDiffMaprN   r*   r   s   ` r&   r  z&RestToGrpc.convert_vectors_config_diff  s    eT"" 	Js5zzQ2;;)1O1OPUVXPY1Z1Z[[[[t$$ 		J)3    SXS^S^S`S`          HHHIIIr(   c                     t          t          j                  rj                     j        j        t          j        j                            fdt          t          j        j                            D             S t          t          j	                  r fdj
        D             S t          d           )Nc           
         g | ]}}t          j        t                              j        j        |                   |         j        j        *t                              j        j        |                   nd           ~S r  )r   r  rU  rv  batchr  payloadsr  )r#   rV  rj   vectors_batchs     r&   r'   z=RestToGrpc.convert_point_insert_operation.<locals>.<listcomp>  s          !;;EKOC<PQQ)#. !;/; #225;3G3LMMM!    r(   c                 :    g | ]}                     |          S r    r  r  s     r&   r'   z=RestToGrpc.convert_point_insert_operation.<locals>.<listcomp>,  s'    NNNC,,U33NNNr(   z%invalid PointInsertOperations model: )rF   r   PointsBatchr  rC  r  rH  r  r  r  r  r*   )r   rj   rE  s   ``@r&   convert_point_insert_operationz)RestToGrpc.convert_point_insert_operation  s     eT-.. 	N030O0O#S%9%91 1M     !U[_!5!566    t// 	NNNNNNNNNLULLMMMr(   c                 ,    |                      |          S r?   )r  r   s     r&   convert_update_operationz#RestToGrpc.convert_update_operation0  s    225999r(   c                 V    t          |t          j                  ry|j        j        r                     |j        j                  nd }t          j        t          j                             	                    |j                  |                    S t          |t          j
                  r}|j        j        r                     |j        j                  nd }                     |j                  }t          j                            ||          }t          j        |          S t          |t          j                  r|j        j        r t          j        |j        j                  }n>|j        j        r t          j        |j        j                  }nt)          d|           |j        j        r                     |j        j                  nd }t          j        t          j                                                 |j        j                                       |          |                    S t          |t          j                  r|j        j        r t          j        |j        j                  }n>|j        j        r t          j        |j        j                  }nt)          d	|           |j        j        r                     |j        j                  nd }t          j        t          j                                                 |j        j                                       |          |          
          S t          |t          j                  r|j        j        r t          j        |j        j                  }n>|j        j        r t          j        |j        j                  }nt)          d|           |j        j        r                     |j        j                  nd }t          j        t          j                            |j        j                             |          |                    S t          |t          j                  r}|j         j        r                     |j         j                  nd }                     |j                   }t          j        !                    ||          }t          j        |          S t          |t          j"                  rw|j#        j        r                     |j#        j                  nd }t          j        t          j        $                     fd|j#        j        D             |                    S t          |t          j%                  r|j&        j        r t          j        |j&        j                  }n>|j&        j        r t          j        |j&        j                  }nt)          d|           |j&        j        r                     |j&        j                  nd }t          j        t          j        '                                         |          t          j(        |j&        j)                  |                    S t)          d|           )N)r  r  r  )r  r  r  z#invalid SetPayloadOperation model: )r/   r  r  r  z)invalid OverwritePayloadOperation model: r  z&invalid DeletePayloadOperation model: )r  r  r  r  r  c                 :    g | ]}                     |          S r    r  r  s     r&   r'   z>RestToGrpc.convert_points_update_operation.<locals>.<listcomp>  s4       =B11%88  r(   r  r  )r  r  r  r  r  )*rF   r   r  r  r  r  r   rI  PointStructListrH  r  r  r  DeletePointsr  r  r  r  r   r  r*   r  r  r/   r  r  OverwritePayloadr  r  r  r  r  r  ClearPayloadr  r  r  r  r  r  r:  r  )r   rj   r  r  r  r  s   `     r&   r  z*RestToGrpc.convert_points_update_operation4  s    eT122 R	H <)..u|/EFFF 
 -1AA==elKK'9 B      t344 F	H <)..u|/EFFF 
 "99%,GGO 6CC&#5 D  M -+    t788 x	H ' P"&"35;L;S"T"T"T") P"&"5U=N=U"V"V"V !Nu!N!NOOO $...u/@/JKKK  - 6AA//0A0IJJ$'$?$?$P$P'9 B      t=>> c	H&- "&"35;R;Y"Z"Z"Z(/ "&"5U=T=["\"\"\ GGG   *4..u/F/PQQQ  -"&"<"M"M//0G0OPP$'$?$?$P$P'9 #N # #    t:;; L	H#* "&"35;O;V"W"W"W%, "&"5U=Q=X"Y"Y"Y DUDD   '1..u/C/MNNN  -#9GG-2$'$?$?$P$P'9  H        t9:: 5	H &0..u/B/LMMM 
 "99%:MNNO 6CC&#5 D  M -+    t:;; '	H '1..u/C/MNNN  -#9GG   FKFZFa   (:	  H        t:;; 	H#* "&"35;O;V"W"W"W%, "&"5U=Q=X"Y"Y"Y DUDD   '1..u/C/MNNN  -#9GG$'$?$?$P$P 0u7K7RSSS'9  H        FuFFGGGr(   c                 h    t          |t          j                  r|j        S t	          d|           )Nzinvalid InitFrom model: )rF   r   r  r  r*   r   s     r&   r  zRestToGrpc.convert_init_from  s7    eT]++ 	A##???@@@r(   c                     |t           j        j        k    rt          j        j        S |t           j        j        k    rt          j        j        S t          d|           r  )r   r  r  r   r  r  r  r*   r   s     r&   ri  z%RestToGrpc.convert_recommend_strategy  sS    D*999)77d,777)33HHHIIIr(   c                     t          j        |j        |j        nd |j        |j        nd |j        |                     |j                  nd           S )Nr  )r   rK  r   r   r&  r$  r   s     r&   convert_sparse_index_paramsz&RestToGrpc.convert_sparse_index_params  s`    %-2-F-R))X\%*]%>EMMD=B^=WS))%.999]a
 
 
 	
r(   c                     |t           j        j        k    rt          j        j        S |t           j        j        k    rt          t          j        d          S t          d|           r  )r   r  r  r   r  r  r   r*   r   s     r&   r  zRestToGrpc.convert_modifier  sV    DM%%%=$$dm(((4=&111???@@@r(   c                     t          j        |j        |                     |j                  nd |j        |                     |j                  nd           S )Nr  )r   r  r  rT  r  r  r   s     r&   r  z'RestToGrpc.convert_sparse_vector_params  s`     &@E@W//<<<]a 9>8R$$U^444X\
 
 
 	
r(   c                      t          j        t           fd|                                D                                 S )Nc              3   L   K   | ]\  }}|                     |          fV  d S r?   r  r  s      r&   rA   z:RestToGrpc.convert_sparse_vector_config.<locals>.<genexpr>  s:      ``hc3c3;;C@@A``````r(   r  )r   rL  rM   rN   r   s   ` r&   r  z'RestToGrpc.convert_sparse_vector_config  sL     &````RWR]R]R_R_`````
 
 
 	
r(   c                     t          |t                    rt          j        |          S t          |t                    rt          j        |          S t          d|           )N)numberr  r  )rF   rH   r   rM  rJ   r*   r   s     r&   r  zRestToGrpc.convert_shard_key  sc    eS!! 	/=....eS!! 	0=////;E;;<<<r(   c                 4    t          |t          t          j                            r)t	          j                             |          g          S t          |t                    r!t	          j         fd|D                       S t          d|           )N)r  c                 :    g | ]}                     |          S r    r  )r#   r\   r   s     r&   r'   z9RestToGrpc.convert_shard_key_selector.<locals>.<listcomp>  s(    4a4a4aTWS5J5J35O5O4a4a4ar(   z invalid ShardKeySelector model: )	rF   r   r   rM  r   r*  r  rK   r*   r   s   ` r&   r  z%RestToGrpc.convert_shard_key_selector  s    e0??@@ 	T(S5J5J55Q5Q4RSSSSeT"" 	c(4a4a4a4a[`4a4a4abbbbCECCDDDr(   c                     |t           j        j        k    rt          j        S |t           j        j        k    rt          j        S t          d|           r  )r   r  r  r   r  r  r  r*   r   s     r&   r  z"RestToGrpc.convert_sharding_method  sK    D',,,9d)000;EeEEFFFr(   c                 N    t          j        |j        |j        |j                  S )Nr  )r   rQ  r   r  r  r   s     r&   r  z%RestToGrpc.convert_health_check_reply   s+    $+M<
 
 
 	
r(   c                     t          j        |                     |j                  |                     |j                  |j                  S r  )r   r  rv  r  r  r  r   s     r&   r  z%RestToGrpc.convert_search_matrix_pair(  sG    $++EG44++EG44+
 
 
 	
r(   c                 P     t          j         fd|j        D                       S )Nc                 :    g | ]}                     |          S r    r  rr  s     r&   r'   z:RestToGrpc.convert_search_matrix_pairs.<locals>.<listcomp>5  r  r(   rt  )r   rR  ru  r   s   ` r&   r  z&RestToGrpc.convert_search_matrix_pairs0  s8     %PPPPEKPPP
 
 
 	
r(   c                      t          j        t          |j                  t          |j                  t          |j                   fd|j        D                       S )Nc                 :    g | ]}                     |          S r    ru  r  s     r&   r'   z<RestToGrpc.convert_search_matrix_offsets.<locals>.<listcomp>@  s'    KKK..t44KKKr(   r  )r   rS  rK   r  r  r  r  r   s   ` r&   r  z(RestToGrpc.convert_search_matrix_offsets8  sa     'U.//U.//%%KKKKKKK	
 
 
 	
r(   N(;  r  r  r  r  r   r   r   r   r   r   r   r   r   r   rc  r   r   r   r   r   r   r   r   r;  r   r  r  r   r   rJ   r  r   r   rl  r"  r!  r  rm   r  rG  rI  rL  rq  rX  r   r`  ra  rg  rh  rm  r   rq  r   ru  r   r}  r  r  r  r%  r  r  r  r  r  r  r  r  r  r&  r   r  r   r   r  r   r  r  r   r   r   r   r  r   r  r  r  r   r   r  r  r  r  r  r  r   r'  r  r(  r  r  r  r   rB  r   r#  r  r/  r  rA  r  r  rF  r  rC  r  r  r  r$  rv  r)  r  r  r   r  r+  r  r  r,  r  rN  r  r  r  r  r  OrderByInterfacer  rO  r  r  rP  r  r
  r-  r  r  r  r  r  r  r  r$  r*  r,  r0  r+  r5  r1  r.  r  r2  r1  r  r<  r;  r  BatchVectorStructrH   r  NamedVectorStructr   rI   r
   r  r  r3  rP  rR  r4  rX  r5  r^  rh  rj  rm  r6  rn  r7  rv  r{  r|  r  r  r  r  r8  r  QueryInterfacer  r  r9  r  r  r=  r  r  r  r>  r  r  r  r?  r  r  r@  r  r  r  r  r  r  r(  r  r)  r  r*  r  r+  r  r,  r  r-  r  r.  r  r/  r  r  r  r  rD  r(  r,  r'  r  r#  r6  rY  r9  r=  rZ  r?  rB  r[  rC  rG  r>  rE  r   ra  r~  rc  rd  rn  ro  rw  rh  rF  rx  r}  r~  rG  r  r  r  rH  r  PointInsertOperationsrH  rJ  rI  rJ  r  r  r  r  ri  r  rK  rT  r  r  r  r  r	   rL  r  rM  r  r*  r  r  r  r  rQ  r  r  r  r  rR  r  r  rS  r  r    r(   r&   rU  rU  ;  s       
4; 
4; 
 
 
 [
, 
$* 
 
 
 
 [
 U8T>%: y    [ 
4+= 
$BT 
 
 
 [
 _t~ _$. _ _ _ [_ ;.;		#; ; ; [;
 
D,? 
DDW 
 
 
 [
 
Ed.C 
EH] 
E 
E 
E [
E ET-B EtG[ E E E [E ^d334^	c4))	*^ ^ ^ [^
 
t/D 
I_ 
 
 
 [
 #H,#H		 #H #H #H [#HJ F0F F4Ka F F F [F( 
$*; 
@Q 
 
 
 [
 A): At?P A A A [A 
T-@ 
TEX 
 
 
 [

 =)9 =d>N = = = [= 
)9 
d>N 
 
 
 [

 =t/D =I^ = = = [= ;d.B ;tG[ ; ; ; [; 
T-A 
dFZ 
 
 
 [
 

$*; 

@Q 

 

 

 [

 d)9 dd>N d d d [d ? ?DO ? ? ? [? 	
)9 	
d>N 	
 	
 	
 [	
 
)9 
d>N 
 
 
 [
 
T-@ 
TEX 
 
 
 [
 
)9 
d>N 
 
 
 [
 MDL MT#tz/5J M M M [M 
T-@ 
TEX 
 
 
 [
 CD,? CDDW C C C [C2 
D,> 
4CU 
 
 
 [
 
d.C 
H] 
 
 
 [
 
 
D<O 
 
 
 [
 
t~ 
$:L 
 
 
 [
 
=T] 
=t} 
= 
= 
= [
= 
d.C 
H] 
 
 
 [
, 

d.C 

Ha 

 

 

 [

 
-
		"
 
 
 [
 
)
<?
		
 
 
 [
@ ;dm ; ; ; ; [; :$* : : : : [:: DT-A DdFZ D D D [D 
d.C 
H] 
 
 
 [
  56	dl	   [   56	dk	   [$ 44+@ 4TEW 4 4 4 [4 Ed.C EHZ E E E [E 
D4E 
$+ 
 
 
 [
 N$*? NDDU N N N [N 
&
 
	 
 
 
 [
 Dd.B Dt| D D D [D 	CD,? 	CDDW 	C 	C 	C [	C >dn > > > > [>  	DT-A 	DdF^ 	D 	D 	D [	D 9(9		!9 9 9 [9
 
I-
I		!
I 
I 
I [
I >t~ >$. > > > [> >dn > > > > [> 	
T\ 	
dl 	
 	
 	
 [	
 E)E	E E E [E ? ?DO ? ? ? [? 
D,> 
4= 
 
 
 [
 
4; 
43F 
 
 
 [
 )DK )D<O ) ) ) [) 3)9 3d>N 3 3 3 [3 	
,	
		!	
 	
 	
 [	
 =T] =t} = = = [= 
$*; 
@Q 
 
 
 [
. 
t/E 
$J` 
 
 
 [

 J.J		#J J J [J 
F4+= 
F$BT 
F 
F 
F [
F E$*; E E E E [E8 D DT=U D D D [D J*J9<J	dl	J J J [J 
J*
J	tE{HT%78(3-G	H
J 
J 
J [
J ,e ,9I , , , [, M$*; M@Q M M M [M 
tDK/@ 
TEZ 
 
 
 [

 @)9 @d>N @ @ @ [@ 
D,? 
DDW 
 
 
 [
 
t/? 
DDY 
 
 
 [
 A$*; A@Q A A A [A 
4+= 
$BT 
 
 
 [
 ;4; ;4; ; ; ; [; ;4; ;4; ; ; ; [; :$* : : : : [:0 =D,? =DJ = = = [= 
4= 
T=O 
 
 
 [
( 
&
9<
		
 
 
 [
< B&B9<B		B B B [B
 "
%"
8;"
		"
 "
 "
 ["
H A%A8;A		A A A [A
 ,
),
<?,
		,
 ,
 ,
 [,
\ D(D;>D		D D D [D
 .
(.
;>.
		.
 .
 .
 [.
` E)E<?E		E E E [E
 
F4+= 
F$BT 
F 
F 
F [
F 

d.B 

tG[ 

 

 

 [

 
+
		 
 
 
 [
 Y+Y		 Y Y Y [Y
 ]t/D ]I^ ] ] ] [] :T-@ :TEX : : : [: &$*> &4CW & & & [& `,`		!` ` ` [`
 Vd.B VtG[ V V V [V 
-
		"
 
 
 [
 
D,? 
DDW 
 
 
 [
 
HT-A 
HdFZ 
H 
H 
H [
H 
L,
L		!
L 
L 
L [
L F4+= F$BT F F F [F 
1
		 
 
 
 [
 
2
		!
 
 
 [
 
1
		 
 
 
 [
 Id.C IH] I I I [I K+K		 K K K [K$ 
1
		&
 
 
 [
 
$*; 
@Q 
 
 
 [
 
$*; 
@Q 
 
 
 [

 
 
DO 
 
 
 [
 @T\ @dl @ @ @ [@" 
 
DO 
 
 
 [
 O/O		$O O O [O, 
t/D 
I^ 
 
 
 [
 J0F J4Ka J J J [J N.N	d	N N N [N0 :T-A :dF` : : : [: UH(UH		#UH UH UH [UHn Adm A A A A [A Jt/E J$J` J J J [J 
0F 
4Ka 
 
 
 [
 AT] At} A A A [A 

+

		 

 

 

 [

 
C!889
		 
 
 
 [
 =dm = = = = [= Et/D EI^ E E E [E GD,? GDDW G G G [G 
t/? 
DDY 
 
 
 [
 
t/D 
I^ 
 
 
 [
 
2
		
 
 
 [
 
4
		!
 
 
 [
 
 
r(   rU  N)0r   r   r   typingr   r   r   r	   r
   r   r   r   r   google.protobuf.json_formatr   google.protobuf.timestamp_pb2r   google.protobuf.pyext._messager   ImportErrorqdrant_clientr   qdrant_client.grpcr   r   r   r   qdrant_client.http.modelsr   r   qdrant_client._pydantic_compatr   r   &qdrant_client.conversions.common_typesr   rJ   rG   r.   r:   rZ   re   ri   rm   ro   r   r   r   rU  r    r(   r&   <module>rs     s   - - - - - - - - - - W W W W W W W W W W W W W W W W W W W W W W 5 5 5 5 5 5 3 3 3 3 3 3	BBBBBBB 	 	 	D	       B B B B B B B B B B B B 4 4 4 4 4 4 H H H H H H H H F F F F F F#s #3 #4 # # # # =3 =5 = = = =,7 73 7 7 7 7@KT#s(^ KS%Z0@ K K K KI4U
+ IS#X I I I IBT-C B B B B B*:T^ :@V : : : :*f
 f
 f
 f
 f
 f
 f
 f
`5F
 F
 F
 F
 F
 F
 F
 F
 F
 F
s   5 ==