Struct NodeBuilder 

pub struct NodeBuilder { /* private fields */ }

Records a node configuration; NodeBuilder::build checks it and creates the node on a host.

The reconstruction settings are a Plan (same fields and TOML as crate::declare); the input folder is the image root, positions/stride are not used (input is declared live), and GPS comes with each set.

Implementations

impl NodeBuilder

pub fn id(self, id: impl Into<String>) -> Self

Node id on the host (default "default").

pub fn plan(self, plan: Plan) -> Self

Replaces the reconstruction settings with a plan (e.g. read from TOML). Input positions/stride and the GPS file are ignored; sinks are ignored (use NodeBuilder::output).

pub fn images(self, dir: impl Into<PathBuf>) -> Self

Image folder: file payloads are relative to it, in-memory payloads are spooled inside it.

pub fn cameras<S: Into<String>>(self, cams: impl IntoIterator<Item = S>) -> Self

Cameras of one synchronized set, in position order.

pub fn zones(self, span: usize, overlap: usize) -> Self

Zone size and overlap in positions.

pub fn align(self, frame: AlignFrame) -> Self

Coordinate alignment (ENU needs GPS fixes in the sets).

pub fn fixed_enu_origin(self, on: bool) -> Self

Fixes the ENU origin at the first GPS fix.

pub fn features(self, f: Features) -> Self

Feature extraction settings.

pub fn match_backend(self, name: &str) -> Self

Descriptor matching backend (cpu | cuda).

pub fn gpu(self) -> Self

CUDA for features, matching and densification.

pub fn incremental_triangulation(self, on: bool) -> Self

Triangulate only newly registered images.

pub fn dense(self, d: Dense) -> Self

Densification settings (enables it).

pub fn no_dense(self) -> Self

No densification (default).

pub fn seed(self, seed: u64) -> Self

RANSAC seed.

pub fn reconcile(self, p: ReconcilePolicy) -> Self

Reconciliation policy (default ReconcilePolicy::AppendOnly).

pub fn backpressure(self, b: Backpressure) -> Self

Producer queue policy for ReconNode::spawn (default Block { max_pending: 8 }).

pub fn source(self, id: impl Into<String>) -> Self

Accept only this source id (default: the first declared source).

pub fn spool(self, rel: impl Into<PathBuf>) -> Self

Spool folder for in-memory payloads, relative to the image folder (default .live).

pub fn output(self, dir: impl Into<PathBuf>, opts: SinkOptions) -> Self

Writes the standard output files (timeline, run.log, zone PLYs, snapshots) to dir.

pub fn on<F>(self, kind: EventKind, f: F) -> Self

where F: FnMut(&Event) + Send + 'static,

Hook for one event kind (Pipeline::on). FrameDecoded turns frame decoding on.

pub fn on_event<F>(self, f: F) -> Self

where F: FnMut(&Event) + Send + 'static,

Hook for every event (Pipeline::on_any).

pub fn on_frame<F>(self, f: F) -> Self

where F: FnMut(&Arc<Frame>) + Send + 'static,

Decoded input frames (Pipeline::on_frame); turns frame decoding on.

pub fn on_zone_preview<F>(self, f: F) -> Self

where F: FnMut(ZoneRange, &Arc<PointCloud>) + Send + 'static,

Zone preview clouds (Pipeline::on_zone_preview).

pub fn on_zone_refined<F>(self, f: F) -> Self

where F: FnMut(ZoneRange, &Arc<PointCloud>) + Send + 'static,

Zone refined clouds (Pipeline::on_zone_refined).

pub fn on_message<F>(self, f: F) -> Self

where F: FnMut(EventKind, &str) + Send + 'static,

Warnings and errors (Pipeline::on_message); includes reconciliation warnings.

pub fn event_policy(self, kind: EventKind, p: QueuePolicy) -> Self

Per-kind hook queue policy (Pipeline::policy), e.g. LatestPerKey for ZonePreview.

pub fn sync_hooks(self, on: bool) -> Self

Runs hooks synchronously on the composing thread (Pipeline::sync).

pub fn build(self, host: &CompositionHost) -> Result<ReconNode, ComposeError>

Checks the configuration, creates the session and pipeline, and registers the node on host. Creates the image folder’s spool folder; nothing else is written until frames are declared.

Trait Implementations

impl Debug for NodeBuilder

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

Formats the value using the given formatter.