Struct LogHub 

pub struct LogHub { /* private fields */ }

Available on crate feature serve only.

Shared, cheaply-cloneable registry of per-run log buffers. One instance is created at subscriber install and shared between RunLogLayer and the /logs handler via ServerState.

Implementations

impl LogHub

pub fn new() -> Self

pub fn enable_persistence( &self, history: Arc<dyn RunHistory>, max_lines_per_run: usize, )

Turn on durable persistence of captured logs (#529): spawn a background writer task that batches lines into history, and route captured lines to it. max_lines_per_run caps how many lines are persisted per run (past it, a truncation marker is recorded). Idempotent — a second call is a no-op.

pub fn capture(&self, run_id: &str, level: &str, ts: String, line: String)

Capture a line for a run: push to the ephemeral ring (SSE) and, when persistence is enabled, enqueue it for durable storage (#529). Called by RunLogLayer::on_event with the pre-redacted line.

pub fn append(&self, run_id: &str, line: String)

Append a captured line without level/timestamp metadata (ephemeral-only; used by tests and any caller that doesn’t persist).

pub fn reader( &self, run_id: &str, ) -> Option<(Vec<LogLine>, Receiver<LogMsg>, bool)>

Open a /logs reader: returns the ring snapshot, a live-tail receiver, and whether the run has already ended. None means no buffer exists for the run (never logged, or already dropped after the drain window).

Subscribe-then-snapshot-then-load-ended ordering is deliberate: a reader that misses the End broadcast still observes ended == true, so the stream can close without hanging. Backfill/live duplicates are removed by sequence number in log_events.

pub fn finish(&self, run_id: &str)

Mark a run terminal: broadcast End so live readers can close, and flush the run’s durable-log buffer (#529).

pub fn drop_run(&self, run_id: &str)

Drop a run’s buffer, freeing its ring (called after the drain window).

Trait Implementations

impl Clone for LogHub

fn clone(&self) -> LogHub

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for LogHub

fn default() -> LogHub

Returns the “default value” for a type.