refactor: add session in lock implement and remove LockRequest types

Closes: 664,684
Signed-off-by: Phoeniix Zhao <Phoenix500526@163.com>

.github/workflows/pull_request.yml

@@ -136,11 +136,11 @@ jobs:
             -e ACTIONS_CACHE_URL=${ACTIONS_CACHE_URL} \
             -e ACTIONS_RUNTIME_TOKEN=${ACTIONS_RUNTIME_TOKEN} \
             ghcr.io/xline-kv/build-env:latest \
-            cargo build --release --bin xline --bin benchmark --bin validation_lock_client
+            cargo build --release --bin xline --bin benchmark
 
           sudo apt-get install -y --force-yes expect
           cd scripts
-          cp ../target/release/{xline,benchmark,validation_lock_client} .
+          cp ../target/release/{xline,benchmark} .
           ldd ./xline
           ldd ./benchmark
           cp ../fixtures/{private,public}.pem .

.github/workflows/validation.yml

@@ -35,6 +35,6 @@ jobs:
         cp ../fixtures/{private,public}.pem .
         docker build . -t ghcr.io/xline-kv/xline:latest
         docker pull gcr.io/etcd-development/etcd:v3.5.5
-      binaries: 'xline,benchmark,validation_lock_client'
+      binaries: 'xline,benchmark'
       script_name: 'validation_test.sh'
       uploadLogs: true

crates/xline-client/Cargo.toml

@@ -12,6 +12,8 @@ keywords = ["Client", "Xline", "RPC"]
 
 [dependencies]
 anyhow = "1.0.83"
+async-dropper = { version = "0.3.1", features = ["tokio", "simple"] }
+async-trait = "0.1.80"
 clippy-utilities = "0.2.0"
 curp = { path = "../curp" }
 futures = "0.3.25"

crates/xline-client/examples/lock.rs

@@ -1,8 +1,5 @@
 use anyhow::Result;
-use xline_client::{
-    types::lock::{LockRequest, UnlockRequest},
-    Client, ClientOptions,
-};
+use xline_client::{clients::Xutex, Client, ClientOptions};
 
 #[tokio::main]
 async fn main() -> Result<()> {
@@ -13,15 +10,14 @@ async fn main() -> Result<()> {
         .await?
         .lock_client();
 
-    // acquire a lock
-    let resp = client.lock(LockRequest::new("lock-test")).await?;
+    let mut xutex = Xutex::new(client, "lock-test", None, None).await?;
+    // when the `xutex_guard` drop, the lock will be unlocked.
+    let xutex_guard = xutex.lock().await?;
 
-    let key = resp.key;
-
-    println!("lock key: {:?}", String::from_utf8_lossy(&key));
-
-    // release the lock
-    client.unlock(UnlockRequest::new(key)).await?;
+    println!(
+        "lock key: {:?}",
+        String::from_utf8_lossy(xutex_guard.key().as_bytes())
+    );
 
     Ok(())
 }