in below/src/main.rs [399:423]
fn cleanup_store(
store: &store::StoreWriter,
logger: &slog::Logger,
store_size_limit: Option<u64>,
retention: Option<Duration>,
) -> Result<()> {
if let Some(limit) = store_size_limit {
if !store
.try_discard_until_size(limit)
.context("Failed to discard earlier data")?
{
warn!(
logger,
"Failed to limit store size since the current shard is \
greater than the limit"
);
}
}
if let Some(retention) = retention {
store
.discard_earlier(SystemTime::now() - retention)
.context("Failed to discard earlier data")?;
}
Ok(())
}