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

Function make_event_on_partition

nodedb/src/event/cdc/buffer.rs:341–345  ·  view source on GitHub ↗
(seq: u64, partition: u32, lsn: u64)

Source from the content-addressed store, hash-verified

339 }
340
341 fn make_event_on_partition(seq: u64, partition: u32, lsn: u64) -> CdcEvent {
342 let mut e = make_event(seq, lsn);
343 e.partition = partition;
344 e
345 }
346
347 /// The `COMMIT OFFSETS` pgwire handler derives per-partition tail LSNs
348 /// by scanning `read_from_lsn(0, usize::MAX)`. After buffer eviction

Callers 1

Calls 1

make_eventFunction · 0.70

Tested by 1