binary and delimited serialization of prost messages in channels

Co-Authored-By: Eloi DEMOLIS <eloi.demolis@clever-cloud.com>
sozu-proxy · Feb 2, 2024 · a6ffebe · a6ffebe
1 parent 630b1a7
commit a6ffebe
Show file tree

Hide file tree

Showing 6 changed files with 169 additions and 180 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/bin/Cargo.toml b/bin/Cargo.toml
@@ -29,6 +29,7 @@ nom = "^7.1.3"
 paw = "^1.0.0"
 serde = { version = "^1.0.195", features = ["derive"] }
 serde_json = "^1.0.111"
+prost = "^0.12.3"
 time = "^0.3.29"
 tempfile = "^3.9.0"
 termion = "^3.0.0"

diff --git a/bin/src/command/sessions.rs b/bin/src/command/sessions.rs
@@ -2,7 +2,7 @@ use std::fmt::Debug;
 
 use libc::pid_t;
 use mio::Token;
-use serde::{de::DeserializeOwned, Serialize};
+use prost::Message;
 
 use sozu_command_lib::{
     channel::Channel,
@@ -265,8 +265,8 @@ impl WorkerSession {
 /// read and parse messages (Requests or Responses) from the channel
 pub fn extract_messages<Tx, Rx>(channel: &mut Channel<Tx, Rx>) -> Vec<Rx>
 where
-    Tx: Debug + Serialize,
-    Rx: Debug + DeserializeOwned,
+    Tx: Debug + Default + Message,
+    Rx: Debug + Default + Message,
 {
     let mut messages = Vec::new();
     loop {