boson-core 0.1.3

Portable Boson types, QueueBackend port, and identity hooks
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

//! Shared types, [`QueueBackend`] trait, router, and identity hooks.
//!
//! Task authors usually start with [`boson`](https://docs.rs/uf-boson). This crate holds
//! shared DTOs, the [`QueueBackend`] trait, and identity types used by runtime and backend adapters.
//!
//! ## Entry points
//!
//! - [`Job`], [`Run`], [`TaskConfig`], [`ExecutionContext`] — portable data and handler context
//! - [`QueueBackend`] — persistence trait for jobs, runs, config, leases (**Developing the backend**)
//! - [`QueueRouter`] — register named backends at host boot (see
//!   [Getting started](https://docs.rs/uf-boson/latest/boson/index.html#getting-started) on `boson`)
//!
//! Hosts inject a `QueueBackend` implementation at build time; this crate has no I/O.

pub mod actor_policy;
pub mod backend;
pub mod error;
pub mod identity;
pub mod models;
pub mod redact;
pub mod router;
pub mod sanitize;

pub use actor_policy::{
    default_http_enqueue_actor, is_system_shaped_actor, ActorJsonPolicy, EnqueueTrust,
    RejectExternalSystemActor,
};
pub use backend::{default_backend_from_global, JobEnqueueDisposition, QueueBackend};
pub use error::{BosonError, IdentityError, Result};
pub use identity::{ExecutionContext, ExecutionContextFactory, JsonExecutionContextFactory};
pub use models::{
    IdempotencyMode, Job, JobStatus, RateLimitPolicy, RetryPolicy, Run, RunStatus, TaskConfig,
    TaskRunStats,
};
pub use redact::{
    map_backend_connect_err, map_backend_connect_err_source, redact_credentials_in_text,
    redact_endpoint,
};
pub use router::QueueRouter;
pub use sanitize::{sanitize_error_message, MAX_ERROR_MESSAGE_CHARS};