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) -> 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, 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. Returns true if accepted, false if the entry was evicted before the upload arrived.