ferrodock 1.14.0

A fast, native container manager for Docker, written in Rust.
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

//! Container logs: the recent tail, then new output as it arrives.

use futures_util::{Stream, StreamExt};

use bollard::query_parameters::LogsOptions;

use super::{DockerClient, describe};

impl DockerClient {
    /// Streams a container's stdout and stderr, starting with the last
    /// `tail` lines. Items are raw chunks: a chunk can hold several lines or
    /// part of one. The stream ends when the container stops.
    pub fn logs(
        &self,
        id: &str,
        tail: usize,
    ) -> impl Stream<Item = Result<String, String>> + use<> {
        let opts = LogsOptions {
            follow: true,
            stdout: true,
            stderr: true,
            tail: tail.to_string(),
            // Each line starts with when it was written; the UI can show it.
            timestamps: true,
            ..Default::default()
        };
        self.docker
            .logs(id, Some(opts))
            .map(|chunk| chunk.map(|output| output.to_string()).map_err(describe))
    }
}