Ë
    lQêj=Y  ã                   óÔ  — d dl mZ d dlmZmZmZmZmZmZm	Z	m
Z
mZmZmZ d dlmZ er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mZmZ d dlmZ d d	l m!Z!m"Z"m#Z#m$Z$m%Z%m&Z& d d
l'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z. d dl/m0Z0m1Z1m2Z3 d dl4m5Z5 d dl6Z6d dl m7Z7m8Z8m9Z9m:Z:m;Z;m<Z< d dl=m>Z> d dl?m@Z@ d dlAZAd dlBZB eBj†                  «       dk7  rd dlDZDn eBj†                  «       dk(  rd dlEZE G d„ de«      ZFy)é    )ÚTYPE_CHECKING)ÚCollectionMetadataÚ
EmbeddingsÚ	GetResultÚIDsÚWhereÚWhereDocumentÚIncludeÚ	DocumentsÚ	MetadatasÚQueryResultÚURIs)Ú	ServerAPI)ÚAttachedFunction)ÚCreateCollectionConfigurationÚUpdateCollectionConfigurationÚ+create_collection_configuration_to_json_strÚ+update_collection_configuration_to_json_str)ÚUserIdentity)ÚDEFAULT_DATABASEÚDEFAULT_TENANTÚSettingsÚSystem)ÚProductTelemetryClient)ÚCollectionAddEventÚCollectionDeleteEventÚCollectionGetEventÚCollectionUpdateEventÚCollectionQueryEventÚClientCreateCollectionEvent)ÚDeleteResultÚIncludeMetadataDocumentsÚ!IncludeMetadataDocumentsDistancesÚ"IncludeMetadataDocumentsEmbeddingsÚ	ReadLevelÚSchemaÚSearchResult)ÚDatabaseÚTenantÚ
Collection)ÚSearchN)ÚOptionalÚSequenceÚListÚDictÚAnyÚTuple)Úoverride)ÚUUIDÚWindowsc                   óª  ‡ — e Zd ZU ej                  ed<   eed<   eed<   defˆ fd„Z	e
dQd„«       Ze
dQd	„«       Ze
efd
ededdfd„«       Ze
efd
ededefd„«       Ze
efd
ededdfd„«       Ze
ddefdee   dee   dedee   fd„«       Ze
d
eddfd„«       Ze
d
edefd„«       Ze
defd„«       Ze
eefdededefd„«       Ze
ddeefdee   dee   dededee   f
d„«       Ze
ddddeefd
edee   dee   dee    de!dededefd„«       Z"e
eefd
edededefd„«       Z#e
eefde$dededefd „«       Z%e
dddeefd
edee   dee   dee    dededefd!„«       Z&e
eefd
edededdfd"„«       Z'e
dddeefd#e$d$ee   d%ee    d&ee(   dededdfd'„«       Z)e
eefde$d$edededef
d(„«       Z*e
eefde$dededefd)„«       Z+e
eefde$dededd*fd+„«       Z,e
eee-j\                  fde$d,e/e0   deded-e-de1fd.„«       Z2e
eee-j\                  fde$deded-e-def
d/„«       Z3e
d0eefde$d1ededede4f
d2„«       Z5e
ddddde6eefde$d3ee7   d4ee8   dee   dee   d5ee9   d6e:dedede4fd7„«       Z;e
dddeefd3e7de$d8e<d9ee=   d:ee>   d;ee?   dedede!fd<„«       Z@e
ddddeefde$d3e7d8ee<   d9ee=   d:ee>   d;ee?   dedede!fd=„«       ZAe
dddeefde$d3e7d8e<d9ee=   d:ee>   d;ee?   dedede!fd>„«       ZBe
dd0ddeCeefde$d?e<d3ee7   d@ed4ee8   d5ee9   d6e:dededeDfdA„«       ZEe
ddddeefde$d3ee7   d4ee8   d5ee9   dee   dededeFfdB„«       ZGe
de!fdC„«       ZHe
defdD„«       ZIe
deJfdE„«       ZKe
defdF„«       ZLe
deefdGed
edHe$dIedJeeMeeNf      dededeOdKe!f   fdL„«       ZPe
eefd
edHe$dededdKf
dM„«       ZQe
deefd
edHe$dNe!dedede!fdO„«       ZRe
deSfdP„«       ZTˆ xZUS )RÚRustBindingsAPIÚbindingsÚhnsw_cache_sizeÚproduct_telemetry_clientÚsystemc                 ó8  •— t         ‰| �  |«       | j                  t        «      | _        t        j                  «       dk7  r't        j                  t        j                  «      d   }n(t        j                  j                  j                  «       }|dz  | _        y )Nr4   r   é   )ÚsuperÚ__init__Úrequirer   r9   Úplatformr:   ÚresourceÚ	getrlimitÚRLIMIT_NOFILEÚctypesÚwindllÚmsvcrtÚ_getmaxstdior8   )Úselfr:   Úmax_file_handlesÚ	__class__s      €úV/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/chromadb/api/rust.pyr>   zRustBindingsAPI.__init__O   s{   ø€ Ü‰Ñ˜Ô Ø(,¯©Ô5KÓ(LˆÔ%ä�?‰?Ó 	Ò)Ü'×1Ñ1´(×2HÑ2HÓIÈ!ÑLÑä%Ÿ}™}×3Ñ3×@Ñ@ÓBÐàð ñð 	Õó    ÚreturnNc                 óê  — | j                   j                  j                  d«      r+| j                   j                  j                  d«      }|dz   }nd }d }| j                   j                  j                  d«      }|dk(  rt        j                  j
                  nt        j                  j                  }| j                   j                  j                  d«      }|dk(  rt        j                  j                  nt        j                  j                  }t        j                  |||¬«      }t        j                  | j                   j                  j                  d	«      ||| j                  ¬
