Struct PostgresEventArchive 

pub struct PostgresEventArchive { /* private fields */ }

Implementations

impl PostgresEventArchive

pub fn new(client: PostgresStoreClient) -> Self

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

Trait Implementations

impl Clone for PostgresEventArchive

fn clone(&self) -> PostgresEventArchive

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl EventArchive for PostgresEventArchive

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 PostgresEventArchive

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

Returns archived frames after the optional archive cursor.