laminar-core 0.26.0

Core streaming engine for LaminarDB - operators, checkpoint barriers, and streaming primitives
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

//! Error types for materialized view operations.

use thiserror::Error;

/// Errors that can occur during materialized view operations.
#[derive(Debug, Error)]
pub enum MvError {
    /// Attempted to register a view with a name that already exists.
    #[error("materialized view already exists: {0}")]
    DuplicateName(String),

    /// A source referenced by the view does not exist.
    #[error("source not found: {0}")]
    SourceNotFound(String),

    /// Registration would create a dependency cycle.
    #[error("dependency cycle detected involving: {0}")]
    CycleDetected(String),

    /// The materialized view was not found.
    #[error("materialized view not found: {0}")]
    ViewNotFound(String),

    /// The operator for a view was not found.
    #[error("operator not found for view: {0}")]
    OperatorNotFound(String),

    /// Cannot drop view because other views depend on it.
    #[error("cannot drop view '{0}': dependent views exist: {1:?}")]
    HasDependents(String, Vec<String>),

    /// Operator error during processing.
    #[error("operator error: {0}")]
    OperatorError(#[from] crate::operator::OperatorError),

    /// State serialization/deserialization error.
    #[error("serialization error: {0}")]
    SerializationError(String),

    /// View is in an invalid state for the requested operation.
    #[error("view '{0}' is in invalid state: {1:?}")]
    InvalidState(String, MvState),

    /// Watermark propagation error.
    #[error("watermark propagation error: {0}")]
    WatermarkError(String),
}

/// Materialized view execution state.
///
/// Production currently only distinguishes `Running` from `Dropping`;
/// the `Paused` and `Error` variants existed for a planned lifecycle
/// transition that was never wired to operator failure events. Re-add
/// them when the registry actually transitions on those signals.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Default)]
pub enum MvState {
    /// View is actively processing events.
    #[default]
    Running,
    /// View is being dropped.
    Dropping,
}