Struct LivePostBundleManager 

pub struct LivePostBundleManager { /* private fields */ }

The production PostBundleManager implementation — the one that actually talks to the network.

LivePostBundleManager is the glue between the pure-logic timeline code and the live network. Each lookup:

1. Checks ClientStorage under BUCKET_POST_BUNDLE for a sufficiently fresh cached copy (freshness is governed by CLIENT_POST_BUNDLE_CACHE_DURATION).
2. Otherwise joins (or starts) a background walk of GetPostBundleV1 RPCs against the closest peers in the PeerTracker, attributing PoW to the locally-held sponsor_id.
3. Returns the walk’s first authoritative bundle (get_post_bundle) or its settled best bundle (get_post_bundle_settled). The walk itself carries on to cache, heal and upload — see crate::client::post_bundle::post_bundle_healing.

Concurrent requests for the same bundle share one walk via InflightPostBundleFetches, so a burst of timeline scrolls cannot fan out into redundant RPCs. The crate::client::caching::cache_radius_tracker::CacheRadiusTracker helps the caching role of a server decide how widely to mirror bundles.

Implementations

impl LivePostBundleManager

pub fn new( runtime_services: Arc<RuntimeServices>, sponsor_id: Id, client_storage: Arc<dyn ClientStorage>, peer_tracker: SharedPeerTracker, ) -> Self

Trait Implementations

impl PostBundleManager for LivePostBundleManager

fn get_post_bundle<'life0, 'life1, 'async_trait>( &'life0 self, bucket_location: &'life1 BucketLocation, time_millis: TimeMillis, ) -> Pin<Box<dyn Future<Output = Result<EncodedPostBundleV1>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The bundle for this bucket, as soon as one is good enough to show. An implementation may answer with a provisional bundle (e.g. the first authoritative reply) while it keeps reconciling in the background, so the posts or overflowed flag may be incomplete. Use this for display; use Self::get_post_bundle_settled when a decision depends on the bundle being complete.

fn get_post_bundle_settled<'life0, 'life1, 'async_trait>( &'life0 self, bucket_location: &'life1 BucketLocation, time_millis: TimeMillis, ) -> Pin<Box<dyn Future<Output = Result<EncodedPostBundleV1>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

The bundle once it has fully settled (e.g. best-of-several-servers). Implementations that never answer provisionally can rely on this default.