qdrant-edge 0.7.1

A lightweight, in-process vector search engine designed for embedded devices, autonomous systems, and mobile agents.
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
37
38
39
40
41
42
43
44
45
46
47
48
49
50

//! Optimizer-related parameters for the edge shard.

use serde::{Deserialize, Serialize};
use crate::shard::optimizers::config::{
    get_indexing_threshold_kb, get_max_segment_size_kb, get_number_segments,
};

/// Optimizer-related parameters for the edge shard.
///
/// Subset of collection-level `OptimizersConfig`: excludes `memmap_threshold`
/// (deprecated), `flush_interval_sec` (edge does not flush on a timer), and
/// `max_optimization_threads` (optimizations are manual).
#[derive(Debug, Clone, Default, PartialEq, Serialize, Deserialize)]
#[serde(rename_all = "snake_case", default)]
pub struct EdgeOptimizersConfig {
    /// Minimal fraction of deleted vectors in a segment required to run vacuum.
    #[serde(default)]
    pub deleted_threshold: Option<f64>,
    /// Minimal number of vectors in a segment required to run vacuum.
    #[serde(default)]
    pub vacuum_min_vector_number: Option<usize>,
    /// Target number of segments. If 0, chosen automatically from CPU count.
    pub default_segment_number: Option<usize>,
    /// Max segment size in KB. If not set, derived from CPU count.
    #[serde(alias = "max_segment_size_kb")]
    pub max_segment_size: Option<usize>,
    /// Indexing threshold in KB; segments above this get HNSW index. If not set, default is used.
    #[serde(alias = "indexing_threshold_kb")]
    pub indexing_threshold: Option<usize>,
    /// If true, points written to unoptimized segments larger than the indexing threshold are
    /// stored as deferred points: they are persisted but skipped from read/search until the
    /// segments are optimized. Updates with `wait=true` return only after the deferred points
    /// become visible.
    #[serde(default)]
    pub prevent_unoptimized: Option<bool>,
}

impl EdgeOptimizersConfig {
    pub fn get_number_segments(&self) -> usize {
        get_number_segments(self.default_segment_number.unwrap_or_default())
    }

    pub fn get_indexing_threshold_kb(&self) -> usize {
        get_indexing_threshold_kb(self.indexing_threshold)
    }

    pub fn get_max_segment_size_kb(&self, num_indexing_threads: usize) -> usize {
        get_max_segment_size_kb(self.max_segment_size, num_indexing_threads)
    }
}