diff --git a/src/traft/mod.rs b/src/traft/mod.rs index ac5346f1f695b202013f014624af7ab7455374c6..108275b2f8ee254778783985458f8aec632f7c91 100644 --- a/src/traft/mod.rs +++ b/src/traft/mod.rs @@ -676,9 +676,9 @@ impl<'a> std::fmt::Display for EntryPayload<'a> { const fn change_type(ct: raft::ConfChangeType) -> &'static str { match ct { - raft::ConfChangeType::AddNode => "Promote", - raft::ConfChangeType::AddLearnerNode => "Demote", - raft::ConfChangeType::RemoveNode => "Remove", + raft::ConfChangeType::AddNode => "AddNode", + raft::ConfChangeType::AddLearnerNode => "AddLearnerNode", + raft::ConfChangeType::RemoveNode => "RemoveNode", } } } diff --git a/test/int/test_basics.py b/test/int/test_basics.py index b83db73668716bcf097d86eda2fd112441c754d5..048f3ac66a236257ea70652bbd57dc5aec84ecdf 100644 --- a/test/int/test_basics.py +++ b/test/int/test_basics.py @@ -220,7 +220,7 @@ def test_raft_log(instance: Instance): | 1 | 1 |1.0.1|PersistPeer(i1, 1, r1, 127.0.0.1:{p}, Offline(0), 1, {b})| | 2 | 1 |1.0.2|Insert(cluster_state, ["replication_factor",1])| | 3 | 1 |1.0.3|Insert(cluster_state, ["desired_schema_version",0])| -| 4 | 1 | |Promote(1)| +| 4 | 1 | |AddNode(1)| | 5 | 2 | |-| | 6 | 2 |1.1.2|PersistPeer(i1, 1, r1, 127.0.0.1:{p}, Offline(0) -> Online(1), 6, {b})| | 7 | 2 |1.1.3|PersistPeer(i1, 1, r1, 127.0.0.1:{p}, RaftSynced(1) -> Online(1), 7, {b})|