openstack_cli_compute/v2/server_group/
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::server_group::list;
32use openstack_sdk::api::{Pagination, paged};
33use openstack_types::compute::v2::server_group::response;
34
35#[derive(Args)]
44#[command(about = "List Server Groups")]
45pub struct ServerGroupsCommand {
46 #[command(flatten)]
48 query: QueryParameters,
49
50 #[command(flatten)]
52 path: PathParameters,
53
54 #[arg(long, default_value_t = 10000)]
56 max_items: usize,
57}
58
59#[derive(Args)]
61struct QueryParameters {
62 #[arg(help_heading = "Query parameters", long)]
63 all_projects: Option<String>,
64
65 #[arg(
70 help_heading = "Query parameters",
71 long("page-size"),
72 visible_alias("limit")
73 )]
74 limit: Option<u32>,
75
76 #[arg(help_heading = "Query parameters", long)]
77 offset: Option<u32>,
78}
79
80#[derive(Args)]
82struct PathParameters {}
83
84impl ServerGroupsCommand {
85 pub async fn take_action<C: CliArgs>(
87 &self,
88 parsed_args: &C,
89 client: &mut AsyncOpenStack,
90 ) -> Result<(), OpenStackCliError> {
91 info!("List ServerGroups");
92
93 let op =
94 OutputProcessor::from_args(parsed_args, Some("compute.server_group"), Some("list"));
95 op.validate_args(parsed_args)?;
96
97 let mut ep_builder = list::Request::builder();
98
99 if let Some(val) = &self.query.all_projects {
101 ep_builder.all_projects(val);
102 }
103 if let Some(val) = &self.query.limit {
104 ep_builder.limit(*val);
105 }
106 if let Some(val) = &self.query.offset {
107 ep_builder.offset(*val);
108 }
109
110 let ep = ep_builder
111 .build()
112 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
113
114 let data: Vec<serde_json::Value> = paged(ep, Pagination::Limit(self.max_items))
115 .query_async(client)
116 .await?;
117
118 op.output_list::<response::list_21::ServerGroupResponse>(data.clone())
119 .or_else(|_| op.output_list::<response::list_213::ServerGroupResponse>(data.clone()))
120 .or_else(|_| op.output_list::<response::list_215::ServerGroupResponse>(data.clone()))
121 .or_else(|_| op.output_list::<response::list_264::ServerGroupResponse>(data.clone()))?;
122 op.show_command_hint()?;
124 Ok(())
125 }
126}