Initial commit.
This commit is contained in:
18
src/main.rs
Normal file
18
src/main.rs
Normal file
@@ -0,0 +1,18 @@
|
||||
use shiplift::Docker;
|
||||
use tokio::prelude::{Future, Stream};
|
||||
|
||||
fn main() {
|
||||
let docker = Docker::new();
|
||||
|
||||
println!("listening for events");
|
||||
|
||||
let fut = docker
|
||||
.events(&Default::default())
|
||||
.for_each(|e| {
|
||||
println!("event -> {:?}", e);
|
||||
Ok(())
|
||||
})
|
||||
.map_err(|e| eprintln!("Error: {}", e));
|
||||
|
||||
tokio::run(fut);
|
||||
}
|
||||
Reference in New Issue
Block a user