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.

ClusterAgent

Entrypoint for starting membership, the local agent, DCP, and node sessions together.

ClusterAgentConfig

Combined configuration for one cluster-aware Datum agent.

ClusterAgentHandle

Running cluster-aware agent.

ClusterJobMetadata

Cluster ownership metadata persisted in the local registry entry for jobs started by the placement coordinator.

ClusterPlacementHistory

One placement-history entry for a cluster-submitted job.

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.

NodeSessionConfig

Configuration for DCP node sessions maintained by a cluster-aware agent.

NodeSessionManagerHandle

PlacementSpec

Placement constraints attached to a cluster-submitted job.

Enums

AgentError

Errors returned by the embeddable agent and job registry.

ClusterAgentError

Errors returned by the cluster-aware agent entrypoint.

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.

NodeSessionTransport

Transport used for node-to-node DCP sessions.

PlacementStrategy

Placement strategy selected for a cluster-submitted job.

Constants

AGENT_ROLE

Role used by cluster-aware agents to discover peers.

VERSION

The datum-agent crate version.

Type Aliases

AgentResult

Result type used by datum-agent.

ClusterAgentResult

Result type for cluster-aware agent startup and shutdown.

JobGraphFactory

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