oxirs-fuseki 0.2.4

SPARQL 1.1/1.2 HTTP protocol server with Fuseki-compatible configuration
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

//! # Store - cleanup_old_changes_group Methods
//!
//! This module contains method implementations for `Store`.
//!
//! 🤖 Generated with [SplitRS](https://github.com/cool-japan/splitrs)

use super::*;
use std::collections::{HashMap, HashSet};

impl Store {
    /// Clear old changes from the log
    pub async fn cleanup_old_changes(
        &self,
        older_than: chrono::DateTime<chrono::Utc>,
    ) -> FusekiResult<usize> {
        let mut metadata = self.metadata.write().map_err(|e| {
            FusekiError::store(format!("Failed to acquire metadata write lock: {e}"))
        })?;
        let initial_count = metadata.change_log.len();
        metadata
            .change_log
            .retain(|change| change.timestamp > older_than);
        let removed_count = initial_count - metadata.change_log.len();
        if removed_count > 0 {
            debug!("Cleaned up {} old change log entries", removed_count);
        }
        Ok(removed_count)
    }
}