Merge #136

136: Rename update status "pending" into "enqueued" r=curquiza a=curquiza

Closes #107 

Co-authored-by: Clémentine Urquizar <clementine@meilisearch.com>

meilisearch-http/src/index_controller/update_actor/actor.rs

@@ -145,7 +145,7 @@ where
             // The payload is valid, we can register it to the update store.
             update_store
                 .register_update(meta, path, uuid)
-                .map(UpdateStatus::Pending)
+                .map(UpdateStatus::Enqueued)
                 .map_err(|e| UpdateError::Error(Box::new(e)))
         })
         .await

meilisearch-http/src/index_controller/update_actor/update_store.rs

@@ -17,7 +17,7 @@ type BEU64 = heed::zerocopy::U64<heed::byteorder::BE>;
 #[derive(Clone)]
 pub struct UpdateStore<M, N, E> {
     pub env: Env,
-    pending_meta: Database<OwnedType<BEU64>, SerdeJson<Pending<M>>>,
+    pending_meta: Database<OwnedType<BEU64>, SerdeJson<Enqueued<M>>>,
     pending: Database<OwnedType<BEU64>, SerdeJson<PathBuf>>,
     processed_meta: Database<OwnedType<BEU64>, SerdeJson<Processed<M, N>>>,
     failed_meta: Database<OwnedType<BEU64>, SerdeJson<Failed<M, E>>>,
@@ -167,7 +167,7 @@ where
         meta: M,
         content: impl AsRef<Path>,
         index_uuid: Uuid,
-    ) -> heed::Result<Pending<M>> {
+    ) -> heed::Result<Enqueued<M>> {
         let mut wtxn = self.env.write_txn()?;
 
         // We ask the update store to give us a new update id, this is safe,
@@ -177,7 +177,7 @@ where
         let update_id = self.new_update_id(&wtxn)?;
         let update_key = BEU64::new(update_id);
 
-        let meta = Pending::new(meta, update_id, index_uuid);
+        let meta = Enqueued::new(meta, update_id, index_uuid);
         self.pending_meta.put(&mut wtxn, &update_key, &meta)?;
         self.pending
             .put(&mut wtxn, &update_key, &content.as_ref().to_owned())?;
@@ -303,7 +303,7 @@ where
         }
 
         if let Some(meta) = self.pending_meta.get(&rtxn, &key)? {
-            return Ok(Some(UpdateStatus::Pending(meta)));
+            return Ok(Some(UpdateStatus::Enqueued(meta)));
         }
 
         if let Some(meta) = self.processed_meta.get(&rtxn, &key)? {

meilisearch-http/src/index_controller/updates.rs

@@ -4,14 +4,14 @@ use uuid::Uuid;
 
 #[derive(Debug, PartialEq, Eq, Hash, Serialize, Deserialize, Clone)]
 #[serde(rename_all = "camelCase")]
-pub struct Pending<M> {
+pub struct Enqueued<M> {
     pub update_id: u64,
     pub meta: M,
     pub enqueued_at: DateTime<Utc>,
     pub index_uuid: Uuid,
 }
 
-impl<M> Pending<M> {
+impl<M> Enqueued<M> {
     pub fn new(meta: M, update_id: u64, index_uuid: Uuid) -> Self {
         Self {
             enqueued_at: Utc::now(),
@@ -63,7 +63,7 @@ impl<M, N> Processed<M, N> {
 #[serde(rename_all = "camelCase")]
 pub struct Processing<M> {
     #[serde(flatten)]
-    pub from: Pending<M>,
+    pub from: Enqueued<M>,
     pub started_processing_at: DateTime<Utc>,
 }
 
@@ -101,7 +101,7 @@ impl<M> Processing<M> {
 #[serde(rename_all = "camelCase")]
 pub struct Aborted<M> {
     #[serde(flatten)]
-    from: Pending<M>,
+    from: Enqueued<M>,
     aborted_at: DateTime<Utc>,
 }
 
@@ -130,7 +130,7 @@ impl<M, E> Failed<M, E> {
 #[serde(tag = "status", rename_all = "camelCase")]
 pub enum UpdateStatus<M, N, E> {
     Processing(Processing<M>),
-    Pending(Pending<M>),
+    Enqueued(Enqueued<M>),
     Processed(Processed<M, N>),
     Aborted(Aborted<M>),
     Failed(Failed<M, E>),
@@ -140,7 +140,7 @@ impl<M, N, E> UpdateStatus<M, N, E> {
     pub fn id(&self) -> u64 {
         match self {
             UpdateStatus::Processing(u) => u.id(),
-            UpdateStatus::Pending(u) => u.id(),
+            UpdateStatus::Enqueued(u) => u.id(),
             UpdateStatus::Processed(u) => u.id(),
             UpdateStatus::Aborted(u) => u.id(),
             UpdateStatus::Failed(u) => u.id(),
@@ -155,9 +155,9 @@ impl<M, N, E> UpdateStatus<M, N, E> {
     }
 }
 
-impl<M, N, E> From<Pending<M>> for UpdateStatus<M, N, E> {
-    fn from(other: Pending<M>) -> Self {
-        Self::Pending(other)
+impl<M, N, E> From<Enqueued<M>> for UpdateStatus<M, N, E> {
+    fn from(other: Enqueued<M>) -> Self {
+        Self::Enqueued(other)
     }
 }