qdrant-edge 0.8.0

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

use std::path::PathBuf;

use crate::blobstore::BlobstoreReader;
use crate::common::universal_io::{CachedReadFs, Populate, UniversalRead, UniversalReadFs};

use super::ReadOnlyPayloadStorage;
use crate::segment::common::operation_error::OperationResult;
use crate::segment::payload_storage::payload_storage_impl::storage_dir;
use crate::segment::types::Payload;

impl<S: UniversalRead> ReadOnlyPayloadStorage<S> {
    pub fn preopen(
        fs: &impl CachedReadFs<File = S>,
        path: PathBuf,
        populate: Populate,
    ) -> OperationResult<()> {
        let path = storage_dir(path);
        BlobstoreReader::<Payload, S>::preopen(fs, path, populate)?;
        Ok(())
    }

    /// Open the payload storage read-only over the generic filesystem `fs` —
    /// the read-only counterpart of [`PayloadStorageImpl::open_or_create`][1].
    ///
    /// [1]: crate::payload_storage::payload_storage_impl::PayloadStorageImpl::open_or_create
    pub fn open(
        fs: &impl UniversalReadFs<File = S>,
        path: PathBuf,
        populate: Populate,
    ) -> OperationResult<Self> {
        let path = storage_dir(path);
        let storage = BlobstoreReader::<Payload, S>::open(fs, path, populate)?;

        Ok(Self { storage })
    }
}