Struct Graph 

pub struct Graph { /* private fields */ }

A single-thread graph/concurrency-domain product surface (D22/B53).

Implementations

impl Graph

pub fn checkpoint(&self) -> GraphRestoreResult<GraphCheckpoint>

Updates or reads checkpoint.

impl Graph

pub fn new(opts: GraphOptions) -> Self

Creates or computes new.

pub fn name(&self) -> Option<&str>

Updates or reads name.

pub fn topology_group(&self) -> TopologyGroup

D152 graph-owned topology/release group. Members are ordinary registered graph nodes and release is quiescent-only; no protocol messages are synthesized.

pub fn topology_group_opts(&self, opts: TopologyGroupOptions) -> TopologyGroup

Updates or reads topology_group_opts.

pub fn find(&self, id: &str) -> Option<GraphNode>

Look up a registered graph node by stable id.

pub fn node<T: 'static, F: Fn(&Ctx) + 'static>( &self, deps: Vec<Core>, f: F, ) -> Node<T>

ctx-level power surface: the raw (ctx)=>void node factory.

pub fn node_opts<T: 'static, F: Fn(&Ctx) + 'static>( &self, deps: Vec<Core>, f: F, opts: GraphNodeOpts, ) -> Node<T>

Updates or reads node_opts.

pub fn state<T: 'static>(&self, initial: T) -> Node<T>

Graph-owned state node with an initial value.

pub fn state_opts<T: 'static>(&self, initial: T, opts: GraphNodeOpts) -> Node<T>

Updates or reads state_opts.

pub fn state_empty<T: 'static>(&self) -> Node<T>

Graph-owned SENTINEL state node.

pub fn state_empty_opts<T: 'static>(&self, opts: GraphNodeOpts) -> Node<T>

Updates or reads state_empty_opts.

pub fn producer<T: 'static, F: Fn(&Ctx) + 'static>(&self, f: F) -> Node<T>

ctx-level depless source; runs once on activation.

pub fn producer_opts<T: 'static, F: Fn(&Ctx) + 'static>( &self, f: F, opts: GraphNodeOpts, ) -> Node<T>

Updates or reads producer_opts.

pub fn derived<T: 'static, F: Fn(&Values<'_>) -> Option<T> + 'static>( &self, deps: Vec<Core>, f: F, ) -> Node<T>

Value-level derived sugar: return Some(value) to emit DATA, None for a no-emit/RESOLVED settle. Reads dep values through Values, not raw Ctx.

pub fn derived_opts<T: 'static, F: Fn(&Values<'_>) -> Option<T> + 'static>( &self, deps: Vec<Core>, f: F, opts: GraphNodeOpts, ) -> Node<T>

Updates or reads derived_opts.

pub fn effect<F: Fn(&Values<'_>) -> Option<Box<dyn FnOnce()>> + 'static>( &self, deps: Vec<Core>, f: F, ) -> Node<()>

Value-level sink sugar. A returned cleanup is registered as onDeactivation.

pub fn effect_opts<F: Fn(&Values<'_>) -> Option<Box<dyn FnOnce()>> + 'static>( &self, deps: Vec<Core>, f: F, opts: GraphNodeOpts, ) -> Node<()>

Updates or reads effect_opts.

pub fn batch<R>(&self, f: impl FnOnce(&BatchCtx) -> R) -> R

Declarative batch (D12): success commits, rollback/panic discards.

pub fn init_node<T: 'static>( &self, op: Operator<T>, deps: Vec<Core>, opts: GraphNodeOpts, ) -> Node<T>

Instantiate a free-standing operator/source as a registered graph node (D43/D40).

pub fn mount(&self, child: Graph, at: impl Into<String>)

Mount a child graph under a stable :: path prefix.

pub fn describe(&self) -> DescribeSnapshot

Static point-in-time inspection snapshot (D39 first cut).

pub fn describe_opts(&self, opts: DescribeOpts) -> DescribeSnapshot

Updates or reads describe_opts.

pub fn observe(&self) -> ObserveStream

Read-only observation egress for every currently registered node in this graph.

pub fn observe_path(&self, path: &str) -> ObserveStream

Read-only observation egress for a single registered id or a :: subtree prefix.

pub fn observe_topology(&self) -> TopologyStream

D145 read-only topology lifecycle egress over the existing graph registry.

This is not a graph node, does not subscribe to nodes, and does not publish DATA.

pub fn observe_topology_path(&self, path: &str) -> TopologyStream

Read-only topology lifecycle egress for one registered id or :: subtree prefix.

pub fn profile(&self) -> Profile

Opt-in accumulated-counter snapshot (D39/R-profile).

Trait Implementations

impl Clone for Graph

fn clone(&self) -> Graph

Returns a duplicate of the value.

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

Performs copy-assignment from source.