Struct MemoryBoundedProcessor 

pub struct MemoryBoundedProcessor { /* private fields */ }

A memory-bounded stream processor that enforces a memory budget.

Processes edge events and maintains approximate graph statistics while staying within a configurable memory limit.

Implementations

impl MemoryBoundedProcessor

pub fn new(config: MemoryBoundedConfig) -> Self

Create a new memory-bounded processor.

pub fn process_edge(&mut self, src: usize, dst: usize, weight: f64)

Process an edge event, evicting old edges if memory budget is exceeded.

pub fn graph(&self) -> &StreamingGraph

Get the current streaming graph.

pub fn edges_evicted(&self) -> u64

Get the number of edges evicted.

pub fn estimated_memory(&self) -> usize

Get estimated memory usage in bytes.

pub fn degree_distribution(&self) -> DegreeDistribution

Get the degree distribution of the current graph.

Trait Implementations

impl Debug for MemoryBoundedProcessor

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

Formats the value using the given formatter.