Struct StubPostBundleManager 

pub struct StubPostBundleManager { /* private fields */ }

Implementations

impl StubPostBundleManager

pub fn add_random_stub_post_bundle( &self, id: &Id, granularity: DurationMillis, epoch_offset_str: &str, num_posts: u8, ) -> Result<EncodedPostBundleV1>

pub fn add_stub_post_bundle( &self, id: &Id, granularity: DurationMillis, epoch_offset_str: &str, post_bundle: &EncodedPostBundleV1, ) -> Result<()>

pub fn requested_location_ids(&self) -> Vec<Id>

Every location_id passed to get_post_bundle, in request order.

Trait Implementations

impl Default for StubPostBundleManager

fn default() -> Self

Returns the “default value” for a type.

impl PostBundleManager for StubPostBundleManager

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.