pub struct MemoryEpisodeBuilder { /* private fields */ }Expand description
Bounded collector for a MemoryEpisode.
Records are retained only after all three limits have been checked. Call
MemoryEpisodeBuilder::finish to sort them into the episode’s stable
timestamp/topic order.
Implementations§
Source§impl MemoryEpisodeBuilder
impl MemoryEpisodeBuilder
Sourcepub fn try_new(limits: EpisodeLimits) -> SyncResult<Self>
pub fn try_new(limits: EpisodeLimits) -> SyncResult<Self>
Creates an empty builder with validated hard limits.
Sourcepub fn push(&mut self, stamped: StampedRecord) -> SyncResult<()>
pub fn push(&mut self, stamped: StampedRecord) -> SyncResult<()>
Adds one stamped record if all configured limits remain satisfied.
Sourcepub const fn limits(&self) -> EpisodeLimits
pub const fn limits(&self) -> EpisodeLimits
Returns the hard limits used by this builder.
Sourcepub fn finish(self) -> MemoryEpisode
pub fn finish(self) -> MemoryEpisode
Finishes the bounded collection as a deterministic in-memory episode.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for MemoryEpisodeBuilder
impl RefUnwindSafe for MemoryEpisodeBuilder
impl Send for MemoryEpisodeBuilder
impl Sync for MemoryEpisodeBuilder
impl Unpin for MemoryEpisodeBuilder
impl UnsafeUnpin for MemoryEpisodeBuilder
impl UnwindSafe for MemoryEpisodeBuilder
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more