(seq: u64, partition: u32, lsn: u64)
| 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 |