obzenflow_core 0.2.1

Core domain layer for ObzenFlow - pure abstractions with minimal dependencies
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

// SPDX-License-Identifier: MIT OR Apache-2.0
// SPDX-FileCopyrightText: 2025-2026 ObzenFlow Contributors
// https://obzenflow.dev

/// Journal errors (domain-level, not I/O specific)
#[derive(Debug, thiserror::Error)]
pub enum JournalError {
    #[error("Journal is full")]
    Full,

    #[error("Event not found: {0}")]
    EventNotFound(String),

    #[error("Writer not authorized")]
    Unauthorized,

    #[error("Causal ordering violation")]
    CausalityViolation,

    #[error("Subscription closed")]
    SubscriptionClosed,

    #[error(
        "Journal does not support atomic append group '{group_id}' with {member_count} members"
    )]
    AtomicAppendUnsupported {
        group_id: String,
        member_count: usize,
    },

    /// Generic implementation error with source
    #[error("Implementation error: {message}")]
    Implementation {
        message: String,
        #[source]
        source: Box<dyn std::error::Error + Send + Sync>,
    },
}