Papaya stores are lighter?

Author: deven96

ahnlich/client/src/db.rs

@@ -547,7 +547,7 @@ mod tests {
             StoreInfo {
                 name: StoreName("Main".to_string()),
                 len: 0,
-                size_in_bytes: 1720,
+                size_in_bytes: 1056,
             },
         ]))));
         let res = pipeline.exec().await.expect("Could not execute pipeline");
@@ -603,7 +603,7 @@ mod tests {
             ServerResponse::StoreList(HashSet::from_iter([StoreInfo {
                 name: StoreName("Main".to_string()),
                 len: 2,
-                size_in_bytes: 2016,
+                size_in_bytes: 1352,
             },]))
         );
         // error as different dimensions
@@ -628,7 +628,7 @@ mod tests {
             ServerResponse::StoreList(HashSet::from_iter([StoreInfo {
                 name: StoreName("Main".to_string()),
                 len: 1,
-                size_in_bytes: 1904,
+                size_in_bytes: 1240,
             },]))
         );
     }

ahnlich/db/src/engine/store.rs

@@ -1130,12 +1130,12 @@ mod tests {
                 StoreInfo {
                     name: odd_store,
                     len: 2,
-                    size_in_bytes: 2096,
+                    size_in_bytes: 1432,
                 },
                 StoreInfo {
                     name: even_store,
                     len: 0,
-                    size_in_bytes: 1744,
+                    size_in_bytes: 1080,
                 },
             ])
         )

ahnlich/db/src/server/handler.rs

@@ -20,9 +20,9 @@ use std::io::Result as IoResult;
 use std::net::SocketAddr;
 use std::sync::atomic::AtomicBool;
 use std::sync::Arc;
+use task_manager::Task;
 use task_manager::TaskManager;
 use task_manager::TaskState;
-use task_manager::{BlockingTask, Task};
 use tokio::io::BufReader;
 use tokio::net::TcpListener;
 use tokio::net::TcpStream;

ahnlich/db/src/tests/server_test.rs

@@ -184,7 +184,7 @@ async fn test_create_stores() {
         StoreInfo {
             name: StoreName("Main".to_string()),
             len: 0,
-            size_in_bytes: 1720,
+            size_in_bytes: 1056,
         },
     ]))));
     let stream = TcpStream::connect(address).await.unwrap();
@@ -1482,7 +1482,7 @@ async fn test_drop_stores() {
         StoreInfo {
             name: StoreName("Main".to_string()),
             len: 0,
-            size_in_bytes: 1720,
+            size_in_bytes: 1056,
         },
     ]))));
     expected.push(Ok(ServerResponse::Del(1)));

ahnlich/grpc_types/src/ai/mod.rs

@@ -1,6 +1,6 @@
-pub mod query;
 pub mod execution_provider;
 pub mod models;
+pub mod pipeline;
 pub mod preprocess;
+pub mod query;
 pub mod server;
-pub mod pipeline;

ahnlich/grpc_types/src/ai/pipeline.rs

@@ -20,9 +20,7 @@ pub mod ai_query {
         #[prost(message, tag = "4")]
         CreatePredIndex(super::super::query::CreatePredIndex),
         #[prost(message, tag = "5")]
-        CreateNonLinearAlgorithmIndex(
-            super::super::query::CreateNonLinearAlgorithmIndex,
-        ),
+        CreateNonLinearAlgorithmIndex(super::super::query::CreateNonLinearAlgorithmIndex),
         #[prost(message, tag = "6")]
         DropPredIndex(super::super::query::DropPredIndex),
         #[prost(message, tag = "7")]

ahnlich/grpc_types/src/ai/query.rs

@@ -63,7 +63,10 @@ pub struct GetSimN {
     #[prost(uint32, tag = "4")]
     pub closest_n: u32,
     /// Algorithm to use for similarity search
-    #[prost(enumeration = "super::super::algorithm::algorithms::Algorithm", tag = "5")]
+    #[prost(
+        enumeration = "super::super::algorithm::algorithms::Algorithm",
+        tag = "5"
+    )]
     pub algorithm: i32,
     /// Preprocessing actions to apply to input before querying
     #[prost(enumeration = "super::preprocess::PreprocessAction", tag = "6")]

ahnlich/grpc_types/src/algorithm/mod.rs

@@ -1,2 +1,2 @@
-pub mod nonlinear;
 pub mod algorithms;
+pub mod nonlinear;

ahnlich/grpc_types/src/db/mod.rs

@@ -1,3 +1,3 @@
-pub mod server;
 pub mod pipeline;
 pub mod query;
+pub mod server;

ahnlich/grpc_types/src/db/pipeline.rs

@@ -22,9 +22,7 @@ pub mod db_query {
         #[prost(message, tag = "5")]
         CreatePredIndex(super::super::query::CreatePredIndex),
         #[prost(message, tag = "6")]
-        CreateNonLinearAlgorithmIndex(
-            super::super::query::CreateNonLinearAlgorithmIndex,
-        ),
+        CreateNonLinearAlgorithmIndex(super::super::query::CreateNonLinearAlgorithmIndex),
         #[prost(message, tag = "7")]
         DropPredIndex(super::super::query::DropPredIndex),
         #[prost(message, tag = "8")]

ahnlich/grpc_types/src/db/query.rs

@@ -58,7 +58,10 @@ pub struct GetSimN {
     #[prost(uint64, tag = "3")]
     pub closest_n: u64,
     /// The algorithm to use for similarity computation.
-    #[prost(enumeration = "super::super::algorithm::algorithms::Algorithm", tag = "4")]
+    #[prost(
+        enumeration = "super::super::algorithm::algorithms::Algorithm",
+        tag = "4"
+    )]
     pub algorithm: i32,
     /// The predicate condition to apply.
     #[prost(message, optional, tag = "5")]

ahnlich/grpc_types/src/db/server.rs

@@ -54,7 +54,10 @@ pub struct CreateIndex {
 }
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct ServerResponse {
-    #[prost(oneof = "server_response::Response", tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10")]
+    #[prost(
+        oneof = "server_response::Response",
+        tags = "1, 2, 3, 4, 5, 6, 7, 8, 9, 10"
+    )]
     pub response: ::core::option::Option<server_response::Response>,
 }
 /// Nested message and enum types in `ServerResponse`.

ahnlich/grpc_types/src/keyval.rs

@@ -36,10 +36,8 @@ pub struct StoreEntry {
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct StoreValue {
     #[prost(map = "string, message", tag = "1")]
-    pub value: ::std::collections::HashMap<
-        ::prost::alloc::string::String,
-        super::metadata::MetadataValue,
-    >,
+    pub value:
+        ::std::collections::HashMap<::prost::alloc::string::String, super::metadata::MetadataValue>,
 }
 #[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
 #[repr(i32)]

ahnlich/grpc_types/src/lib.rs

@@ -1,13 +1,13 @@
-pub mod services;
-pub mod metadata;
-pub mod client;
-pub mod predicates;
-pub mod version;
-pub mod utils;
 pub mod ai;
+pub mod algorithm;
+pub mod client;
 pub mod db;
-pub mod shared;
 pub mod keyval;
+pub mod metadata;
+pub mod predicates;
+pub mod server_types;
+pub mod services;
+pub mod shared;
 pub mod similarity;
-pub mod algorithm;
-pub mod server_types;
+pub mod utils;
+pub mod version;