pjson-rs 0.7.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
50
51
52
53
54
55
56
57
58

//! 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::{
    BatchGenerateFramesCommand, CloseSessionCommand, CompleteStreamCommand, CreateSessionCommand,
    CreateStreamCommand, GenerateFramesCommand, StartStreamCommand,
};
pub use queries::{
    FramesResponse, GetActiveSessionsQuery, GetSessionHealthQuery, GetSessionQuery,
    GetSessionStatsQuery, GetStreamFramesQuery, GetStreamQuery, GetStreamsForSessionQuery,
    GetSystemStatsQuery, HealthResponse, SearchSessionsQuery, SessionFilters, SessionResponse,
    SessionSortField, SessionStatsResponse, SessionsResponse, SortOrder, StreamResponse,
    StreamsResponse, SystemStatsResponse,
};
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),
}