test(volume/resize): add cargo tests for volume resize

Signed-off-by: Diwakar Sharma <diwakar.sharma@datacore.com>

Author: dsharma-dc

Cargo.lock

@@ -17,6 +17,7 @@ use super::{
             RebuildHistoryRecord,
             RebuildHistoryRequest,
             RemoveChildNexusRequest,
+            ResizeNexusRequest,
             ShutdownNexusRequest,
         },
         snapshot::SnapshotInfo,
@@ -250,6 +251,19 @@ impl NexusBuilder {
             .map(|r| r.into_inner().nexus.unwrap())
     }
 
+    pub async fn resize(&self, req_size: u64) -> Result<Nexus, Status> {
+        self.rpc()
+            .lock()
+            .await
+            .nexus
+            .resize_nexus(ResizeNexusRequest {
+                uuid: self.uuid(),
+                requested_size: req_size,
+            })
+            .await
+            .map(|r| r.into_inner().nexus.unwrap())
+    }
+
     pub async fn add_child(
         &self,
         bdev: &str,

io-engine-tests/src/nexus.rs

@@ -11,6 +11,7 @@ use io_engine_api::v1::replica::{
     DestroyReplicaRequest,
     ListReplicaOptions,
     Replica,
+    ResizeReplicaRequest,
     ShareReplicaRequest,
 };
 
@@ -184,6 +185,22 @@ impl ReplicaBuilder {
         Ok(r)
     }
 
+    pub async fn resize(&mut self, req_size: u64) -> Result<Replica, Status> {
+        let r = self
+            .rpc()
+            .lock()
+            .await
+            .replica
+            .resize_replica(ResizeReplicaRequest {
+                uuid: self.uuid(),
+                requested_size: req_size,
+            })
+            .await
+            .map(|r| r.into_inner())?;
+        self.size = Some(r.size);
+        Ok(r)
+    }
+
     pub async fn get_replica(&self) -> Result<Replica, Status> {
         let uuid = self.uuid();
         list_replicas(self.rpc())