datum-agent 0.10.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
25
26
27
28
29
30

#![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;
mod cluster;
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 cluster::{
    AGENT_ROLE, ClusterAgent, ClusterAgentConfig, ClusterAgentError, ClusterAgentHandle,
    ClusterAgentResult, NodeSessionConfig, NodeSessionManagerHandle, NodeSessionTransport,
};
pub use error::{AgentError, AgentResult};
pub use job::{
    ClusterJobMetadata, ClusterPlacementHistory, DesiredJobState, JobContext, JobControl,
    JobDrainBehavior, JobEvent, JobEventKind, JobExitReason, JobGraphFactory, JobId,
    JobInstrumentationSnapshot, JobMat, JobRestartPolicy, JobSpec, JobState, JobStatus,
    PlacementSpec, PlacementStrategy,
};
pub use registry::{JobRegistry, JobRegistryHandle};