The last transaction offset written to disk, or `None` if nothing has been written yet. Note that this does not imply durability: [`Self::sync`] may not have been called at this offset.
(&self)
| 162 | /// Note that this does not imply durability: [`Self::sync`] may not have |
| 163 | /// been called at this offset. |
| 164 | pub fn max_committed_offset(&self) -> Option<u64> { |
| 165 | // Naming is hard: the segment's `next_tx_offset` indicates how many |
| 166 | // txs are already in the log (it's the next commit's min-tx-offset). |
| 167 | // If the value is zero, however, the initial commit hasn't been |
| 168 | // committed yet. |
| 169 | self.head.next_tx_offset().checked_sub(1) |
| 170 | } |
| 171 | |
| 172 | /// The first transaction offset written to disk, or `None` if nothing has |
| 173 | /// been written yet. |
nothing calls this directly
no test coverage detected