Struct SessionBuffer

pub struct SessionBuffer { /* private fields */ }

Implementations

impl SessionBuffer

pub fn new(store: Arc<CacheStore>) -> Self

pub fn record( &self, rovenue_id: &str, kind: SessionEventKind, occurred_at: &str, duration_ms: Option<u32>, ) -> RovenueResult<()>

Buffer one event under rovenue_id, the wire identity current when it happened; the dispatcher posts it under that identity even after a log out.

pub fn peek(&self, limit: usize) -> RovenueResult<Vec<SessionEventRow>>

Read up to limit buffered events WITHOUT removing them. The dispatcher removes them (via delete) only after the server confirms receipt, so a 503 (Kafka down) / network failure retains the batch for the next flush instead of dropping it. Growth is bounded by the store’s FIFO cap (newest 1000) applied on append.

pub fn delete(&self, ids: &[i64]) -> RovenueResult<()>

Remove the given event ids — called only after a successful dispatch.