From 16ab3e02a9d68baf89abb2d0f75af74c8e51f299 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Cl=C3=A9ment=20Renault?= <clement@meilisearch.com>
Date: Wed, 21 Oct 2020 13:42:49 +0200
Subject: [PATCH] Change the UpdateStore internal meta serializer

---
 src/update_store.rs | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/update_store.rs b/src/update_store.rs
index 564190af7..1b0fe4620 100644
--- a/src/update_store.rs
+++ b/src/update_store.rs
@@ -2,7 +2,7 @@ use std::path::Path;
 use std::sync::Arc;
 
 use crossbeam_channel::Sender;
-use heed::types::{OwnedType, DecodeIgnore, SerdeJson, ByteSlice};
+use heed::types::{OwnedType, DecodeIgnore, SerdeBincode, ByteSlice};
 use heed::{EnvOpenOptions, Env, Database};
 use serde::{Serialize, Deserialize};
 
@@ -11,9 +11,9 @@ use crate::BEU64;
 #[derive(Clone)]
 pub struct UpdateStore<M> {
     env: Env,
-    pending_meta: Database<OwnedType<BEU64>, SerdeJson<M>>,
+    pending_meta: Database<OwnedType<BEU64>, SerdeBincode<M>>,
     pending: Database<OwnedType<BEU64>, ByteSlice>,
-    processed_meta: Database<OwnedType<BEU64>, SerdeJson<M>>,
+    processed_meta: Database<OwnedType<BEU64>, SerdeBincode<M>>,
     notification_sender: Sender<()>,
 }
 
@@ -153,8 +153,8 @@ impl<M: 'static> UpdateStore<M> {
     where
         M: for<'a> Deserialize<'a>,
         F: for<'a> FnMut(
-            heed::RoIter<'a, OwnedType<BEU64>, SerdeJson<M>>,
-            heed::RoIter<'a, OwnedType<BEU64>, SerdeJson<M>>,
+            heed::RoIter<'a, OwnedType<BEU64>, SerdeBincode<M>>,
+            heed::RoIter<'a, OwnedType<BEU64>, SerdeBincode<M>>,
         ) -> heed::Result<T>,
     {
         let rtxn = self.env.read_txn()?;