aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2025-12-27 13:04:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

core/mvcc/logical-log: rename Insert and Delete -> InsertRow and DeleteRow in LogRecordType

Browse Source
This commit is contained in:
Pere Diaz Bou
2025-09-22 13:21:54 +02:00
parent db326affc6
commit 4cc88ee2bb
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
core/mvcc/persistent_storage/logical_log.rs
View File

@@ -43,24 +43,24 @@ impl LogHeader {
#[repr(u8)]
#[derive(Debug, Clone, Copy, PartialEq)]
enum LogRecordType {
Delete = 0,
Insert = 1,
DeleteRow = 0,
InsertRow = 1,
}
impl LogRecordType {
fn from_row_version(row_version: &RowVersion) -> Self {
if row_version.end.is_some() {
Self::Delete
Self::DeleteRow
} else {
Self::Insert
Self::InsertRow
}
}
#[allow(dead_code)]
fn from_u8(value: u8) -> Option<Self> {
match value {
0 => Some(LogRecordType::Delete),
1 => Some(LogRecordType::Insert),
0 => Some(LogRecordType::DeleteRow),
1 => Some(LogRecordType::InsertRow),
_ => None,
}
}
@@ -91,10 +91,10 @@ impl LogRecordType {
buffer.extend_from_slice(&self.as_u8().to_be_bytes());
let size_before_payload = buffer.len();
match self {
LogRecordType::Delete => {
LogRecordType::DeleteRow => {
write_varint_to_vec(row_version.row.id.row_id as u64, buffer);
}
LogRecordType::Insert => {
LogRecordType::InsertRow => {
write_varint_to_vec(row_version.row.id.row_id as u64, buffer);
let data = &row_version.row.data;