blob: e44d68f70446677522ad0566ad47f9f0b6eb6c30 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
use futures::StreamExt;
use shiplift::Docker;
#[tokio::main]
async fn main() {
let docker = Docker::new();
println!("listening for events");
while let Some(event_result) = docker.events(&Default::default()).next().await {
match event_result {
Ok(event) => println!("event -> {:?}", event),
Err(e) => eprintln!("Error: {}", e),
}
}
}
|