shodh-redb 0.5.0

Multi-modal embedded database - vectors, blobs, TTL, merge operators, and causal tracking built on ACID B-trees
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

//! Backend-agnostic trait for blob queries used by `CompositeQuery`.
//!
//! `BlobQueryProvider` abstracts the blob-related query operations that
//! `CompositeQuery` needs, enabling composite queries to work with any
//! storage backend that implements this trait.

use alloc::vec::Vec;

use crate::blob_store::types::{BlobId, BlobMeta, CausalEdge, TemporalKey};

/// Provides blob query operations needed by `CompositeQuery`.
///
/// This trait decouples the composite query engine from the storage backend.
pub trait BlobQueryProvider {
    /// Error type returned by blob operations.
    type Error: Into<crate::StorageError>;

    /// Get blob metadata by ID.
    fn get_blob_meta(&self, blob_id: &BlobId) -> Result<Option<BlobMeta>, Self::Error>;

    /// Look up a blob by its sequence number.
    ///
    /// Returns the `(BlobId, BlobMeta)` pair for the blob with the given sequence,
    /// or `None` if no blob matches.
    fn blob_by_sequence(&self, seq: u64) -> Result<Option<(BlobId, BlobMeta)>, Self::Error>;

    /// Query blobs in a temporal range `[start_ns, end_ns]`.
    fn blobs_in_time_range(
        &self,
        start_ns: u64,
        end_ns: u64,
    ) -> Result<Vec<(TemporalKey, BlobMeta)>, Self::Error>;

    /// Query blobs in a namespace, returning `(BlobId, BlobMeta)` pairs.
    fn blobs_in_namespace(&self, namespace: &str) -> Result<Vec<(BlobId, BlobMeta)>, Self::Error>;

    /// Query blobs that have the given tag.
    fn blobs_by_tag(&self, tag: &str) -> Result<Vec<BlobId>, Self::Error>;

    /// Get the causal children of a parent blob.
    fn causal_children(&self, blob_id: &BlobId) -> Result<Vec<CausalEdge>, Self::Error>;
}

// ---------------------------------------------------------------------------
// Legacy ReadTransaction implementation
// ---------------------------------------------------------------------------

impl BlobQueryProvider for crate::transactions::ReadTransaction {
    type Error = crate::StorageError;

    fn get_blob_meta(&self, blob_id: &BlobId) -> Result<Option<BlobMeta>, Self::Error> {
        self.get_blob_meta(blob_id)
    }

    fn blob_by_sequence(&self, seq: u64) -> Result<Option<(BlobId, BlobMeta)>, Self::Error> {
        self.blob_by_sequence(seq)
    }

    fn blobs_in_time_range(
        &self,
        start_ns: u64,
        end_ns: u64,
    ) -> Result<Vec<(TemporalKey, BlobMeta)>, Self::Error> {
        self.blobs_in_time_range(start_ns, end_ns)
    }

    fn blobs_in_namespace(&self, namespace: &str) -> Result<Vec<(BlobId, BlobMeta)>, Self::Error> {
        self.blobs_in_namespace(namespace)
    }

    fn blobs_by_tag(&self, tag: &str) -> Result<Vec<BlobId>, Self::Error> {
        self.blobs_by_tag(tag)
    }

    fn causal_children(&self, blob_id: &BlobId) -> Result<Vec<CausalEdge>, Self::Error> {
        self.causal_children(blob_id)
    }
}