Struct TestCounterSourceTensor 

pub struct TestCounterSourceTensor<Clock, const BACKLOG_CAP: usize>
where
    Clock: PlatformClock,
{ /* private fields */ }

A test source that:

• Produces an incrementing counter encoded into a TestTensor on each try_produce().
• Exposes ingress pressure via either an internal backlog or a std probe.

Implementations

impl<Clock, const BACKLOG_CAP: usize> TestCounterSourceTensor<Clock, BACKLOG_CAP>

where Clock: PlatformClock,

pub const fn new( clock: Clock, starting_value_inclusive: u32, trace_id: TraceId, starting_sequence: SequenceNumber, deadline_ns: Option<DeadlineNs>, qos: QoSClass, flags: MessageFlags, node_capabilities: NodeCapabilities, node_policy: NodePolicy, output_placement_acceptance: [PlacementAcceptance; 1], ingress_policy: EdgePolicy, ) -> Self

Create a new tensor-producing test source.

pub fn with_probe( self, probe: SourceIngressProbe, updater: SourceIngressUpdater, ) -> Self

Attach a std ingress probe + updater (authoritative for occupancy when present).

pub fn produce_n_items_in_backlog(&mut self, n: usize)

Set a synthetic upstream backlog (items).

Trait Implementations

impl<Clock, const BACKLOG_CAP: usize> Source<Tensor<u32, TEST_TENSOR_ELEMENT_COUNT, 2>, 1> for TestCounterSourceTensor<Clock, BACKLOG_CAP>

where Clock: PlatformClock,

fn peek_ingress_creation_tick(&self, item_index: usize) -> Option<u64>

Peek the creation tick of the item_index’th ingress item (0 = oldest). Non-blocking and non-destructive. Returns None if metadata is not available (no backlog) or item_index is out of range.

type Error = Infallible

Source-specific error type for open().

fn open(&mut self) -> Result<(), Self::Error>

Prepare the source for production (e.g., open device, init driver).

fn try_produce(&mut self) -> Option<(usize, Message<TestTensor>)>

Attempt to produce exactly one (port, message) pair.

fn ingress_occupancy(&self) -> EdgeOccupancy

Report ingress pressure (items/bytes before the source).

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

Return output placement acceptances for zero-copy compatibility.

fn capabilities(&self) -> NodeCapabilities

Describe source capabilities (device streams, degrade tiers, etc.).

fn policy(&self) -> NodePolicy

Provide the node policy bundle (batching/budget/deadlines).

fn ingress_policy(&self) -> EdgePolicy

Provude the ingress edge policy for this source node.

fn into_sourcenode(self, policy: NodePolicy) -> SourceNode<Self, OutP, OUT>

where Self: Sized,

Convenience: wrap this source in a SourceNode with the provided policy.