use futures::pin_mut;
use futures::stream::{StreamExt, TryStreamExt};
#[cfg(feature = "image")]
#[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 images: Vec<openstack::image::Image> = os
.find_images()
.sort_by(openstack::Sort::Asc(openstack::image::ImageSortKey::Id))
.into_stream()
.take(10)
.try_collect()
.await
.expect("Cannot list images");
println!("First 10 images:");
for img in &images {
println!(
"ID = {}, Name = {}, Status = {}, Visibility = {}",
img.id(),
img.name(),
img.status(),
img.visibility()
);
}
let public = os
.find_images()
.sort_by(openstack::Sort::Asc(openstack::image::ImageSortKey::Name))
.with_visibility(openstack::image::ImageVisibility::Public)
.into_stream();
println!("All public images:");
pin_mut!(public);
while let Some(img) = public.next().await.transpose().unwrap() {
println!(
"ID = {}, Name = {}, Status = {}, Visibility = {}",
img.id(),
img.name(),
img.status(),
img.visibility()
);
}
}
#[cfg(not(feature = "image"))]
fn main() {
panic!("This example cannot run with 'image' feature disabled");
}