openstack_cli/network/v2/qos/policy/minimum_packet_rate_rule/
set.rs1use clap::Args;
23use eyre::WrapErr;
24use tracing::info;
25
26use openstack_sdk::AsyncOpenStack;
27
28use crate::Cli;
29use crate::OpenStackCliError;
30use crate::output::OutputProcessor;
31
32use clap::ValueEnum;
33use openstack_sdk::api::QueryAsync;
34use openstack_sdk::api::network::v2::qos::policy::minimum_packet_rate_rule::set;
35use openstack_types::network::v2::qos::policy::minimum_packet_rate_rule::response::set::MinimumPacketRateRuleResponse;
36
37#[derive(Args)]
39pub struct MinimumPacketRateRuleCommand {
40 #[command(flatten)]
42 query: QueryParameters,
43
44 #[command(flatten)]
46 path: PathParameters,
47
48 #[command(flatten)]
49 minimum_packet_rate_rule: MinimumPacketRateRule,
50}
51
52#[derive(Args)]
54struct QueryParameters {}
55
56#[derive(Args)]
58struct PathParameters {
59 #[arg(
62 help_heading = "Path parameters",
63 id = "path_param_id",
64 value_name = "ID"
65 )]
66 id: String,
67
68 #[arg(
71 help_heading = "Path parameters",
72 id = "path_param_policy_id",
73 value_name = "POLICY_ID"
74 )]
75 policy_id: String,
76}
77
78#[derive(Clone, Eq, Ord, PartialEq, PartialOrd, ValueEnum)]
79enum Direction {
80 Any,
81 Egress,
82 Ingress,
83}
84
85#[derive(Args, Clone)]
87struct MinimumPacketRateRule {
88 #[arg(help_heading = "Body parameters", long)]
89 direction: Option<Direction>,
90
91 #[arg(help_heading = "Body parameters", long)]
92 min_kpps: Option<i32>,
93}
94
95impl MinimumPacketRateRuleCommand {
96 pub async fn take_action(
98 &self,
99 parsed_args: &Cli,
100 client: &mut AsyncOpenStack,
101 ) -> Result<(), OpenStackCliError> {
102 info!("Set MinimumPacketRateRule");
103
104 let op = OutputProcessor::from_args(
105 parsed_args,
106 Some("network.qos/policy/minimum_packet_rate_rule"),
107 Some("set"),
108 );
109 op.validate_args(parsed_args)?;
110
111 let mut ep_builder = set::Request::builder();
112
113 ep_builder.id(&self.path.id);
114 ep_builder.policy_id(&self.path.policy_id);
115
116 let args = &self.minimum_packet_rate_rule;
119 let mut minimum_packet_rate_rule_builder = set::MinimumPacketRateRuleBuilder::default();
120 if let Some(val) = &args.direction {
121 let tmp = match val {
122 Direction::Any => set::Direction::Any,
123 Direction::Egress => set::Direction::Egress,
124 Direction::Ingress => set::Direction::Ingress,
125 };
126 minimum_packet_rate_rule_builder.direction(tmp);
127 }
128
129 if let Some(val) = &args.min_kpps {
130 minimum_packet_rate_rule_builder.min_kpps(*val);
131 }
132
133 ep_builder.minimum_packet_rate_rule(
134 minimum_packet_rate_rule_builder
135 .build()
136 .wrap_err("error preparing the request data")?,
137 );
138
139 let ep = ep_builder
140 .build()
141 .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
142
143 let data = ep.query_async(client).await?;
144 op.output_single::<MinimumPacketRateRuleResponse>(data)?;
145 op.show_command_hint()?;
147 Ok(())
148 }
149}