Struct AtomicSyncStats 

pub struct AtomicSyncStats { /* private fields */ }

Thread-safe wrapper for SyncStats using atomic counters.

This is useful for concurrent harvesting where multiple tasks update statistics simultaneously without requiring a mutex.

Example

use ceres_core::sync::{AtomicSyncStats, SyncOutcome};

let stats = AtomicSyncStats::new();

// Can be safely called from multiple threads
stats.record(SyncOutcome::Created);
stats.record(SyncOutcome::Unchanged);

let snapshot = stats.to_stats();
assert_eq!(snapshot.created, 1);
assert_eq!(snapshot.unchanged, 1);

Implementations

impl AtomicSyncStats

pub fn new() -> Self

Creates a new zeroed stats tracker.

pub fn record(&self, outcome: SyncOutcome)

Records an outcome, incrementing the appropriate counter atomically.

pub fn to_stats(&self) -> SyncStats

Converts atomic counters to a snapshot SyncStats.

Trait Implementations

impl Default for AtomicSyncStats

fn default() -> Self

Returns the “default value” for a type.