Crate datum_agent 

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.

Modules

dcp

Datum Control Protocol (DCP) server and client.

Structs

Agent

Minimal embeddable entrypoint for the local agent.

AgentConfig

Configuration for an embeddable Datum agent.

AgentHandle

Handle returned by Agent::start and Agent::start_with_config.

JobContext

Context passed to a job blueprint factory for one materialized generation.

JobControl

Control handles associated with a running job generation.

JobEvent

Lifecycle event emitted by the registry.

JobId

Stable identifier assigned by the local registry when a job is submitted.

JobInstrumentationSnapshot

Reserved integration point for WP-A1 stream instrumentation.

JobMat

Standardized materialized value for daemon-managed jobs.

JobRegistry

Ractor-backed local job registry.

JobRegistryHandle

Cloneable in-process handle to the registry actor.

JobSpec

A named, supervised stream program.

JobStatus

Point-in-time registry snapshot for one job.

Enums

AgentError

Errors returned by the embeddable agent and job registry.

DesiredJobState

Desired state recorded by the registry.

JobDrainBehavior

Drain behavior declared by a job spec.

JobEventKind

Kind-specific lifecycle event details.

JobExitReason

Why the latest generation exited.

JobRestartPolicy

Registry-visible restart policy for a job.

JobState

Observed lifecycle state of a job.

Constants

VERSION

The datum-agent crate version.

Type Aliases

AgentResult

Result type used by datum-agent.

JobGraphFactory

Factory used by JobSpec to build a fresh job blueprint for one generation.