Merge pull request #124 from gtema/loadbalancer

feat: Add LoadBalancer

Author: gtema

doc/src/osc.md

@@ -30,6 +30,7 @@ use crate::catalog;
 use crate::compute::v2 as compute;
 use crate::identity::v3 as identity;
 use crate::image::v2 as image;
+use crate::load_balancer::v2 as load_balancer;
 use crate::network::v2 as network;
 use crate::object_store::v1 as object_store;
 
@@ -101,6 +102,7 @@ pub enum TopLevelCommands {
     Compute(compute::ComputeCommand),
     Identity(identity::IdentityCommand),
     Image(image::ImageCommand),
+    LoadBalancer(load_balancer::LoadBalancerCommand),
     Network(network::NetworkCommand),
     ObjectStore(object_store::ObjectStoreCommand),
 }
@@ -116,6 +118,7 @@ impl Cli {
             TopLevelCommands::Compute(args) => args.take_action(self, client).await,
             TopLevelCommands::Identity(args) => args.take_action(self, client).await,
             TopLevelCommands::Image(args) => args.take_action(self, client).await,
+            TopLevelCommands::LoadBalancer(args) => args.take_action(self, client).await,
             TopLevelCommands::Network(args) => args.take_action(self, client).await,
             TopLevelCommands::ObjectStore(args) => args.take_action(self, client).await,
         }

openstack_cli/src/cli.rs

@@ -30,6 +30,7 @@ mod common;
 mod compute;
 mod identity;
 mod image;
+mod load_balancer;
 mod network;
 mod object_store;
 

openstack_cli/src/lib.rs

@@ -0,0 +1,16 @@
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+// SPDX-License-Identifier: Apache-2.0
+
+//! Load Balancer (Octavia) commands
+pub(super) mod v2;

openstack_cli/src/load_balancer/mod.rs

@@ -0,0 +1,66 @@
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+// SPDX-License-Identifier: Apache-2.0
+
+//! Octavia `Amphorae` resource commands
+
+use clap::{Parser, Subcommand};
+
+use openstack_sdk::AsyncOpenStack;
+
+use crate::{Cli, OpenStackCliError};
+
+mod config;
+mod delete;
+mod failover;
+mod list;
+mod show;
+mod stats;
+
+/// Amphorae (Octavia) commands
+#[derive(Parser)]
+pub struct AmphoraeCommand {
+    /// subcommand
+    #[command(subcommand)]
+    command: AmphoraeCommands,
+}
+
+/// Supported subcommands
+#[allow(missing_docs)]
+#[derive(Subcommand)]
+pub enum AmphoraeCommands {
+    Config(config::AmphoraeCommand),
+    Delete(delete::AmphoraeCommand),
+    Failover(failover::AmphoraeCommand),
+    List(list::AmphoraesCommand),
+    Show(show::AmphoraeCommand),
+    Stats(stats::AmphoraeCommand),
+}
+
+impl AmphoraeCommand {
+    /// Perform command action
+    pub async fn take_action(
+        &self,
+        parsed_args: &Cli,
+        session: &mut AsyncOpenStack,
+    ) -> Result<(), OpenStackCliError> {
+        match &self.command {
+            AmphoraeCommands::Config(cmd) => cmd.take_action(parsed_args, session).await,
+            AmphoraeCommands::Delete(cmd) => cmd.take_action(parsed_args, session).await,
+            AmphoraeCommands::Failover(cmd) => cmd.take_action(parsed_args, session).await,
+            AmphoraeCommands::List(cmd) => cmd.take_action(parsed_args, session).await,
+            AmphoraeCommands::Show(cmd) => cmd.take_action(parsed_args, session).await,
+            AmphoraeCommands::Stats(cmd) => cmd.take_action(parsed_args, session).await,
+        }
+    }
+}

openstack_cli/src/load_balancer/v2/amphorae.rs

