laser-wire 0.5.1

LaserData SDK over Apache Iggy: typed streaming, operational and lakehouse query, materialization destinations, key-value state, copy-on-write forks, and an optional agent runtime with the Agent Data Exchange Protocol (AGDX).
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

/// A codec, framing, or payload decode failure. Deterministic for a given
/// input, so never retryable. The SDK maps it into its own error type, and
/// ports surface it as-is.
#[derive(Debug, thiserror::Error)]
#[non_exhaustive]
pub enum DecodeError {
    #[error("encode: {0}")]
    Encode(String),
    #[error("decode: {0}")]
    Decode(String),
    #[error("no payload: {0}")]
    MissingPayload(&'static str),
    /// A `[len: u32 LE][bytes]` frame violated the framing contract (over the
    /// frame cap, or a length prefix pointing past the cap).
    #[error("frame: {0}")]
    Frame(String),
}

/// Client-side validation rejected the input before any encode or round-trip
/// (missing required builder fields, empty identifiers).
#[derive(Debug, PartialEq, Eq, thiserror::Error)]
#[error("{0}")]
pub struct InvalidError(pub String);

impl InvalidError {
    /// A validation failure with this message.
    pub fn new(message: impl Into<String>) -> Self {
        Self(message.into())
    }
}