weave-lens · iterator

Reviewed implementation boundary: The current batching helper rejects multiple operations instead of implementing atomic batch commits. Cache/compaction/retention configuration fields do not establish running background compaction. See /libraries/lens/overview.

Source: sigil/weave/models/lens/src/iterator.rs. SHA-256: 0de4037a9076866a5129d31ccf5148c68645cf0f970d3380115610ac794c817b.

This reference follows declared source modules, retains conditional attributes, and includes public declarations and implementation methods. Private-module re-exports and trait resolution require the compiler; this is a source reference, not a claim that every listed item is a root import. Function bodies and constant values are omitted.

iterator::Direction

Direction for iteration

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum Direction {
    /// Forward iteration (ascending)
    Forward,
    /// Reverse iteration (descending)
    Reverse,
}

Source line: 8.

iterator::ReadOptions

Options for read streams

#[derive(Debug, Clone)]
pub struct ReadOptions {
/// Iteration direction

pub direction: Direction,
/// Include the start key

pub include_start: bool,
/// Include the end key

pub include_end: bool,
/// Maximum number of results

pub limit: Option<usize>,
/// Use snapshot if provided

pub snapshot: Option<uuid::Uuid>
}

Source line: 17.

iterator::ReadStream

Async iterator over key-value pairs

pub struct ReadStream {

}

Source line: 47.

iterator::ReadStream::next

Get next key-value pair

pub async fn next(&mut self) -> Result<Option<(Key, Value)>>;

Source line: 114.

iterator::ReadStream::collect

Collect all results into a vector

pub async fn collect(mut self) -> Result<Vec<(Key, Value)>>;

Source line: 364.