summaryrefslogtreecommitdiffstats
path: root/examples/containercreate.rs
diff options
context:
space:
mode:
authorAntoine Büsch <antoine.busch@gmail.com>2018-11-14 20:36:14 +1100
committerdoug tangren <d.tangren@gmail.com>2018-11-14 18:36:14 +0900
commit79d65c286025c551a775c0964d168e6feb4b3409 (patch)
tree34b49a0f97f6f851f47711be1cad0c002b8b78f7 /examples/containercreate.rs
parent29bd95b42cd2b3c364f0be1f3e07e4b654e0ccf3 (diff)
Async api (#128)
* Refactored Transport for better async use Still a bit rough, but it now builds a big future using combinators. It still does one `Runtime::block_on()` to keep the existing API, but this is a first up before making the whole API async. * Migrate most APIs to be Future-based I still need to finish a few of the more tricky ones that I've commented out for now, but most of it compiles and some examples work. In particular, `Docker::stats()` now properly returns an async stream of stats. * Fix events and containerinspect examples * Fix imageinspect, images, info and top examples * Fix containercreate, imagedelete and imagepull examples * Fix more examples * Add back debug statement in Transport::request * De-glob imports in examples * Remove unused imports in examples * Fix NetworkCreateOptions serialization * Add back error message extraction in Transport * Fix Container::create serialization of options * Add containerdelete example * Simplify result * Fix some error handling to remove unwrap() * Fix Image::export() * Fix imagebuild example * Add adapter from Stream of Chunks to AsyncRead Having an `AsyncRead` is required to be able to use the `FramedRead` and `Decoder` stuff from tokio_codec. This code is "borrowed" from https:/github.com/ferristseng/rust-ipfs-api though should probably be moved to its own crate or to tokio_codec. * Fix Container::logs() It now properly demuxes stdout/stderr, and returns a `Stream<Item = TtyLine>`. * Fix Container::export() * Use LineCodec for streaming JSON Although in my limited testing it seemed to work fine, there is no guarantee that 1 chunk == 1 piece of valid JSON. However, each JSON structure seems to be serialized on one line, so use LineCodec to turn the body into a stream of lines, then deserialize over this. * Fix serialization of ExecContainerOptions * Fix Container::exec() (kind of...) * Simplify deserialisation in Image::delete() * Small clean-ups * More clean ups * Fix rustdoc + remove extraneous "extern crate" * Fix doc example * Fix formatting
Diffstat (limited to 'examples/containercreate.rs')
-rw-r--r--examples/containercreate.rs18
1 files changed, 11 insertions, 7 deletions
diff --git a/examples/containercreate.rs b/examples/containercreate.rs
index 71307b8..f5baf39 100644
--- a/examples/containercreate.rs
+++ b/examples/containercreate.rs
@@ -1,15 +1,19 @@
extern crate shiplift;
+extern crate tokio;
use shiplift::{ContainerOptions, Docker};
use std::env;
+use tokio::prelude::Future;
fn main() {
let docker = Docker::new();
- let containers = docker.containers();
- if let Some(image) = env::args().nth(1) {
- let info = containers
- .create(&ContainerOptions::builder(image.as_ref()).build())
- .unwrap();
- println!("{:?}", info);
- }
+ let image = env::args()
+ .nth(1)
+ .expect("You need to specify an image name");
+ let fut = docker
+ .containers()
+ .create(&ContainerOptions::builder(image.as_ref()).build())
+ .map(|info| println!("{:?}", info))
+ .map_err(|e| eprintln!("Error: {}", e));
+ tokio::run(fut);
}