Move NO_SNAPSHOT to tests.

src/lib.rs

@@ -298,9 +298,3 @@ where
 }
 
 pub(crate) const HEARTBEAT_INTERVAL_MILLIS: u64 = 150;
-
-impl<C> Raft<C> {
-    /// Pass this function to [`Raft::new`] if the application will not accept
-    /// any request for taking snapshots.
-    pub const NO_SNAPSHOT: fn(Index) = |_| {};
-}

test_configs/src/raft/config.rs

@@ -10,7 +10,7 @@ use parking_lot::Mutex;
 use rand::{thread_rng, Rng};
 
 use crate::register_server;
-use crate::utils::sleep_millis;
+use crate::utils::{sleep_millis, NO_SNAPSHOT};
 use ruaft::{ApplyCommandMessage, Persister, Raft, Term};
 
 struct ConfigState {
@@ -319,7 +319,7 @@ impl Config {
                 Self::apply_command(log_clone.clone(), index, message)
             },
             None,
-            Raft::<i32>::NO_SNAPSHOT,
+            NO_SNAPSHOT,
         );
         self.state.lock().rafts[index].replace(raft.clone());
 

test_configs/src/rpcs.rs

@@ -224,7 +224,7 @@ mod tests {
                 Arc::new(DoNothingPersister),
                 |_: ApplyCommandMessage<i32>| {},
                 None,
-                Raft::<i32>::NO_SNAPSHOT,
+                crate::utils::NO_SNAPSHOT,
             ));
             register_server(raft, name, network.as_ref())?;
 

test_configs/src/utils.rs

@@ -8,3 +8,7 @@ pub const LONG_ELECTION_TIMEOUT_MILLIS: u64 = 1000;
 pub fn sleep_election_timeouts(count: u64) {
     sleep_millis(LONG_ELECTION_TIMEOUT_MILLIS * count)
 }
+
+/// Pass this function to [`Raft::new`] if the application will not accept
+/// any request for taking snapshots.
+pub const NO_SNAPSHOT: fn(ruaft::Index) = |_| {};