use futures::stream::{StreamExt, TryStreamExt};
#[cfg(feature = "block-storage")]
#[tokio::main(flavor = "current_thread")]
async fn main() {
env_logger::init();
let os = openstack::Cloud::from_env()
.await
.expect("Failed to create an identity provider from the environment");
let sorting = openstack::block_storage::VolumeSortKey::Name;
let volumes: Vec<openstack::block_storage::Volume> = os
.find_volumes()
.sort_by(openstack::Sort::Asc(sorting))
.into_stream()
.take(10)
.try_collect()
.await
.expect("Cannot list volumes");
println!("First 10 volumes:");
for s in &volumes {
println!(
"ID = {}, Name = {:?}, Status = {:?}",
s.id(),
s.name(),
s.status(),
);
}
}
#[cfg(not(feature = "block-storage"))]
fn main() {
panic!("This example cannot run with 'block-storage' feature disabled");
}