#![cfg(feature = "docker_create")]
#![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::ClusterVolume;
use super::shared::ClusterVolumeSpec;
use super::shared::ErrorDetail;
use super::shared::IDResponse;
use super::shared::ObjectVersion;
use super::shared::ProgressDetail;
use super::shared::Topology;
use super::shared::Volume;
use super::shared::ApiResponse;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ConfigCreateRequest {
#[serde(rename = "Data")]
pub data: Option<String>,
#[serde(rename = "Labels")]
pub labels: Option<serde_json::Value>,
#[serde(rename = "Name")]
pub name: Option<String>,
#[serde(rename = "Templating")]
pub templating: Option<Driver>,
}
pub type ConfigReference = super::shared::NetworkObject;
pub type ConfigSpec = ConfigCreateRequest;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ContainerConfig {
#[serde(rename = "ArgsEscaped")]
pub args_escaped: Option<bool>,
#[serde(rename = "AttachStderr")]
pub attach_stderr: Option<bool>,
#[serde(rename = "AttachStdin")]
pub attach_stdin: Option<bool>,
#[serde(rename = "AttachStdout")]
pub attach_stdout: Option<bool>,
#[serde(rename = "Cmd")]
pub cmd: Option<Vec<String>>,
#[serde(rename = "Domainname")]
pub domainname: Option<String>,
#[serde(rename = "Entrypoint")]
pub entrypoint: Option<Vec<String>>,
#[serde(rename = "Env")]
pub env: Option<Vec<String>>,
#[serde(rename = "ExposedPorts")]
pub exposed_ports: Option<serde_json::Value>,
#[serde(rename = "Healthcheck")]
pub healthcheck: Option<HealthConfig>,
#[serde(rename = "Hostname")]
pub hostname: Option<String>,
#[serde(rename = "Image")]
pub image: Option<String>,
#[serde(rename = "Labels")]
pub labels: Option<serde_json::Value>,
#[serde(rename = "NetworkDisabled")]
pub network_disabled: Option<bool>,
#[serde(rename = "OnBuild")]
pub on_build: Option<Vec<String>>,
#[serde(rename = "OpenStdin")]
pub open_stdin: Option<bool>,
#[serde(rename = "Shell")]
pub shell: Option<Vec<String>>,
#[serde(rename = "StdinOnce")]
pub stdin_once: Option<bool>,
#[serde(rename = "StopSignal")]
pub stop_signal: Option<String>,
#[serde(rename = "StopTimeout")]
pub stop_timeout: Option<i64>,
#[serde(rename = "Tty")]
pub tty: Option<bool>,
#[serde(rename = "User")]
pub user: Option<String>,
#[serde(rename = "Volumes")]
pub volumes: Option<serde_json::Value>,
#[serde(rename = "WorkingDir")]
pub working_dir: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ContainerCreateRequest {
#[serde(rename = "ArgsEscaped")]
pub args_escaped: Option<bool>,
#[serde(rename = "AttachStderr")]
pub attach_stderr: Option<bool>,
#[serde(rename = "AttachStdin")]
pub attach_stdin: Option<bool>,
#[serde(rename = "AttachStdout")]
pub attach_stdout: Option<bool>,
#[serde(rename = "Cmd")]
pub cmd: Option<Vec<String>>,
#[serde(rename = "Domainname")]
pub domainname: Option<String>,
#[serde(rename = "Entrypoint")]
pub entrypoint: Option<Vec<String>>,
#[serde(rename = "Env")]
pub env: Option<Vec<String>>,
#[serde(rename = "ExposedPorts")]
pub exposed_ports: Option<serde_json::Value>,
#[serde(rename = "Healthcheck")]
pub healthcheck: Option<HealthConfig>,
#[serde(rename = "HostConfig")]
pub host_config: Option<HostConfig>,
#[serde(rename = "Hostname")]
pub hostname: Option<String>,
#[serde(rename = "Image")]
pub image: Option<String>,
#[serde(rename = "Labels")]
pub labels: Option<serde_json::Value>,
#[serde(rename = "NetworkDisabled")]
pub network_disabled: Option<bool>,
#[serde(rename = "NetworkingConfig")]
pub networking_config: Option<NetworkingConfig>,
#[serde(rename = "OnBuild")]
pub on_build: Option<Vec<String>>,
#[serde(rename = "OpenStdin")]
pub open_stdin: Option<bool>,
#[serde(rename = "Shell")]
pub shell: Option<Vec<String>>,
#[serde(rename = "StdinOnce")]
pub stdin_once: Option<bool>,
#[serde(rename = "StopSignal")]
pub stop_signal: Option<String>,
#[serde(rename = "StopTimeout")]
pub stop_timeout: Option<i64>,
#[serde(rename = "Tty")]
pub tty: Option<bool>,
#[serde(rename = "User")]
pub user: Option<String>,
#[serde(rename = "Volumes")]
pub volumes: Option<serde_json::Value>,
#[serde(rename = "WorkingDir")]
pub working_dir: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ContainerCreateResponse {
#[serde(rename = "Id")]
pub id: String,
#[serde(rename = "Warnings")]
pub warnings: Vec<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct CreateImageInfo {
#[serde(rename = "errorDetail")]
pub error_detail: Option<ErrorDetail>,
pub id: Option<String>,
#[serde(rename = "progressDetail")]
pub progress_detail: Option<ProgressDetail>,
pub status: Option<String>,
}
pub type DeviceMapping = super::shared::CgroupPermissionsPathInContainerPathOnHostObject;
pub type DeviceRequest = super::shared::DeviceRequestShape;
pub type Driver = super::shared::NameOptionsObject;
pub type EndpointPortConfig = super::shared::EndpointPortConfigShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct EndpointSpec {
#[serde(rename = "Mode")]
pub mode: Option<String>,
#[serde(rename = "Ports")]
pub ports: Option<Vec<EndpointPortConfig>>,
}
pub type GenericResources = Vec<std::collections::HashMap<String, serde_json::Value>>;
pub type HealthConfig = super::shared::HealthConfigShape;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct HostConfig {
#[serde(rename = "Annotations")]
pub annotations: Option<serde_json::Value>,
#[serde(rename = "AutoRemove")]
pub auto_remove: Option<bool>,
#[serde(rename = "Binds")]
pub binds: Option<Vec<String>>,
#[serde(rename = "BlkioDeviceReadBps")]
pub blkio_device_read_bps: Option<Vec<ThrottleDevice>>,
#[serde(rename = "BlkioDeviceReadIOps")]
pub blkio_device_read_i_ops: Option<Vec<ThrottleDevice>>,
#[serde(rename = "BlkioDeviceWriteBps")]
pub blkio_device_write_bps: Option<Vec<ThrottleDevice>>,
#[serde(rename = "BlkioDeviceWriteIOps")]
pub blkio_device_write_i_ops: Option<Vec<ThrottleDevice>>,
#[serde(rename = "BlkioWeight")]
pub blkio_weight: Option<i64>,
#[serde(rename = "BlkioWeightDevice")]
pub blkio_weight_device: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
#[serde(rename = "CapAdd")]
pub cap_add: Option<Vec<String>>,
#[serde(rename = "CapDrop")]
pub cap_drop: Option<Vec<String>>,
#[serde(rename = "Cgroup")]
pub cgroup: Option<String>,
#[serde(rename = "CgroupParent")]
pub cgroup_parent: Option<String>,
#[serde(rename = "CgroupnsMode")]
pub cgroupns_mode: Option<String>,
#[serde(rename = "ConsoleSize")]
pub console_size: Option<Vec<i64>>,
#[serde(rename = "ContainerIDFile")]
pub container_id_file: Option<String>,
#[serde(rename = "CpuCount")]
pub cpu_count: Option<i64>,
#[serde(rename = "CpuPercent")]
pub cpu_percent: Option<i64>,
#[serde(rename = "CpuPeriod")]
pub cpu_period: Option<i64>,
#[serde(rename = "CpuQuota")]
pub cpu_quota: Option<i64>,
#[serde(rename = "CpuRealtimePeriod")]
pub cpu_realtime_period: Option<i64>,
#[serde(rename = "CpuRealtimeRuntime")]
pub cpu_realtime_runtime: Option<i64>,
#[serde(rename = "CpuShares")]
pub cpu_shares: Option<i64>,
#[serde(rename = "CpusetCpus")]
pub cpuset_cpus: Option<String>,
#[serde(rename = "CpusetMems")]
pub cpuset_mems: Option<String>,
#[serde(rename = "DeviceCgroupRules")]
pub device_cgroup_rules: Option<Vec<String>>,
#[serde(rename = "DeviceRequests")]
pub device_requests: Option<Vec<DeviceRequest>>,
#[serde(rename = "Devices")]
pub devices: Option<Vec<DeviceMapping>>,
#[serde(rename = "Dns")]
pub dns: Option<Vec<String>>,
#[serde(rename = "DnsOptions")]
pub dns_options: Option<Vec<String>>,
#[serde(rename = "DnsSearch")]
pub dns_search: Option<Vec<String>>,
#[serde(rename = "ExtraHosts")]
pub extra_hosts: Option<Vec<String>>,
#[serde(rename = "GroupAdd")]
pub group_add: Option<Vec<String>>,
#[serde(rename = "Init")]
pub init: Option<bool>,
#[serde(rename = "IOMaximumBandwidth")]
pub io_maximum_bandwidth: Option<i64>,
#[serde(rename = "IOMaximumIOps")]
pub io_maximum_i_ops: Option<i64>,
#[serde(rename = "IpcMode")]
pub ipc_mode: Option<String>,
#[serde(rename = "Isolation")]
pub isolation: Option<String>,
#[serde(rename = "Links")]
pub links: Option<Vec<String>>,
#[serde(rename = "LogConfig")]
pub log_config: Option<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "MaskedPaths")]
pub masked_paths: Option<Vec<String>>,
#[serde(rename = "Memory")]
pub memory: Option<i64>,
#[serde(rename = "MemoryReservation")]
pub memory_reservation: Option<i64>,
#[serde(rename = "MemorySwap")]
pub memory_swap: Option<i64>,
#[serde(rename = "MemorySwappiness")]
pub memory_swappiness: Option<i64>,
#[serde(rename = "Mounts")]
pub mounts: Option<Vec<Mount>>,
#[serde(rename = "NanoCpus")]
pub nano_cpus: Option<i64>,
#[serde(rename = "NetworkMode")]
pub network_mode: Option<String>,
#[serde(rename = "OomKillDisable")]
pub oom_kill_disable: Option<bool>,
#[serde(rename = "OomScoreAdj")]
pub oom_score_adj: Option<i64>,
#[serde(rename = "PidMode")]
pub pid_mode: Option<String>,
#[serde(rename = "PidsLimit")]
pub pids_limit: Option<i64>,
#[serde(rename = "PortBindings")]
pub port_bindings: Option<serde_json::Value>,
#[serde(rename = "Privileged")]
pub privileged: Option<bool>,
#[serde(rename = "PublishAllPorts")]
pub publish_all_ports: Option<bool>,
#[serde(rename = "ReadonlyPaths")]
pub readonly_paths: Option<Vec<String>>,
#[serde(rename = "ReadonlyRootfs")]
pub readonly_rootfs: Option<bool>,
#[serde(rename = "RestartPolicy")]
pub restart_policy: Option<RestartPolicy>,
#[serde(rename = "Runtime")]
pub runtime: Option<String>,
#[serde(rename = "SecurityOpt")]
pub security_opt: Option<Vec<String>>,
#[serde(rename = "ShmSize")]
pub shm_size: Option<i64>,
#[serde(rename = "StorageOpt")]
pub storage_opt: Option<serde_json::Value>,
#[serde(rename = "Sysctls")]
pub sysctls: Option<serde_json::Value>,
#[serde(rename = "Tmpfs")]
pub tmpfs: Option<serde_json::Value>,
#[serde(rename = "Ulimits")]
pub ulimits: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
#[serde(rename = "UsernsMode")]
pub userns_mode: Option<String>,
#[serde(rename = "UTSMode")]
pub uts_mode: Option<String>,
#[serde(rename = "VolumeDriver")]
pub volume_driver: Option<String>,
#[serde(rename = "VolumesFrom")]
pub volumes_from: Option<Vec<String>>,
}
#[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;
pub type Limit = super::shared::MemoryBytesNanoCpUsPidsObject;
pub type Mount = super::shared::MountShape;
pub type NetworkAttachmentConfig = super::shared::AliasesDriverOptsTargetObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NetworkCreateRequest {
#[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 = "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 = "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: String,
#[serde(rename = "Options")]
pub options: Option<serde_json::Value>,
#[serde(rename = "Scope")]
pub scope: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NetworkCreateResponse {
#[serde(rename = "Id")]
pub id: String,
#[serde(rename = "Warning")]
pub warning: String,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct NetworkingConfig {
#[serde(rename = "EndpointsConfig")]
pub endpoints_config: Option<serde_json::Value>,
}
pub type Platform = super::shared::ArchitectureOsObject;
pub type PluginPrivilege = super::shared::DescriptionNameValueObject;
pub type PortMap = serde_json::Value;
pub type ResourceObject = super::shared::GenericResourcesMemoryBytesNanoCpUsObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct Resources {
#[serde(rename = "BlkioDeviceReadBps")]
pub blkio_device_read_bps: Option<Vec<ThrottleDevice>>,
#[serde(rename = "BlkioDeviceReadIOps")]
pub blkio_device_read_i_ops: Option<Vec<ThrottleDevice>>,
#[serde(rename = "BlkioDeviceWriteBps")]
pub blkio_device_write_bps: Option<Vec<ThrottleDevice>>,
#[serde(rename = "BlkioDeviceWriteIOps")]
pub blkio_device_write_i_ops: Option<Vec<ThrottleDevice>>,
#[serde(rename = "BlkioWeight")]
pub blkio_weight: Option<i64>,
#[serde(rename = "BlkioWeightDevice")]
pub blkio_weight_device: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
#[serde(rename = "CgroupParent")]
pub cgroup_parent: Option<String>,
#[serde(rename = "CpuCount")]
pub cpu_count: Option<i64>,
#[serde(rename = "CpuPercent")]
pub cpu_percent: Option<i64>,
#[serde(rename = "CpuPeriod")]
pub cpu_period: Option<i64>,
#[serde(rename = "CpuQuota")]
pub cpu_quota: Option<i64>,
#[serde(rename = "CpuRealtimePeriod")]
pub cpu_realtime_period: Option<i64>,
#[serde(rename = "CpuRealtimeRuntime")]
pub cpu_realtime_runtime: Option<i64>,
#[serde(rename = "CpuShares")]
pub cpu_shares: Option<i64>,
#[serde(rename = "CpusetCpus")]
pub cpuset_cpus: Option<String>,
#[serde(rename = "CpusetMems")]
pub cpuset_mems: Option<String>,
#[serde(rename = "DeviceCgroupRules")]
pub device_cgroup_rules: Option<Vec<String>>,
#[serde(rename = "DeviceRequests")]
pub device_requests: Option<Vec<DeviceRequest>>,
#[serde(rename = "Devices")]
pub devices: Option<Vec<DeviceMapping>>,
#[serde(rename = "IOMaximumBandwidth")]
pub io_maximum_bandwidth: Option<i64>,
#[serde(rename = "IOMaximumIOps")]
pub io_maximum_i_ops: Option<i64>,
#[serde(rename = "Init")]
pub init: Option<bool>,
#[serde(rename = "Memory")]
pub memory: Option<i64>,
#[serde(rename = "MemoryReservation")]
pub memory_reservation: Option<i64>,
#[serde(rename = "MemorySwap")]
pub memory_swap: Option<i64>,
#[serde(rename = "MemorySwappiness")]
pub memory_swappiness: Option<i64>,
#[serde(rename = "NanoCpus")]
pub nano_cpus: Option<i64>,
#[serde(rename = "OomKillDisable")]
pub oom_kill_disable: Option<bool>,
#[serde(rename = "PidsLimit")]
pub pids_limit: Option<i64>,
#[serde(rename = "Ulimits")]
pub ulimits: Option<Vec<std::collections::HashMap<String, serde_json::Value>>>,
}
pub type RestartPolicy = super::shared::MaximumRetryCountNameObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct SecretCreateRequest {
#[serde(rename = "Data")]
pub data: Option<String>,
#[serde(rename = "Driver")]
pub driver: Option<Driver>,
#[serde(rename = "Labels")]
pub labels: Option<serde_json::Value>,
#[serde(rename = "Name")]
pub name: Option<String>,
#[serde(rename = "Templating")]
pub templating: Option<Driver>,
}
pub type SecretSpec = SecretCreateRequest;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ServiceCreateRequest {
#[serde(rename = "EndpointSpec")]
pub endpoint_spec: Option<EndpointSpec>,
#[serde(rename = "Labels")]
pub labels: Option<serde_json::Value>,
#[serde(rename = "Mode")]
pub mode: Option<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "Name")]
pub name: Option<String>,
#[serde(rename = "Networks")]
pub networks: Option<Vec<NetworkAttachmentConfig>>,
#[serde(rename = "RollbackConfig")]
pub rollback_config: Option<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "TaskTemplate")]
pub task_template: Option<TaskSpec>,
#[serde(rename = "UpdateConfig")]
pub update_config: Option<std::collections::HashMap<String, serde_json::Value>>,
}
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct ServiceCreateResponse {
#[serde(rename = "ID")]
pub id: Option<String>,
#[serde(rename = "Warnings")]
pub warnings: Option<Vec<String>>,
}
pub type ServiceSpec = ServiceCreateRequest;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct TaskSpec {
#[serde(rename = "ContainerSpec")]
pub container_spec: Option<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "ForceUpdate")]
pub force_update: Option<i64>,
#[serde(rename = "LogDriver")]
pub log_driver: Option<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "NetworkAttachmentSpec")]
pub network_attachment_spec: Option<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "Networks")]
pub networks: Option<Vec<NetworkAttachmentConfig>>,
#[serde(rename = "Placement")]
pub placement: Option<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "PluginSpec")]
pub plugin_spec: Option<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "Resources")]
pub resources: Option<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "RestartPolicy")]
pub restart_policy: Option<std::collections::HashMap<String, serde_json::Value>>,
#[serde(rename = "Runtime")]
pub runtime: Option<String>,
}
pub type ThrottleDevice = super::shared::PathRateObject;
#[derive(Debug, Clone, Default, Serialize, Deserialize, JsonHash)]
pub struct VolumeCreateRequest {
#[serde(rename = "ClusterVolumeSpec")]
pub cluster_volume_spec: Option<ClusterVolumeSpec>,
#[serde(rename = "Driver")]
pub driver: Option<String>,
#[serde(rename = "DriverOpts")]
pub driver_opts: Option<serde_json::Value>,
#[serde(rename = "Labels")]
pub labels: Option<serde_json::Value>,
#[serde(rename = "Name")]
pub name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ConfigCreateArgs {
pub body: ConfigCreateRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ContainerCreateArgs {
pub name: Option<String>,
pub platform: Option<String>,
pub body: ContainerCreateRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ImageCreateArgs {
pub from_image: Option<String>,
pub from_src: Option<String>,
pub repo: Option<String>,
pub tag: Option<String>,
pub message: Option<String>,
pub changes: Vec<String>,
pub platform: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct NetworkCreateArgs {
pub body: NetworkCreateRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct PluginCreateArgs {
pub name: Option<String>,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct SecretCreateArgs {
pub body: SecretCreateRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct ServiceCreateArgs {
pub body: ServiceCreateRequest,
}
#[derive(Debug, Clone, Default, Serialize, JsonHash)]
pub struct VolumeCreateArgs {
pub body: VolumeCreateRequest,
}
pub async fn config_create_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ConfigCreateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<IDResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/configs/create",);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn container_create_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ContainerCreateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ContainerCreateResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/containers/create",);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("name", args.name.as_deref());
builder = builder.query("platform", args.platform.as_deref());
builder = builder
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn image_create_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ImageCreateArgs,
base_url: &str,
body: Option<foundation_netio::shared::http::SendSafeBody>,
builder_mod: Option<F>,
) -> Result<ApiResponse<super::shared::JsonLinesStream<CreateImageInfo>>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/images/create",);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("fromImage", args.from_image.as_deref());
builder = builder.query("fromSrc", args.from_src.as_deref());
builder = builder.query("repo", args.repo.as_deref());
builder = builder.query("tag", args.tag.as_deref());
builder = builder.query("message", args.message.as_deref());
for value in &args.changes {
builder = builder.query("changes", Some(value.as_str()));
}
builder = builder.query("platform", args.platform.as_deref());
if let Some(body) = body {
builder = super::shared::with_raw_body(builder, "text/plain", body);
}
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json_lines(client.into(), builder.build()).await
}
pub async fn network_create_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &NetworkCreateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<NetworkCreateResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/networks/create",);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn plugin_create_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &PluginCreateArgs,
base_url: &str,
body: Option<foundation_netio::shared::http::SendSafeBody>,
builder_mod: Option<F>,
) -> Result<ApiResponse<()>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/plugins/create",);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder.query("name", args.name.as_deref());
if let Some(body) = body {
builder = super::shared::with_raw_body(builder, "application/x-tar", body);
}
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_without_body(client.into(), builder.build()).await
}
pub async fn secret_create_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &SecretCreateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<IDResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/secrets/create",);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn service_create_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &ServiceCreateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<ServiceCreateResponse>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/services/create",);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}
pub async fn volume_create_request<F>(
client: impl Into<super::shared::ApiClient>,
args: &VolumeCreateArgs,
base_url: &str,
builder_mod: Option<F>,
) -> Result<ApiResponse<Volume>, super::shared::ApiError>
where
F: FnOnce(&mut PreparedRequestBuilder),
{
let path = format!("/volumes/create",);
let endpoint_url = format!("{}{}", base_url, path);
let mut builder = PreparedRequestBuilder::post(&endpoint_url)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
builder = builder
.body_json(&args.body)
.map_err(|e| super::shared::ApiError::RequestBuildFailed(e.to_string()))?;
if let Some(f) = builder_mod {
f(&mut builder);
}
super::shared::send_json(client.into(), builder.build()).await
}