velesdb-core 1.7.1

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

//! 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.

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

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

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

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

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