Module sync 

Re-exports

pub use constants::PUSH_DRAIN_LIMIT;

pub use array::KvOpLogStore;

pub use client::SyncClient;

pub use client::SyncConfig;

pub use client::SyncState;

pub use clock::VectorClock;

pub use compensation::CompensationEvent;

pub use compensation::CompensationHandler;

pub use compensation::CompensationRegistry;

pub use delegate::SyncDelegate;

pub use flow_control::FlowControlConfig;

pub use flow_control::FlowController;

pub use flow_control::SyncMetrics;

pub use flow_control::SyncMetricsSnapshot;

pub use outbound::ColumnarOutbound;

pub use outbound::DurableOutboundQueue;

pub use outbound::FtsOutbound;

pub use outbound::KvOutbound;

pub use outbound::PendingColumnarBatch;

pub use outbound::PendingFtsDelete;

pub use outbound::PendingFtsIndex;

pub use outbound::PendingKvOp;

pub use outbound::PendingKvWrite;

pub use outbound::PendingSpatialDelete;

pub use outbound::PendingSpatialInsert;

pub use outbound::PendingTimeseriesBatch;

pub use outbound::PendingVectorDelete;

pub use outbound::PendingVectorInsert;

pub use outbound::SpatialOutbound;

pub use outbound::TimeseriesOutbound;

pub use outbound::VectorOutbound;

pub use shapes::ShapeManager;

pub use stream_seq::StreamSeqTracker;

pub use transport::run_sync_loop;

Modules

array

Array CRDT synchronization for NodeDB-Lite.

client

WebSocket sync client for edge ↔ Origin communication.

clock

Vector clock for sync handshake and delta tracking.

compensation

Compensation handling for rejected sync deltas.

constants

Sync-layer constants shared across push and drain paths.

delegate

SyncDelegate — the callback interface the transport uses to read pending work from the owning NodeDbLite and to apply inbound state changes.

flow_control

Flow control, adaptive batching, and sync metrics.

outbound

shapes

Shape subscription management on the edge side.

stream_seq

Per-stream monotonic sequence frontier — durable state for outbound frame stamping and inbound ack tracking.

transport

WebSocket transport — the runtime side of Lite ↔ Origin sync.