Skip to content

Commit afe1252

Browse files
committed
chore: scaffold for new pool API
Signed-off-by: Diwakar Sharma <diwakar.sharma@datacore.com>
1 parent dec723f commit afe1252

File tree

6 files changed

+7
-1
lines changed

6 files changed

+7
-1
lines changed

io-engine-tests/src/pool.rs

+1
Original file line numberDiff line numberDiff line change
@@ -195,6 +195,7 @@ impl PoolBuilderRpc {
195195
disks: vec![self.bdev.as_ref().unwrap().clone()],
196196
cluster_size: None,
197197
md_args: None,
198+
encryption: None,
198199
})
199200
.await
200201
.map(|r| r.into_inner())

io-engine/src/bin/io-engine-client/v1/pool_cli.rs

+2
Original file line numberDiff line numberDiff line change
@@ -261,6 +261,7 @@ async fn create(mut ctx: Context, matches: &ArgMatches) -> crate::Result<()> {
261261
pooltype: v1rpc::pool::PoolType::from(pooltype) as i32,
262262
cluster_size,
263263
md_args: Some(v1rpc::pool::PoolMetadataArgs { md_resv_ratio }),
264+
encryption: None,
264265
})
265266
.await
266267
.context(GrpcStatus)?;
@@ -333,6 +334,7 @@ async fn import(mut ctx: Context, matches: &ArgMatches) -> crate::Result<()> {
333334
uuid: uuid.map(ToString::to_string),
334335
disks: disks_list,
335336
pooltype: v1rpc::pool::PoolType::from(pooltype) as i32,
337+
encryption: None,
336338
})
337339
.await
338340
.context(GrpcStatus)?;

io-engine/tests/nexus_with_local.rs

+1
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,7 @@ async fn create_replicas(h: &mut RpcHandle) {
4646
disks: vec!["malloc:///disk0?size_mb=64".into()],
4747
cluster_size: None,
4848
md_args: None,
49+
encryption: None,
4950
})
5051
.await
5152
.unwrap();

io-engine/tests/nvmf.rs

+1
Original file line numberDiff line numberDiff line change
@@ -260,6 +260,7 @@ async fn test_rdma_target() {
260260
disks: vec!["malloc:///disk0?size_mb=100".into()],
261261
cluster_size: None,
262262
md_args: None,
263+
encryption: None,
263264
})
264265
.await
265266
.unwrap();

io-engine/tests/snapshot_nexus.rs

+1
Original file line numberDiff line numberDiff line change
@@ -129,6 +129,7 @@ async fn launch_instance(create_replicas: bool) -> (ComposeTest, Vec<String>) {
129129
disks: vec!["malloc:///disk0?size_mb=128".into()],
130130
cluster_size: None,
131131
md_args: None,
132+
encryption: None,
132133
})
133134
.await
134135
.unwrap();

0 commit comments

Comments
 (0)