podman_client/manifests/
push_list_to_registry.rs1use 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}