MCPcopy Create free account
hub / github.com/NodeDB-Lab/nodedb / scan_from

Method scan_from

nodedb-array/src/sync/op_log.rs:86–97  ·  view source on GitHub ↗
(&'a self, from: Hlc)

Source from the content-addressed store, hash-verified

84 }
85
86 fn scan_from<'a>(&'a self, from: Hlc) -> ArrayResult<OpIter<'a>> {
87 let guard = self.lock()?;
88 let results: Vec<ArrayOp> = guard
89 .iter()
90 .filter(|((_, hlc_bytes), _)| {
91 let hlc = Hlc::from_bytes(hlc_bytes);
92 hlc >= from
93 })
94 .map(|(_, op)| op.clone())
95 .collect();
96 Ok(Box::new(results.into_iter().map(Ok)))
97 }
98
99 fn scan_range<'a>(&'a self, array: &str, from: Hlc, to: Hlc) -> ArrayResult<OpIter<'a>> {
100 let guard = self.lock()?;

Callers 3

collapse_belowFunction · 0.45
append_then_scanFunction · 0.45
scan_from_skips_belowFunction · 0.45

Calls 4

lockMethod · 0.80
collectMethod · 0.80
iterMethod · 0.45
cloneMethod · 0.45

Tested by 2

append_then_scanFunction · 0.36
scan_from_skips_belowFunction · 0.36