Method append_temporal_purge

nodedb/src/wal/manager/append.rs:171–194

Append a `CollectionTombstoned` record. Any subsequent replay that extracts this record will filter prior writes for `(tid, collection)` whose LSN is less than `purge_lsn`. `vshard_id` of `0` is conventional — tombstones are tenant-level metadata, not sharded user data. Replay filters on `(tenant_id, collection)` pair alone. Append a `TemporalPurge` audit record. Emitted by the Control Plane's bi

(
        &self,
        tid: TenantId,
        engine: nodedb_wal::TemporalPurgeEngine,
        collection: &str,
        cutoff_system_ms: i64,
        purged_count: u64,
    )

    /// `vshard_id` is `0` — bitemporal audit-purge is collection-scoped
    /// metadata, not sharded user data.
    pub fn append_temporal_purge(
        &self,
        tid: TenantId,
        engine: nodedb_wal::TemporalPurgeEngine,
        collection: &str,
        cutoff_system_ms: i64,
        purged_count: u64,
    ) -> crate::Result<Lsn> {
        let payload = nodedb_wal::TemporalPurgePayload::new(
            engine,
            collection,
            cutoff_system_ms,
            purged_count,
        )
        .to_bytes()
        .map_err(crate::Error::Wal)?;
        self.append_record(
            RecordType::TemporalPurge,
            tid,
            VShardId::new(0),
            DatabaseId::DEFAULT,
            &payload,
        )
    }

    /// Append a `SurrogateAlloc` high-watermark record. Emitted by
    /// `SurrogateRegistry::flush` (every 1024 allocations or 200 ms,