Skip to content

Commit 01aef13

Browse files
committed
cluster: fix log message on leadership change to be more readable
1 parent 29aca00 commit 01aef13

2 files changed

Lines changed: 8 additions & 4 deletions

File tree

src/core/cluster/background.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -167,7 +167,7 @@ async fn leadership_changes(handle: RaftState) -> tokio::sync::broadcast::Receiv
167167
|m| {
168168
let mut l = last_leader.lock().unwrap();
169169
if m.current_leader != *l {
170-
tracing::debug!(old_leader = ?l, new_leader = ?m, "leader has changed");
170+
tracing::debug!(old_leader = ?l, new_leader = ?m.current_leader, "leader has changed");
171171
*l = m.current_leader;
172172
if tx.send(m.current_leader).is_err() {
173173
return true;

src/core/cluster/node.rs

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -88,9 +88,7 @@ impl Node {
8888
}
8989
}
9090

91-
#[derive(
92-
Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Default, Hash, Serialize, Deserialize,
93-
)]
91+
#[derive(Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Default, Hash, Serialize, Deserialize)]
9492
#[serde(transparent)]
9593
pub struct NodeId {
9694
#[serde(with = "uuid::serde::simple")]
@@ -111,6 +109,12 @@ impl JsonSchema for NodeId {
111109
}
112110
}
113111

112+
impl std::fmt::Debug for NodeId {
113+
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
114+
write!(f, "NodeId({})", self.inner.simple())
115+
}
116+
}
117+
114118
impl std::fmt::Display for NodeId {
115119
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
116120
self.inner.simple().fmt(f)

0 commit comments

Comments
 (0)