nodedb 0.2.0

Local-first, real-time, edge-to-cloud hybrid database for multi-modal workloads
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

// SPDX-License-Identifier: BUSL-1.1

//! Response payload serialization for SPSC bridge transport.
//!
//! Replaces `serde_json::to_vec` + `serde_json::json!` on all Data Plane
//! response hot paths. Uses MessagePack (`zerompk`) for serialization which
//! is 2-3x faster and 30-50% smaller than JSON.
//!
//! Split by concern:
//!
//! - `encode` — generic encoders + the JSON/msgpack transcoder used by
//!   `decode_payload_to_json` at the Control Plane boundary.
//! - `decode` — payload→docs decoders for inline sub-plans (e.g. multi-way
//!   joins consuming an inner-join Response).
//! - `raw` — raw-msgpack passthrough encoders (`encode_raw_document_rows`,
//!   `encode_binary_rows`) plus `decode_raw_scan_to_docs`.
//! - `arrow` — Arrow IPC encoder for columnar transport.
//! - `hits` — hit-row structs (Vector / Text / Hybrid search, GraphRag, etc.)
//!   plus their `ToMessagePack` impls.

mod arrow;
mod decode;
mod encode;
mod hits;
mod raw;

#[cfg(test)]
mod tests;

pub use arrow::encode_as_arrow_ipc;
pub(in crate::data::executor) use decode::{
    decode_response_to_docs, decode_response_to_docs_from_bytes,
};
pub use encode::decode_payload_to_json;
pub(in crate::data::executor) use encode::{
    encode, encode_count, encode_json, encode_json_vec, encode_serde, encode_value_vec,
};
#[allow(unused_imports)]
pub(crate) use hits::ArrayAggregateResponse;
pub(crate) use hits::{ArraySliceResponse, RowsPayload};
pub(in crate::data::executor) use hits::{
    DocumentRow, GraphRagMetadata, GraphRagResponse, GraphRagResult, HybridSearchHit,
    NeighborEntry, NeighborMultiEntry, SubgraphEdge, VectorSearchHit,
};
pub use raw::encode_binary_rows;
pub(in crate::data::executor) use raw::{decode_raw_scan_to_docs, encode_raw_document_rows};