Struct DurableRetentionService 

pub struct DurableRetentionService { /* private fields */ }

Background task that prunes terminal executions on a fixed interval.

Spawn DurableRetentionService::run on a supervised task (alongside the JournalWriter). It owns no write path of its own — it calls Journal::prune on the shared backend, which performs the batched delete off the hot path.

Implementations

impl DurableRetentionService

pub fn new(backend: Arc<DurableBackendEnum>, policy: RetentionPolicy) -> Self

Build the service from the shared backend and the configured retention policy.

Examples

use std::sync::Arc;
use zeph_durable::{DurableBackendEnum, DurableRetentionService, LocalBackend, RetentionPolicy};

let backend = Arc::new(DurableBackendEnum::Local(Arc::new(
    LocalBackend::open("durable.db", 1_048_576).await?,
)));
let service = DurableRetentionService::new(backend, RetentionPolicy::default());
let task = tokio::spawn(service.run());

pub async fn run(self)

Run the prune loop until the task is aborted.

Each tick first runs the crash-orphan sweep (#6254), then prunes terminal executions older than their TTL — in that order, so a just-aborted orphan is visible to the same tick’s TTL check (INV-17, M3). A sweep or prune failure is logged and the loop continues (a transient database error must not kill retention).

Trait Implementations

impl Debug for DurableRetentionService

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

Formats the value using the given formatter.