Module wire 

Sync wire protocol: frame format and message types.

Frame format: [msg_type: 1B][length: 4B LE][rkyv/msgpack body]

Message types:

• 0x01 Handshake (client → server)
• 0x02 HandshakeAck (server → client)
• 0x10 DeltaPush (client → server)
• 0x11 DeltaAck (server → client)
• 0x12 DeltaReject (server → client)
• 0x14 CollectionPurged (server → client)
• 0x20 ShapeSubscribe (client → server)
• 0x21 ShapeSnapshot (server → client)
• 0x22 ShapeDelta (server → client)
• 0x23 ShapeUnsubscribe (client → server)
• 0x30 VectorClockSync (bidirectional)
• 0x40 TimeseriesPush (client → server)
• 0x41 TimeseriesAck (server → client)
• 0x50 ResyncRequest (bidirectional)
• 0x52 Throttle (client → server)
• 0x60 TokenRefresh (client → server)
• 0x61 TokenRefreshAck (server → client)
• 0x70 DefinitionSync (server → client)
• 0x80 PresenceUpdate (client → server)
• 0x81 PresenceBroadcast (server → all subscribers)
• 0x82 PresenceLeave (server → all subscribers)
• 0x90 ArrayDelta (client → server)
• 0x91 ArrayDeltaBatch (client → server)
• 0x92 ArraySnapshot (server → client)
• 0x93 ArraySnapshotChunk (server → client)
• 0x94 ArraySchema (bidirectional)
• 0x95 ArrayAck (client → server)
• 0x96 ArrayReject (server → client)
• 0x97 ArrayCatchupRequest (client → server)
• 0xA0 ColumnarInsert (client → server)
• 0xA1 ColumnarInsertAck (server → client)
• 0xA2 VectorInsert (client → server)
• 0xA3 VectorInsertAck (server → client)
• 0xA4 VectorDelete (client → server)
• 0xA5 VectorDeleteAck (server → client)
• 0xA6 FtsIndex (client → server)
• 0xA7 FtsIndexAck (server → client)
• 0xA8 FtsDelete (client → server)
• 0xA9 FtsDeleteAck (server → client)
• 0xAA SpatialInsert (client → server)
• 0xAB SpatialInsertAck (server → client)
• 0xAC SpatialDelete (client → server)
• 0xAD SpatialDeleteAck (server → client)
• 0xFF Ping/Pong (bidirectional)

Re-exports

pub use array::ArrayAckMsg;

pub use array::ArrayCatchupRequestMsg;

pub use array::ArrayDeltaBatchMsg;

pub use array::ArrayDeltaMsg;

pub use array::ArrayRejectMsg;

pub use array::ArrayRejectReason;

pub use array::ArraySchemaSyncMsg;

pub use array::ArraySnapshotChunkMsg;

pub use array::ArraySnapshotMsg;

pub use columnar::ColumnarInsertAckMsg;

pub use columnar::ColumnarInsertMsg;

pub use delta::CollectionPurgedMsg;

pub use delta::DeltaAckMsg;

pub use delta::DeltaPushMsg;

pub use delta::DeltaRejectMsg;

pub use frame::SyncFrame;

pub use frame::SyncMessageType;

pub use fts::FtsDeleteAckMsg;

pub use fts::FtsDeleteMsg;

pub use fts::FtsIndexAckMsg;

pub use fts::FtsIndexMsg;

pub use presence::PeerPresence;

pub use presence::PresenceBroadcastMsg;

pub use presence::PresenceLeaveMsg;

pub use presence::PresenceUpdateMsg;

pub use resync::ResyncReason;

pub use resync::ResyncRequestMsg;

pub use resync::ThrottleMsg;

pub use session::HandshakeAckMsg;

pub use session::HandshakeMsg;

pub use session::PingPongMsg;

pub use session::TokenRefreshAckMsg;

pub use session::TokenRefreshMsg;

pub use shape::ShapeDeltaMsg;

pub use shape::ShapeSnapshotMsg;

pub use shape::ShapeSubscribeMsg;

pub use shape::ShapeUnsubscribeMsg;

pub use shape::VectorClockSyncMsg;

pub use spatial::SpatialDeleteAckMsg;

pub use spatial::SpatialDeleteMsg;

pub use spatial::SpatialInsertAckMsg;

pub use spatial::SpatialInsertMsg;

pub use timeseries::DefinitionSyncMsg;

pub use timeseries::TimeseriesAckMsg;

pub use timeseries::TimeseriesPushMsg;

pub use vector::VectorDeleteAckMsg;

pub use vector::VectorDeleteMsg;

pub use vector::VectorInsertAckMsg;

pub use vector::VectorInsertMsg;

Modules

array

Array CRDT sync wire envelopes.

columnar

Columnar insert sync messages (client → server / server → client).

delta

Delta push / ack / reject / collection-purged messages.

frame

Wire frame format and message-type discriminants.

fts

FTS index/delete sync messages (client → server / server → client).

presence

Presence / awareness messages.

resync

Re-sync request and throttle messages.

session

Session lifecycle messages: handshake, token refresh, keepalive.

shape

Shape subscribe/snapshot/delta/unsubscribe + vector clock sync messages.

spatial

Spatial insert/delete sync messages (client → server / server → client).

timeseries

Timeseries ingest + definition-sync messages.

vector

Vector insert/delete sync messages (client → server / server → client).