This is an automated email from the ASF dual-hosted git repository. hubcio pushed a commit to branch feat/message-bus-transports in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 0574d68a12a3de186f26faf92cbd249e9492fe3a Author: Hubert Gruszecki <[email protected]> AuthorDate: Fri Apr 24 14:41:57 2026 +0200 docs(message_bus): demote broken intra-doc links to code spans `LABEL_REPLICA`, `LABEL_CLIENT`, `handshake_verify`, and `TcpTransportWriter::send_batch` were not in rustdoc scope at their reference sites, triggering broken-link warnings. Downgrade to plain code spans. No behavior change. --- core/message_bus/src/auth.rs | 4 ++-- core/message_bus/src/replica_listener.rs | 2 +- core/message_bus/src/transports/tcp.rs | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/core/message_bus/src/auth.rs b/core/message_bus/src/auth.rs index dd90b18d2..2fc2819f9 100644 --- a/core/message_bus/src/auth.rs +++ b/core/message_bus/src/auth.rs @@ -101,8 +101,8 @@ impl AuthKind { /// All fields come from the header (`GenericHeader.cluster`, /// `GenericHeader.replica`, `GenericHeader.release`) plus the envelope /// timestamp and nonce. `label` is the plane-tagged domain-separation -/// prefix; pick [`LABEL_REPLICA`] for the consensus plane and -/// [`LABEL_CLIENT`] for the SDK-client plane (Phase 2). +/// prefix; pick `LABEL_REPLICA` for the consensus plane and +/// `LABEL_CLIENT` for the SDK-client plane (Phase 2). #[derive(Debug, Clone, Copy, PartialEq, Eq)] pub struct AuthChallenge { pub cluster: u128, diff --git a/core/message_bus/src/replica_listener.rs b/core/message_bus/src/replica_listener.rs index 6a0789369..db35362be 100644 --- a/core/message_bus/src/replica_listener.rs +++ b/core/message_bus/src/replica_listener.rs @@ -117,7 +117,7 @@ pub async fn bind(addr: SocketAddr) -> Result<(TcpListener, SocketAddr), IggyErr /// `nonces` is the bus-resident per-peer nonce dedup store. The listener /// reaches into it via `borrow_mut().entry(peer).or_default()` for each /// handshake; the borrow is held only across the synchronous -/// [`handshake_verify`], never across an `await`, so the `RefCell` is +/// `handshake_verify`, never across an `await`, so the `RefCell` is /// safe under the single-threaded compio runtime. #[allow(clippy::future_not_send)] #[allow(clippy::too_many_arguments)] diff --git a/core/message_bus/src/transports/tcp.rs b/core/message_bus/src/transports/tcp.rs index 79694b06d..5864c39e2 100644 --- a/core/message_bus/src/transports/tcp.rs +++ b/core/message_bus/src/transports/tcp.rs @@ -19,7 +19,7 @@ //! //! Behavior-preserving wrappers around `compio::net::TcpListener`, //! `compio::net::TcpStream`, and the split halves. The hot path on -//! [`TcpTransportWriter::send_batch`] is identical to +//! `TcpTransportWriter::send_batch` is identical to //! [`crate::writer_task::run`]'s inner `write_vectored_all` call: one //! syscall per batch, zero intermediate copies of `Frozen`. //!