«      | _        y )NÚis_persistentÚpersist_directoryz/chroma.sqlite3Úmigrations_hash_algorithmÚmd5Ú
migrationsÚapply)Ú	hash_typeÚmigration_modeÚurlÚallow_reset)rX   Úsqlite_db_configÚpersist_pathr8   )Ú_systemÚsettingsr?   Úchromadb_rust_bindingsÚMigrationHashÚMD5ÚSHA256ÚMigrationModeÚApplyÚValidateÚSqliteDBConfigÚBindingsr8   r7   )rH   rZ   Úsqlite_persist_pathrU   Úhash_type_bindingsrV   Úmigration_mode_bindingsÚsqlite_configs           rK   ÚstartzRustBindingsAPI.start^   s9  € ð �<‰<× Ñ ×(Ñ(¨Ô9ØŸ<™<×0Ñ0×8Ñ8Ð9LÓMˆLØ".Ð1BÑ"BÑàˆLØ"&ÐØ—L‘L×)Ñ)×1Ñ1Ð2MÓNˆ	ð ˜EÒ!ô #×0Ñ0×4Ò4ä'×5Ñ5×<Ñ<ð 	ð
 Ÿ™×.Ñ.×6Ñ6°|ÓDˆð  Ò(ô #×0Ñ0×6Ò6ä'×5Ñ5×>Ñ>ð 	 ô
 /×=Ñ=Ø(Ø2Ø#ô
ˆô /×7Ñ7ØŸ™×-Ñ-×5Ñ5°mÓDØ*Ø%Ø ×0Ñ0ô	
ˆ�rL   c                 ó   — | ` y ©N)r7   ©rH   s    rK   ÚstopzRustBindingsAPI.stop�   s   € à‰MrL   ÚnameÚtenantc                 ó:   — | j                   j                  ||«      S rl   )r7   Úcreate_database©rH   ro   rp   s      rK   rr   zRustBindingsAPI.create_database‡   ó   € à�}‰}×,Ñ,¨T°6Ó:Ð:rL   c                 ó‚   — | j                   j                  ||«      }|j                  |j                  |j                  dœS ©N)Úidro   rp   )r7   Úget_databaserw   ro   rp   ©rH   ro   rp   Údatabases       rK   rx   zRustBindingsAPI.get_database‹   s7   € à—=‘=×-Ñ-¨d°FÓ;ˆà—+‘+Ø—M‘MØ—o‘oñ
ð 	
rL   c                 ó:   — | j                   j                  ||«      S rl   )r7   Údelete_databasers   s      rK   r|   zRustBindingsAPI.delete_database”   rt   rL   ÚlimitÚoffsetc                 óª   — | j                   j                  |||«      }|D �cg c]&  }|j                  |j                  |j                  dœ‘Œ( c}S c c}w rv   )r7   Úlist_databasesrw   ro   rp   )rH   r}   r~   rp   Ú	databasesrz   s         rK   r€   zRustBindingsAPI.list_databases˜   sW   € ð —M‘M×0Ñ0°¸ÀÓGˆ	ð &ö
ð ð	 —k‘kØ Ÿ™Ø"Ÿ/™/óò
ð 	
ùò 
s   ¢+Ac                 ó8   — | j                   j                  |«      S rl   )r7   Úcreate_tenant)rH   ro   s     rK   rƒ   zRustBindingsAPI.create_tenant©   s   € à�}‰}×*Ñ*¨4Ó0Ð0rL   c                 ód   — | j                   j                  |«      }t        |j                  ¬«      S )N)ro   )r7   Ú
get_tenantr)   ro   rs   s      rK   r…   zRustBindingsAPI.get_tenant­   s%   € à—‘×)Ñ)¨$Ó/ˆÜ˜6Ÿ;™;Ô'Ð'rL   c                 ó6   — | j                   j                  «       S rl   )r7   Ú	heartbeatrm   s    rK   r‡   zRustBindingsAPI.heartbeat´   s   € à�}‰}×&Ñ&Ó(Ð(rL   rz   c                 ó:   — | j                   j                  ||«      S rl   )r7   Úcount_collections)rH   rp   rz   s      rK   r‰   z!RustBindingsAPI.count_collections¸   s   € ð �}‰}×.Ñ.¨v°xÓ@Ð@rL   c                 ó*  — | j                   j                  ||||«      }|D �cg c]e  }t        |j                  |j                  |j
                  |j                  |j                  |j                  |j                  |j                  ¬«      ‘Œg c}S c c}w )N)rw   ro   Úserialized_schemaÚconfiguration_jsonÚmetadataÚ	dimensionrp   rz   )r7   Úlist_collectionsÚCollectionModelrw   ro   ÚschemaÚconfigurationr�   rŽ   rp   rz   )rH   r}   r~   rp   rz   ÚcollectionsÚ
collections          rK   r�   z RustBindingsAPI.list_collections¾   s‹   € ð —m‘m×4Ñ4°U¸FÀFÈHÓUˆð *ö
ð ô Ø—=‘=Ø—_‘_Ø",×"3Ñ"3Ø#-×#;Ñ#;Ø#×,Ñ,Ø$×.Ñ.Ø!×(Ñ(Ø#×,Ñ,ö	ò
ð 	
ùò 
s   £A*BFr‘   r’   r�   Úget_or_createc           
      óä  — | j                   j                  t        t        t        «      ¬«      «       |rt        ||«      }nd }|r$t        j                  |j                  «       «      }	nd }	| j                  j                  |||	||||«      }
t        |
j                  |
j                  |
j                  |
j                  |
j                  |
j                   |
j"                  |
j$                  ¬«      }|S )N)Úcollection_uuid©rw   ro   rŒ   r‹   r�   rŽ   rp   rz   )r9   Úcapturer    Ústrrw   r   ÚjsonÚdumpsÚserialize_to_jsonr7   Úcreate_collectionr�   ro   r’   r‘   r�   rŽ   rp   rz   )rH   ro   r‘   r’   r�   r•   rp   rz   Úconfiguration_json_strÚ
schema_strr”   Úcollection_models               rK   rž   z!RustBindingsAPI.create_collectionÕ   så   € ð 	×%Ñ%×-Ñ-Ü'Ü #¤B£ôô	
ñ Ü%PØ˜xó&Ñ"ð &*Ð"áÜŸ™ F×$<Ñ$<Ó$>Ó?‰JàˆJà—]‘]×4Ñ4ØØ"ØØØØØó
ˆ
ô +Ø�}‰}Ø—‘Ø)×7Ñ7Ø(×/Ñ/Ø×(Ñ(Ø ×*Ñ*Ø×$Ñ$Ø×(Ñ(ô	
Ðð  ÐrL   c           
      ó  — | j                   j                  |||«      }t        |j                  |j                  |j
                  |j                  |j                  |j                  |j                  |j                  ¬«      S ©Nr˜   )r7   Úget_collectionr�   rw   ro   r’   r‘   r�   rŽ   rp   rz   )rH   ro   rp   rz   r”   s        rK   r¤   zRustBindingsAPI.get_collection	  sm   € ð —]‘]×1Ñ1°$¸ÀÓIˆ
ÜØ�}‰}Ø—‘Ø)×7Ñ7Ø(×/Ñ/Ø×(Ñ(Ø ×*Ñ*Ø×$Ñ$Ø×(Ñ(ô	
ð 		
rL   Úcollection_idc           
      ó  — | j                   j                  t        |«      ||«      }t        |j                  |j
                  |j                  |j                  |j                  |j                  |j                  |j                  ¬«      S r£   )r7   Úget_collection_by_idrš   r�   rw   ro   r’   r‘   r�   rŽ   rp   rz   )rH   r¥   rp   rz   r”   s        rK   r§   z$RustBindingsAPI.get_collection_by_id  ss   € ð —]‘]×7Ñ7¼¸MÓ8JÈFÐT\Ó]ˆ
ÜØ�}‰}Ø—‘Ø)×7Ñ7Ø(×/Ñ/Ø×(Ñ(Ø ×*Ñ*Ø×$Ñ$Ø×(Ñ(ô	
ð 		
rL   c           	      ó0   — | j                  ||||d||«      S )NT)rž   )rH   ro   r‘   r’   r�   rp   rz   s          rK   Úget_or_create_collectionz(RustBindingsAPI.get_or_create_collection/  s&   € ð ×%Ñ%Ø�&˜-¨°4¸Àó
ð 	
rL   c                 ó>   — | j                   j                  |||«       y rl   )r7   Údelete_collectionry   s       rK   r«   z!RustBindingsAPI.delete_collection=  s   € ð 	�‰×'Ñ'¨¨f°hÕ?rL   rw   Únew_nameÚnew_metadataÚnew_configurationc                 ór   — |rt        |«      }nd }| j                  j                  t        |«      |||«       y rl   )r   r7   Úupdate_collectionrš   )rH   rw   r¬   r­   r®   rp   rz   Únew_configuration_json_strs           rK   Ú_modifyzRustBindingsAPI._modifyF  s=   € ñ Ü)TØ!ó*Ñ&ð *.Ð&Ø�‰×'Ñ'Ü�‹G�X˜|Ð-Gõ	
rL   c                 ó   — t        d«      ‚)Nz6Collection forking is not implemented for Local Chroma©ÚNotImplementedError)rH   r¥   r¬   rp   rz   s        rK   Ú_forkzRustBindingsAPI._forkZ  s   € ô "ØDó
ð 	
rL   c                 ó   — t        d«      ‚)Nz.Fork count is not implemented for Local Chromar´   ©rH   r¥   rp   rz   s       rK   Ú_fork_countzRustBindingsAPI._fork_countf  s   € ô "Ø<ó
ð 	
rL   ÚIndexingStatusc                 ó   — t        d«      ‚)Nz3Indexing status is not implemented for Local Chromar´   r¸   s       rK   Ú_get_indexing_statusz$RustBindingsAPI._get_indexing_statusq  s   € ô "Ð"WÓXÐXrL   ÚsearchesÚ
read_levelc                 ó   — t        d«      ‚)Nz*Search is not implemented for Local Chromar´   )rH   r¥   r½   rp   rz   r¾   s         rK   Ú_searchzRustBindingsAPI._searchz  s   € ô "Ð"NÓOÐOrL   c                 óN   — | j                   j                  t        |«      ||«      S rl   )r7   Úcountrš   )rH   r¥   rp   rz   r¾   s        rK   Ú_countzRustBindingsAPI._count…  s"   € ð �}‰}×"Ñ"¤3 }Ó#5°v¸xÓHÐHrL   é
   Únc                 ó6   — | j                  ||||t        ¬«      S )N)r}   rp   rz   Úinclude)Ú_getr$   )rH   r¥   rÅ   rp   rz   s        rK   Ú_peekzRustBindingsAPI._peek�  s)   € ð �y‰yØØØØÜ6ð ó 
ð 	
rL   ÚidsÚwhereÚwhere_documentrÇ   c
                 óö  — |rt        |«      nd}
| j                  j                  t        t	        |«      |
|r|ndd|v r|
ndd|v r|
ndd|v r|
nd¬«      «       | j
                  j                  t	        |«      ||rt        j                  |«      nd ||xs d|rt        j                  |«      nd |||	«	      }t        |j                  |j                  |j                  |j                  |d |j                  ¬«      S )Nr   Ú	metadatasÚ	documentsÚuris)r—   Ú	ids_countr}   Úinclude_metadataÚinclude_documentsÚinclude_uris)rÊ   Ú
embeddingsrÏ   rÐ   ÚincludedÚdatarÎ   )Úlenr9   r™   r   rš   r7   Úgetr›   rœ   r   rÊ   rÕ   rÏ   rÐ   rÎ   )rH   r¥   rÊ   rË   r}   r~   rÌ   rÇ   rp   rz   Ú
ids_amountÚrust_responses               rK   rÈ   zRustBindingsAPI._getŸ  sù   € ñ "%”S˜”X¨!ˆ
Ø×%Ñ%×-Ñ-ÜÜ # MÓ 2Ø$Ù$‘e¨!Ø/:¸gÑ/E¡È1Ø0;¸wÑ0F¡*ÈAØ+1°WÑ+<™ZÀ!ôô		
ð Ÿ™×)Ñ)Ü�ÓØÙ!&ŒD�J‰J�uÔ¨DØØŠK�aÙ*8ŒD�J‰J�~Ô&¸dØØØó

ˆô Ø×!Ñ!Ø$×/Ñ/Ø#×-Ñ-Ø×#Ñ#ØØØ#×-Ñ-ô
ð 	
rL   rÕ   rÎ   rÏ   rÐ   c	                 ó  — | j                   j                  t        t        |«      t	        |«      |�t	        |«      nd|�t	        |«      nd|�t	        |«      nd¬«      «       | j
                  j                  |t        |«      ||||||«      S )Nr   )r—   Ú
add_amountÚwith_metadataÚwith_documentsÚ	with_uris)r9   r™   r   rš   rØ   r7   Úadd)	rH   rÊ   r¥   rÕ   rÎ   rÏ   rÐ   rp   rz   s	            rK   Ú_addzRustBindingsAPI._addÎ  s�   € ð 	×%Ñ%×-Ñ-ÜÜ # MÓ 2Ü˜s›8Ø*3Ð*?œc #œhÀQØ+4Ð+@œs 3œxÀaØ&*Ð&6œ#˜cœ(¸Aôô	
ð �}‰}× Ñ ØÜ�ÓØØØØØØó	
ð 		
rL   c	                 ó8  — | j                   j                  t        t        |«      t	        |«      |rt	        |«      nd|rt	        |«      nd|rt	        |«      nd|rt	        |«      nd¬«      «       | j
                  j                  t        |«      |||||||«      S )Nr   )r—   Úupdate_amountÚwith_embeddingsrÞ   rß   rà   )r9   r™   r   rš   rØ   r7   Úupdate©	rH   r¥   rÊ   rÕ   rÎ   rÏ   rÐ   rp   rz   s	            rK   Ú_updatezRustBindingsAPI._updateï  s‘   € ð 	×%Ñ%×-Ñ-Ü!Ü # MÓ 2Ü! #›hÙ3=¤ J¤À1Ù09œc )œn¸qÙ1:œs 9œ~ÀÙ'+œ#˜dœ)°ôô		
ð �}‰}×#Ñ#Ü�ÓØØØØØØØó	
ð 		
rL   c	           
      óX   — | j                   j                  t        |«      |||||||«      S rl   )r7   Úupsertrš   rç   s	            rK   Ú_upsertzRustBindingsAPI._upsert  s8   € ð �}‰}×#Ñ#Ü�ÓØØØØØØØó	
ð 		
rL   Úquery_embeddingsÚ	n_resultsc
                 ó6  — t        |«      }
|rt        |«      nd}| j                  j                  t        t	        |«      |
|||�|
nd|�|
ndd|v r|
ndd|v r|
ndd|v r|
ndd|v r|
nd¬«
      «       | j
                  j                  t	        |«      ||||rt        j                  |«      nd |rt        j                  |«      nd |||	«	      }t        |j                  |j                  |j                  |j                  |d |j                  |j                  ¬«      S )Nr   rÎ   rÏ   rÐ   Ú	distances)
r—   Úquery_amountÚfiltered_ids_amountrí   Úwith_metadata_filterÚwith_document_filterÚinclude_metadatasrÓ   rÔ   Úinclude_distances)rÊ   rÕ   rÏ   rÐ   rÖ   r×   rÎ   rï   )rØ   r9   r™   r   rš   r7   Úqueryr›   rœ   r   rÊ   rÕ   rÏ   rÐ   rÎ   rï   )rH   r¥   rì   rÊ   rí   rË   rÌ   rÇ   rp   rz   rð   rñ   rÛ   s                rK   Ú_queryzRustBindingsAPI._query(  s*  € ô Ð+Ó,ˆÙ*-œc #œh°1ÐØ×%Ñ%×-Ñ-Ü Ü # MÓ 2Ø)Ø$7Ø#Ø5:Ð5F¡\ÈAØ5CÐ5O¡\ÐUVØ2=ÀÑ2H¡,ÈaØ2=ÀÑ2H¡,ÈaØ-3°wÑ->™\ÀAØ2=ÀÑ2H¡,Èaôô	
ð Ÿ™×+Ñ+Ü�ÓØØØÙ!&ŒD�J‰J�uÔ¨DÙ*8ŒD�J‰J�~Ô&¸dØØØó

ˆô Ø×!Ñ!Ø$×/Ñ/Ø#×-Ñ-Ø×#Ñ#ØØØ#×-Ñ-Ø#×-Ñ-ô	
ð 		
rL   c           	      ó(  — | j                   j                  t        |«      ||rt        j                  |«      nd |rt        j                  |«      nd |||«      }| j
                  j                  t        t        |«      |¬«      «       t        |¬«      S )N)r—   Údelete_amount)Údeleted)	r7   Údeleterš   r›   rœ   r9   r™   r   r!   )	rH   r¥   rÊ   rË   rÌ   r}   rp   rz   rú   s	            rK   Ú_deletezRustBindingsAPI._delete]  s‚   € ð —-‘-×&Ñ&Ü�ÓØÙ!&ŒD�J‰J�uÔ¨DÙ*8ŒD�J‰J�~Ô&¸dØØØó
ˆð 	×%Ñ%×-Ñ-Ü!Ü # MÓ 2Ø%ôô	
ô  GÔ,Ð,rL   c                 ó6   — | j                   j                  «       S rl   )r7   Úresetrm   s    rK   rþ   zRustBindingsAPI.reset{  s   € à�}‰}×"Ñ"Ó$Ð$rL   c                 ó6   — | j                   j                  «       S rl   )r7   Úget_versionrm   s    rK   r   zRustBindingsAPI.get_version  s   € à�}‰}×(Ñ(Ó*Ð*rL   c                 ó.   — | j                   j                  S rl   )r[   r\   rm   s    rK   Úget_settingszRustBindingsAPI.get_settingsƒ  s   € à�|‰|×$Ñ$Ð$rL   c                 ó6   — | j                   j                  «       S rl   )r7   Úget_max_batch_sizerm   s    rK   r  z"RustBindingsAPI.get_max_batch_size‡  s   € à�}‰}×/Ñ/Ó1Ð1rL   Úfunction_idÚinput_collection_idÚoutput_collectionÚparamsr   c                 ó   — t        d«      ‚©zPAttached functions are not supported in the Rust bindings (local embedded mode).z§Attached functions are only supported when connecting to a Chroma server via HttpClient. The Rust bindings (embedded mode) do not support attached function operations.r´   )rH   r  ro   r  r  r  rp   rz   s           rK   Úattach_functionzRustBindingsAPI.attach_function‹  s   € ô "ð]ó
ð 	
rL   c                 ó   — t        d«      ‚r
  r´   )rH   ro   r  rp   rz   s        rK   Úget_attached_functionz%RustBindingsAPI.get_attached_functionœ  s   € ô "ð]ó
ð 	
rL   Údelete_outputc                 ó   — t        d«      ‚r
  r´   )rH   ro   r  r  rp   rz   s         rK   Údetach_functionzRustBindingsAPI.detach_functionª  s   € ô "ð]ó
ð 	
rL   c                 ó0   — t        dt        t        g¬«      S )NÚ )Úuser_idrp   r�   )r   r   r   rm   s    rK   Úget_user_identityz!RustBindingsAPI.get_user_identityº  s   € äØÜ!Ü'Ð(ô
ð 	
rL   )rM   N)VÚ__name__Ú
__module__Ú__qualname__r]   re   Ú__annotations__Úintr   r   r>   r2   rj   rn   r   rš   rr   r(   rx   r|   r,   r-   r€   rƒ   r)   r…   r‡   r   r‰   r�   r�   r&   r   r   Úboolrž   r¤   r3   r§   r©   r«   r   r²   r¶   r¹   r¼   r%   ÚINDEX_AND_WALr.   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/   r0   r1   r  r  r  r   r  Ú__classcell__)rJ   s   @rK   r6   r6   J   sr  ø… Ø$×-Ñ-Ó-ØÓØ4Ó4ð
˜võ 
ð ò 
ó ð 
ðD òó ðð
 Ø7Eñ ; Cð ;°ð ;È$ò ;ó ð;ð Ø4Bñ 
 ð 
¨cð 
Àxò 
ó ð
ð Ø7Eñ ; Cð ;°ð ;È$ò ;ó ð;ð ð  $Ø $Ø$ñ	
à˜‰}ð
ð ˜‘ð
ð ð	
ð
 
�(Ñ	ò
ó ð
ð  ð1 #ð 1¨$ò 1ó ð1ð ð(˜sð ( vò (ó ð(ð ð)˜3ò )ó ð)ð à*Ð<LñAØðAØ69ðAà	òAó ðAð
 ð  $Ø $Ø$Ø(ñ
à˜‰}ð
ð ˜‘ð
ð ð	
ð
 ð
ð 
�/Ñ	"ò
ó ð
ð, ð $(ØAEØ15Ø#Ø$Ø(ñ1 àð1 ð ˜Ñ ð1 ð  Ð =Ñ>ð	1 ð
 Ð-Ñ.ð1 ð ð1 ð ð1 ð ð1 ð 
ò1 ó ð1 ðf ð %Ø(ñ	
àð
ð ð
ð ð	
ð
 
ò
ó ð
ð$ ð %Ø(ñ	
àð
ð ð
ð ð	
ð
 
ò
ó ð
ð$ ð $(ØAEØ15Ø$Ø(ñ
àð
ð ˜Ñ ð
ð  Ð =Ñ>ð	
ð
 Ð-Ñ.ð
ð ð
ð ð
ð 
ò
ó ð
ð ð %Ø(ñ	@àð@ð ð@ð ð	@ð
 
ò@ó ð@ð ð #'Ø59ØEIØ$Ø(ñ
àð
ð ˜3‘-ð
ð Ð1Ñ2ð	
ð
 $Ð$AÑBð
ð ð
ð ð
ð 
ò
ó ð
ð& ð
 %Ø(ñ	
àð	
ð ð	
ð ð		
ð
 ð	
ð 
ò	
ó ð	
ð ð %Ø(ñ	
àð
ð ð
ð ð	
ð
 
ò
ó ð
ð ð %Ø(ñ	YàðYð ðYð ð	Yð
 
òYó ðYð ð
 %Ø(Ø )× 7Ñ 7ñPàðPð �v‘,ðPð ð	Pð
 ðPð ðPð 
òPó ðPð ð %Ø(Ø )× 7Ñ 7ñIàðIð ðIð ð	Ið
 ðIð 
òIó ðIð ð Ø$Ø(ñ
àð
ð ð
ð ð	
ð
 ð
ð 
ò
ó ð
ð ð "Ø!%Ø#Ø $Ø26Ø3Ø$Ø(ñ,
àð,
ð �c‰]ð,
ð ˜‰ð	,
ð
 ˜‰}ð,
ð ˜‘ð,
ð ! Ñ/ð,
ð ð,
ð ð,
ð ð,
ð 
ò,
ó ð,
ð\ ð *.Ø)-Ø#Ø$Ø(ñ
àð
ð ð
ð ð	
ð
 ˜IÑ&ð
ð ˜IÑ&ð
ð �t‰nð
ð ð
ð ð
ð 
ò
ó ð
ð@ ð
 ,0Ø)-Ø)-Ø#Ø$Ø(ñ
àð
ð ð
ð ˜ZÑ(ð	
ð
 ˜IÑ&ð
ð ˜IÑ&ð
ð �t‰nð
ð ð
ð ð
ð 
ò
ó ð
ðB ð *.Ø)-Ø#Ø$Ø(ñ
àð
ð ð
ð ð	
ð
 ˜IÑ&ð
ð ˜IÑ&ð
ð �t‰nð
ð ð
ð ð
ð 
ò
ó ð
ð, ð
 "ØØ!%Ø26Ø<Ø$Ø(ñ2
àð2
ð %ð2
ð �c‰]ð	2
ð
 ð2
ð ˜‰ð2
ð ! Ñ/ð2
ð ð2
ð ð2
ð ð2
ð 
ò2
ó ð2
ðh ð "Ø!%Ø26Ø#Ø$Ø(ñ-àð-ð �c‰]ð-ð ˜‰ð	-ð
 ! Ñ/ð-ð ˜‰}ð-ð ð-ð ð-ð 
ò-ó ð-ð: ð%�tò %ó ð%ð ð+˜Sò +ó ð+ð ð%˜hò %ó ð%ð ð2 Cò 2ó ð2ð ð ,0Ø$Ø(ñ
àð
ð ð
ð "ð	
ð
 ð
ð ˜˜c 3˜h™Ñ(ð
ð ð
ð ð
ð 
Ð! 4Ð'Ñ	(ò
ó ð
ð  ð
 %Ø(ñ
àð
ð "ð
ð ð	
ð
 ð
ð 
ò
ó ð
ð ð
 $Ø$Ø(ñ
àð
ð "ð
ð ð	
ð
 ð
ð ð
ð 
ò
ó ð
ð ð
 <ò 
ó ô
rL   r6   )GÚtypingr   Úchromadbr   r   r   r   r   r	   r
   r   r   r   r   Úchromadb.apir   Ú$chromadb.api.models.AttachedFunctionr   Ú%chromadb.api.collection_configurationr   r   r   r   Úchromadb.authr   Úchromadb.configr   r   r   r   Úchromadb.telemetry.productr   Ú!chromadb.telemetry.product.eventsr   r   r   r   r   r    Úchromadb.api.typesr!   r"   r#   r$   r%   r&   r'   Úchromadb.typesr(   r)   r*   r�   Ú"chromadb.execution.expression.planr+   r]   r,   r-   r.   r/   r0   r1   Ú	overridesr2   Úuuidr3   r›   r@   r:   rA   rD   r6   © rL   rK   ú<module>r,     s±   ðÝ  ÷÷ ÷ ñ õ #áÝE÷ó õ 'ß NÓ NÝ =÷÷ ÷÷ ñ ÷ KÑ JÝ 5Û ÷ >× =Ý Ý Û Û à€8‡?�?Ó˜	Ò!ÜØ€X‡_�_Ó˜)Ò#Ûôv	
�iõ v	
rL   