hashiverse_lib::client::post_bundle::live_post_bundle_manager

Struct LivePostBundleManager

pub struct LivePostBundleManager { /* private fields */ }

Expand description

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 get_post_bundle call:

Checks ClientStorage under BUCKET_POST_BUNDLE for a sufficiently fresh cached copy (freshness is governed by CLIENT_POST_BUNDLE_CACHE_DURATION).
Falls back to a GetPostBundleV1 RPC against the closest peers in the PeerTracker, attributing PoW to the locally-held sponsor_id.
Initiates post-bundle healing when the bundle has gaps — see crate::client::post_bundle::post_bundle_healing.

Concurrent requests for the same bundle are de-duplicated via post_bundle_inflight 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.

LivePostBundleManager

Struct LivePostBundleManager Copy item path

Implementations§

impl LivePostBundleManager

pub fn new( runtime_services: Arc<RuntimeServices>, sponsor_id: Id, client_storage: Arc<dyn ClientStorage>, peer_tracker: Arc<RwLock<PeerTracker>>, ) -> 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,

Auto Trait Implementations§

impl !Freeze for LivePostBundleManager

impl !RefUnwindSafe for LivePostBundleManager

impl Send for LivePostBundleManager

impl Sync for LivePostBundleManager

impl Unpin for LivePostBundleManager

impl UnsafeUnpin for LivePostBundleManager

impl !UnwindSafe for LivePostBundleManager

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct 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,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,