storage-kit 0.0.1

Portable database and transactional state-store Kit.
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

mod scan;
mod shared;
mod text;
mod vector;

use crate::{QueryRequest, QueryResponse, StorageError};

use super::manager::LanceManager;

pub(super) async fn handle(
    db: &LanceManager,
    request: QueryRequest,
) -> Result<QueryResponse, StorageError> {
    match request {
        QueryRequest::Nearest(request) => vector::nearest(db, request).await,
        QueryRequest::Text(request) => {
            db.require_capability(
                crate::CapabilitySet::FULL_TEXT,
                "FULL_TEXT",
                format!(
                    "text search for collection `{}`",
                    request.query.collection()
                ),
            )?;
            text::text(db, request).await
        }
        QueryRequest::Scroll(request) => scan::scroll(db, request).await,
    }
}