diff options
| author | Jan Tuomi <jan@jantuomi.fi> | 2025-02-21 14:25:15 +0200 |
|---|---|---|
| committer | Jan Tuomi <jan@jantuomi.fi> | 2025-02-21 14:28:00 +0200 |
| commit | 147c589ce617c1d500c3b698321eeb71bacd74a3 (patch) | |
| tree | b5cc3041ad5043bf1228634c1cf8ca933a6c8d54 /log_db/src/log_reader_forward.rs | |
| parent | bea37e2834a5265035b960277ff27e5f8d74d079 (diff) | |
Rename Record -> Row
Diffstat (limited to 'log_db/src/log_reader_forward.rs')
| -rw-r--r-- | log_db/src/log_reader_forward.rs | 10 |
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, }); |
