Struct MockBackendStreams 

pub struct MockBackendStreams {
    pub pending: Option<u32>,
    pub capacity: u32,
}

A test-only fuel_backend_contract::backend::BackendStreams handle reporting a fixed (pending_work_count, slot_capacity) — the simulated live-load signal C2’s tests inject in place of a real device. Lives here (not behind #[cfg(test)]) so the route-picker + bridge tests can build a fake load lookup without re-deriving the trait wiring.

Fields

pending: Option<u32>

What pending_work_count() reports. None = “I can’t measure” (a streaming backend with no depth available) ⇒ tier 0.

capacity: u32

What slot_capacity() reports.

Implementations

impl MockBackendStreams

pub fn new(pending: Option<u32>, capacity: u32) -> Self

A handle reporting pending in-flight ops against capacity slots.

Trait Implementations

impl BackendRuntime for MockBackendStreams

fn available_bytes(&self) -> Option<u64>

Bytes currently available for new allocations on this backend’s device. None when the backend genuinely cannot measure (no OS query exposed, no vendor API supports it).

fn total_bytes(&self) -> Option<u64>

Total memory on this backend’s device. Static after first call; implementations cache unconditionally. None for backends with unbounded notional capacity (e.g. Reference returns Some(u64::MAX), or None if the backend prefers to advertise “unknowable”).

fn as_backend_streams(&self) -> Option<&dyn BackendStreams>

Tier-2 upcast seam: a runtime handle that also exposes a deferred-execution queue model returns Some(self) so a selector holding only a &dyn BackendRuntime (the type the route picker’s BackendRuntimeLookup hands out) can reach the BackendStreams live-load surface without naming the concrete handle type.

fn would_fit(&self, size: u64) -> FitStatus

Predictive fit-check: would an allocation of size bytes likely succeed given current state? Returns FitStatus::Tight when projected post-allocation usage crosses the pressure threshold (default 0.85 of total).

impl BackendStreams for MockBackendStreams

fn pending_work_count(&self) -> Option<u32>

Number of slots (streams / queues / command buffers) currently busy with submitted-but-not-yet-finished work, for this handle’s device. None when the backend dispatches synchronously and has no queue concept (selectors then have no load signal — fall back to static cost, never treat None as “idle”).

fn slot_capacity(&self) -> u32

Maximum concurrent in-flight work this backend advertises. Used by the runtime route picker for load tiering (count / slot_capacity) and dispatch lookahead sizing.

fn flush(&self) -> Result<()>

Block until all submitted work on this backend’s slots has completed. Used at realize boundaries and by training-loop barriers (gradient accumulation, optimizer step).