docker-api 0.14.0

Interface to 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

use containers_api::conn::tty;
use containers_api::conn::Payload;
use futures_util::{AsyncRead, AsyncWrite};
use hyper::Body;

use crate::{Docker, Result};

/// Attaches a multiplexed TCP stream to the container that can be used to read Stdout, Stderr and write Stdin.
async fn attach_raw(
    docker: Docker,
    endpoint: String,
    payload: Payload<Body>,
) -> Result<impl AsyncRead + AsyncWrite + Send> {
    docker.post_upgrade_stream(endpoint, payload).await
}

pub async fn attach(
    docker: Docker,
    endpoint: String,
    payload: Payload<Body>,
    is_tty: bool,
) -> Result<tty::Multiplexer> {
    attach_raw(docker, endpoint, payload).await.map(|s| {
        if is_tty {
            tty::Multiplexer::new(s, tty::decode_raw)
        } else {
            tty::Multiplexer::new(s, tty::decode_chunk)
        }
    })
}