#![cfg(feature = "docker_networks")]
#![allow(clippy::too_many_arguments, clippy::type_complexity)]
#![allow(
clippy::missing_errors_doc,
clippy::doc_markdown,
clippy::useless_format
)]
#![allow(unused_imports)]
use foundation_macros::JsonHash;
use foundation_netio::shared::client::http_client::HttpClient;
use foundation_netio::{DynNetClient, PreparedRequestBuilder};
use serde::{Deserialize, Serialize};
use super::shared::ApiResponse;
pub type ConfigReference = super::shared::NetworkObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct IPAM {
#[serde(rename = "Config")]
pub config: Option<Vec<IPAMConfig>>,
#[serde(rename = "Driver")]
pub driver: Option<String>,
#[serde(rename = "Options")]
pub options: Option<serde_json::Value>,
}
pub type IPAMConfig = super::shared::IPAMConfigShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct IPAMStatus {
#[serde(rename = "Subnets")]
pub subnets: Option<serde_json::Value>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct Network {
#[serde(rename = "Attachable")]
pub attachable: Option<bool>,
#[serde(rename = "ConfigFrom")]
pub config_from: Option<ConfigReference>,
#[serde(rename = "ConfigOnly")]
pub config_only: Option<bool>,
#[serde(rename = "Created")]
pub created: Option<String>,
#[serde(rename = "Driver")]
pub driver: Option<String>,
#[serde(rename = "EnableIPv4")]
pub enable_i_pv4: Option<bool>,
#[serde(rename = "EnableIPv6")]
pub enable_i_pv6: Option<bool>,
#[serde(rename = "IPAM")]
pub ipam: Option<IPAM>,
#[serde(rename = "Id")]
pub id: Option<String>,
#[serde(rename = "Ingress")]
pub ingress: Option<bool>,
#[serde(rename = "Internal")]
pub internal: Option<bool>,
#[serde(rename = "Labels")]
pub labels: Option<serde_json::Value>,
#[serde(rename = "Name")]
pub name: Option<String>,
#[serde(rename = "Options")]
pub options: Option<serde_json::Value>,
#[serde(rename = "Peers")]
pub peers: Option<Vec<PeerInfo>>,
#[serde(rename = "Scope")]
pub scope: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NetworkInspect {
#[serde(rename = "Attachable")]
pub attachable: Option<bool>,
#[serde(rename = "ConfigFrom")]
pub config_from: Option<ConfigReference>,
#[serde(rename = "ConfigOnly")]
pub config_only: Option<bool>,
#[serde(rename = "Created")]
pub created: Option<String>,
#[serde(rename = "Driver")]
pub driver: Option<String>,
#[serde(rename = "EnableIPv4")]
pub enable_i_pv4: Option<bool>,
#[serde(rename = "EnableIPv6")]
pub enable_i_pv6: Option<bool>,
#[serde(rename = "Id")]
pub id: Option<String>,
#[serde(rename = "Ingress")]
pub ingress: Option<bool>,
#[serde(rename = "Internal")]
pub internal: Option<bool>,
#[serde(rename = "IPAM")]
pub ipam: Option<IPAM>,
#[serde(rename = "Labels")]
pub labels: Option<serde_json::Value>,
#[serde(rename = "Name")]
pub name: Option<String>,
#[serde(rename = "Options")]
pub options: Option<serde_json::Value>,
#[serde(rename = "Peers")]
pub peers: Option<Vec<PeerInfo>>,
#[serde(rename = "Scope")]
pub scope: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NetworkStatus {
#[serde(rename = "IPAM")]
pub ipam: Option<IPAMStatus>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PeerInfo {
#[serde(rename = "IP")]
pub ip: Option<String>,
#[serde(rename = "Name")]
pub name: Option<String>,
}
pub type NetworkListArgs = super::shared::FiltersArgs;
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NetworkInspectArgs {
pub id: String,
pub verbose: Option<String>,
pub scope: Option<String>,
}
pub type NetworkDeleteArgs = super::shared::IdArgs;
pub async fn network_list_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NetworkListArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<serde_json::Value>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/networks",);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("filters", args.filters.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn network_inspect_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NetworkInspectArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NetworkInspect>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/networks/{}", args.id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::get(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("verbose", args.verbose.as_deref());
builder = builder.query("scope", args.scope.as_deref());
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn network_delete_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NetworkDeleteArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/networks/{}", args.id,);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::delete(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_without_body(client.into(), builder.build()).await
}