This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a commit to branch durable-offset-watermark
in repository https://gitbox.apache.org/repos/asf/iggy.git
The following commit(s) were added to refs/heads/durable-offset-watermark by
this push:
new f3e6246bf fix(partitions): keep the offset reservation helpers
lint-clean
f3e6246bf is described below
commit f3e6246bf18fb4d459613b2c868222fd8f29c727
Author: Krishna Vishal <[email protected]>
AuthorDate: Thu Aug 27 18:36:42 2026 +0530
fix(partitions): keep the offset reservation helpers lint-clean
`restore_offset_frontier` is public, so its intra-doc link to the
private `mint_floor` is a hard rustdoc error under `-D warnings`. It
failed the pre-merge Rust lane before clippy, machete or any test job
got a runner, hiding two more denials behind it: the lease default
widened with an `as` cast, and `armed_mint_floor` reads only Copy
state, so both trip the pedantic set.
---
core/partitions/src/iggy_partition.rs | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/core/partitions/src/iggy_partition.rs
b/core/partitions/src/iggy_partition.rs
index 518443a45..7c1420624 100644
--- a/core/partitions/src/iggy_partition.rs
+++ b/core/partitions/src/iggy_partition.rs
@@ -503,7 +503,7 @@ where
purge_deferred: false,
durable_offset_frontier: Cell::new(0),
durable_offset_reserved: Cell::new(0),
- offset_reservation_lease:
iggy_common::DEFAULT_OFFSET_RESERVATION_LEASE as u64,
+ offset_reservation_lease:
u64::from(iggy_common::DEFAULT_OFFSET_RESERVATION_LEASE),
mint_floor_pending: Cell::new(false),
transfer: None,
transfer_attempts: 0,
@@ -844,7 +844,7 @@ where
/// nothing, it re-stamps what the primary sends and rejects anything that
/// does not continue its own counter, so seeding from a ceiling would put
it
/// a lease block above its group and fork its chain. Applied at the point
of
- /// MINTING instead: see [`Self::mint_floor`].
+ /// MINTING instead: see `Self::mint_floor`.
///
/// Lives HERE rather than in the server crate so the boot paths and the
/// simulator share one implementation. A copy in the harness was a copy of
@@ -1096,7 +1096,7 @@ where
/// [`Self::mint_floor`] without spending it, for the boot re-anchor, which
/// has to know where the first mint will land before there is one.
- fn armed_mint_floor(&self) -> u64 {
+ const fn armed_mint_floor(&self) -> u64 {
if self.consensus.replica_count() > 1 ||
!self.mint_floor_pending.get() {
return 0;
}
