systemd-journal-sdk-engine 0.6.0

Async query engine components for the pure Rust systemd journal SDK
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

//! Error types for journal engine operations

use std::path::PathBuf;
use thiserror::Error;

/// Errors that can occur during engine operations
#[derive(Debug, Error)]
pub enum EngineError {
    /// I/O error when reading files
    #[error("I/O error: {0}")]
    Io(#[from] std::io::Error),

    /// Error from journal core operations
    #[error("Journal error: {0}")]
    Journal(#[from] journal_core::JournalError),

    /// Error from journal indexing operations
    #[error("Index error: {0}")]
    Index(#[from] journal_index::IndexError),

    /// Error from repository operations
    #[error("Repository error: {0}")]
    Repository(#[from] journal_registry::repository::RepositoryError),

    /// Error from registry operations
    #[error("Registry error: {0}")]
    Registry(#[from] journal_registry::RegistryError),

    /// Error when parsing a journal file path
    #[error("Failed to parse journal file path: {path}")]
    InvalidPath { path: String },

    /// Error when a path contains invalid UTF-8
    #[error("Path contains invalid UTF-8: {}", .path.display())]
    InvalidUtf8 { path: PathBuf },

    /// Channel closed error
    #[error("Channel closed")]
    ChannelClosed,

    /// Foyer cache error
    #[error("Cache error: {0}")]
    Foyer(#[from] foyer::Error),

    /// Foyer IO engine error
    #[error("Foyer IO error: {0}")]
    FoyerIo(#[from] foyer::IoError),

    /// Operation was cancelled
    #[error("Operation cancelled")]
    Cancelled,

    /// Invalid time range (start >= end)
    #[error("Invalid time range: start={start} >= end={end}")]
    InvalidTimeRange { start: u32, end: u32 },
}

static_assertions::const_assert!(std::mem::size_of::<EngineError>() <= 64);

/// A specialized Result type for engine operations
pub type Result<T> = std::result::Result<T, EngineError>;