foundation_deployment_docker 0.1.1

//! Auto-generated API module for docker services.
//!
//! Generated by `cargo run --bin ewe_platform gen_api`.
//! DO NOT EDIT MANUALLY.
//!
//! Feature flag: `docker_services `

#![cfg(feature = "docker_services")]
#![allow(clippy::too_many_arguments, clippy::type_complexity)]
#![allow(clippy::missing_errors_doc, clippy::doc_markdown, clippy::useless_format)]
#![allow(unused_imports)]

use foundation_netio::{DynNetClient, PreparedRequestBuilder};
use foundation_netio::shared::client::http_client::HttpClient;
use serde::{Deserialize, Serialize};
use foundation_macros::JsonHash;

// Import shared types used by this module
use super::shared::ObjectVersion;

use super::shared::ApiResponse;

// =============================================================================
// TYPE DECLARATIONS
// =============================================================================

/// `Service` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct Service {
    /// CreatedAt property.
    #[serde(rename = "CreatedAt")]
    pub created_at: Option<String>,
    /// Endpoint property.
    #[serde(rename = "Endpoint")]
    pub endpoint: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// ID property.
    #[serde(rename = "ID")]
    pub id: Option<String>,
    /// JobStatus property.
    #[serde(rename = "JobStatus")]
    pub job_status: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// ServiceStatus property.
    #[serde(rename = "ServiceStatus")]
    pub service_status: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// Spec property.
    #[serde(rename = "Spec")]
    pub spec: Option<ServiceSpec>,
    /// UpdateStatus property.
    #[serde(rename = "UpdateStatus")]
    pub update_status: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// UpdatedAt property.
    #[serde(rename = "UpdatedAt")]
    pub updated_at: Option<String>,
    /// Version property.
    #[serde(rename = "Version")]
    pub version: Option<ObjectVersion>,
}

/// `NetworkAttachmentConfig` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NetworkAttachmentConfig {
    /// Aliases property.
    #[serde(rename = "Aliases")]
    pub aliases: Option<Vec<String>>,
    /// DriverOpts property.
    #[serde(rename = "DriverOpts")]
    pub driver_opts: Option<serde_json::Value>,
    /// Target property.
    #[serde(rename = "Target")]
    pub target: Option<String>,
}

/// `HealthConfig` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct HealthConfig {
    /// Interval property.
    #[serde(rename = "Interval")]
    pub interval: Option<i64>,
    /// Retries property.
    #[serde(rename = "Retries")]
    pub retries: Option<i64>,
    /// StartInterval property.
    #[serde(rename = "StartInterval")]
    pub start_interval: Option<i64>,
    /// StartPeriod property.
    #[serde(rename = "StartPeriod")]
    pub start_period: Option<i64>,
    /// Test property.
    #[serde(rename = "Test")]
    pub test: Option<Vec<String>>,
    /// Timeout property.
    #[serde(rename = "Timeout")]
    pub timeout: Option<i64>,
}

/// `TaskSpec` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TaskSpec {
    /// ContainerSpec property.
    #[serde(rename = "ContainerSpec")]
    pub container_spec: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// ForceUpdate property.
    #[serde(rename = "ForceUpdate")]
    pub force_update: Option<i64>,
    /// LogDriver property.
    #[serde(rename = "LogDriver")]
    pub log_driver: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// NetworkAttachmentSpec property.
    #[serde(rename = "NetworkAttachmentSpec")]
    pub network_attachment_spec: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// Networks property.
    #[serde(rename = "Networks")]
    pub networks: Option<Vec<NetworkAttachmentConfig>>,
    /// Placement property.
    #[serde(rename = "Placement")]
    pub placement: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// PluginSpec property.
    #[serde(rename = "PluginSpec")]
    pub plugin_spec: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// Resources property.
    #[serde(rename = "Resources")]
    pub resources: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// RestartPolicy property.
    #[serde(rename = "RestartPolicy")]
    pub restart_policy: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// Runtime property.
    #[serde(rename = "Runtime")]
    pub runtime: Option<String>,
}

