Struct StreamingConfig 

pub struct StreamingConfig {
    pub max_depth: u32,
    pub limit: Option<usize>,
    pub max_visited_size: usize,
    pub rel_types: Vec<String>,
    pub deadline: Option<Instant>,
}

Configuration for streaming traversal.

Unlike TraversalConfig, this is optimized for memory-bounded streaming where results are yielded lazily via an iterator.

Fields

max_depth: u32

Maximum depth for traversal.

limit: Option<usize>

Maximum number of results to yield (None = unlimited).

max_visited_size: usize

Maximum size of visited set before switching to approximate mode. When exceeded, the iterator stops tracking visited nodes exactly, which may cause some nodes to be visited multiple times in cyclic graphs.

rel_types: Vec<String>

Filter by relationship types (empty = all types).

deadline: Option<Instant>

Optional wall-clock deadline. When set and reached, the iterator stops expanding and terminates (returns None), yielding the partial result accumulated so far. None (the default) disables the time bound.

Implementations

impl StreamingConfig

pub fn with_limit(self, limit: usize) -> Self

Creates a config with a result limit.

pub fn with_max_depth(self, max_depth: u32) -> Self

Sets the maximum depth.

pub fn with_max_visited(self, max_visited: usize) -> Self

Sets the maximum visited set size.

pub fn with_rel_types(self, types: Vec<String>) -> Self

Filters by relationship types.

pub fn with_deadline(self, deadline: Instant) -> Self

Sets a wall-clock deadline after which the iterator terminates, yielding only the results accumulated so far.

Trait Implementations

impl Clone for StreamingConfig

fn clone(&self) -> StreamingConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingConfig

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

Formats the value using the given formatter.

impl Default for StreamingConfig

fn default() -> Self

Returns the “default value” for a type.