diff --git a/wal/src/blocking/writer.rs b/wal/src/blocking/writer.rs index 44cd15454d..810c0d5650 100644 --- a/wal/src/blocking/writer.rs +++ b/wal/src/blocking/writer.rs @@ -87,9 +87,10 @@ impl OpenSegmentFileWriter { self.bytes_written += bytes_written; Ok(WriteSummary { - checksum, total_bytes: self.bytes_written, bytes_written, + segment_id: self.id, + checksum, }) } diff --git a/wal/src/lib.rs b/wal/src/lib.rs index 997e89039b..738e485638 100644 --- a/wal/src/lib.rs +++ b/wal/src/lib.rs @@ -378,6 +378,8 @@ pub struct WriteSummary { pub total_bytes: usize, /// Number of bytes written to segment in this write pub bytes_written: usize, + /// Which segment file this entry was written to + pub segment_id: SegmentId, /// Checksum for the compressed data written to segment checksum: u32, }