change: rename RaftStorage::create_snapshot() to RaftStorage::begin_r…

…eceiving_snapshot

async-raft/src/core/install_snapshot.rs

@@ -111,7 +111,8 @@ impl<D: AppData, R: AppDataResponse, N: RaftNetwork<D>, S: RaftStorage<D, R>> Ra
         }
 
         // Create a new snapshot and begin writing its contents.
-        let mut snapshot = self.storage.create_snapshot().await.map_err(|err| self.map_fatal_storage_error(err))?;
+        let mut snapshot =
+            self.storage.begin_receiving_snapshot().await.map_err(|err| self.map_fatal_storage_error(err))?;
         snapshot.as_mut().write_all(&req.data).await?;
 
         // If this was a small snapshot, and it is already done, then finish up.

async-raft/src/storage.rs

@@ -218,12 +218,14 @@ where
 
     /// Create a new blank snapshot, returning a writable handle to the snapshot object.
     ///
+    /// Raft will use this handle to receive snapshot data.
+    ///
     /// ### implementation guide
     /// See the [storage chapter of the guide](https://async-raft.github.io/async-raft/storage.html)
     /// for details on log compaction / snapshotting.
     ///
     /// Errors returned from this method will cause Raft to go into shutdown.
-    async fn create_snapshot(&self) -> Result<Box<Self::SnapshotData>>;
+    async fn begin_receiving_snapshot(&self) -> Result<Box<Self::SnapshotData>>;
 
     /// Finalize the installation of a snapshot which has finished streaming from the cluster leader.
     ///

memstore/src/lib.rs

@@ -397,7 +397,7 @@ impl RaftStorage<ClientRequest, ClientResponse> for MemStore {
     }
 
     #[tracing::instrument(level = "trace", skip(self))]
-    async fn create_snapshot(&self) -> Result<Box<Self::SnapshotData>> {
+    async fn begin_receiving_snapshot(&self) -> Result<Box<Self::SnapshotData>> {
         Ok(Box::new(Cursor::new(Vec::new())))
     }