podman_client/containers/
list.rs

1use std::collections::HashMap;
2
3use http_body_util::Empty;
4use hyper::body::Bytes;
5use url::form_urlencoded::{self, byte_serialize};
6
7use crate::{
8    client::Client,
9    models::{
10        connection::SendRequestOptions,
11        lib::Error,
12        podman::containers::list::{ContainerList, ContainerListOptions},
13    },
14    utils::bool_to_str::bool_to_str,
15};
16
17impl Client {
18    pub async fn container_list(
19        &self,
20        options: Option<ContainerListOptions>,
21    ) -> Result<ContainerList, Error> {
22        let mut path = "/libpod/containers/json".to_owned();
23
24        if let Some(options) = options {
25            let mut query = form_urlencoded::Serializer::new(String::new());
26            if let Some(all) = options.all {
27                query.append_pair("alla", bool_to_str(all));
28            }
29            if let Some(opt_filters) = options.filters {
30                let mut filters = HashMap::new();
31                if let Some(ancestor) = opt_filters.ancestor {
32                    filters.insert("ancestor", ancestor);
33                }
34                if let Some(before) = opt_filters.before {
35                    filters.insert("before", before);
36                }
37                if let Some(expose) = opt_filters.expose {
38                    filters.insert("expose", expose);
39                }
40                if let Some(exited) = opt_filters.exited {
41                    filters.insert(
42                        "exited",
43                        exited
44                            .iter()
45                            .map(|&d| itoa::Buffer::new().format(d).to_owned())
46                            .collect(),
47                    );
48                }
49                if let Some(health) = opt_filters.health {
50                    filters.insert(
51                        "health",
52                        health.iter().map(|h| h.as_str().to_owned()).collect(),
53                    );
54                }
55                if let Some(id) = opt_filters.id {
56                    filters.insert("id", id);
57                }
58                if let Some(is_task) = opt_filters.is_task {
59                    filters.insert(
60                        "is-task",
61                        is_task.iter().map(|&t| bool_to_str(t).to_owned()).collect(),
62                    );
63                }
64                if let Some(label) = opt_filters.label {
65                    filters.insert("label", label);
66                }
67                if let Some(name) = opt_filters.name {
68                    filters.insert("name", name);
69                }
70                if let Some(network) = opt_filters.network {
71                    filters.insert("network", network);
72                }
73                if let Some(pod) = opt_filters.pod {
74                    filters.insert("pod", pod);
75                }
76                if let Some(publish) = opt_filters.publish {
77                    filters.insert("publish", publish);
78                }
79                if let Some(since) = opt_filters.since {
80                    filters.insert("since", since);
81                }
82                if let Some(status) = opt_filters.status {
83                    filters.insert(
84                        "status",
85                        status.iter().map(|s| s.as_str().to_owned()).collect(),
86                    );
87                }
88                if let Some(volume) = opt_filters.volume {
89                    filters.insert("volume", volume);
90                }
91                if !filters.is_empty() {
92                    let filters_json = serde_json::to_string(&filters)?;
93                    let filters_encoded: String = byte_serialize(filters_json.as_bytes()).collect();
94                    query.append_pair("filters", &filters_encoded);
95                }
96            }
97            if let Some(limit) = options.limit {
98                query.append_pair("limit", itoa::Buffer::new().format(limit));
99            }
100            if let Some(namespace) = options.namespace {
101                query.append_pair("namespace", bool_to_str(namespace));
102            }
103            if let Some(pod) = options.pod {
104                query.append_pair("pod", bool_to_str(pod));
105            }
106            if let Some(size) = options.size {
107                query.append_pair("size", bool_to_str(size));
108            }
109            if let Some(sync) = options.sync {
110                query.append_pair("sync", bool_to_str(sync));
111            }
112            let query_string = query.finish();
113            if !query_string.is_empty() {
114                path += &["?", &query_string].concat();
115            }
116        }
117
118        let (_, data) = self
119            .send_request::<_, (), _>(SendRequestOptions {
120                method: "GET",
121                path: &path,
122                header: None,
123                body: Empty::<Bytes>::new(),
124            })
125            .await?;
126
127        Ok(data)
128    }
129}
podman_client/containers/list.rs

podman_client/containers/
list.rs
