pub struct DeltaCounters {
pub updates: u64,
pub supersteps: u64,
}Expand description
Delta tracking counters for a channel
Tracks incremental changes since the last complete snapshot,
enabling efficient DeltaChannel optimization.
Fields§
§updates: u64Number of updates since last snapshot
supersteps: u64Number of supersteps since last snapshot
Implementations§
Source§impl DeltaCounters
impl DeltaCounters
Sourcepub const fn new() -> DeltaCounters
pub const fn new() -> DeltaCounters
Create a new delta counter with zero values.
Sourcepub fn exceeds_frequency(&self, snapshot_frequency: usize) -> bool
pub fn exceeds_frequency(&self, snapshot_frequency: usize) -> bool
Check if this channel’s update count exceeds the given snapshot frequency.
Returns true when a full snapshot should be taken instead of a delta.
A frequency of zero is treated as “always snapshot” (snapshot on every write).
Trait Implementations§
Source§impl Clone for DeltaCounters
impl Clone for DeltaCounters
Source§fn clone(&self) -> DeltaCounters
fn clone(&self) -> DeltaCounters
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · 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 DeltaCounters
impl Debug for DeltaCounters
Source§impl Default for DeltaCounters
impl Default for DeltaCounters
Source§fn default() -> DeltaCounters
fn default() -> DeltaCounters
Returns the “default value” for a type. Read more
Source§impl<'de> Deserialize<'de> for DeltaCounters
impl<'de> Deserialize<'de> for DeltaCounters
Source§fn deserialize<__D>(
__deserializer: __D,
) -> Result<DeltaCounters, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(
__deserializer: __D,
) -> Result<DeltaCounters, <__D as Deserializer<'de>>::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl Serialize for DeltaCounters
impl Serialize for DeltaCounters
Source§fn serialize<__S>(
&self,
__serializer: __S,
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
fn serialize<__S>(
&self,
__serializer: __S,
) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>where
__S: Serializer,
Serialize this value into the given Serde serializer. Read more
Auto Trait Implementations§
impl Freeze for DeltaCounters
impl RefUnwindSafe for DeltaCounters
impl Send for DeltaCounters
impl Sync for DeltaCounters
impl Unpin for DeltaCounters
impl UnsafeUnpin for DeltaCounters
impl UnwindSafe for DeltaCounters
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