Struct SlotTracker 

pub struct SlotTracker { /* private fields */ }

Tracks the last processed slot for stream resumption after reconnection.

Includes a Notify that wakes waiters whenever the slot advances, allowing the scheduler to react immediately to new slots instead of polling. Also maintains a cache of slot hashes indexed by slot number.

Implementations

impl SlotTracker

pub fn new() -> Self

pub fn record(&self, slot: u64)

pub async fn record_slot_hash(&self, slot: u64, slot_hash: String)

Record a slot hash for a specific slot

pub async fn get_slot_hash(&self, slot: u64) -> Option<String>

Get the slot hash for a specific slot (if cached)

pub fn get(&self) -> u64

pub fn notified(&self) -> impl Future<Output = ()> + '_

Returns a future that resolves when the slot advances. Use with tokio::select! and a fallback timeout.

Trait Implementations

impl Clone for SlotTracker

fn clone(&self) -> SlotTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for SlotTracker

fn default() -> Self

Returns the “default value” for a type.