nodedb_types/sync/wire/
mod.rs

1// SPDX-License-Identifier: Apache-2.0
2
3//! Sync wire protocol: frame format and message types.
4//!
5//! Frame format: `[msg_type: 1B][length: 4B LE][rkyv/msgpack body]`
6//!
7//! Message types:
8//! - `0x01` Handshake (client → server)
9//! - `0x02` HandshakeAck (server → client)
10//! - `0x10` DeltaPush (client → server)
11//! - `0x11` DeltaAck (server → client)
12//! - `0x12` DeltaReject (server → client)
13//! - `0x14` CollectionPurged (server → client)
14//! - `0x20` ShapeSubscribe (client → server)
15//! - `0x21` ShapeSnapshot (server → client)
16//! - `0x22` ShapeDelta (server → client)
17//! - `0x23` ShapeUnsubscribe (client → server)
18//! - `0x30` VectorClockSync (bidirectional)
19//! - `0x40` TimeseriesPush (client → server)
20//! - `0x41` TimeseriesAck (server → client)
21//! - `0x50` ResyncRequest (bidirectional)
22//! - `0x52` Throttle (client → server)
23//! - `0x60` TokenRefresh (client → server)
24//! - `0x61` TokenRefreshAck (server → client)
25//! - `0x70` DefinitionSync (server → client)
26//! - `0x80` PresenceUpdate (client → server)
27//! - `0x81` PresenceBroadcast (server → all subscribers)
28//! - `0x82` PresenceLeave (server → all subscribers)
29//! - `0x90` ArrayDelta (client → server)
30//! - `0x91` ArrayDeltaBatch (client → server)
31//! - `0x92` ArraySnapshot (server → client)
32//! - `0x93` ArraySnapshotChunk (server → client)
33//! - `0x94` ArraySchema (bidirectional)
34//! - `0x95` ArrayAck (client → server)
35//! - `0x96` ArrayReject (server → client)
36//! - `0x97` ArrayCatchupRequest (client → server)
37//! - `0xA0` ColumnarInsert (client → server)
38//! - `0xA1` ColumnarInsertAck (server → client)
39//! - `0xA2` VectorInsert (client → server)
40//! - `0xA3` VectorInsertAck (server → client)
41//! - `0xA4` VectorDelete (client → server)
42//! - `0xA5` VectorDeleteAck (server → client)
43//! - `0xA6` FtsIndex (client → server)
44//! - `0xA7` FtsIndexAck (server → client)
45//! - `0xA8` FtsDelete (client → server)
46//! - `0xA9` FtsDeleteAck (server → client)
47//! - `0xAA` SpatialInsert (client → server)
48//! - `0xAB` SpatialInsertAck (server → client)
49//! - `0xAC` SpatialDelete (client → server)
50//! - `0xAD` SpatialDeleteAck (server → client)
51//! - `0xFF` Ping/Pong (bidirectional)
52
53pub mod array;
54pub mod columnar;
55pub mod delta;
56pub mod frame;
57pub mod fts;
58pub mod presence;
59pub mod resync;
60pub mod session;
61pub mod shape;
62pub mod spatial;
63pub mod timeseries;
64pub mod vector;
65
66#[cfg(test)]
67mod tests;
68
69pub use array::{
70    ArrayAckMsg, ArrayCatchupRequestMsg, ArrayDeltaBatchMsg, ArrayDeltaMsg, ArrayRejectMsg,
71    ArrayRejectReason, ArraySchemaSyncMsg, ArraySnapshotChunkMsg, ArraySnapshotMsg,
72};
73pub use columnar::{ColumnarInsertAckMsg, ColumnarInsertMsg};
74pub use delta::{CollectionPurgedMsg, DeltaAckMsg, DeltaPushMsg, DeltaRejectMsg};
75pub use frame::{SyncFrame, SyncMessageType};
76pub use fts::{FtsDeleteAckMsg, FtsDeleteMsg, FtsIndexAckMsg, FtsIndexMsg};
77pub use presence::{PeerPresence, PresenceBroadcastMsg, PresenceLeaveMsg, PresenceUpdateMsg};
78pub use resync::{ResyncReason, ResyncRequestMsg, ThrottleMsg};
79pub use session::{
80    HandshakeAckMsg, HandshakeMsg, PingPongMsg, TokenRefreshAckMsg, TokenRefreshMsg,
81};
82pub use shape::{
83    ShapeDeltaMsg, ShapeSnapshotMsg, ShapeSubscribeMsg, ShapeUnsubscribeMsg, VectorClockSyncMsg,
84};
85pub use spatial::{SpatialDeleteAckMsg, SpatialDeleteMsg, SpatialInsertAckMsg, SpatialInsertMsg};
86pub use timeseries::{DefinitionSyncMsg, TimeseriesAckMsg, TimeseriesPushMsg};
87pub use vector::{VectorDeleteAckMsg, VectorDeleteMsg, VectorInsertAckMsg, VectorInsertMsg};
nodedb_types/sync/wire/mod.rs

nodedb_types/sync/wire/
mod.rs
