jzombie · jzombie · Jun 28, 2025 · Jun 25, 2025 · Jun 26, 2025 · Jun 26, 2025
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [workspace.package]
 authors = ["Jeremy Harris <[email protected]>"]
-version = "0.8.0-alpha"
+version = "0.9.0-alpha"
 edition = "2024"
 repository = "https://github.com/jzombie/rust-simd-r-drive"
 license = "Apache-2.0"
@@ -22,9 +22,9 @@ publish.workspace = true # Inherit from workspace
 
 [workspace.dependencies]
 # Intra-workspace crates
-simd-r-drive = { path = ".", version = "0.8.0-alpha" }
-simd-r-drive-ws-client = { path = "./experiments/simd-r-drive-ws-client", version = "0.8.0-alpha" }
-simd-r-drive-muxio-service-definition = { path = "./experiments/simd-r-drive-muxio-service-definition", version = "0.8.0-alpha" }
+simd-r-drive = { path = ".", version = "0.9.0-alpha" }
+simd-r-drive-ws-client = { path = "./experiments/simd-r-drive-ws-client", version = "0.9.0-alpha" }
+simd-r-drive-muxio-service-definition = { path = "./experiments/simd-r-drive-muxio-service-definition", version = "0.9.0-alpha" }
 
 [dependencies]
 async-trait = "0.1.88"

diff --git a/experiments/bindings/python-ws-client/Cargo.lock b/experiments/bindings/python-ws-client/Cargo.lock
diff --git a/experiments/bindings/python-ws-client/integration_test.sh b/experiments/bindings/python-ws-client/integration_test.sh
@@ -10,7 +10,8 @@ EXPERIMENTS_DIR_REL_PATH="../../"
 # Server and test settings
 SERVER_PACKAGE_NAME="simd-r-drive-ws-server"
 STORAGE_FILE="/tmp/simd-r-drive-pytest-storage.bin"
-SERVER_ADDR="127.0.0.1:34129"
+SERVER_HOST="127.0.0.1"
+SERVER_PORT=34129
 SERVER_PID=""
 
 # --- Cleanup Function ---
@@ -49,7 +50,7 @@ echo "--> Starting server in background mode..."
 set -m
 # Use 'cargo run' to start the server, which is more reliable than a direct path.
 # The '--' separates cargo's arguments from the application's arguments.
-cargo run --package "$SERVER_PACKAGE_NAME" -- "$STORAGE_FILE" --listen "$SERVER_ADDR" &
+cargo run --package "$SERVER_PACKAGE_NAME" -- "$STORAGE_FILE" --host "$SERVER_HOST" --port "$SERVER_PORT" &
 SERVER_PID=$!
 set +m
 echo "Server process started with PID: $SERVER_PID."
@@ -79,7 +80,8 @@ pwd
 
 echo "--> Running pytest..."
 # Export the server address so the Python test script can use it
-export TEST_SERVER_ADDR=$SERVER_ADDR
+export TEST_SERVER_HOST=$SERVER_HOST
+export TEST_SERVER_PORT=$SERVER_PORT
 # Run pytest using the virtual environment's executable
 uv run pytest -v -s
 

diff --git a/experiments/bindings/python-ws-client/pyproject.toml b/experiments/bindings/python-ws-client/pyproject.toml
@@ -1,6 +1,6 @@
 [project]
 name = "simd-r-drive-ws-client"
-version = "0.8.0-alpha"
+version = "0.9.0-alpha"
 description = "SIMD-optimized append-only schema-less storage engine. Key-based binary storage in a single-file storage container."
 repository = "https://github.com/jzombie/rust-simd-r-drive"
 license = "Apache-2.0"

diff --git a/experiments/bindings/python-ws-client/simd_r_drive_ws_client/simd_r_drive_ws_client.pyi b/experiments/bindings/python-ws-client/simd_r_drive_ws_client/simd_r_drive_ws_client.pyi
@@ -12,12 +12,13 @@ class DataStoreWsClient:
     key/value pairs, streaming writes, and zero-copy reads.
     """
 
-    def __init__(self, ws_addr: str) -> None:
+    def __init__(self, host: str, port: int) -> None:
         """
         Connects to a SIMD R Drive server.
 
         Args:
