Struct ElasticsearchVectorIndex 

pub struct ElasticsearchVectorIndex { /* private fields */ }

Async vector index backed by an Elasticsearch 8.x index.

The index is created on construction (a dense_vector field with cosine similarity) if it does not already exist. All operations are async over a plain reqwest::Client. Connection-string credentials embedded in url (e.g. https://user:pass@host) are used for the request but never leaked in error messages — see redact_credentials.

Implementations

impl ElasticsearchVectorIndex

pub async fn new(url: &str, index: &str, dim: usize) -> Result<Self>

Connect to url (e.g. http://localhost:9200) and ensure index exists with a dense_vector field of dim dimensions and cosine similarity.

pub async fn delete_index(&self) -> Result<()>

Drop the backing index (useful for test cleanup or full reset).

Trait Implementations

impl AsyncVectorIndex for ElasticsearchVectorIndex

fn search<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 [f32], k: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<SearchHit>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

kNN search over the dense_vector field. Each SearchHit.score is the ES knn _score ((1 + cosine) / 2), which is not comparable across backends — see Score semantics.

fn add<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, vectors: &'life1 [Vec<f32>], ids: &'life2 [u64], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Upsert vectors keyed by their explicit external IDs.

fn remove<'life0, 'life1, 'async_trait>( &'life0 self, ids: &'life1 [u64], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove vectors by their external IDs.

fn search_filtered<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query: &'life1 [f32], k: usize, allowlist: &'life2 [u64], ) -> Pin<Box<dyn Future<Output = Result<Vec<SearchHit>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Search restricted to an allowlist of candidate IDs.

fn len<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Number of vectors currently indexed.

fn dim(&self) -> usize

Vector dimensionality.

fn is_empty<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Whether the index is empty.