update Pelikan dependencies (#384)

Updates the Pelikan dependencies to the latest versions. This pulls
in a fix for the session buffer.

Author: brayniac

Cargo.lock

@@ -1,7 +1,7 @@
 [package]
 name = "rpc-perf"
 description = "RPC Performance Testing"
-version = "5.21.0"
+version = "5.21.1-alpha.0"
 authors = ["Brian Martin <[email protected]>"]
 edition = "2021"
 homepage = "https://github.com/iopsystems/rpc-perf"

Cargo.toml

@@ -1,7 +1,7 @@
 use super::*;
 use crate::clients::ResponseError;
 use crate::net::Connector;
-use protocol_memcache::{Compose, Parse, Request, Response, Ttl};
+use protocol_memcache::{Parse, Protocol, Request, Response, TextProtocol, Ttl};
 use session::{Buf, BufMut, Buffer};
 use std::borrow::{Borrow, BorrowMut};
 
@@ -40,6 +40,8 @@ async fn task(
 ) -> Result<()> {
     let connector = Connector::new(&config)?;
 
+    let protocol = TextProtocol::default();
+
     // we would not be creating a memcache client task if we didn't have a
     // client config, so this unwrap will succeed.
     let client_config = config.client().unwrap();
@@ -103,7 +105,7 @@ async fn task(
 
         // compose request
         REQUEST_OK.increment();
-        request.request.compose(&mut write_buffer);
+        let _ = protocol.compose_request(&request.request, &mut write_buffer);
 
         // send request
         let start = Instant::now();

src/clients/cache/memcache/mod.rs

@@ -20,7 +20,7 @@ mod net;
 mod output;
 mod workload;
 
-use config::*;
+use config::{Protocol, *};
 use metrics::*;
 
 static RUNNING: AtomicBool = AtomicBool::new(true);