aboutsummaryrefslogtreecommitdiffstats
path: root/log_db/src/lib.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/lib.rs
parentbea37e2834a5265035b960277ff27e5f8d74d079 (diff)
Rename Record -> Row
Diffstat (limited to 'log_db/src/lib.rs')
-rw-r--r--log_db/src/lib.rs18
1 files changed, 9 insertions, 9 deletions
diff --git a/log_db/src/lib.rs b/log_db/src/lib.rs
index fddb344..b7229fe 100644
--- a/log_db/src/lib.rs
+++ b/log_db/src/lib.rs
@@ -23,7 +23,7 @@ mod lock;
mod log_reader_forward;
mod memtable_primary;
mod memtable_secondary;
-mod record;
+mod row;
pub use common::{DBError, DBResult, OwnedBounds, QueryParams, Value, DEFAULT_QUERY_PARAMS};
pub use config::{ReadConsistency, Schema, WriteDurability};
@@ -35,7 +35,7 @@ use lock::*;
use log_reader_forward::*;
use memtable_primary::PrimaryMemtable;
use memtable_secondary::SecondaryMemtable;
-use record::*;
+use row::*;
pub struct DB<T> {
engine: Engine<T>,
@@ -55,11 +55,11 @@ impl<T> DB<T> {
/// Insert a record into the database. If the primary key value already exists,
/// the existing record will be replaced by the supplied one.
pub fn upsert(&mut self, recordable: T) -> DBResult<()> {
- let record = Record::from(&(self.engine.config.into_record)(recordable));
- debug!("Upserting record: {:?}", record);
+ let row = Row::from(&(self.engine.config.into_record)(recordable));
+ debug!("Upserting record: {:?}", row);
self.engine
- .with_exclusive_lock(move |engine| engine.upsert_record(record))?;
+ .with_exclusive_lock(move |engine| engine.upsert_record(row))?;
Ok(())
}
@@ -67,7 +67,7 @@ impl<T> DB<T> {
/// Get a record by its primary index value.
/// E.g. `db.get(Value::Int(10))`.
pub fn get(&mut self, value: &Value) -> DBResult<Option<T>> {
- let recs = self.engine.with_shared_lock(|engine| {
+ let tagged_rows = self.engine.with_shared_lock(|engine| {
engine.batch_find_by_records(
// TODO: This clone is only here to appease the borrow checker
&engine.config.primary_key.clone(),
@@ -76,12 +76,12 @@ impl<T> DB<T> {
)
})?;
- assert!(recs.len() <= 1);
+ assert!(tagged_rows.len() <= 1);
- Ok(recs
+ Ok(tagged_rows
.into_iter()
.next()
- .map(|(_, rec)| (self.engine.config.from_record)(rec.values)))
+ .map(|(_, row)| (self.engine.config.from_record)(row.values)))
}
/// Get a collection of records based on an indexed field value.