Skip to content

Commit

Permalink
chore: scaffold for new pool API
Browse files Browse the repository at this point in the history
Signed-off-by: Diwakar Sharma <[email protected]>
  • Loading branch information
dsharma-dc committed Feb 17, 2025
1 parent dec723f commit afe1252
Show file tree
Hide file tree
Showing 6 changed files with 7 additions and 1 deletion.
1 change: 1 addition & 0 deletions io-engine-tests/src/pool.rs
Original file line number Diff line number Diff line change
Expand Up @@ -195,6 +195,7 @@ impl PoolBuilderRpc {
disks: vec![self.bdev.as_ref().unwrap().clone()],
cluster_size: None,
md_args: None,
encryption: None,
})
.await
.map(|r| r.into_inner())
Expand Down
2 changes: 2 additions & 0 deletions io-engine/src/bin/io-engine-client/v1/pool_cli.rs
Original file line number Diff line number Diff line change
Expand Up @@ -261,6 +261,7 @@ async fn create(mut ctx: Context, matches: &ArgMatches) -> crate::Result<()> {
pooltype: v1rpc::pool::PoolType::from(pooltype) as i32,
cluster_size,
md_args: Some(v1rpc::pool::PoolMetadataArgs { md_resv_ratio }),
encryption: None,
})
.await
.context(GrpcStatus)?;
Expand Down Expand Up @@ -333,6 +334,7 @@ async fn import(mut ctx: Context, matches: &ArgMatches) -> crate::Result<()> {
uuid: uuid.map(ToString::to_string),
disks: disks_list,
pooltype: v1rpc::pool::PoolType::from(pooltype) as i32,
encryption: None,
})
.await
.context(GrpcStatus)?;
Expand Down
1 change: 1 addition & 0 deletions io-engine/tests/nexus_with_local.rs
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,7 @@ async fn create_replicas(h: &mut RpcHandle) {
disks: vec!["malloc:///disk0?size_mb=64".into()],
cluster_size: None,
md_args: None,
encryption: None,
})
.await
.unwrap();
Expand Down
1 change: 1 addition & 0 deletions io-engine/tests/nvmf.rs
Original file line number Diff line number Diff line change
Expand Up @@ -260,6 +260,7 @@ async fn test_rdma_target() {
disks: vec!["malloc:///disk0?size_mb=100".into()],
cluster_size: None,
md_args: None,
encryption: None,
})
.await
.unwrap();
Expand Down
1 change: 1 addition & 0 deletions io-engine/tests/snapshot_nexus.rs
Original file line number Diff line number Diff line change
Expand Up @@ -129,6 +129,7 @@ async fn launch_instance(create_replicas: bool) -> (ComposeTest, Vec<String>) {
disks: vec!["malloc:///disk0?size_mb=128".into()],
cluster_size: None,
md_args: None,
encryption: None,
})
.await
.unwrap();
Expand Down

0 comments on commit afe1252

Please sign in to comment.