/// `Mount` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct Mount {
    /// BindOptions property.
    #[serde(rename = "BindOptions")]
    pub bind_options: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// Consistency property.
    #[serde(rename = "Consistency")]
    pub consistency: Option<String>,
    /// ImageOptions property.
    #[serde(rename = "ImageOptions")]
    pub image_options: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// ReadOnly property.
    #[serde(rename = "ReadOnly")]
    pub read_only: Option<bool>,
    /// Source property.
    #[serde(rename = "Source")]
    pub source: Option<String>,
    /// Target property.
    #[serde(rename = "Target")]
    pub target: Option<String>,
    /// TmpfsOptions property.
    #[serde(rename = "TmpfsOptions")]
    pub tmpfs_options: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// Type property.
    #[serde(rename = "Type")]
    pub r#type: Option<serde_json::Value>,
    /// VolumeOptions property.
    #[serde(rename = "VolumeOptions")]
    pub volume_options: Option<std::collections::HashMap<String, serde_json::Value>>,
}

/// `Platform` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct Platform {
    /// Architecture property.
    #[serde(rename = "Architecture")]
    pub architecture: Option<String>,
    /// OS property.
    #[serde(rename = "OS")]
    pub os: Option<String>,
}

/// `GenericResources` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct GenericResources {
    #[serde(flatten)]
    pub data: std::collections::HashMap<String, serde_json::Value>,
}

/// `EndpointSpec` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct EndpointSpec {
    /// Mode property.
    #[serde(rename = "Mode")]
    pub mode: Option<String>,
    /// Ports property.
    #[serde(rename = "Ports")]
    pub ports: Option<Vec<EndpointPortConfig>>,
}

/// `EndpointPortConfig` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct EndpointPortConfig {
    /// Name property.
    #[serde(rename = "Name")]
    pub name: Option<String>,
    /// Protocol property.
    #[serde(rename = "Protocol")]
    pub protocol: Option<String>,
    /// PublishMode property.
    #[serde(rename = "PublishMode")]
    pub publish_mode: Option<String>,
    /// PublishedPort property.
    #[serde(rename = "PublishedPort")]
    pub published_port: Option<i64>,
    /// TargetPort property.
    #[serde(rename = "TargetPort")]
    pub target_port: Option<i64>,
}

/// `PluginPrivilege` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct PluginPrivilege {
    /// Description property.
    #[serde(rename = "Description")]
    pub description: Option<String>,
    /// Name property.
    #[serde(rename = "Name")]
    pub name: Option<String>,
    /// Value property.
    #[serde(rename = "Value")]
    pub value: Option<Vec<String>>,
}

/// `ServiceSpec` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ServiceSpec {
    /// EndpointSpec property.
    #[serde(rename = "EndpointSpec")]
    pub endpoint_spec: Option<EndpointSpec>,
    /// Labels property.
    #[serde(rename = "Labels")]
    pub labels: Option<serde_json::Value>,
    /// Mode property.
    #[serde(rename = "Mode")]
    pub mode: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// Name property.
    #[serde(rename = "Name")]
    pub name: Option<String>,
    /// Networks property.
    #[serde(rename = "Networks")]
    pub networks: Option<Vec<NetworkAttachmentConfig>>,
    /// RollbackConfig property.
    #[serde(rename = "RollbackConfig")]
    pub rollback_config: Option<std::collections::HashMap<String, serde_json::Value>>,
    /// TaskTemplate property.
    #[serde(rename = "TaskTemplate")]
    pub task_template: Option<TaskSpec>,
    /// UpdateConfig property.
    #[serde(rename = "UpdateConfig")]
    pub update_config: Option<std::collections::HashMap<String, serde_json::Value>>,
}

