Struct StatsDatabase 

pub struct StatsDatabase { /* private fields */ }

Implementations

impl StatsDatabase

pub fn open(path: impl AsRef<Path>) -> Result<Self>

Open (or create) the stats database at the given path.

Errors

Returns an error if the database cannot be opened or initialized.

pub fn record_upload( &self, bytes: u64, files: u64, folder: Option<&str>, peer: Option<&str>, network_id: Option<&str>, ) -> Result<()>

Record an upload bandwidth event.

Errors

Returns an error if the database write fails.

pub fn record_download( &self, bytes: u64, files: u64, folder: Option<&str>, peer: Option<&str>, network_id: Option<&str>, ) -> Result<()>

Record a download bandwidth event.

Errors

Returns an error if the database write fails.

pub fn record_transfer( &self, direction: &str, bytes: u64, files: u64, folder: Option<&str>, peer: Option<&str>, network_id: Option<&str>, ) -> Result<()>

Record a transfer (upload or download) bandwidth event.

Errors

Returns an error if the database write fails.

pub fn record_connection(&self, peer: &str) -> Result<()>

Record a connection event for the given peer.

Errors

Returns an error if the database write fails.

pub fn current_stats(&self) -> Result<BandwidthStats>

Return aggregated bandwidth statistics for the current period.

Errors

Returns an error if the database cannot be queried.

pub fn stats_since(&self, since_ts: i64) -> Result<BandwidthStats>

Return bandwidth statistics aggregated from transfer events recorded on or after since_ts. Unlike Self::current_stats, the folder/peer breakdowns are computed directly from bandwidth_events, so the window can be any timestamp (not just a persisted hourly period bucket).

Errors

Returns an error if the database cannot be queried.

pub fn network_events_after( &self, after_id: i64, limit: usize, ) -> Result<Vec<NetworkEventRecord>>

Return network events newer than after_id, ordered by id.

Errors

Returns an error if the database query fails.

pub fn sync_sessions_after( &self, after_id: i64, limit: usize, ) -> Result<Vec<SyncSessionRecord>>

Return sync sessions newer than after_id, ordered by id.

Errors

Returns an error if the database query fails.

pub fn reset_bandwidth(&self) -> Result<()>

Delete all persisted bandwidth counters and transfer events across every period, zeroing the totals reported by Self::current_stats.

Errors

Returns an error if the database operation fails.

pub fn append_log( &self, level: &str, module: Option<&str>, message: &str, ) -> Result<()>

Append a daemon log entry.

Errors

Returns an error if the database write fails.

pub fn purge_old_bandwidth(&self, older_than: Duration) -> Result<usize>

Delete bandwidth events older than the given duration.

Errors

Returns an error if the database operation fails.

pub fn record_network_event( &self, network_id: &str, event_type: &str, peer: Option<&str>, details: Option<&str>, metadata_json: Option<&str>, ) -> Result<()>

Record a network event.

Errors

Returns an error if the database write fails.

pub fn record_sync_session_start( &self, network_id: &str, folder_namespace: &str, ) -> Result<i64>

Record a sync session start and return its session ID.

Errors

Returns an error if the database write fails.

pub fn record_sync_session_finish( &self, session_id: i64, files: u64, bytes: u64, errors: u64, status: &str, ) -> Result<()>

Record a sync session finish.

Errors

Returns an error if the database write fails.

pub fn record_relay_check( &self, relay_url: &str, connected: bool, latency_ms: Option<i64>, error_message: Option<&str>, ) -> Result<()>

Record a relay health check.

Errors

Returns an error if the database write fails.

pub fn recent_network_events( &self, network_id: &str, limit: usize, ) -> Result<Vec<NetworkEventRecord>>

Query recent network events for a given network.

Errors

Returns an error if the database query fails.

pub fn recent_sync_sessions( &self, network_id: &str, limit: usize, ) -> Result<Vec<SyncSessionRecord>>

Query recent sync sessions for a given network.

Errors

Returns an error if the database query fails.

pub fn relay_uptime(&self, relay_url: &str, window_secs: i64) -> Result<f64>

Calculate relay uptime as a ratio (0.0-1.0) over the given time window.

Errors

Returns an error if the database query fails.

pub fn vacuum(&self) -> Result<()>

Run VACUUM to reclaim space.

Errors

Returns an error if the database operation fails.

pub fn size_on_disk(&self) -> Result<u64>

Return estimated database size in bytes.

Errors

Returns an error if the file metadata cannot be read.

pub fn freelist_count(&self) -> Result<i64>

Return the freelist page count (indicates whether VACUUM would help).

Errors

Returns an error if the database operation fails.

pub fn check_integrity(&self) -> Result<Vec<String>>

Run integrity_check PRAGMA. Returns list of errors (empty = healthy).

Errors

Returns an error if the database operation fails.

pub fn purge_old_logs(&self, older_than: Duration) -> Result<usize>

Delete daemon log entries older than the given duration.

Errors

Returns an error if the database operation fails.

Trait Implementations

impl Clone for StatsDatabase

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StatsDatabase

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Vacuumable for StatsDatabase

fn vacuum(&self) -> Result<()>

Run VACUUM to reclaim space.

fn freelist_count(&self) -> Result<i64>

Return the freelist page count (indicates whether VACUUM would help).