Skip to main content

Module mesh_store_core

Module mesh_store_core 

Source
Expand description

Shared routed mesh store core.

This module provides a concrete store wrapper that works with any local storage backend plus any signaling transport and peer-link factory. Both production and simulation (mocks) use this same code.

Structs§

DataPumpStats
Aggregate stats from draining currently available peer-link messages.
MeshRoutingConfig
Routing policy for request ordering + dispatch fanout.
MeshStoreCore
Routed mesh store core that works with any storage backend and transport implementation.
PubsubEvent
Pubsub data delivered to a local subscription.
PubsubPublishStats
Send-side accounting from a pubsub publish or forwarded pubsub message.
RequestDispatchConfig
Request dispatch strategy for peer queries.
ResponseBehaviorConfig
Response behavior profile for simulation/game-theory actors.
VerifiedBlockDelivery
Evidence that this peer won an outstanding, hash-verified block request.
VerifiedBlockDeliveryBatch
One atomic drain of verified delivery evidence and any overflow since the prior drain.

Enums§

HedgedWaveAction
Outcome returned after waiting on a hedged dispatch wave.
PubsubDeliveryMode
Production pubsub delivery strategy.

Functions§

build_hedged_wave_plan
Build wave sizes for staged hedged dispatch.
normalize_dispatch_config
Normalize fanout config against current peer availability.
run_hedged_waves
Run a staged hedged dispatch over peer index ranges.
sync_selector_peers
Keep selector membership aligned with currently connected peer IDs.

Type Aliases§

SimMeshStore
Type alias for simulation store.