Skip to main content

CsrMutableEdges

Struct CsrMutableEdges 

Source
pub struct CsrMutableEdges { /* private fields */ }
Expand description

Mutable edge storage combining CSR base with delta slab

Provides efficient edge mutations with automatic rebuild when delta grows too large.

Implementations§

Source§

impl CsrMutableEdges

Source

pub fn new() -> Self

Create new mutable edges with empty base

Source

pub fn with_coords(coords: Vec<AbsCoord>) -> Self

Create with initial vertex coordinates

Source

pub fn add_edge(&mut self, from: VertexId, to: VertexId)

Add an edge, rebuilding if threshold reached

Source

pub fn remove_edge(&mut self, from: VertexId, to: VertexId)

Remove an edge, rebuilding if threshold reached

Source

pub fn out_edges(&self, v: VertexId) -> Vec<VertexId>

Get outgoing edges for a vertex (merged view)

Source

pub fn out_edges_ref(&self, v: VertexId) -> Option<&[VertexId]>

Borrow outgoing edges when no delta mutations are pending.

This is a zero-allocation hot path for read-heavy evaluation/scheduling phases.

Source

pub fn in_edges(&self, v: VertexId) -> &[VertexId]

Get incoming edges from base CSR (delta not applied for performance) After rebuild, this will include all changes

Source

pub fn in_edges_ref(&self, v: VertexId) -> Option<&[VertexId]>

Borrow incoming edges when no delta mutations are pending.

This is a zero-allocation hot path for read-heavy evaluation/scheduling phases.

Source

pub fn delta_size(&self) -> usize

Get the current delta size

Source

pub fn num_edges_exact(&self) -> usize

Return the exact number of logical outgoing dependency edges, including pending delta mutations.

This is intended for read-only observability. When the delta slab is non-empty, the implementation walks the known vertex ids and merges each outgoing edge list, so callers should avoid putting it on hot evaluation paths.

Source

pub fn rebuild(&mut self)

Force a rebuild of the CSR structure

Source

pub fn begin_batch(&mut self)

Enter batch mode - defer rebuilds until the outer end_batch() call.

Source

pub fn end_batch(&mut self)

Exit batch mode and rebuild if needed.

Source

pub fn add_vertex(&mut self, coord: AbsCoord, vertex_id: u32) -> usize

Add a new vertex with its coordinate and ID

Source

pub fn add_vertices_batch(&mut self, items: &[(AbsCoord, u32)])

Add many vertices at once; single rebuild at end.

Source

pub fn update_coord(&mut self, vertex_id: VertexId, new_coord: AbsCoord)

Update coordinate for a vertex in the cache Marks for rebuild to maintain sort order

Source

pub fn adjacency_with_carried_forward_edges( &self, adjacency: Vec<(u32, Vec<u32>)>, ) -> Vec<(u32, Vec<u32>)>

Return a copy of adjacency extended with the current base+delta out-edges of every existing vertex that the input does not cover.

Named-range pass-through vertices (NamedScalar/NamedArray) emit edges to their underlying cells via add_edge during load; those edges live in base/delta but are not part of the formula-target adjacency that bulk-ingest’s finalize hands to [build_from_adjacency]. Feeding the raw adjacency straight to that (pure) builder would therefore silently drop the pass-through vertices’ out-edges, and build_demand_subgraph could never reach the underlying cells. Callers run this first to merge those edges back in, then pass the result to build_from_adjacency.

Must be called BEFORE build_from_adjacency, which overwrites base/delta/vertex_ids.

Source

pub fn build_from_adjacency( &mut self, adjacency: Vec<(u32, Vec<u32>)>, coords: Vec<AbsCoord>, vertex_ids: Vec<u32>, )

Build underlying CSR directly from adjacency and provided coords/ids. This replaces the current base and clears the delta slab.

Pure builder: it uses exactly the edges in adjacency and does not consult the existing base/delta. To preserve edges for vertices absent from adjacency (e.g. named-range pass-through vertices), run [adjacency_with_carried_forward_edges] first and pass its result in.

Trait Implementations§

Source§

impl Debug for CsrMutableEdges

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for CsrMutableEdges

Source§

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.