Struct SourceNode 

pub struct SourceNode<S, OutP, const OUT: usize>
where
    S: Source<OutP, OUT>,
    OutP: Payload,
{ /* private fields */ }

A thin adapter that exposes a Source as a Node<0, OUT, (), OutP>.

This allows sources to participate in graphs and be scheduled by runtimes without any special-case code. The node owns the source and forwards the node lifecycle calls as needed.

Implementations

impl<S, OutP, const OUT: usize> SourceNode<S, OutP, OUT>

where S: Source<OutP, OUT>, OutP: Payload,

pub const fn new(src: S, policy: NodePolicy) -> Self

Construct a SourceNode from a source and a static policy bundle.

pub fn source_ref(&self) -> &S

Borrow the underlying source immutably.

pub fn source_mut(&mut self) -> &mut S

Borrow the underlying source mutably.

pub fn ingress_edge_has_batch(&self) -> bool

Return true if the ingress (external) edge for this source can produce a batch now under the given batching policy.

This mirrors StepContext::input_edge_has_batch semantics and the step_batch checks: it is observational (no side effects) and conservative on header-peek failures.

Trait Implementations

impl<S, OutP, const OUT: usize> From<S> for SourceNode<S, OutP, OUT>

where S: Source<OutP, OUT>, OutP: Payload,

Allow graphs to accept any Source and convert implicitly.

fn from(src: S) -> Self

Converts to this type from the input type.

impl<S, OutP, const OUT: usize> Node<0, OUT, (), OutP> for SourceNode<S, OutP, OUT>

where S: Source<OutP, OUT>, OutP: Payload + Copy,

fn set_policy(&mut self, policy: NodePolicy)

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

fn describe_capabilities(&self) -> NodeCapabilities

Return the node’s capability descriptor.

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

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, _c: &C, _t: &mut T) -> Result<(), NodeError>

where T: Telemetry,

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

fn start<C, T>(&mut self, _c: &C, _t: &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<()>, _sys_clock: &C, ) -> Result<ProcessResult<OutP>, NodeError>

where C: PlatformClock + Sized,

Per-message processing hook.

fn step<'g, 't, 'ck, InQ, OutQ, InM, OutM, C, Tel>( &mut self, ctx: &mut StepContext<'g, 't, 'ck, 0, OUT, (), OutP, InQ, OutQ, InM, OutM, C, Tel>, ) -> Result<StepResult, NodeError>

where InQ: Edge, OutQ: Edge, InM: MemoryManager<()>, OutM: MemoryManager<OutP>, C: PlatformClock + Sized, Tel: Telemetry + Sized,

Execute one cooperative step using the provided context.

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

where InQ: Edge, OutQ: Edge, InM: MemoryManager<()>, OutM: MemoryManager<OutP>, C: PlatformClock + Sized, Tel: 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, Tel>( &mut self, _c: &C, _t: &mut Tel, ) -> Result<StepResult, NodeError>

where Tel: Telemetry,

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

fn stop<C, Tel>(&mut self, _c: &C, _t: &mut Tel) -> Result<(), NodeError>

where Tel: Telemetry,

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