pjson-rs 0.6.0

Priority JSON Streaming Protocol - high-performance priority-based JSON streaming (requires nightly Rust)
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

//! Application layer - Use cases and orchestration
//!
//! Implements CQRS pattern with separate command and query handlers.
//! Orchestrates domain logic and infrastructure concerns.

pub mod commands;
pub mod dto;
pub mod handlers;
pub mod queries;
pub mod shared;

pub use commands::*;
pub use queries::*;
pub use shared::AdjustmentUrgency;

/// Application Result type
pub type ApplicationResult<T> = Result<T, ApplicationError>;

/// Application-specific errors
#[derive(Debug, thiserror::Error)]
pub enum ApplicationError {
    /// Wraps a domain-layer error that bubbled up to the application boundary.
    #[error("Domain error: {0}")]
    Domain(#[from] crate::domain::DomainError),

    /// Input failed validation before any domain logic ran.
    #[error("Validation error: {0}")]
    Validation(String),

    /// Caller is not authorized to perform the requested operation.
    #[error("Authorization error: {0}")]
    Authorization(String),

    /// A concurrent operation conflicted with the current request.
    #[error("Concurrency error: {0}")]
    Concurrency(String),

    /// Requested entity does not exist.
    #[error("Not found: {0}")]
    NotFound(String),

    /// Operation conflicted with the current state of the resource.
    #[error("Conflict: {0}")]
    Conflict(String),

    /// Generic application-layer logic error not covered by other variants.
    #[error("Application logic error: {0}")]
    Logic(String),
}