azums-core 1.0.1

Zero-dependency core traits, models, and QueueError for azums
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

//! # Azums Core
//!
//! Zero-dependency core traits, models, and [`QueueError`] for `azums`.

#![deny(unsafe_code)]
#![allow(clippy::double_must_use)]
#![cfg_attr(not(feature = "std"), no_std)]

#[cfg(feature = "alloc")]
extern crate alloc;

pub mod backend;
pub mod error;
pub mod model;
pub mod semantics;

pub use backend::{
    CallRecord, JobExplanation, JobObservationEvent, MemoryAttempt, MemoryBackend, MockBackend,
    NotificationStream, ObservabilityBackend, QueueMetrics, StorageBackend, StreamBackend,
};
pub use error::{Error, QueueError};
pub use model::{
    BackendCapabilities, BackendSemanticCapabilities, BackpressureCapability,
    ConsumerGroupCapability, ConsumerGroupStatus, DurabilityCapability, Event, Job, JobExecution,
    JobHandler, JobLifecycleState, JobListItem, JobProcessor, JobStatus, NewEvent, NewJob,
    NotificationCapability, OrderingCapability, Queue, QueueConfig, QueueOrdering,
    RetentionCapability, TransactionalEnqueueCapability, Worker,
};
pub use semantics::{
    semantic_contract, SemanticBehavior, SemanticClassification, SemanticContract,
};

/// Helper function to extract a human-readable panic message string from a panic payload.
pub fn format_panic_message(err: Box<dyn std::any::Any + Send>) -> String {
    if let Some(s) = err.downcast_ref::<&str>() {
        s.to_string()
    } else if let Some(s) = err.downcast_ref::<String>() {
        s.clone()
    } else {
        "job handler panicked with unknown payload".to_string()
    }
}