-            ws_addr (str): The WebSocket address of the SIMD R Drive server.
+            host (str): The hostname or IP address of the server to connect to.
+            port (int): The TCP port of the server.
         """
         ...
 

diff --git a/experiments/bindings/python-ws-client/src/base_ws_client_py.rs b/experiments/bindings/python-ws-client/src/base_ws_client_py.rs
@@ -11,6 +11,11 @@ use std::time::Duration;
 use tokio::runtime::{Builder, Runtime};
 use tokio::time::timeout;
 
+// TODO: Borrow configuration props from MySQL
+// connection_timeout=10,  # Timeout for the connection attempt (in seconds)
+// read_timeout=30,        # Timeout for waiting for response from server (in seconds)
+// write_timeout=30        # Timeout for sending data to server (in seconds)
+
 #[pyclass(subclass)]
 pub struct BaseDataStoreWsClient {
     ws_client: Arc<WsClient>,
@@ -21,7 +26,7 @@ pub struct BaseDataStoreWsClient {
 #[pymethods]
 impl BaseDataStoreWsClient {
     #[new]
-    fn new(_py: Python<'_>, ws_address: &str) -> PyResult<Self> {
+    fn new(_py: Python<'_>, host: &str, port: u16) -> PyResult<Self> {
         let runtime = Arc::new(
             Builder::new_multi_thread()
                 .enable_all()
@@ -32,7 +37,7 @@ impl BaseDataStoreWsClient {
         );
 
         let ws_client = runtime
-            .block_on(async { WsClient::new(ws_address).await })
+            .block_on(async { WsClient::new(host, port).await })
             .map_err(|e| PyIOError::new_err(e.to_string()))?;
 
         let is_connected_clone = Arc::new(AtomicBool::new(true));

diff --git a/experiments/bindings/python-ws-client/tests/integraton/test_client.py b/experiments/bindings/python-ws-client/tests/integraton/test_client.py
@@ -5,7 +5,8 @@
 import secrets
 
 # Server address, configurable via environment variable
-SERVER_ADDR = os.environ.get("TEST_SERVER_ADDR", "127.0.0.1:34129")
+SERVER_HOST = os.environ.get("TEST_SERVER_HOST", "127.0.0.1")
+SERVER_PORT = int(os.environ.get("TEST_SERVER_PORT", 34129))
 
 
 @pytest.fixture(scope="module")
@@ -17,11 +18,11 @@ def client():
     # Allow some time for the server to start up.
     time.sleep(2)
     try:
-        ws_client = DataStoreWsClient(SERVER_ADDR)
+        ws_client = DataStoreWsClient(SERVER_HOST, SERVER_PORT)
         yield ws_client
     except Exception as e:
         pytest.fail(
-            f"Failed to connect to the WebSocket server at {SERVER_ADDR}. Is it running? Error: {e}"
+            f"Failed to connect to the WebSocket server at {SERVER_HOST}. Is it running? Error: {e}"
         )
 
 
@@ -123,9 +124,9 @@ def test_large_batch_write(client):
 def test_batch_read_with_missing_key(client):
     """
     Verifies that batch_read:
-    – returns payloads for existing keys,
-    – returns None for keys that are absent,
-    – preserves order (results[i] matches keys[i]).
+    - returns payloads for existing keys,
+    - returns None for keys that are absent,
+    - preserves order (results[i] matches keys[i]).
     """
     # --- Arrange ----------------------------------------------------------
     entries = [

diff --git a/experiments/bindings/python-ws-client/tests/integraton/test_multithreaded_read_write.py b/experiments/bindings/python-ws-client/tests/integraton/test_multithreaded_read_write.py
@@ -7,7 +7,8 @@
 import secrets
 
 # Server address, configurable via environment variable
-SERVER_ADDR = os.environ.get("TEST_SERVER_ADDR", "127.0.0.1:34129")
+SERVER_HOST = os.environ.get("TEST_SERVER_HOST", "127.0.0.1")
+SERVER_PORT = int(os.environ.get("TEST_SERVER_PORT", 34129))
 
 
 @pytest.fixture(scope="module")
@@ -19,11 +20,11 @@ def client():
     # Allow some time for the server to start up.
     time.sleep(2)
     try:
-        ws_client = DataStoreWsClient(SERVER_ADDR)
+        ws_client = DataStoreWsClient(SERVER_HOST, SERVER_PORT)
         yield ws_client
     except Exception as e:
         pytest.fail(
-            f"Failed to connect to the WebSocket server at {SERVER_ADDR}. Is it running? Error: {e}"
+            f"Failed to connect to the WebSocket server at {SERVER_HOST}. Is it running? Error: {e}"
         )
 
 def test_concurrent_read_write_stress(client):
@@ -47,7 +48,7 @@ def worker(thread_id):
         # Each worker creates its own client connection to simulate concurrent users.
         local_client = None
         try:
-            local_client = DataStoreWsClient(SERVER_ADDR)
+            local_client = DataStoreWsClient(SERVER_HOST, SERVER_PORT)
             for i in range(OPERATIONS_PER_THREAD):
                 # Randomly choose between writing and reading
                 if (

diff --git a/experiments/bindings/python-ws-client/uv.lock b/experiments/bindings/python-ws-client/uv.lock
diff --git a/experiments/bindings/python/pyproject.toml b/experiments/bindings/python/pyproject.toml
@@ -1,6 +1,6 @@
 [project]
 name = "simd-r-drive-py"
-version = "0.8.0-alpha"
+version = "0.9.0-alpha"
 description = "SIMD-optimized append-only schema-less storage engine. Key-based binary storage in a single-file storage container."
 repository = "https://github.com/jzombie/rust-simd-r-drive"
 license = "Apache-2.0"

diff --git a/experiments/simd-r-drive-muxio-service-definition/Cargo.toml b/experiments/simd-r-drive-muxio-service-definition/Cargo.toml
@@ -12,5 +12,5 @@ publish.workspace = true # Inherit from workspace
 
 [dependencies]
 bitcode = "0.6.6"
-muxio-rpc-service = "0.8.0-alpha"
+muxio-rpc-service = "0.9.0-alpha"
 
diff --git a/experiments/simd-r-drive-muxio-service-definition/src/prebuffered/api_version.rs.TODO b/experiments/simd-r-drive-muxio-service-definition/src/prebuffered/api_version.rs.TODO
@@ -0,0 +1 @@
+// TODO: Add `api_version` route
diff --git a/experiments/simd-r-drive-ws-client/Cargo.toml b/experiments/simd-r-drive-ws-client/Cargo.toml
@@ -13,9 +13,9 @@ publish.workspace = true # Inherit from workspace
 [dependencies]
 simd-r-drive = { workspace = true }
 simd-r-drive-muxio-service-definition = { workspace = true }
-muxio-tokio-rpc-client = "0.8.0-alpha"
-muxio-rpc-service = "0.8.0-alpha"
-muxio-rpc-service-caller = "0.8.0-alpha"
+muxio-tokio-rpc-client = "0.9.0-alpha"
+muxio-rpc-service = "0.9.0-alpha"
+muxio-rpc-service-caller = "0.9.0-alpha"
 tokio = "1.45.1"
 tracing = "0.1.41"
 async-trait = "0.1.88"