Struct ReadYourWritesTracker 

pub struct ReadYourWritesTracker { /* private fields */ }

Read-Your-Writes Tracker

Tracks the last write LSN per session to ensure reads are routed to replicas that have replayed past that point.

Implementations

impl ReadYourWritesTracker

pub fn new(retention: Duration) -> Self

Create a new RYW tracker

pub fn with_defaults() -> Self

Create with default retention (5 minutes)

pub fn record_write(&self, session_id: &str, lsn: u64)

Record that a session wrote at this LSN

pub fn get_required_lsn(&self, session_id: &str) -> Option<u64>

Get the required LSN for read-your-writes

Returns None if no writes recorded or requirement expired

pub fn has_requirement(&self, session_id: &str) -> bool

Check if a session has a pending RYW requirement

pub fn clear(&self, session_id: &str)

Clear LSN requirement (after successful read that satisfied it)

pub fn clear_session(&self, session_id: &str)

Clear all requirements for a session

pub fn session_count(&self) -> usize

Get number of tracked sessions

pub fn get_session_info(&self, session_id: &str) -> Option<(u64, Duration, u64)>

Get session info

pub fn cleanup(&self)

Force cleanup now

pub fn clear_all(&self)

Clear all tracked sessions

Trait Implementations

impl Debug for ReadYourWritesTracker

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

Formats the value using the given formatter.