MCPcopy Create free account
hub / github.com/clockworklabs/SpacetimeDB / remove_segment

Method remove_segment

crates/commitlog/src/repo/fs.rs:314–322  ·  view source on GitHub ↗
(&self, offset: u64)

Source from the content-addressed store, hash-verified

312 }
313
314 fn remove_segment(&self, offset: u64) -> io::Result<()> {
315 let _ = self.remove_offset_index(offset).map_err(|e| {
316 warn!(
317 "repo {}: failed to remove offset index for segment {}: {}",
318 self, offset, e
319 );
320 });
321 fs::remove_file(self.segment_path(offset))
322 }
323
324 fn compress_segment_with(&self, offset: u64, f: impl CompressOnce) -> io::Result<CompressionStats> {
325 let src = self.open_segment_reader(offset)?;

Callers 4

openMethod · 0.45
resetMethod · 0.45
reset_to_internalFunction · 0.45
create_segmentFunction · 0.45

Calls 2

segment_pathMethod · 0.80
remove_offset_indexMethod · 0.45

Tested by

no test coverage detected