pub struct ResyncRequestMsg {
pub reason: ResyncReason,
pub from_mutation_id: u64,
pub collection: String,
}Expand description
Re-sync request message (bidirectional, 0x50).
Sent when a receiver detects:
- Sequence gap: missing
mutation_ids in the delta stream - Checksum failure: CRC32C mismatch on a delta payload
- State divergence: local state inconsistent with received deltas
On receiving a ResyncRequest, the sender should:
- Re-send all deltas from
from_mutation_idonwards, OR - Send a full snapshot if
from_mutation_idis 0
Fields§
§reason: ResyncReasonReason for requesting re-sync.
from_mutation_id: u64Resume from this mutation ID (0 = full re-sync).
collection: StringCollection scope (empty = all collections).
Trait Implementations§
Source§impl Clone for ResyncRequestMsg
impl Clone for ResyncRequestMsg
Source§fn clone(&self) -> ResyncRequestMsg
fn clone(&self) -> ResyncRequestMsg
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 ResyncRequestMsg
impl Debug for ResyncRequestMsg
Source§impl<'de> Deserialize<'de> for ResyncRequestMsg
impl<'de> Deserialize<'de> for ResyncRequestMsg
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl<'__msgpack_de> FromMessagePack<'__msgpack_de> for ResyncRequestMsg
impl<'__msgpack_de> FromMessagePack<'__msgpack_de> for ResyncRequestMsg
Source§impl Serialize for ResyncRequestMsg
impl Serialize for ResyncRequestMsg
Auto Trait Implementations§
impl Freeze for ResyncRequestMsg
impl RefUnwindSafe for ResyncRequestMsg
impl Send for ResyncRequestMsg
impl Sync for ResyncRequestMsg
impl Unpin for ResyncRequestMsg
impl UnsafeUnpin for ResyncRequestMsg
impl UnwindSafe for ResyncRequestMsg
Blanket Implementations§
Source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
Source§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
Source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
Source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Returns the layout of the type.
Source§impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
Source§unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool
Returns whether the given value has been niched. Read more
Source§fn resolve_niched(out: Place<NichedOption<T, N1>>)
fn resolve_niched(out: Place<NichedOption<T, N1>>)
Writes data to
out indicating that a T is niched.