laminar-core 0.26.0

//! Core streaming engine for `LaminarDB`.

#![deny(missing_docs)]
#![warn(clippy::all, clippy::pedantic)]
#![allow(clippy::duration_suboptimal_units)] // MSRV 1.85; from_mins/from_hours are 1.91+
#![allow(clippy::module_name_repetitions)]

/// Z-set changelog `__weight` column name, shared between the MV producer and
/// upsert-sink consumers.
pub mod changelog;
/// Distributed checkpoint barrier protocol.
pub mod checkpoint;
/// Compatibility alias for checkpoint storage
pub use checkpoint as storage;
/// Structured error code registry (`LDB-NNNN`) and Ring 0 hot path error type.
pub mod error_codes;
/// Lookup table types and predicate pushdown.
pub mod lookup;
pub mod mv;
pub mod operator;
/// Shared Arrow IPC serialization for `RecordBatch` ↔ bytes.
pub mod serialization;
/// Cross-instance shuffle: message codec, credit flow, wire protocol.
pub mod shuffle;
/// Pluggable state backend (`StateBackend` trait + impls).
pub mod state;
pub mod streaming;
pub mod time;

/// Distributed cluster coordination. Unstable: gated behind `cluster`.
#[cfg(feature = "cluster")]
pub mod cluster;

/// Per-epoch checkpoint commit marker store. Used by the checkpoint
/// coordinator's 2PC to record the commit decision durably before
/// sinks are told to commit, so recovery can re-establish the verdict
/// after a crash. Lives outside the cluster gate because
/// single-instance also needs it.
pub mod checkpoint_decision;

/// Result type for laminar-core operations
pub type Result<T> = std::result::Result<T, Error>;

/// Error types for laminar-core
#[derive(Debug, thiserror::Error)]
pub enum Error {
    /// Operator errors
    #[error("Operator error: {0}")]
    Operator(#[from] operator::OperatorError),

    /// Time-related errors
    #[error("Time error: {0}")]
    Time(#[from] time::TimeError),

    /// Materialized view errors
    #[error("MV error: {0}")]
    Mv(#[from] mv::MvError),
}