podman_client/manifests/
push_list_to_registry.rs

1use http_body_util::Empty;
2use hyper::body::Bytes;
3use url::form_urlencoded;
4
5use crate::{
6    client::Client,
7    models::{
8        connection::SendRequestOptions,
9        lib::Error,
10        podman::manifests::push_list_to_registry::{
11            ManifestPushListToRegistry, ManifestPushListToRegistryOptions,
12        },
13    },
14    utils::bool_to_str::bool_to_str,
15};
16
17impl Client {
18    pub async fn manifest_push_list_to_registry(
19        &self,
20        options: ManifestPushListToRegistryOptions<'_>,
21    ) -> Result<ManifestPushListToRegistry, Error> {
22        let mut path = [
23            "/libpod/manifests/",
24            options.name,
25            "/registry/",
26            options.destination,
27        ]
28        .concat();
29
30        let mut query = form_urlencoded::Serializer::new(String::new());
31        if let Some(add_compression) = options.add_compression {
32            for compression in add_compression {
33                query.append_pair("addCompression", compression);
34            }
35        }
36        if let Some(all) = options.all {
37            query.append_pair("all", bool_to_str(all));
38        }
39        if let Some(force_compression_format) = options.force_compression_format {
40            query.append_pair(
41                "forceCompressionFormat",
42                bool_to_str(force_compression_format),
43            );
44        }
45        if let Some(quiet) = options.quiet {
46            query.append_pair("quiet", bool_to_str(quiet));
47        }
48        if let Some(tls_verify) = options.tls_verify {
49            query.append_pair("tlsVerify", bool_to_str(tls_verify));
50        }
51        let query_string = query.finish();
52        if !query_string.is_empty() {
53            path += &["?", &query_string].concat();
54        }
55
56        let (_, data) = self
57            .send_request::<_, (), _>(SendRequestOptions {
58                method: "POST",
59                path: &path,
60                header: None,
61                body: Empty::<Bytes>::new(),
62            })
63            .await?;
64
65        Ok(data)
66    }
67}