openstack_cli_block_storage/v3/group/
enable_replication_338.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_cli_core::common::parse_key_val;
31use openstack_sdk::api::QueryAsync;
32use openstack_sdk::api::block_storage::v3::group::enable_replication_338;
33use serde_json::Value;
34
35#[derive(Args)]
37pub struct GroupCommand {
38 #[command(flatten)]
40 query: QueryParameters,
41
42 #[command(flatten)]
44 path: PathParameters,
45
46 #[arg(help_heading = "Body parameters", long, value_name="key=value", value_parser=parse_key_val::<String, Value>)]
47 enable_replication: Vec<(String, Value)>,
48}
49
50#[derive(Args)]
52struct QueryParameters {}
53
54#[derive(Args)]
56struct PathParameters {}
57
58impl GroupCommand {
59 pub async fn take_action<C: CliArgs>(
61 &self,
62 parsed_args: &C,
63 client: &mut AsyncOpenStack,
64 ) -> Result<(), OpenStackCliError> {
65 info!("Action Group");
66
67 let op = OutputProcessor::from_args(
68 parsed_args,
69 Some("block-storage.group"),
70 Some("enable_replication"),
71 );
72 op.validate_args(parsed_args)?;
73
74 let mut ep_builder = enable_replication_338::Request::builder();
75 ep_builder.header(
76 http::header::HeaderName::from_static("openstack-api-version"),
77 http::header::HeaderValue::from_static("volume 3.38"),
78 );
79
80 ep_builder.enable_replication(self.enable_replication.iter().cloned());
84
85 let ep = ep_builder
86 .build()
87 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
88 openstack_sdk::api::ignore(ep).query_async(client).await?;
89 op.show_command_hint()?;
91 Ok(())
92 }
93}