Struct PrnsNode 

pub struct PrnsNode<St, R, F, S, H, M, const LANE_COUNT: usize, const INTERFACE_CAPACITY: usize, const NOTIFY: usize, const COMMANDS: usize, const LIFECYCLE: usize, const COMPLETIONS: usize, const ROUTED_REQUESTS: usize = 4, const ROUTED_REQUEST_BYTES: usize = MAX_SEND_REQUEST_DATA_LEN>
where
    S: StorageLayout,
    M: RawMutex + 'static,
{ /* private fields */ }

Implementations

impl<St, R, F, S, H, M, const LANE_COUNT: usize, const INTERFACE_CAPACITY: usize, const NOTIFY: usize, const COMMANDS: usize, const LIFECYCLE: usize, const COMPLETIONS: usize> PrnsNode<St, R, F, S, H, M, LANE_COUNT, INTERFACE_CAPACITY, NOTIFY, COMMANDS, LIFECYCLE, COMPLETIONS, 4, MAX_SEND_REQUEST_DATA_LEN>

where R: RequestEndpointSet<St>, F: FnMut(PrnsEvent<'_>, &St), S: StorageLayout, H: Host, M: RawMutex + 'static,

pub fn new<'d, D>( recipe: PrnsNodeRecipe<D, St, R, F, ManuallyAttached, S>, wiring: ManifoldWiring<M, LANE_COUNT, NOTIFY, COMMANDS, LIFECYCLE, COMPLETIONS>, host: H, ) -> Self

where D: IntoIterator<Item = PreConfiguredDestination<'d>>,

impl<St, R, F, S, H, M, const LANE_COUNT: usize, const INTERFACE_CAPACITY: usize, const NOTIFY: usize, const COMMANDS: usize, const LIFECYCLE: usize, const COMPLETIONS: usize, const ROUTED_REQUESTS: usize, const ROUTED_REQUEST_BYTES: usize> PrnsNode<St, R, F, S, H, M, LANE_COUNT, INTERFACE_CAPACITY, NOTIFY, COMMANDS, LIFECYCLE, COMPLETIONS, ROUTED_REQUESTS, ROUTED_REQUEST_BYTES>

where R: RequestEndpointSet<St>, F: FnMut(PrnsEvent<'_>, &St), S: StorageLayout, H: Host, M: RawMutex + 'static,

pub fn init_static<'d, D>( cell: &'static StaticCell<Self>, recipe: PrnsNodeRecipe<D, St, R, F, ManuallyAttached, S>, wiring: ManifoldWiring<M, LANE_COUNT, NOTIFY, COMMANDS, LIFECYCLE, COMPLETIONS>, host: H, ) -> &'static mut Self

where D: IntoIterator<Item = PreConfiguredDestination<'d>>,

pub fn init_static_with_persistence<'d, D, P>( cell: &'static StaticCell<Self>, recipe: PrnsNodeRecipe<D, St, R, F, ManuallyAttached, S, P>, wiring: ManifoldWiring<M, LANE_COUNT, NOTIFY, COMMANDS, LIFECYCLE, COMPLETIONS>, host: H, ) -> (&'static mut Self, P)

where D: IntoIterator<Item = PreConfiguredDestination<'d>>,

pub fn new_with_request_capacity<'d, D>( recipe: PrnsNodeRecipe<D, St, R, F, ManuallyAttached, S>, wiring: ManifoldWiring<M, LANE_COUNT, NOTIFY, COMMANDS, LIFECYCLE, COMPLETIONS>, host: H, _capacity: RequestRoutingCapacity<ROUTED_REQUESTS, ROUTED_REQUEST_BYTES>, ) -> Self

where D: IntoIterator<Item = PreConfiguredDestination<'d>>,

pub fn set_protocol_policy(&mut self, policy: EngineProtocolPolicy)

pub fn handle(&self) -> PrnsNodeHandle<'static, M, COMMANDS, COMPLETIONS>

pub async fn run(self, drive: impl Future<Output = ()>)

Runs the manifold with the caller’s interface and supervisor tasks.

pub async fn run_with_proof_decider<P>( self, should_prove: P, drive: impl Future<Output = ()>, )

where P: FnMut(&ProofRequest<'_>) -> bool,

Runs the node with the synchronous application decision used by destinations configured with ProofStrategy::ProveIf.

The closure lives in this future and is consulted inline after delivery is journaled. Prns allocates no policy table or per-packet decision state; capture a shared handle to application state when proof policy must change at runtime.

pub async fn run_with_interface_store<const INTERFACES: usize, const PACKET_PHY_CAPACITY: usize, const PACKET_PHY_INDEX_BUCKETS: usize>( self, store: &EmbassyInterfaceStore<M, INTERFACES, PACKET_PHY_CAPACITY, PACKET_PHY_INDEX_BUCKETS>, drive: impl Future<Output = ()>, )

where M: Sync,

pub async fn run_with_interface_store_and_proof_decider<P, const INTERFACES: usize, const PACKET_PHY_CAPACITY: usize, const PACKET_PHY_INDEX_BUCKETS: usize>( self, store: &EmbassyInterfaceStore<M, INTERFACES, PACKET_PHY_CAPACITY, PACKET_PHY_INDEX_BUCKETS>, should_prove: P, drive: impl Future<Output = ()>, )

where M: Sync, P: FnMut(&ProofRequest<'_>) -> bool,

pub async fn run_manifold(&mut self)

Runs only the manifold for boards that schedule interfaces separately.

pub async fn run_manifold_with_proof_decider<P>(&mut self, should_prove: P)

where P: FnMut(&ProofRequest<'_>) -> bool,

Runs only the manifold with a synchronous application proof decision.

pub async fn run_manifold_with_interface_store<const INTERFACES: usize, const PACKET_PHY_CAPACITY: usize, const PACKET_PHY_INDEX_BUCKETS: usize>( &mut self, store: &EmbassyInterfaceStore<M, INTERFACES, PACKET_PHY_CAPACITY, PACKET_PHY_INDEX_BUCKETS>, )

where M: Sync,

pub async fn run_manifold_with_interface_store_and_proof_decider<P, const INTERFACES: usize, const PACKET_PHY_CAPACITY: usize, const PACKET_PHY_INDEX_BUCKETS: usize>( &mut self, store: &EmbassyInterfaceStore<M, INTERFACES, PACKET_PHY_CAPACITY, PACKET_PHY_INDEX_BUCKETS>, should_prove: P, )

where M: Sync, P: FnMut(&ProofRequest<'_>) -> bool,

pub async fn run_manifold_with_persistence_and_interface_store<Fl, Keys, Observe, const PENDING: usize, const INTERFACES: usize, const PACKET_PHY_CAPACITY: usize, const PACKET_PHY_INDEX_BUCKETS: usize>( &mut self, store: &EmbassyInterfaceStore<M, INTERFACES, PACKET_PHY_CAPACITY, PACKET_PHY_INDEX_BUCKETS>, persistence: &mut EmbeddedFlashPersistence<Fl, Keys, Observe, PENDING>, )

where M: Sync, Fl: NorFlash, Keys: RouteSnapshotKeys, Observe: FnMut(EmbeddedPersistenceDiagnostic),

pub async fn run_manifold_with_persistence_and_interface_store_and_proof_decider<Fl, Keys, Observe, Decide, const PENDING: usize, const INTERFACES: usize, const PACKET_PHY_CAPACITY: usize, const PACKET_PHY_INDEX_BUCKETS: usize>( &mut self, store: &EmbassyInterfaceStore<M, INTERFACES, PACKET_PHY_CAPACITY, PACKET_PHY_INDEX_BUCKETS>, persistence: &mut EmbeddedFlashPersistence<Fl, Keys, Observe, PENDING>, should_prove: Decide, )

where M: Sync, Fl: NorFlash, Keys: RouteSnapshotKeys, Observe: FnMut(EmbeddedPersistenceDiagnostic), Decide: FnMut(&ProofRequest<'_>) -> bool,

pub async fn restore_embedded_persistence<Fl, Keys, Observe, const PENDING: usize>( &mut self, persistence: &mut EmbeddedFlashPersistence<Fl, Keys, Observe, PENDING>, ) -> EmbeddedPersistenceRestoreReport

where Fl: NorFlash, Keys: RouteSnapshotKeys, Observe: FnMut(EmbeddedPersistenceDiagnostic), H: ResumableHost,