Struct NodeLink 

#[non_exhaustive]
pub struct NodeLink<N, const IN: usize, const OUT: usize, InP, OutP>
where
    InP: Payload,
    OutP: Payload,
    N: Node<IN, OUT, InP, OutP>,
{ /* private fields */ }

A lightweight descriptor that links to a concrete node instance and records its static topology and policy metadata.

Unlike a pure descriptor, NodeLink owns the concrete node instance (N) and records its identity, kind, port counts, policy, and optional name for graph construction, scheduling, diagnostics, and tooling. It exposes &N and &mut N accessors so runtimes can operate on the live node.

Type Parameters

• 'a: Lifetime of the borrowed node reference. The descriptor cannot outlive the node.
• N: Concrete node type implementing Node<IN, OUT, InP, OutP>.
• IN: Compile-time number of input ports for the node.
• OUT: Compile-time number of output ports for the node.
• InP: Input payload type (must implement Payload).
• OutP: Output payload type (must implement Payload).

Invariants

Callers should ensure in_ports == IN as u16 and out_ports == OUT as u16 so the stored counts are consistent with the node’s const-generic port arity.

Implementations

impl<N, const IN: usize, const OUT: usize, InP, OutP> NodeLink<N, IN, OUT, InP, OutP>

where InP: Payload, OutP: Payload, N: Node<IN, OUT, InP, OutP>,

pub fn new(node: N, id: NodeIndex, name: Option<&'static str>) -> Self

Construct a new NodeLink that borrows the given node and records its metadata.

Parameters

• node: Borrowed reference to the concrete node instance.
• id: Unique identifier of the node in the graph.
• name: Optional static name for diagnostics or tooling.

pub fn node(&self) -> &N

Get a reference to the inner node.

pub fn node_mut(&mut self) -> &mut N

Get a mutable reference to the inner node.

pub fn id(&self) -> NodeIndex

Get the unique identifier of this node.

pub fn input_port_ids(&self) -> [PortId; IN]

Returns the input port ids for the node.

pub fn output_port_ids(&self) -> [PortId; OUT]

Returns the input port ids for the node.

pub fn policy(&self) -> NodePolicy

Return the node’s policy bundle.

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

Get the optional static name of this node.

pub fn descriptor(&self) -> NodeDescriptor

Return the NodeDescriptor for this NodeLink.

Trait Implementations

impl<N, const IN: usize, const OUT: usize, InP, OutP> Clone for NodeLink<N, IN, OUT, InP, OutP>

where InP: Payload + Clone, OutP: Payload + Clone, N: Node<IN, OUT, InP, OutP> + Clone,

fn clone(&self) -> NodeLink<N, IN, OUT, InP, OutP>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<N, const IN: usize, const OUT: usize, InP, OutP> Debug for NodeLink<N, IN, OUT, InP, OutP>

where InP: Payload + Debug, OutP: Payload + Debug, N: Node<IN, OUT, InP, OutP> + Debug,

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

Formats the value using the given formatter.

impl<N, const IN: usize, const OUT: usize, InP, OutP> Node<IN, OUT, InP, OutP> for NodeLink<N, IN, OUT, InP, OutP>

where InP: Payload, OutP: Payload, N: Node<IN, OUT, InP, OutP>,

fn set_policy(&mut self, policy: NodePolicy)

TEST ONLY method used to override batching policis for node contract tests.

fn describe_capabilities(&self) -> NodeCapabilities

Return the node’s capability descriptor.

fn input_acceptance(&self) -> [PlacementAcceptance; IN]

Return the node’s port placement acceptances (zero-copy compatibility).

fn output_acceptance(&self) -> [PlacementAcceptance; OUT]

Return the node’s output placement preferences (zero-copy compatibility).

fn policy(&self) -> NodePolicy

Return the node’s policy bundle.

fn node_kind(&self) -> NodeKind

Return the type of node (Model, processing, source, sink).

fn initialize<C, T>( &mut self, clock: &C, telemetry: &mut T, ) -> Result<(), NodeError>

where T: Telemetry,

Prepare internal state, acquire buffers, and register telemetry series.

fn start<C, T>(&mut self, clock: &C, telemetry: &mut T) -> Result<(), NodeError>

where T: Telemetry,

Optional warm-up (e.g., compile kernels, prime pools). Default: no-op.

fn process_message<C>( &mut self, msg: &Message<InP>, sys_clock: &C, ) -> Result<ProcessResult<OutP>, NodeError>

where C: PlatformClock + Sized,

Per-message processing hook.

fn step<'graph, 'telemetry, 'clock, InQ, OutQ, InM, OutM, C, T>( &mut self, ctx: &mut StepContext<'graph, 'telemetry, 'clock, IN, OUT, InP, OutP, InQ, OutQ, InM, OutM, C, T>, ) -> Result<StepResult, NodeError>

where InQ: Edge, OutQ: Edge, InM: MemoryManager<InP>, OutM: MemoryManager<OutP>, C: PlatformClock + Sized, T: Telemetry + Sized,

Execute one cooperative step using the provided context.

fn step_batch<'graph, 'telemetry, 'clock, InQ, OutQ, InM, OutM, C, T>( &mut self, ctx: &mut StepContext<'graph, 'telemetry, 'clock, IN, OUT, InP, OutP, InQ, OutQ, InM, OutM, C, T>, ) -> Result<StepResult, NodeError>

where InQ: Edge, OutQ: Edge, InM: MemoryManager<InP>, OutM: MemoryManager<OutP>, C: PlatformClock + Sized, T: Telemetry + Sized,

Default batched-step implementation that honors all NodePolicy batching variants while delegating actual consumption to the implementor’s single-message process_message() method.

fn on_watchdog_timeout<C, T>( &mut self, clock: &C, telemetry: &mut T, ) -> Result<StepResult, NodeError>

where C: PlatformClock + Sized, T: Telemetry,

Handle watchdog timeouts by applying over-budget policy (degrade/default/skip).

fn stop<C, T>(&mut self, clock: &C, telemetry: &mut T) -> Result<(), NodeError>

where T: Telemetry,

Flush and release resources, if any. Default: no-op.