MCPcopy Create free account
hub / github.com/clockworklabs/SpacetimeDB / commits_from

Method commits_from

crates/commitlog/src/commitlog.rs:203–216  ·  view source on GitHub ↗
(&self, offset: u64)

Source from the content-addressed store, hash-verified

201 }
202
203 pub fn commits_from(&self, offset: u64) -> Commits<R> {
204 let offsets = self.segment_offsets_from(offset);
205 let segments = Segments {
206 offs: offsets.into_iter(),
207 repo: self.repo.clone(),
208 max_log_format_version: self.opts.log_format_version,
209 };
210 Commits {
211 inner: None,
212 segments,
213 last_commit: CommitInfo::Initial { next_offset: offset },
214 last_error: None,
215 }
216 }
217
218 pub fn reset(mut self) -> io::Result<Self> {
219 info!("hard reset");

Calls 3

segment_offsets_fromMethod · 0.80
into_iterMethod · 0.45
cloneMethod · 0.45