@@ -0,0 +1,114 @@
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+// WARNING: This file is automatically generated from OpenAPI schema using
+// `openstack-codegenerator`.
+
+//! Action Amphorae command
+//!
+//! Wraps invoking of the `v2/octavia/amphorae/{amphora_id}/config` with `PUT` method
+
+use clap::Args;
+use serde::{Deserialize, Serialize};
+use tracing::info;
+
+use anyhow::Result;
+
+use openstack_sdk::AsyncOpenStack;
+
+use crate::output::OutputProcessor;
+use crate::Cli;
+use crate::OpenStackCliError;
+use crate::OutputConfig;
+use crate::StructTable;
+
+use crate::common::parse_key_val;
+use bytes::Bytes;
+use http::Response;
+use openstack_sdk::api::load_balancer::v2::amphorae::config;
+use openstack_sdk::api::RawQueryAsync;
+use serde_json::Value;
+use structable_derive::StructTable;
+
+/// Request of the octavia/amphorae/amphora_id/config:put operation
+///
+#[derive(Args)]
+#[command(about = "Configure Amphora")]
+pub struct AmphoraeCommand {
+    /// Request Query parameters
+    #[command(flatten)]
+    query: QueryParameters,
+
+    /// Path parameters
+    #[command(flatten)]
+    path: PathParameters,
+
+    #[arg(long="property", value_name="key=value", value_parser=parse_key_val::<String, Value>)]
+    #[arg(help_heading = "Body parameters")]
+    properties: Option<Vec<(String, Value)>>,
+}
+
+/// Query parameters
+#[derive(Args)]
+struct QueryParameters {}
+
+/// Path parameters
+#[derive(Args)]
+struct PathParameters {
+    /// amphora_id parameter for /v2/octavia/amphorae/{amphora_id}/config API
+    ///
+    #[arg(
+        help_heading = "Path parameters",
+        id = "path_param_amphora_id",
+        value_name = "AMPHORA_ID"
+    )]
+    amphora_id: String,
+}
+/// Amphorae response representation
+#[derive(Deserialize, Serialize, Clone, StructTable)]
+struct ResponseData {}
+
+impl AmphoraeCommand {
+    /// Perform command action
+    pub async fn take_action(
+        &self,
+        parsed_args: &Cli,
+        client: &mut AsyncOpenStack,
+    ) -> Result<(), OpenStackCliError> {
+        info!("Action Amphorae");
+
+        let op = OutputProcessor::from_args(parsed_args);
+        op.validate_args(parsed_args)?;
+
+        let mut ep_builder = config::Request::builder();
+
+        // Set path parameters
+        ep_builder.amphora_id(&self.path.amphora_id);
+        // Set query parameters
+        // Set body parameters
+        if let Some(properties) = &self.properties {
+            ep_builder.properties(properties.iter().cloned());
+        }
+
+        let ep = ep_builder
+            .build()
+            .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
+
+        let _rsp: Response<Bytes> = ep.raw_query_async(client).await?;
+        let data = ResponseData {};
+        // Maybe output some headers metadata
+        op.output_human::<ResponseData>(&data)?;
+        Ok(())
+    }
+}

openstack_cli/src/load_balancer/v2/amphorae/config.rs

@@ -0,0 +1,107 @@
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+// WARNING: This file is automatically generated from OpenAPI schema using
+// `openstack-codegenerator`.
+
+//! Delete Amphorae command
+//!
+//! Wraps invoking of the `v2/octavia/amphorae/{amphora_id}` with `DELETE` method
+
+use clap::Args;
+use serde::{Deserialize, Serialize};
+use tracing::info;
+
+use anyhow::Result;
+
+use openstack_sdk::AsyncOpenStack;
+
+use crate::output::OutputProcessor;
+use crate::Cli;
+use crate::OpenStackCliError;
+use crate::OutputConfig;
+use crate::StructTable;
+
+use bytes::Bytes;
+use http::Response;
+use openstack_sdk::api::load_balancer::v2::amphorae::delete;
+use openstack_sdk::api::RawQueryAsync;
+use structable_derive::StructTable;
+
+/// Removes an amphora and its associated configuration.
+///
+/// The API immediately purges any and all configuration data, depending on the
+/// configuration settings. You cannot recover it.
+///
+/// **New in version 2.20**
+///
+#[derive(Args)]
+#[command(about = "Remove an Amphora")]
+pub struct AmphoraeCommand {
+    /// Request Query parameters
+    #[command(flatten)]
+    query: QueryParameters,
+
+    /// Path parameters
+    #[command(flatten)]
+    path: PathParameters,
+}
+
+/// Query parameters
+#[derive(Args)]
+struct QueryParameters {}
+
+/// Path parameters
+#[derive(Args)]
+struct PathParameters {
+    /// amphora_id parameter for /v2/octavia/amphorae/{amphora_id} API
+    ///
+    #[arg(
+        help_heading = "Path parameters",
+        id = "path_param_amphora_id",
+        value_name = "AMPHORA_ID"
+    )]
+    amphora_id: String,
+}
+/// Amphorae response representation
+#[derive(Deserialize, Serialize, Clone, StructTable)]
+struct ResponseData {}
+
+impl AmphoraeCommand {
+    /// Perform command action
+    pub async fn take_action(
+        &self,
+        parsed_args: &Cli,
+        client: &mut AsyncOpenStack,
+    ) -> Result<(), OpenStackCliError> {
+        info!("Delete Amphorae");
+
+        let op = OutputProcessor::from_args(parsed_args);
+        op.validate_args(parsed_args)?;
+
+        let mut ep_builder = delete::Request::builder();
+
+        // Set path parameters
+        ep_builder.amphora_id(&self.path.amphora_id);
+        // Set query parameters
+        // Set body parameters
+
+        let ep = ep_builder
+            .build()
+            .map_err(|x| OpenStackCliError::EndpointBuild(x.to_string()))?;
+
+        let _rsp: Response<Bytes> = ep.raw_query_async(client).await?;
+        Ok(())
+    }
+}