Struct StoreSnapshot 

pub struct StoreSnapshot<R: GridRow> { /* private fields */ }

An immutable view of every row at one store version.

Implementations

impl<R: GridRow> StoreSnapshot<R>

pub fn version(&self) -> u64

The store version this snapshot was published at.

pub fn len(&self) -> usize

The number of live rows.

pub fn is_empty(&self) -> bool

Returns true if there are no rows.

pub fn capacity(&self) -> usize

The number of slots, live or free. Row indices are below this.

pub fn epoch(&self) -> Instant

The instant stamps are measured from.

pub fn row(&self, id: RowId) -> Option<&Arc<R>>

The row with this id, or None if it was removed since.

pub fn row_id(&self, key: &R::Key) -> Option<RowId>

The id of the row with this key in this snapshot.

pub fn get(&self, key: &R::Key) -> Option<&Arc<R>>

The row with this key in this snapshot.

pub fn stamps(&self, id: RowId) -> Option<RowStamps<'_>>

The change stamps of the row’s cells, if any is hot. Read a cell’s with RowStamps::get.

pub fn seq(&self, id: RowId) -> u64

The insertion sequence of the row: the stable tie-breaker for sorting.

pub fn iter(&self) -> impl Iterator<Item = (RowId, &Arc<R>)>

Every live row with its id, in storage order.

pub fn pinned_rows(&self, edge: PinnedEdge) -> &[Arc<R>]

The rows pinned at edge, in order. Their keys are a space of their own: a pinned row may share its key with a data row or with a row of the other band.

pub fn pinned_stamps( &self, edge: PinnedEdge, ix: usize, ) -> Option<RowStamps<'_>>

The change stamps of the cells of the ix-th row pinned at edge, if any is hot.

pub fn progress(&self) -> Option<&GridProgress>

The progress written through GridWriter::set_progress.

pub fn fading_row(&self, id: RowId) -> Option<(&Arc<R>, Stamp)>

A removed row while it fades out (HighlightPolicy::with_removal_fade): its last version and its removal stamp. id is the row’s id before removal (its old generation), so it never resolves to a live row.

pub fn fading_rows(&self) -> impl Iterator<Item = (RowId, &Arc<R>, Stamp, u64)>

Every fading row with its id, removal stamp and insertion sequence (the tie-breaker for sorting, as Self::seq of a live row), in no particular order.

pub fn stamp_bytes(&self) -> usize

Bytes held by the change stamps of data rows, their allocations’ reference counts included (for the spike’s memory measurement).