Function run_tier_cycle_at

nodedb/src/control/cold_tier.rs:76–171

Run one tiering cycle against the given segments directory. Uploads eligible segment files (older than `tier_after`) to the cold store under `{prefix}segments/{filename}`, then removes the local copies.

(
    cold: &crate::storage::cold::ColdStorage,
    segments_dir: &std::path::Path,
    tier_after: Duration,
    prefix: &str,
)

/// Uploads eligible segment files (older than `tier_after`) to the cold store
/// under `{prefix}segments/{filename}`, then removes the local copies.
pub(crate) async fn run_tier_cycle_at(
    cold: &crate::storage::cold::ColdStorage,
    segments_dir: &std::path::Path,
    tier_after: Duration,
    prefix: &str,
) {
    let now = SystemTime::now();

    let entries = match read_dir_sync(segments_dir).await {
        Ok(e) => e,
        Err(e) => {
            warn!(
                error = %e,
                dir = %segments_dir.display(),
                "cold tier: failed to read segments directory"
            );
            return;
        }
    };

    let mut tiered: u64 = 0;
    let mut errors: u64 = 0;

    for entry_path in entries {
        let age = match file_age(&entry_path, now) {
            Some(a) => a,
            None => {
                debug!(path = %entry_path.display(), "cold tier: skipping entry (mtime unavailable)");
                continue;
            }
        };

        if age < tier_after {
            debug!(
                path = %entry_path.display(),
                age_secs = age.as_secs(),
                "cold tier: segment too recent, skipping"
            );
            continue;
        }

        let segment_name = match entry_path.file_name().and_then(|n| n.to_str()) {
            Some(n) => n.to_owned(),
            None => {
                warn!(path = %entry_path.display(), "cold tier: invalid segment filename, skipping");
                continue;
            }
        };

        let object_path = format!("{}segments/{}", prefix, segment_name);
        let entry_path_clone = entry_path.clone();

        match upload_raw_segment(cold, &entry_path_clone, &object_path).await {
            Ok(()) => {
                info!(
                    segment = %segment_name,
                    object_path = %object_path,
                    age_secs = age.as_secs(),