Struct ScanOperator 

pub struct ScanOperator { /* private fields */ }

A scan operator that reads nodes from storage.

Implementations

impl ScanOperator

pub fn new(store: Arc<LpgStore>) -> Self

Creates a new scan operator for all nodes.

pub fn with_label(store: Arc<LpgStore>, label: impl Into<String>) -> Self

Creates a new scan operator for nodes with a specific label.

pub fn with_chunk_capacity(self, capacity: usize) -> Self

Sets the chunk capacity.

pub fn with_tx_context(self, epoch: EpochId, tx_id: Option<TxId>) -> Self

Sets the transaction context for MVCC visibility.

When set, the scan will only return nodes visible to this transaction.

Trait Implementations

impl Operator for ScanOperator

fn next(&mut self) -> OperatorResult

Returns the next chunk of data, or None if exhausted.

fn reset(&mut self)

Resets the operator to its initial state.

fn name(&self) -> &'static str

Returns the name of this operator for debugging.