openstack_cli_compute/v2/hypervisor/
list.rs1use clap::Args;
23use tracing::info;
24
25use openstack_cli_core::cli::CliArgs;
26use openstack_cli_core::error::OpenStackCliError;
27use openstack_cli_core::output::OutputProcessor;
28use openstack_sdk::AsyncOpenStack;
29
30use openstack_sdk::api::QueryAsync;
31use openstack_sdk::api::compute::v2::hypervisor::list_detailed;
32use openstack_sdk::api::{Pagination, paged};
33use openstack_types::compute::v2::hypervisor::response;
34
35#[derive(Args)]
45#[command(about = "List Hypervisors Details")]
46pub struct HypervisorsCommand {
47 #[command(flatten)]
49 query: QueryParameters,
50
51 #[command(flatten)]
53 path: PathParameters,
54
55 #[arg(long, default_value_t = 10000)]
57 max_items: usize,
58}
59
60#[derive(Args)]
62struct QueryParameters {
63 #[arg(help_heading = "Query parameters", long)]
64 hypervisor_hostname_pattern: Option<String>,
65
66 #[arg(
71 help_heading = "Query parameters",
72 long("page-size"),
73 visible_alias("limit")
74 )]
75 limit: Option<u32>,
76
77 #[arg(help_heading = "Query parameters", long)]
81 marker: Option<String>,
82
83 #[arg(action=clap::ArgAction::Set, help_heading = "Query parameters", long)]
84 with_servers: Option<bool>,
85}
86
87#[derive(Args)]
89struct PathParameters {}
90
91impl HypervisorsCommand {
92 pub async fn take_action<C: CliArgs>(
94 &self,
95 parsed_args: &C,
96 client: &mut AsyncOpenStack,
97 ) -> Result<(), OpenStackCliError> {
98 info!("List Hypervisors");
99
100 let op = OutputProcessor::from_args(parsed_args, Some("compute.hypervisor"), Some("list"));
101 op.validate_args(parsed_args)?;
102
103 let mut ep_builder = list_detailed::Request::builder();
104
105 if let Some(val) = &self.query.hypervisor_hostname_pattern {
107 ep_builder.hypervisor_hostname_pattern(val);
108 }
109 if let Some(val) = &self.query.limit {
110 ep_builder.limit(*val);
111 }
112 if let Some(val) = &self.query.marker {
113 ep_builder.marker(val);
114 }
115 if let Some(val) = &self.query.with_servers {
116 ep_builder.with_servers(*val);
117 }
118
119 let ep = ep_builder
120 .build()
121 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
122
123 let data: Vec<serde_json::Value> = paged(ep, Pagination::Limit(self.max_items))
124 .query_async(client)
125 .await?;
126
127 op.output_list::<response::list_detailed_21::HypervisorResponse>(data.clone())
128 .or_else(|_| {
129 op.output_list::<response::list_detailed_228::HypervisorResponse>(data.clone())
130 })
131 .or_else(|_| {
132 op.output_list::<response::list_detailed_233::HypervisorResponse>(data.clone())
133 })
134 .or_else(|_| {
135 op.output_list::<response::list_detailed_253::HypervisorResponse>(data.clone())
136 })
137 .or_else(|_| {
138 op.output_list::<response::list_detailed_288::HypervisorResponse>(data.clone())
139 })?;
140 op.show_command_hint()?;
142 Ok(())
143 }
144}