/// `ResourceObject` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ResourceObject {
    /// GenericResources property.
    #[serde(rename = "GenericResources")]
    pub generic_resources: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
    /// MemoryBytes property.
    #[serde(rename = "MemoryBytes")]
    pub memory_bytes: Option<i64>,
    /// NanoCPUs property.
    #[serde(rename = "NanoCPUs")]
    pub nano_cp_us: Option<i64>,
}

/// `Limit` type.
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct Limit {
    /// MemoryBytes property.
    #[serde(rename = "MemoryBytes")]
    pub memory_bytes: Option<i64>,
    /// NanoCPUs property.
    #[serde(rename = "NanoCPUs")]
    pub nano_cp_us: Option<i64>,
    /// Pids property.
    #[serde(rename = "Pids")]
    pub pids: Option<i64>,
}

// =============================================================================
// ARGS TYPES (per-endpoint)
// =============================================================================

/// Arguments for [`ServiceList_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ServiceListArgs {
    /// Query parameter: `filters`.
    pub filters: Option<String>,
    /// Query parameter: `status`.
    pub status: Option<String>,
}

/// Arguments for [`ServiceInspect_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ServiceInspectArgs {
    /// Path parameter: `id`.
    pub id: String,
    /// Query parameter: `insertDefaults`.
    pub insert_defaults: Option<String>,
}

/// Arguments for [`ServiceDelete_request`].
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ServiceDeleteArgs {
    /// Path parameter: `id`.
    pub id: String,
}

// =============================================================================
// CLIENT FUNCTIONS (per-endpoint)
// =============================================================================

// -----------------------------------------------------------------------------
// GET /services
// -----------------------------------------------------------------------------

/// GET /services.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = service_list_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn service_list_request<F>(
    client: DynNetClient,
    args: &ServiceListArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<serde_json::Value>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/services",
    );
    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());
    builder = builder.query("status", args.status.as_deref());

    if let Some(f) = builder_mod {
        f(&mut builder);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body: None });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: serde_json::Value = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// GET /services/{id}
// -----------------------------------------------------------------------------

/// GET /services/{id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = service_inspect_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn service_inspect_request<F>(
    client: DynNetClient,
    args: &ServiceInspectArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<Service>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/services/{}",
        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("insertDefaults", args.insert_defaults.as_deref());

    if let Some(f) = builder_mod {
        f(&mut builder);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body: None });
    }
    let body_bytes = foundation_netio::shared::client::body_reader::collect_bytes_from_send_safe(response.take_body());
    let parsed: Service = serde_json::from_slice(&body_bytes).map_err(|e: serde_json::Error| super::shared::ApiError::ParseFailed(e.to_string()))?;
    Ok(ApiResponse { status: status as u16, headers, body: parsed })
}

// -----------------------------------------------------------------------------
// DELETE /services/{id}
// -----------------------------------------------------------------------------

/// DELETE /services/{id}.
///
/// Takes a `DynNetClient` and args, builds the request, optionally applies
/// modifications, then sends it via `send_async().await`.
///
/// # Arguments
///
/// * `client` - HTTP client for making the request
/// * `args` - Request arguments (path params, query params, body)
/// * `builder_mod` - Optional closure to modify the request builder (e.g., add headers)
///
/// # Example
///
/// ```ignore
/// let response = service_delete_request(client.clone(), &args, Some(|b: &mut PreparedRequestBuilder| {
///     b.header("X-Custom-Header", "value");
/// })).await?;
/// ```
pub async fn service_delete_request<F>(
    client: DynNetClient,
    args: &ServiceDeleteArgs,
    base_url: &str,
    builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
    F: FnOnce(&mut PreparedRequestBuilder),
{
    let path = format!("/services/{}",
        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);
    }

    let response = client.send_async(builder.build()).await
        .map_err(|e| super::shared::ApiError::RequestSendFailed(e.to_string()))?;

    let status: usize = response.get_status().into();
    let headers = response.get_headers_ref().clone();
    if status < 200 || status >= 300 {
        return Err(super::shared::ApiError::HttpStatus { code: status as u16, headers, body: None });
    }
    Ok(ApiResponse { status: status as u16, headers, body: () })
}