Method open_segment_reader

crates/commitlog/src/repo/fs.rs:306–312

(&self, offset: u64)

    }

    fn open_segment_reader(&self, offset: u64) -> io::Result<Self::SegmentReader> {
        let path = self.segment_path(offset);
        debug!("fs: open segment at {}", path.display());
        let file = File::open(&path)?;
        let len = file.metadata()?.len();
        CompressReader::new(file).map(|inner| ReadOnlySegment { inner, len })
    }

    fn remove_segment(&self, offset: u64) -> io::Result<()> {
        let _ = self.remove_offset_index(offset).map_err(|e| {