Struct PostBundleCache 

pub struct PostBundleCache { /* private fields */ }

Intermediate-server cache for EncodedPostBundleV1 data.

Two Moka caches:

• bundles: weighted Cache<Id, Arc<Mutex<CachedPostBundleLocationEntry>>> with TTI. If a location_id hasn’t been queried within CACHE_LOCATION_TTI, the entire entry is evicted. Individual bundles within an entry may also be stale (live bundles have a per-bundle expires_at; sealed bundles are never individually stale).
• inflight: Cache<Id, ()> with 30-second TTL — tracks locations for which a CacheRequestToken has been issued but the client hasn’t uploaded yet.

Implementations

impl PostBundleCache

pub fn new( max_originators_per_location: usize, max_bytes: u64, time_provider: Arc<dyn TimeProvider>, ) -> Self

pub fn on_get( &self, bucket_location: &BucketLocation, already_retrieved_peer_ids: &[Id], peer_self: &Peer, server_id: &ServerId, now: TimeMillis, ) -> GetCacheResult

Called by the dispatch handler when serving a GetPostBundleV1 request.

• bucket_location — used as the cache key (location_id) and included in any token issued.
• already_retrieved_peer_ids — originator IDs the client already has; filtered out of cached_items.
• peer_self / server_id — used to sign the CacheRequestToken if one is issued.
• now — current time.

pub fn on_upload( &self, location_id: Id, originator_peer_id: Id, bundle_bytes: Bytes, bundle_time_millis: TimeMillis, server_time: TimeMillis, is_sealed: bool, ) -> bool

Called by the dispatch handler when a CachePostBundleV1 upload arrives. The token must have been verified and expiry-checked by the caller. bundle_time_millis is the bundle’s signed header.time_millis: an upload older than the bundle already cached for the same originator is rejected (newest wins). There is deliberately no flat age limit - old sealed bundles are fine. Returns true if accepted, false if the entry was evicted before the upload arrived, the upload is older than the cached bundle for this originator, or it lost the per-location capacity eviction.