Struct InMemorySubscriptionHub 

pub struct InMemorySubscriptionHub { /* private fields */ }

Carries in memory subscription hub data across a host-port boundary. Constructing the value does not call the host; the port method that receives it documents any adapter, network, or storage effect.

Implementations

impl InMemorySubscriptionHub

pub fn publish(&self, frame: EventFrame) -> Result<(), AgentError>

Mutates the in-memory event/subscription state and may wake local subscribers. It does not persist durable journal truth or call network sinks.

pub fn publish_all( &self, frames: impl IntoIterator<Item = EventFrame>, ) -> Result<(), AgentError>

Mutates the in-memory event/subscription state and may wake local subscribers. It does not persist durable journal truth or call network sinks.

pub fn expire_live_before(&self, event_seq: u64) -> Result<(), AgentError>

Mutates the in-memory event/subscription state and may wake local subscribers. It does not persist durable journal truth or call network sinks.

pub fn frames(&self) -> Result<Vec<EventFrame>, AgentError>

Builds the frames value. This is data construction and performs no I/O, journal append, event publication, or process work.

Trait Implementations

impl Clone for InMemorySubscriptionHub

fn clone(&self) -> InMemorySubscriptionHub

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemorySubscriptionHub

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

Formats the value using the given formatter.

impl Default for InMemorySubscriptionHub

fn default() -> InMemorySubscriptionHub

Returns the “default value” for a type.

impl RunSubscriptionSource for InMemorySubscriptionHub

fn subscribe_all( &self, cursor: Option<EventCursor>, ) -> Result<AgentEventStream, AgentError>

Creates a read-only event stream for all visible events. This is data-only and does not perform I/O, call host ports, append journals, publish events, or start processes.

fn subscribe_run( &self, run_id: RunId, cursor: Option<EventCursor>, ) -> Result<AgentEventStream, AgentError>

Creates a read-only event stream scoped to one run. This is data-only and does not perform I/O, call host ports, append journals, publish events, or start processes.

fn subscribe_agent( &self, agent_id: AgentId, cursor: Option<EventCursor>, ) -> Result<AgentEventStream, AgentError>

Creates a read-only event stream scoped to one agent. Implementations create a read-only subscription or replay stream; the call must not start runs, publish events, or append journal records.

fn subscribe_events( &self, filter: CompiledEventFilter, cursor: Option<EventCursor>, ) -> Result<AgentEventStream, AgentError>

Creates a read-only event stream matching a compiled filter. Implementations create a read-only subscription or replay stream; the call must not start runs, publish events, or append journal records.

fn replay_run_from_cursor( &self, run_id: RunId, cursor: JournalCursor, ) -> Result<AgentEventStream, AgentError>

Replays one run from durable cursor state. Implementations create a read-only subscription or replay stream; the call must not start runs, publish events, or append journal records.

fn latest_terminal_event( &self, run_id: &RunId, ) -> Result<Option<EventFrame>, AgentError>

Reads the latest terminal event for one run, when available. Implementations read subscription state for the latest terminal frame; the lookup must not publish events or alter run state.