kglite 0.16.10

Pure-Rust embedded Cypher knowledge graph engine with in-memory, mmap, and disk storage, and agent-facing schema introspection
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

//! Postcard 1.x adapter. No other production module may import postcard.

use super::CodecError;
use serde::de::Deserialize;
use serde::Serialize;

const CODEC: &str = "postcard-v1";

fn encode_error(error: impl ToString) -> CodecError {
    CodecError::Encode {
        codec: CODEC,
        message: error.to_string(),
    }
}

fn decode_error(error: impl ToString) -> CodecError {
    CodecError::Decode {
        codec: CODEC,
        message: error.to_string(),
    }
}

pub(super) fn encode_bounded<T: Serialize + ?Sized>(
    value: &T,
    limit: u64,
) -> Result<Vec<u8>, CodecError> {
    let bytes = postcard::to_stdvec(value).map_err(encode_error)?;
    let actual = bytes.len() as u64;
    if actual > limit {
        return Err(CodecError::SizeLimit { actual, limit });
    }
    Ok(bytes)
}

pub(super) fn decode_exact<'de, T: Deserialize<'de>>(bytes: &'de [u8]) -> Result<T, CodecError> {
    let (value, trailing) = postcard::take_from_bytes(bytes).map_err(decode_error)?;
    if !trailing.is_empty() {
        return Err(CodecError::TrailingBytes {
            remaining: trailing.len() as u64,
        });
    }
    Ok(value)
}