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

extern crate async_docker;
extern crate http;
extern crate futures;
extern crate tokio;

use async_docker::{DockerApi, new_docker};
use futures::{future, Future};
use std::env;
use std::fs::OpenOptions;
use std::io::copy;
use futures::Stream;


fn main() {
    if env::args().count() < 2 {
        println!("Too few arguments (<1).");
        return;
    }

    let image_id = env::args().nth(1).unwrap();

    let work = future::lazy(||  {
        let docker: Box<DockerApi> = new_docker(None).unwrap();

        let mut export = OpenOptions::new()
            .write(true)
            .create(true)
            .open(format!("{}.tgz", &image_id))
            .unwrap();

        docker
            .image(image_id.into())
            .export()
            .concat2()
            .and_then(move |chunk| {
                let strin = chunk.into_bytes();
                copy(&mut strin.as_ref(), &mut export).unwrap();
                Ok(println!("Success"))
            })
            .map_err(|a| eprintln!("{:?}", a))
    });

    tokio::runtime::run(work);
}