Struct BrokerStateInner 

pub struct BrokerStateInner {
    pub agents: HashMap<String, AgentRecord>,
    pub agent_clis: HashMap<String, String>,
    pub queues: HashMap<String, Vec<(u64, BrokerMessage)>>,
    pub message_log: Vec<(u64, SystemTime, BrokerMessage)>,
    pub republish_working_ttl: Duration,
    pub watched_paths: HashSet<PathBuf>,
}

Mutable broker state protected by an RwLock.

Fields

agents: HashMap<String, AgentRecord>

Known agents keyed by agent ID.

agent_clis: HashMap<String, String>

CLI label per agent, populated from WatchTarget at broker start.

queues: HashMap<String, Vec<(u64, BrokerMessage)>>

Per-agent message inboxes: (sequence_number, message).

message_log: Vec<(u64, SystemTime, BrokerMessage)>

Append-only message log for disk flush.

republish_working_ttl: Duration

Post-commit re-entry TTL for the filesystem watcher (bug 8).

A file modification observed within this window after an agent’s committed event re-publishes working. Duration::ZERO disables the behaviour (v0.5.0 model). Defaults to 60s; overwritten from [broker.watcher].republish_working_ttl_seconds at broker start.

watched_paths: HashSet<PathBuf>

Worktree paths the broker is currently watching, for idempotent live registration via POST /watch. Seeded with the start-time watch targets in start_broker_with and extended at runtime by BrokerState::register_watch_target. A vanished worktree is pruned by its watcher task (see watcher::watch_worktree), so re-adding the same path later spawns a fresh watcher.

Trait Implementations

impl Debug for BrokerStateInner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.