datum-agent 0.9.1

Embeddable Datum job registry and lifecycle supervisor
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

#![forbid(unsafe_code)]
//! Embeddable job registry and lifecycle supervisor for Datum streams.
//!
//! `datum-agent` is intentionally local and protocol-free in WP-A2. The registry actor owns job
//! specs, desired state, restart timers, completion polling, and lifecycle events. Job data paths
//! remain ordinary Datum streams.

mod agent;
pub mod dcp;
mod error;
mod job;
mod registry;

/// The `datum-agent` crate version.
pub const VERSION: &str = env!("CARGO_PKG_VERSION");

pub use agent::{Agent, AgentConfig, AgentHandle};
pub use error::{AgentError, AgentResult};
pub use job::{
    DesiredJobState, JobContext, JobControl, JobDrainBehavior, JobEvent, JobEventKind,
    JobExitReason, JobGraphFactory, JobId, JobInstrumentationSnapshot, JobMat, JobRestartPolicy,
    JobSpec, JobState, JobStatus,
};
pub use registry::{JobRegistry, JobRegistryHandle};