Function enforcement_loop

nodedb/src/engine/bitemporal/enforcement.rs:58–85

(
    state: Arc<SharedState>,
    registry: Arc<BitemporalRetentionRegistry>,
    mut shutdown: watch::Receiver<bool>,
    tick: Duration,
)

}

async fn enforcement_loop(
    state: Arc<SharedState>,
    registry: Arc<BitemporalRetentionRegistry>,
    mut shutdown: watch::Receiver<bool>,
    tick: Duration,
) {
    tokio::time::sleep(Duration::from_secs(STARTUP_DELAY_SECS)).await;

    loop {
        tokio::select! {
            _ = tokio::time::sleep(tick) => {}
            _ = shutdown.changed() => {
                if *shutdown.borrow() {
                    info!("bitemporal retention loop shutting down");
                    return;
                }
            }
        }

        let entries = registry.snapshot();
        if entries.is_empty() {
            continue;
        }
        for entry in entries {
            run_one(&state, &entry).await;
        }
    }
}

async fn run_one(state: &Arc<SharedState>, entry: &Entry) {
    let audit_ms = entry.retention.audit_retain_ms;