Struct AutonomousRegistry 

pub struct AutonomousRegistry { /* private fields */ }

Shared registry of autonomous goal sessions.

Cloned freely — all clones share the same underlying Mutex<HashMap>. The agent owns one clone; the /agents handler owns another.

Example

use zeph_core::goal::registry::AutonomousRegistry;

let reg = AutonomousRegistry::default();
let snapshots = reg.list();
assert!(snapshots.is_empty());

Implementations

impl AutonomousRegistry

pub fn new() -> Self

Create an empty registry.

pub fn upsert( &self, goal_id: impl Into<String>, goal_text: impl Into<String>, state: AutonomousState, turns_executed: u32, max_turns: u32, started_at: Instant, last_verdict: Option<SupervisorVerdict>, )

Insert or update a session entry.

All fields are taken as a flat argument list; the registry owns the produced entry. The lock is never held across an .await.

pub fn remove(&self, goal_id: &str)

Remove a session entry.

pub fn list(&self) -> Vec<SessionSnapshot>

Return snapshots for all sessions currently in the registry.

In practice this is 0 or 1 entries (invariant A1).

Trait Implementations

impl Clone for AutonomousRegistry

fn clone(&self) -> AutonomousRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for AutonomousRegistry

fn default() -> AutonomousRegistry

Returns the “default value” for a type.