pub struct IncrementalUpdateManager { /* private fields */ }Expand description
Incremental update manager
Implementations§
Source§impl IncrementalUpdateManager
impl IncrementalUpdateManager
Sourcepub fn register(
&self,
entity_id: String,
version: u64,
full_data: Option<Bytes>,
) -> Result<()>
pub fn register( &self, entity_id: String, version: u64, full_data: Option<Bytes>, ) -> Result<()>
Register an entity for incremental updates
Sourcepub fn add_delta(&self, entity_id: &str, delta: UpdateDelta) -> Result<()>
pub fn add_delta(&self, entity_id: &str, delta: UpdateDelta) -> Result<()>
Add a delta for an entity
Sourcepub fn get_update(
&self,
entity_id: &str,
client_version: u64,
) -> Option<UpdateResponse>
pub fn get_update( &self, entity_id: &str, client_version: u64, ) -> Option<UpdateResponse>
Get full data or delta for an entity
Sourcepub fn remove(&self, entity_id: &str) -> Option<IncrementalUpdate>
pub fn remove(&self, entity_id: &str) -> Option<IncrementalUpdate>
Remove an entity
Sourcepub fn entity_count(&self) -> usize
pub fn entity_count(&self) -> usize
Get entity count
Sourcepub fn total_delta_count(&self) -> usize
pub fn total_delta_count(&self) -> usize
Get total delta count
Sourcepub fn stats(&self) -> IncrementalUpdateStats
pub fn stats(&self) -> IncrementalUpdateStats
Get statistics
Trait Implementations§
Auto Trait Implementations§
impl Freeze for IncrementalUpdateManager
impl !RefUnwindSafe for IncrementalUpdateManager
impl Send for IncrementalUpdateManager
impl Sync for IncrementalUpdateManager
impl Unpin for IncrementalUpdateManager
impl UnsafeUnpin for IncrementalUpdateManager
impl !UnwindSafe for IncrementalUpdateManager
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