Struct CursorAffinity 

pub struct CursorAffinity { /* private fields */ }

A bounded, TTL’d map from cursor id to the cluster that created it (docs/03 §6). Cloneable handles are not provided; wrap in an Arc to share.

Implementations

impl CursorAffinity

pub fn new(ttl: Duration, capacity: usize) -> Self

Builds a cursor-affinity map with the given binding TTL and capacity, reading time from the system clock.

pub fn with_clock(self, clock: Arc<dyn Clock>) -> Self

Swaps the clock that drives expiry (tests inject a ManualClock).

pub fn pin(&self, cursor_id: impl Into<String>, cluster: ClusterId)

Records that cursor_id lives on cluster. Expired bindings are swept first; if the map is still at capacity, the oldest binding is evicted so the new one fits (bounded memory).

pub fn resolve(&self, cursor_id: &str) -> Option<ClusterId>

The cluster cursor_id is pinned to, or None if it is unknown or its binding has expired (lazy expiry, a stale binding is never returned).

pub fn release(&self, cursor_id: &str)

Drops cursor_id’s binding (e.g. on an explicit clear-scroll / close-PIT).

pub fn len(&self) -> usize

The number of bindings currently held (including any not yet swept).

pub fn is_empty(&self) -> bool

Whether no bindings are held.

Trait Implementations

impl Debug for CursorAffinity

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

Formats the value using the given formatter.