async_docker 0.1.1

A Rust asynchronous interface for Docker API
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

use std::sync::Arc;
use transport::interact::InteractApi;
use build::NetworkListOptions;
use Error;
use futures::Future;
use representation::rep::NetworkDetails;
use transport::parse::parse_to_trait;
use communicate::util::AsSlice;
use transport::interact::InteractApiExt;
use representation::rep::NetworkCreateInfo;
use build::NetworkCreateOptions;
use hyper::Body;

/// Interface for docker networks
pub struct Networks {
    interact: Arc<InteractApi>,
}

impl Networks {
    /// Exports an interface for interacting with docker Networks
    pub(crate) fn new(interact: Arc<InteractApi>) -> Networks {
        Networks {
            interact
        }
    }

    /// List the docker networks on the current docker host
    pub fn list(&self, opts: &NetworkListOptions)
        -> impl Future<Item=Vec<NetworkDetails>, Error=Error> {
        let path = "/networks";
        let query = opts.serialize();
        let args = (path, query.as_slice());

        parse_to_trait::<Vec<NetworkDetails>>(self.interact.get(args))
    }

    pub fn create(&self, opts: &NetworkCreateOptions)
            -> impl Future<Item=NetworkCreateInfo, Error=Error> {
        let path = "/networks/create";
        let bytes = opts.serialize().expect("Error during serialization");
        let body = Some(Body::from(bytes));
        let args = (path, body);

        parse_to_trait::<NetworkCreateInfo>(self.interact.post_json(args))
    }
}