aboutsummaryrefslogtreecommitdiffstats
path: root/log_db/src/log_reader_forward.rs
diff options
context:
space:
mode:
authorJan Tuomi <jan@jantuomi.fi>2025-02-21 14:25:15 +0200
committerJan Tuomi <jan@jantuomi.fi>2025-02-21 14:28:00 +0200
commit147c589ce617c1d500c3b698321eeb71bacd74a3 (patch)
treeb5cc3041ad5043bf1228634c1cf8ca933a6c8d54 /log_db/src/log_reader_forward.rs
parentbea37e2834a5265035b960277ff27e5f8d74d079 (diff)
Rename Record -> Row
Diffstat (limited to 'log_db/src/log_reader_forward.rs')
-rw-r--r--log_db/src/log_reader_forward.rs10
1 files changed, 5 insertions, 5 deletions
diff --git a/log_db/src/log_reader_forward.rs b/log_db/src/log_reader_forward.rs
index 66b0b47..f3fc16c 100644
--- a/log_db/src/log_reader_forward.rs
+++ b/log_db/src/log_reader_forward.rs
@@ -6,7 +6,7 @@ pub struct ForwardLogReader {
}
pub struct ForwardLogReaderItem {
- pub record: Record,
+ pub row: Row,
pub index: u64,
}
@@ -74,8 +74,8 @@ impl ForwardLogReader {
let mut result_buf = vec![0; entry_length as usize];
self.data_reader.read_exact(&mut result_buf)?;
- let record = Record::deserialize(&result_buf);
- return Ok(Some(ForwardLogReaderItem { record, index }));
+ let row = Row::deserialize(&result_buf);
+ return Ok(Some(ForwardLogReaderItem { row, index }));
}
}
}
@@ -121,10 +121,10 @@ mod tests {
// There are two records in the log with "schema" with one field: Bytes
- let first_record = forward_log_reader
+ let ForwardLogReaderItem { row, index: _ } = forward_log_reader
.next()
.expect("Failed to read the first record");
- assert!(match &first_record.record.values[..] {
+ assert!(match &row.values[..] {
[Value::Bytes(bytes)] => bytes.len() == 256,
_ => false,
});