openstack_cli_network/v2/floatingip_pool/
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::network::v2::floatingip_pool::list;
32use openstack_sdk::api::{Pagination, paged};
33use openstack_types::network::v2::floatingip_pool::response;
34
35#[derive(Args)]
37pub struct FloatingipPoolsCommand {
38 #[command(flatten)]
40 query: QueryParameters,
41
42 #[command(flatten)]
44 path: PathParameters,
45
46 #[arg(long, default_value_t = 10000)]
48 max_items: usize,
49}
50
51#[derive(Args)]
53struct QueryParameters {
54 #[arg(
59 help_heading = "Query parameters",
60 long("page-size"),
61 visible_alias("limit")
62 )]
63 limit: Option<u32>,
64
65 #[arg(help_heading = "Query parameters", long)]
69 marker: Option<String>,
70
71 #[arg(action=clap::ArgAction::Set, help_heading = "Query parameters", long)]
73 page_reverse: Option<bool>,
74
75 #[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
78 sort_dir: Option<Vec<String>>,
79
80 #[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
83 sort_key: Option<Vec<String>>,
84}
85
86#[derive(Args)]
88struct PathParameters {}
89
90impl FloatingipPoolsCommand {
91 pub async fn take_action<C: CliArgs>(
93 &self,
94 parsed_args: &C,
95 client: &mut AsyncOpenStack,
96 ) -> Result<(), OpenStackCliError> {
97 info!("List FloatingipPools");
98
99 let op =
100 OutputProcessor::from_args(parsed_args, Some("network.floatingip_pool"), Some("list"));
101 op.validate_args(parsed_args)?;
102
103 let mut ep_builder = list::Request::builder();
104
105 if let Some(val) = &self.query.limit {
107 ep_builder.limit(*val);
108 }
109 if let Some(val) = &self.query.marker {
110 ep_builder.marker(val);
111 }
112 if let Some(val) = &self.query.page_reverse {
113 ep_builder.page_reverse(*val);
114 }
115 if let Some(val) = &self.query.sort_dir {
116 ep_builder.sort_dir(val.iter());
117 }
118 if let Some(val) = &self.query.sort_key {
119 ep_builder.sort_key(val.iter());
120 }
121
122 let ep = ep_builder
123 .build()
124 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
125
126 let data: Vec<serde_json::Value> = paged(ep, Pagination::Limit(self.max_items))
127 .query_async(client)
128 .await?;
129
130 op.output_list::<response::list::FloatingipPoolResponse>(data.clone())?;
131 op.show_command_hint()?;
133 Ok(())
134 }
135}