Struct ReconNode 

pub struct ReconNode { /* private fields */ }

A retained reconstruction node: session, pipeline, accepted-frame journal and lifecycle. Cheap to clone (shared); all clones address the same node.

Implementations

impl ReconNode

pub fn declare() -> NodeBuilder

Starts a node declaration with the default plan (aerial-formation cameras, zones 12/2), dense off, no output files.

impl ReconNode

pub fn id(&self) -> &str

Node id on its host.

pub fn compose(&self, state: FrameState) -> Result<Outcome, ComposeError>

Declares the current input state and reconciles it (see the module table).

pub fn compose_all( &self, states: impl IntoIterator<Item = FrameState>, ) -> Result<Vec<Outcome>, ComposeError>

Declares several states in order, stopping at the first error.

pub fn compose_batch( &self, states: impl IntoIterator<Item = FrameState>, ) -> Vec<Result<Outcome, ComposeError>>

Declares several states in order, like ReconNode::compose_all, but appended sets are handed to the session together as one backlog batch: their features are extracted in one go, all their pairs are matched in one call, and the batch is registered and triangulated once (see crate::session::Input::Batch). The batch is split where the session closes a zone. Late arrivals, corrections and End inside the list flush the batch first. Returns one result per state (a session failure shows up on the last appended state of the batch); unlike compose_all it does not stop at the first error.

pub fn poll(&self) -> usize

Collects finished background (refinement) events without new input.

pub fn subscribe(&self) -> Option<Receiver<Event>>

Channel receiving every event of this node (see Pipeline::subscribe). None after close.

pub fn stats(&self) -> ComposeStats

Reconciliation counters so far.

pub fn positions(&self) -> usize

Positions ingested so far.

pub fn journal(&self) -> Vec<(u64, u32)>

Accepted (sequence, revision) per position.

pub fn waiting(&self) -> Vec<(u64, Vec<String>)>

Sets currently waiting for cameras: (sequence, missing cameras).

pub fn with_session<T>(&self, f: impl FnOnce(&Session) -> T) -> Option<T>

Read access to the session (e.g. arrived zones, models).

pub fn close(&self) -> Result<Closed, ComposeError>

Closes the node: closes open zones, waits for background refinement and emits the final events. The node stays listed on its host; CompositionHost::close also removes it.

pub fn spawn(&self) -> ComposeHandle

Moves the node onto its own thread behind a queue with the builder’s Backpressure policy. The node stays registered on its host; composing on it directly while spawned is serialized with the worker.

Trait Implementations

impl Clone for ReconNode

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReconNode

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

Formats the value using the given formatter.