Enum SyncMessageType 

#[non_exhaustive]
#[repr(u8)]
pub enum SyncMessageType {
    Handshake = 1,
    HandshakeAck = 2,
    DeltaPush = 16,
    DeltaAck = 17,
    DeltaReject = 18,
    CollectionPurged = 20,
    ShapeSubscribe = 32,
    ShapeSnapshot = 33,
    ShapeDelta = 34,
    ShapeUnsubscribe = 35,
    VectorClockSync = 48,
    TimeseriesPush = 64,
    TimeseriesAck = 65,
    ResyncRequest = 80,
    Throttle = 82,
    TokenRefresh = 96,
    TokenRefreshAck = 97,
    DefinitionSync = 112,
    PresenceUpdate = 128,
    PresenceBroadcast = 129,
    PresenceLeave = 130,
    ArrayDelta = 144,
    ArrayDeltaBatch = 145,
    ArraySnapshot = 146,
    ArraySnapshotChunk = 147,
    ArraySchema = 148,
    ArrayAck = 149,
    ArrayReject = 150,
    ArrayCatchupRequest = 151,
    PingPong = 255,
}

Sync message type identifiers.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Handshake = 1

HandshakeAck = 2

DeltaPush = 16

DeltaAck = 17

DeltaReject = 18

CollectionPurged = 20

Collection purged notification (server → client, 0x14). Sent when an Origin collection is hard-deleted (UNDROP window expired or explicit DROP COLLECTION ... PURGE). The client must drop local Loro state and remove the collection’s redb record; future deltas for the collection are not sync-eligible.

ShapeSubscribe = 32

ShapeSnapshot = 33

ShapeDelta = 34

ShapeUnsubscribe = 35

VectorClockSync = 48

TimeseriesPush = 64

Timeseries metric batch push (client → server, 0x40).

TimeseriesAck = 65

Timeseries push acknowledgment (server → client, 0x41).

ResyncRequest = 80

Re-sync request (bidirectional, 0x50). Sent when sequence gaps or checksum failures are detected.

Throttle = 82

Downstream throttle (client → server, 0x52). Sent when Lite’s incoming queue is overwhelmed.

TokenRefresh = 96

Token refresh request (client → server, 0x60).

TokenRefreshAck = 97

Token refresh acknowledgment (server → client, 0x61).

DefinitionSync = 112

Definition sync (server → client, 0x70). Carries function/trigger/procedure definitions from Origin to Lite.

PresenceUpdate = 128

Presence update (client → server, 0x80).

PresenceBroadcast = 129

Presence broadcast (server → all subscribers except sender, 0x81).

PresenceLeave = 130

Presence leave (server → all subscribers, 0x82).

ArrayDelta = 144

Array CRDT delta (single op, client → server, 0x90).

ArrayDeltaBatch = 145

Array CRDT delta batch (multiple ops, client → server, 0x91).

ArraySnapshot = 146

Array snapshot header (server → client, 0x92).

ArraySnapshotChunk = 147

Array snapshot chunk (server → client, 0x93).

ArraySchema = 148

Array schema CRDT sync (bidirectional, 0x94).

ArrayAck = 149

Array ack — advances GC frontier (client → server, 0x95).

ArrayReject = 150

Array reject (server → client, 0x96). Compensation hint.

ArrayCatchupRequest = 151

Array catchup request (client → server, 0x97).

PingPong = 255

Implementations

impl SyncMessageType

pub fn from_u8(v: u8) -> Option<Self>

Trait Implementations

impl Clone for SyncMessageType

fn clone(&self) -> SyncMessageType

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SyncMessageType

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for SyncMessageType

fn eq(&self, other: &SyncMessageType) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for SyncMessageType

impl Eq for SyncMessageType

impl StructuralPartialEq for SyncMessageType