pub struct LocalStreamArchive { /* private fields */ }Expand description
Stream archive bound to a resolved CLI database path.
Implementations§
Source§impl LocalStreamArchive
impl LocalStreamArchive
Sourcepub fn new(config: CliConfig) -> ReplayResult<Self>
pub fn new(config: CliConfig) -> ReplayResult<Self>
Open a CLI archive adapter before it is used by async runtime code.
Sourcepub fn replay_display_window(
&self,
session_id: &str,
run_id: Option<&str>,
cursor: Option<&ReplayCursor>,
) -> CliResult<DisplayReplayWindow>
pub fn replay_display_window( &self, session_id: &str, run_id: Option<&str>, cursor: Option<&ReplayCursor>, ) -> CliResult<DisplayReplayWindow>
Replay display messages as a CLI projection window.
Trait Implementations§
Source§impl Clone for LocalStreamArchive
impl Clone for LocalStreamArchive
Source§fn clone(&self) -> LocalStreamArchive
fn clone(&self) -> LocalStreamArchive
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for LocalStreamArchive
impl Debug for LocalStreamArchive
Source§impl StreamArchive for LocalStreamArchive
impl StreamArchive for LocalStreamArchive
Source§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,
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.
Source§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,
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.
Source§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,
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.
Source§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,
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.
Source§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,
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.
Source§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,
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.
Source§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,
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.
Auto Trait Implementations§
impl Freeze for LocalStreamArchive
impl RefUnwindSafe for LocalStreamArchive
impl Send for LocalStreamArchive
impl Sync for LocalStreamArchive
impl Unpin for LocalStreamArchive
impl UnsafeUnpin for LocalStreamArchive
impl UnwindSafe for LocalStreamArchive
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more