mirrors/loro
1
0
Fork 0
mirror of https://github.com/loro-dev/loro.git synced 2025-02-02 02:59:51 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

pr: impl kv store

Browse source
This commit is contained in:
Zixuan Chen 2024-07-09 00:32:16 +08:00
parent f802ede4b9
commit 27daa08b77
No known key found for this signature in database
2 changed files with 25 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
crates/loro-internal/src/kv_store.rs
View file

@ -12,9 +12,14 @@ pub trait KvStore: std::fmt::Debug + Send + Sync {
&self,
start: Bound<&[u8]>,
end: Bound<&[u8]>,
) -> Box<dyn DoubleEndedIterator<Item = (Bytes, Bytes)>>;
) -> Box<dyn DoubleEndedIterator<Item = (Bytes, Bytes)> + '_>;
fn len(&self) -> usize;
fn size(&self) -> usize;
/// Performs a binary search over the keys in the store.
///
/// The comparator function should return an order code that indicates
/// whether its argument is `Less`, `Equal` or `Greater` the desired
/// target.
fn binary_search_by(
&self,
start: Bound<&[u8]>,
@ -73,8 +78,11 @@ mod mem {
&self,
start: Bound<&[u8]>,
end: Bound<&[u8]>,
) -> Box<dyn DoubleEndedIterator<Item = (Bytes, Bytes)>> {
todo!()
) -> Box<dyn DoubleEndedIterator<Item = (Bytes, Bytes)> + '_> {
Box::new(
self.range::<[u8], _>((start, end))
.map(|(k, v)| (k.clone(), v.clone())),
)
}
fn len(&self) -> usize {
@ -97,9 +105,17 @@ mod mem {
&self,
start: Bound<&[u8]>,
end: Bound<&[u8]>,
f: Box<dyn FnMut(&Bytes, &Bytes) -> std::cmp::Ordering>,
mut f: Box<dyn FnMut(&Bytes, &Bytes) -> std::cmp::Ordering>,
) -> Option<(Bytes, Bytes)> {
todo!()
for (k, v) in self.range::<[u8], _>((start, end)) {
match f(k, v) {
std::cmp::Ordering::Equal => return Some((k.clone(), v.clone())),
std::cmp::Ordering::Less => continue,
std::cmp::Ordering::Greater => break,
}
}
None
}
}
}

5
crates/loro-internal/src/oplog/change_store.rs
View file

@ -165,7 +165,10 @@ impl ChangeStore {
}
let store = self.external_kv.lock().unwrap();
let mut iter = store.scan(std::ops::Bound::Unbounded, Bound::Included(&id.to_bytes()));
let mut iter = store.scan(
std::ops::Bound::Unbounded,
Bound::Included(&Bytes::copy_from_slice(&id.to_bytes())),
);
let (b_id, b_bytes) = iter.next_back()?;
let block_id: ID = ID::from_bytes(&b_id[..]);
let block = ChangesBlock::from_bytes(b_bytes, true).unwrap();