Struct LogStore 

pub struct LogStore { /* private fields */ }

Implementations

impl LogStore

pub fn new() -> Self

pub async fn create_session_log(&self, session_id: &str)

pub async fn append(&self, session_id: &str, entry: LogEntry)

pub async fn get_log(&self, session_id: &str) -> Option<Vec<LogEntry>>

pub async fn get_incoming_after( &self, session_id: &str, after_sequence: u64, ) -> Vec<(u64, LogEntry)>

Returns incoming log entries with 0-based index >= after_sequence. Only Incoming entries are returned (Internal/Checkpoint are filtered). RFC-MACP-0006-A1: used by StreamSession passive subscribe to replay accepted session history to late-joining agents.

Trait Implementations

impl Default for LogStore

fn default() -> Self

Returns the “default value” for a type.