pub fn boundary_watermark(
position: Position,
boundary: Option<u64>,
) -> WatermarkExpand description
Build a standalone scan-frontier Watermark. cursor_cp / position
are the boundary cursor coordinates the caller has already resolved for
its scan domain (see boundary_cursor_cp for the per-checkpoint
scanners’ direction adjustment); boundary is the accumulated
completion boundary.