velesdb-core 1.15.0

High-performance vector database engine written in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

//! Streaming ingestion pipeline for continuous vector insertion.
//!
//! Provides [`StreamIngester`] which accepts points via a bounded tokio mpsc
//! channel and drains micro-batches into the existing `Collection::upsert`
//! pipeline. Backpressure is signaled via `BackpressureError::BufferFull`
//! when the channel is at capacity.

pub mod async_index_builder;

#[cfg(feature = "persistence")]
pub mod delta;

#[cfg(feature = "persistence")]
mod delta_merge;

#[cfg(feature = "persistence")]
pub mod deferred;

#[cfg(feature = "persistence")]
mod ingester;

pub use async_index_builder::{AsyncIndexBuilder, AsyncIndexBuilderConfig};

#[cfg(feature = "persistence")]
pub use deferred::{DeferredIndexer, DeferredIndexerConfig};
#[cfg(feature = "persistence")]
pub use delta_merge::{merge_with_delta, merge_with_delta_scored};
#[cfg(feature = "persistence")]
pub use ingester::{BackpressureError, StreamIngester, StreamingConfig};

#[cfg(test)]
mod async_index_builder_tests;
#[cfg(all(test, feature = "persistence"))]
mod delta_tests;
#[cfg(all(test, feature = "persistence"))]
mod ingester_tests;