openstack_cli_network/v2/subnet/
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::subnet::list;
32use openstack_sdk::api::{Pagination, paged};
33use openstack_types::network::v2::subnet::response;
34
35#[derive(Args)]
59#[command(about = "List subnets")]
60pub struct SubnetsCommand {
61 #[command(flatten)]
63 query: QueryParameters,
64
65 #[command(flatten)]
67 path: PathParameters,
68
69 #[arg(long, default_value_t = 10000)]
71 max_items: usize,
72}
73
74#[derive(Args)]
76struct QueryParameters {
77 #[arg(help_heading = "Query parameters", long)]
79 cidr: Option<String>,
80
81 #[arg(help_heading = "Query parameters", long)]
83 description: Option<String>,
84
85 #[arg(action=clap::ArgAction::Set, help_heading = "Query parameters", long)]
87 enable_dhcp: Option<bool>,
88
89 #[arg(help_heading = "Query parameters", long)]
91 gateway_ip: Option<String>,
92
93 #[arg(help_heading = "Query parameters", long)]
95 id: Option<String>,
96
97 #[arg(help_heading = "Query parameters", long)]
99 ip_version: Option<i32>,
100
101 #[arg(help_heading = "Query parameters", long, value_parser = ["dhcpv6-stateful","dhcpv6-stateless","slaac"])]
103 ipv6_address_mode: Option<String>,
104
105 #[arg(help_heading = "Query parameters", long, value_parser = ["dhcpv6-stateful","dhcpv6-stateless","slaac"])]
107 ipv6_ra_mode: Option<String>,
108
109 #[arg(
114 help_heading = "Query parameters",
115 long("page-size"),
116 visible_alias("limit")
117 )]
118 limit: Option<u32>,
119
120 #[arg(help_heading = "Query parameters", long)]
124 marker: Option<String>,
125
126 #[arg(help_heading = "Query parameters", long)]
128 name: Option<String>,
129
130 #[arg(help_heading = "Query parameters", long)]
132 network_id: Option<String>,
133
134 #[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
136 not_tags: Option<Vec<String>>,
137
138 #[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
140 not_tags_any: Option<Vec<String>>,
141
142 #[arg(action=clap::ArgAction::Set, help_heading = "Query parameters", long)]
144 page_reverse: Option<bool>,
145
146 #[arg(help_heading = "Query parameters", long)]
148 revision_number: Option<String>,
149
150 #[arg(action=clap::ArgAction::Set, help_heading = "Query parameters", long)]
152 router_external: Option<bool>,
153
154 #[arg(help_heading = "Query parameters", long)]
156 segment_id: Option<String>,
157
158 #[arg(action=clap::ArgAction::Set, help_heading = "Query parameters", long)]
160 shared: Option<bool>,
161
162 #[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
165 sort_dir: Option<Vec<String>>,
166
167 #[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
170 sort_key: Option<Vec<String>>,
171
172 #[arg(help_heading = "Query parameters", long)]
174 subnetpool_id: Option<String>,
175
176 #[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
178 tags: Option<Vec<String>>,
179
180 #[arg(action=clap::ArgAction::Append, help_heading = "Query parameters", long)]
182 tags_any: Option<Vec<String>>,
183
184 #[arg(help_heading = "Query parameters", long)]
186 tenant_id: Option<String>,
187}
188
189#[derive(Args)]
191struct PathParameters {}
192
193impl SubnetsCommand {
194 pub async fn take_action<C: CliArgs>(
196 &self,
197 parsed_args: &C,
198 client: &mut AsyncOpenStack,
199 ) -> Result<(), OpenStackCliError> {
200 info!("List Subnets");
201
202 let op = OutputProcessor::from_args(parsed_args, Some("network.subnet"), Some("list"));
203 op.validate_args(parsed_args)?;
204
205 let mut ep_builder = list::Request::builder();
206
207 if let Some(val) = &self.query.limit {
209 ep_builder.limit(*val);
210 }
211 if let Some(val) = &self.query.marker {
212 ep_builder.marker(val);
213 }
214 if let Some(val) = &self.query.page_reverse {
215 ep_builder.page_reverse(*val);
216 }
217 if let Some(val) = &self.query.sort_dir {
218 ep_builder.sort_dir(val.iter());
219 }
220 if let Some(val) = &self.query.sort_key {
221 ep_builder.sort_key(val.iter());
222 }
223 if let Some(val) = &self.query.cidr {
224 ep_builder.cidr(val);
225 }
226 if let Some(val) = &self.query.description {
227 ep_builder.description(val);
228 }
229 if let Some(val) = &self.query.enable_dhcp {
230 ep_builder.enable_dhcp(*val);
231 }
232 if let Some(val) = &self.query.gateway_ip {
233 ep_builder.gateway_ip(val);
234 }
235 if let Some(val) = &self.query.id {
236 ep_builder.id(val);
237 }
238 if let Some(val) = &self.query.ip_version {
239 ep_builder.ip_version(*val);
240 }
241 if let Some(val) = &self.query.ipv6_address_mode {
242 ep_builder.ipv6_address_mode(val);
243 }
244 if let Some(val) = &self.query.ipv6_ra_mode {
245 ep_builder.ipv6_ra_mode(val);
246 }
247 if let Some(val) = &self.query.name {
248 ep_builder.name(val);
249 }
250 if let Some(val) = &self.query.network_id {
251 ep_builder.network_id(val);
252 }
253 if let Some(val) = &self.query.not_tags {
254 ep_builder.not_tags(val.iter());
255 }
256 if let Some(val) = &self.query.not_tags_any {
257 ep_builder.not_tags_any(val.iter());
258 }
259 if let Some(val) = &self.query.revision_number {
260 ep_builder.revision_number(val);
261 }
262 if let Some(val) = &self.query.router_external {
263 ep_builder.router_external(*val);
264 }
265 if let Some(val) = &self.query.segment_id {
266 ep_builder.segment_id(val);
267 }
268 if let Some(val) = &self.query.shared {
269 ep_builder.shared(*val);
270 }
271 if let Some(val) = &self.query.subnetpool_id {
272 ep_builder.subnetpool_id(val);
273 }
274 if let Some(val) = &self.query.tags {
275 ep_builder.tags(val.iter());
276 }
277 if let Some(val) = &self.query.tags_any {
278 ep_builder.tags_any(val.iter());
279 }
280 if let Some(val) = &self.query.tenant_id {
281 ep_builder.tenant_id(val);
282 }
283
284 let ep = ep_builder
285 .build()
286 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
287
288 let data: Vec<serde_json::Value> = paged(ep, Pagination::Limit(self.max_items))
289 .query_async(client)
290 .await?;
291
292 op.output_list::<response::list::SubnetResponse>(data.clone())?;
293 op.show_command_hint()?;
295 Ok(())
296 }
297}