xtrace_sdk.x_vec.retrievers.retriever¶
Attributes¶
Classes¶
Retrieves and decrypts chunks from XTrace using encrypted hamming distance search. |
Functions¶
|
Top-level helper for multiprocessing — must be picklable. |
Module Contents¶
- xtrace_sdk.x_vec.retrievers.retriever._log¶
- xtrace_sdk.x_vec.retrievers.retriever._decode_item(homomorphic_client, ciphertext)¶
Top-level helper for multiprocessing — must be picklable.
- Parameters:
homomorphic_client (xtrace_sdk.x_vec.crypto.hamming_client_base.HammingClientBase)
- Return type:
- class xtrace_sdk.x_vec.retrievers.retriever.Retriever(execution_context, integration, parallel=False)¶
Retrieves and decrypts chunks from XTrace using encrypted hamming distance search.
- Parameters:
execution_context (xtrace_sdk.x_vec.utils.execution_context.ExecutionContext) – Holds AES + homomorphic clients and context ID.
integration (xtrace_sdk.integrations.xtrace.XTraceIntegration) – XTrace API integration instance.
parallel (bool) – If True, decode hamming distances in parallel using multiprocessing.
- execution_context¶
- integration¶
- parallel = False¶
- async nn_search_for_ids(query_vector, k=3, kb_id='', meta_filter=None, range_filter=None, include_scores=False)¶
Find the k nearest neighbors by encrypted hamming distance.
- Parameters:
query_vector (list[float]) – Float embedding vector to search with.
k (int) – Number of nearest neighbors to return.
kb_id (str) – Knowledge-base ID to search.
meta_filter (dict | None) – Optional metadata filter dict (MongoDB-style operators).
range_filter (list[int] | None) – Optional
[min, max]range to restrict which chunks are searched.include_scores (bool) – If True, also return the plain hamming distances.
- Returns:
List of chunk IDs, or (chunk_ids, scores) if include_scores=True.
- Return type:
- async retrieve_and_decrypt(chunk_ids, kb_id, projection=None)¶
Fetch chunks by ID and AES-decrypt their content.