Struct LocalStreamArchive 

pub struct LocalStreamArchive { /* private fields */ }

Shared stream archive adapter backed by the CLI local SQLite store.

Implementations

impl LocalStreamArchive

pub const fn new(config: CliConfig) -> Self

Create a local stream archive adapter from resolved CLI config.

pub fn replay_display_window( &self, session_id: &str, run_id: Option<&str>, cursor: Option<&ReplayCursor>, ) -> CliResult<DisplayReplayWindow>

Replay display messages as scoped replay events for local RPC and TUI hosts.

Trait Implementations

impl Clone for LocalStreamArchive

fn clone(&self) -> LocalStreamArchive

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LocalStreamArchive

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

Formats the value using the given formatter.

impl StreamArchive for LocalStreamArchive

fn append_raw_records<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, records: Vec<AgentStreamRecord>, ) -> Pin<Box<dyn Future<Output = ReplayResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Append raw runtime stream records.

fn replay_raw_after<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: &'life1 SessionId, run_id: &'life2 RunId, cursor: Option<ReplayCursor>, ) -> Pin<Box<dyn Future<Output = ReplayResult<Vec<AgentStreamRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Replay raw runtime stream records after a cursor.

fn append_display_messages<'life0, 'async_trait>( &'life0 self, _scope: ReplayScope, messages: Vec<DisplayMessage>, ) -> Pin<Box<dyn Future<Output = ReplayResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Append projected display messages.

fn replay_display_after<'life0, 'life1, 'async_trait>( &'life0 self, scope: &'life1 ReplayScope, cursor: Option<ReplayCursor>, ) -> Pin<Box<dyn Future<Output = ReplayResult<Vec<DisplayMessage>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Replay projected display messages after a cursor.

fn append_snapshot<'life0, 'async_trait>( &'life0 self, scope: ReplayScope, snapshot: ReplaySnapshot, ) -> Pin<Box<dyn Future<Output = ReplayResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Append compact snapshot.

fn latest_snapshot<'life0, 'life1, 'async_trait>( &'life0 self, scope: &'life1 ReplayScope, ) -> Pin<Box<dyn Future<Output = ReplayResult<Option<ReplaySnapshot>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Load latest compact snapshot.

fn cursor_range<'life0, 'life1, 'async_trait>( &'life0 self, scope: &'life1 ReplayScope, ) -> Pin<Box<dyn Future<Output = ReplayResult<Option<(ReplayCursor, ReplayCursor)>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Return cursor range for a display scope.