Use bincode instead of serde_json

Cargo.toml

@@ -25,6 +25,7 @@ codegen-units = 1
 
 [dependencies]
 anyhow = "1.0.88"
+bincode = "1.3.3"
 clap = { version = "4.5.17", features = ["derive"] }
 dashmap = "6.1.0"
 env_logger = "0.11.5"
@@ -36,7 +37,6 @@ redb = { version = "2.1.3", optional = true }
 redis = { version = "0.24.0", features = ["tokio-comp"], optional = true }
 rocksdb = { git = "https://github.com/surrealdb/rust-rocksdb", features = ["lz4", "snappy"], optional = true }
 serde = { version = "1.0.210", features = ["derive"] }
-serde_json = "1.0.128"
 speedb = { version = "0.0.5", features = ["lz4", "snappy"], optional = true }
 surrealdb = { version = "2.0.1", optional = true }
 surrealkv = { version = "0.3.6", optional = true }

src/redb.rs

@@ -46,7 +46,7 @@ impl BenchmarkClient for ReDBClient {
 
 	async fn create(&mut self, key: i32, record: &Record) -> Result<()> {
 		let key = &key.to_ne_bytes();
-		let val = serde_json::to_vec(record)?;
+		let val = bincode::serialize(record)?;
 		// Create a new transaction
 		let txn = self.db.begin_write()?;
 		// Open the database table
@@ -72,7 +72,7 @@ impl BenchmarkClient for ReDBClient {
 
 	async fn update(&mut self, key: i32, record: &Record) -> Result<()> {
 		let key = &key.to_ne_bytes();
-		let val = serde_json::to_vec(record)?;
+		let val = bincode::serialize(record)?;
 		// Create a new transaction
 		let txn = self.db.begin_write()?;
 		// Open the database table

src/redis.rs

@@ -34,7 +34,7 @@ pub(crate) struct RedisClient {
 impl BenchmarkClient for RedisClient {
 	#[allow(dependency_on_unit_never_type_fallback)]
 	async fn create(&mut self, key: i32, record: &Record) -> Result<()> {
-		let val = serde_json::to_vec(record)?;
+		let val = bincode::serialize(record)?;
 		self.conn.set(key, val).await?;
 		Ok(())
 	}
@@ -47,7 +47,7 @@ impl BenchmarkClient for RedisClient {
 
 	#[allow(dependency_on_unit_never_type_fallback)]
 	async fn update(&mut self, key: i32, record: &Record) -> Result<()> {
-		let val = serde_json::to_vec(record)?;
+		let val = bincode::serialize(record)?;
 		self.conn.set(key, val).await?;
 		Ok(())
 	}

src/rocksdb.rs

@@ -85,7 +85,7 @@ impl BenchmarkClient for RocksDBClient {
 
 	async fn create(&mut self, key: i32, record: &Record) -> Result<()> {
 		let key = &key.to_ne_bytes();
-		let val = serde_json::to_vec(record)?;
+		let val = bincode::serialize(record)?;
 		// Set the transaction options
 		let mut to = OptimisticTransactionOptions::default();
 		to.set_snapshot(true);
@@ -125,7 +125,7 @@ impl BenchmarkClient for RocksDBClient {
 
 	async fn update(&mut self, key: i32, record: &Record) -> Result<()> {
 		let key = &key.to_ne_bytes();
-		let val = serde_json::to_vec(record)?;
+		let val = bincode::serialize(record)?;
 		// Set the transaction options
 		let mut to = OptimisticTransactionOptions::default();
 		to.set_snapshot(true);

src/speedb.rs

@@ -85,7 +85,7 @@ impl BenchmarkClient for SpeeDBClient {
 
 	async fn create(&mut self, key: i32, record: &Record) -> Result<()> {
 		let key = &key.to_ne_bytes();
-		let val = serde_json::to_vec(record)?;
+		let val = bincode::serialize(record)?;
 		// Set the transaction options
 		let mut to = OptimisticTransactionOptions::default();
 		to.set_snapshot(true);
@@ -125,7 +125,7 @@ impl BenchmarkClient for SpeeDBClient {
 
 	async fn update(&mut self, key: i32, record: &Record) -> Result<()> {
 		let key = &key.to_ne_bytes();
-		let val = serde_json::to_vec(record)?;
+		let val = bincode::serialize(record)?;
 		// Set the transaction options
 		let mut to = OptimisticTransactionOptions::default();
 		to.set_snapshot(true);

src/surrealkv.rs

@@ -51,7 +51,7 @@ impl BenchmarkClient for SurrealKVClient {
 
 	async fn create(&mut self, key: i32, record: &Record) -> Result<()> {
 		let key = &key.to_ne_bytes();
-		let val = serde_json::to_vec(record)?;
+		let val = bincode::serialize(record)?;
 		let mut txn = self.db.begin_with_mode(Mode::WriteOnly)?;
 		txn.set(key, &val)?;
 		txn.commit().await?;
@@ -68,7 +68,7 @@ impl BenchmarkClient for SurrealKVClient {
 
 	async fn update(&mut self, key: i32, record: &Record) -> Result<()> {
 		let key = &key.to_ne_bytes();
-		let val = serde_json::to_vec(record)?;
+		let val = bincode::serialize(record)?;
 		let mut txn = self.db.begin_with_mode(Mode::WriteOnly)?;
 		txn.set(key, &val)?;
 		txn.commit().await?;