(
&self,
tid: TenantId,
collection: &str,
purge_lsn: u64,
)
| 261 | } |
| 262 | |
| 263 | pub fn append_collection_tombstone( |
| 264 | &self, |
| 265 | tid: TenantId, |
| 266 | collection: &str, |
| 267 | purge_lsn: u64, |
| 268 | ) -> crate::Result<Lsn> { |
| 269 | let payload = nodedb_wal::CollectionTombstonePayload::new(collection, purge_lsn) |
| 270 | .to_bytes() |
| 271 | .map_err(crate::Error::Wal)?; |
| 272 | self.append_record( |
| 273 | RecordType::CollectionTombstoned, |
| 274 | tid, |
| 275 | VShardId::new(0), |
| 276 | DatabaseId::DEFAULT, |
| 277 | &payload, |
| 278 | ) |
| 279 | } |
| 280 | } |
no test coverage detected