Struct SqliteEventArchive 

pub struct SqliteEventArchive { /* private fields */ }

SQLite-backed event archive.

Implementations

impl SqliteEventArchive

pub fn open(path: impl AsRef<Path>) -> Result<Self, AgentError>

Opens or creates a SQLite event archive.

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

Appends one event frame and assigns an archive cursor when absent.

Trait Implementations

impl Clone for SqliteEventArchive

fn clone(&self) -> SqliteEventArchive

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteEventArchive

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

Formats the value using the given formatter.

impl EventArchive for SqliteEventArchive

fn replay_filtered_from_cursor( &self, filter: CompiledEventFilter, cursor: ArchiveCursor, ) -> Result<AgentEventStream, AgentError>

Replays archived frames matching a compiled envelope filter from the archive cursor. Implementations read archived event frames from the requested cursor and return a stream; replaying must not publish new events or append journal records.

impl EventArchiveReader for SqliteEventArchive

fn frames_after( &self, cursor: Option<ArchiveCursor>, ) -> Result<Vec<EventFrame>, AgentError>

Returns archived frames after the optional archive cursor.