datum_agent/
lib.rs

1#![forbid(unsafe_code)]
2//! Embeddable job registry and lifecycle supervisor for Datum streams.
3//!
4//! `datum-agent` is intentionally local and protocol-free in WP-A2. The registry actor owns job
5//! specs, desired state, restart timers, completion polling, and lifecycle events. Job data paths
6//! remain ordinary Datum streams.
7
8mod agent;
9pub mod dcp;
10mod error;
11mod job;
12mod registry;
13
14/// The `datum-agent` crate version.
15pub const VERSION: &str = env!("CARGO_PKG_VERSION");
16
17pub use agent::{Agent, AgentConfig, AgentHandle};
18pub use error::{AgentError, AgentResult};
19pub use job::{
20    DesiredJobState, JobContext, JobControl, JobDrainBehavior, JobEvent, JobEventKind,
21    JobExitReason, JobGraphFactory, JobId, JobInstrumentationSnapshot, JobMat, JobRestartPolicy,
22    JobSpec, JobState, JobStatus,
23};
24pub use registry::{JobRegistry, JobRegistryHandle};
datum_agent/lib.rs

datum_agent/
lib.rs
