pub struct PersistedChangeBatch { /* private fields */ }Expand description
Change batch persisted before its following cursor becomes active.
Implementations§
Source§impl PersistedChangeBatch
impl PersistedChangeBatch
Sourcepub const fn new(
id: ChangeBatchId,
scope: CloudScope,
base_cursor: Option<ChangeCursor>,
batch: ChangeBatch,
) -> Self
pub const fn new( id: ChangeBatchId, scope: CloudScope, base_cursor: Option<ChangeCursor>, batch: ChangeBatch, ) -> Self
Creates the first durable form of a fetched change batch.
Sourcepub const fn id(&self) -> &ChangeBatchId
pub const fn id(&self) -> &ChangeBatchId
Returns the batch identity.
Sourcepub const fn scope(&self) -> &CloudScope
pub const fn scope(&self) -> &CloudScope
Returns the namespace/root checkpoint scope.
Sourcepub const fn base_cursor(&self) -> Option<&ChangeCursor>
pub const fn base_cursor(&self) -> Option<&ChangeCursor>
Returns the active cursor from which this batch was fetched.
Sourcepub const fn batch(&self) -> &ChangeBatch
pub const fn batch(&self) -> &ChangeBatch
Returns the durable backend batch.
Sourcepub const fn state(&self) -> PersistedChangeBatchState
pub const fn state(&self) -> PersistedChangeBatchState
Returns whether replay prerequisites are durable.
Sourcepub fn mark_effects_replayable(&mut self) -> bool
pub fn mark_effects_replayable(&mut self) -> bool
Marks the batch effects replayable. The operation is idempotent.
Trait Implementations§
Source§impl Clone for PersistedChangeBatch
impl Clone for PersistedChangeBatch
Source§fn clone(&self) -> PersistedChangeBatch
fn clone(&self) -> PersistedChangeBatch
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for PersistedChangeBatch
impl Debug for PersistedChangeBatch
Source§impl PartialEq for PersistedChangeBatch
impl PartialEq for PersistedChangeBatch
impl Eq for PersistedChangeBatch
impl StructuralPartialEq for PersistedChangeBatch
Auto Trait Implementations§
impl Freeze for PersistedChangeBatch
impl RefUnwindSafe for PersistedChangeBatch
impl Send for PersistedChangeBatch
impl Sync for PersistedChangeBatch
impl Unpin for PersistedChangeBatch
impl UnwindSafe for PersistedChangeBatch
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