Struct SyncMetrics 

pub struct SyncMetrics {
    pub deltas_pushed: AtomicU64,
    pub deltas_received: AtomicU64,
    pub deltas_rejected: AtomicU64,
    pub reconnect_count: AtomicU64,
    pub last_sync_ts: AtomicU64,
    pub checksum_failures: AtomicU64,
    pub conflicts_total: AtomicU64,
    pub clock_skew_warnings: AtomicU64,
    pub stale_timeouts: AtomicU64,
    /* private fields */
}

Sync metrics — atomic counters for lock-free concurrent access.

Fields

deltas_pushed: AtomicU64

deltas_received: AtomicU64

deltas_rejected: AtomicU64

reconnect_count: AtomicU64

last_sync_ts: AtomicU64

checksum_failures: AtomicU64

conflicts_total: AtomicU64

Total conflict-related rejections (UNIQUE, FK, schema violations).

clock_skew_warnings: AtomicU64

Clock-skew warnings received from Origin on DeltaAck.

stale_timeouts: AtomicU64

In-flight entries evicted by stale-timeout (lifetime).

Implementations

impl SyncMetrics

pub fn new() -> Self

pub fn record_stale_timeouts(&self, count: u64)

Record stale in-flight evictions (from cleanup_stale).

pub fn record_clock_skew_warning(&self)

Record a clock-skew warning reported by Origin in a DeltaAck.

pub fn record_push(&self, count: u64)

pub fn record_received(&self)

pub fn record_reject(&self)

pub fn record_reconnect(&self)

pub fn record_checksum_failure(&self)

pub fn record_conflict(&self, collection: &str)

Record a conflict (constraint-related rejection) for a collection.

pub fn conflicts_by_collection(&self) -> HashMap<String, u64>

Get per-collection conflict counts snapshot.

Trait Implementations

impl Default for SyncMetrics

fn default() -> Self

Returns the “default value” for a type.