add benchmark into gh action workflow

.github/workflows/benchmark_group_2.yml

@@ -79,7 +79,7 @@ jobs:
       - run-server
     runs-on: ${{ needs.start-runner.outputs.benchmark-label }} # run the job on the newly created runner  
     env:
-      SERVER_IP: ${{ needs.start-runner.outputs.private-ip }}
+      SERVER_URL: http://${{ needs.start-runner.outputs.private-ip }}:26379
     steps:
       - name: Clone Server
         uses: actions/checkout@v4

Cargo.toml

@@ -18,4 +18,4 @@ async-trait = "0.1"
 rocket = { version = "0.5.0", features = ["json"] }
 reqwest = { version = "0.11", features = ["stream", "json"] }
 csv = "1.3.0"
-istziio-client = "0.1.0"
+istziio-client = "0.1.1"

src/benchmark.rs

@@ -57,7 +57,9 @@ pub async fn run_trace(mut trace: VecDeque<TraceEntry>, client_builder: &dyn Fn(
             let req = next_entry.request;
 
             let res = client.request_data_sync(req.clone()).await;
-            assert!(res.is_ok());
+            if let Err(e) = res {
+                println!("Error: {}", e);
+            }
             let client_duration = client_start.elapsed();
             tx.send(client_duration).await.unwrap();
         });

src/utils.rs

@@ -5,15 +5,19 @@ use std::fs;
 use std::path::Path;
 
 pub fn setup_client_1() -> Box<dyn StorageClient> {
+    let server_url = std::env::var("SERVER_URL").unwrap_or(String::from("http://127.0.0.1:26379"));
+    println!("server url: {}", &server_url);
     let bench_files_path = "./bench_files".to_string();
     let map = create_table_file_map(&bench_files_path).unwrap();
-    Box::new(StorageClientImpl::new_for_test(1, map.clone()))
+    Box::new(StorageClientImpl::new_for_test(1, map.clone(), &server_url))
 }
 
 pub fn setup_client_2() -> Box<dyn StorageClient> {
+    let server_url = std::env::var("SERVER_URL").unwrap_or(String::from("http://127.0.0.1:26379"));
+    println!("server url: {}", &server_url);
     let bench_files_path = "./bench_files".to_string();
     let map = create_table_file_map(&bench_files_path).unwrap();
-    Box::new(StorageClientImpl::new_for_test(1, map.clone()))
+    Box::new(StorageClientImpl::new_for_test(1, map.clone(), &server_url))
 }
 
 pub fn create_table_file_map(directory: &str) -> Result<HashMap<TableId, String>, std::io::Error> {

traces/trace1.csv

@@ -2,8 +2,5 @@ timestamp,file
 300,0
 1000,1
 1000,1
-1000,1
-1000,1
-1000,1
 3000,2
 9000,3