Expand description
Sync wire protocol: frame format and message types.
Frame format: [msg_type: 1B][length: 4B LE][rkyv/msgpack body]
Message types:
0x01Handshake (client → server)0x02HandshakeAck (server → client)0x10DeltaPush (client → server)0x11DeltaAck (server → client)0x12DeltaReject (server → client)0x14CollectionPurged (server → client)0x20ShapeSubscribe (client → server)0x21ShapeSnapshot (server → client)0x22ShapeDelta (server → client)0x23ShapeUnsubscribe (client → server)0x30VectorClockSync (bidirectional)0x40TimeseriesPush (client → server)0x41TimeseriesAck (server → client)0x50ResyncRequest (bidirectional)0x52Throttle (client → server)0x60TokenRefresh (client → server)0x61TokenRefreshAck (server → client)0x70DefinitionSync (server → client)0x80PresenceUpdate (client → server)0x81PresenceBroadcast (server → all subscribers)0x82PresenceLeave (server → all subscribers)0xFFPing/Pong (bidirectional)
Re-exports§
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 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 timeseries::DefinitionSyncMsg;pub use timeseries::TimeseriesAckMsg;pub use timeseries::TimeseriesPushMsg;
Modules§
- delta
- Delta push / ack / reject / collection-purged messages.
- frame
- Wire frame format and message-type discriminants.
- 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.
- timeseries
- Timeseries ingest + definition-sync messages.