Expand description
Framework primitives bundled into every RuntimeResourceRef.
9 framework primitives the engine bundles into the
RuntimeResourceRef for every dispatch_atomic call per
docs/ENGINE.md §10 + docs/internal/IMPLEMENTATION_PLAN.md //! lines 770-779.
ships real impls for Scheduler / PeerGate / RequestTracker + adds 3 new primitives (serialize_queue / hold_table / record_buffer). Other primitives stay minimal until
Re-exports§
pub use address_book::Address;pub use address_book::AddressBook;pub use address_book::AddressBookError;pub use address_book::AddressError;pub use address_book::Multiaddress;pub use address_book::Protocol;pub use backoff_table::BackoffTable;pub use backpressure_notice::backoff_notice_type_hash;pub use backpressure_notice::build_backoff_notice_envelope;pub use backpressure_notice::BackoffCauseWire;pub use backpressure_notice::BackoffNoticePayload;pub use backpressure_notice::BACKPRESSURE_DOMAIN;pub use backpressure_tracker::BackoffCause;pub use backpressure_tracker::BackpressureEntry;pub use backpressure_tracker::BackpressureTracker;pub use backpressure_tracker::Decision as BackpressureDecision;pub use backpressure_tracker::DEFAULT_HIGH_WATER_PCT;pub use backpressure_tracker::DEFAULT_K_BEFORE_SILENT;pub use backpressure_tracker::DEFAULT_MIN_NOTICE_INTERVAL_NS;pub use event_source::EventSource;pub use hold_table::HoldTable;pub use inbound_dedup::InboundDedup;pub use outbound_queue::OutboundQueue;pub use peer_gate::PeerGate;pub use peer_governor::BlockReason;pub use peer_governor::Decision;pub use peer_governor::LifecycleTransition;pub use peer_governor::PeerGovernor;pub use peer_governor::PeerHealth;pub use peer_governor::DEFAULT_FAILURE_THRESHOLD;pub use peer_state::PeerState;pub use record_buffer::RecordBuffer;pub use request_tracker::RequestTracker;pub use rng::CounterRng;pub use rng::GetrandomU64;pub use rng::RngU64Source;pub use scheduler::Scheduler;pub use scheduler::TimerKind;pub use serialize_queue::SerializeQueue;
Modules§
- address_
book AddressBook- globalPeerId → (Vec<Address>, ref_count)registry perENGINE.md§10.5 +docs/ADDRESSING.md.- backoff_
table BackoffTable- per-peer exponential backoff state used by wire syscalls + transport adapters per ENGINE.md §10.2.- backpressure_
notice BackoffNoticePayload- typed wire payload for the backpressure protocol perdocs/internal/superpowers/specs/2026-06-23-backpressure-runtime.md§2.- backpressure_
tracker BackpressureTracker- per-peer receiver-side state for the typed-overload-signal protocol perdocs/internal/superpowers/specs/2026-06-23-backpressure-runtime.md.- event_
source EventSource- registeredevent_kind → ComponentTagsubscription table consulted by the engine’s Phase 3 bus event routing per ENGINE.md §10.7.- hold_
table HoldTable- slot-named value buffer forHold.Stash/Hold.Flushsyscalls.- inbound_
dedup InboundDedup- sliding-window seen-message tracker per ENGINE.md §10.4.- outbound_
queue OutboundQueue- FIFO of wire envelopes ready to ship.- peer_
gate PeerGate- per-name concurrency limiter used byLimit.Acquire/Limit.Releasesyscalls.- peer_
governor PeerGovernor- the single source of truth for peer policy and health tracking per .- peer_
state PeerState— the framework’s consolidated per-peer state.- record_
buffer RecordBuffer- bounded per-name ring buffer used by theRecordsyscall.- request_
tracker RequestTracker- mint correlation tokens forCorrelateTagand track in-flight wire requests.- rng
RngU64Source- pluggable u64 RNG used by theRngU64syscall op. Default impl wrapsgetrandom.- rtt_
tracker - for adaptive deadlines on every wire round-trip.
- scheduler
Scheduler- sorted timer heap.- serialize_
queue SerializeQueue- named-FIFO map forSerialize.Enqueue/Serialize.Dequeuesyscalls.
Structs§
- Framework
Components docs/ENGINE.md§3 bundle of framework primitives. Split-borrowed into eachdispatch_atomiccall’sRuntimeResourceRef.- Inbound
Context - Per-
ExecIdcontext captured at inbound envelope delivery. Replaces the four parallelenvelope_*HashMaps with one struct of optional fields. Components access this throughRuntimeResourceRef::inbound.