async_docker 0.1.1

A Rust asynchronous interface for 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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113

pub use build::*;

pub use std::marker::Sized;
pub use errors::Error;
/// Represents the result of all docker operations
pub use errors::Result;

use hyper::Body;
use std::str;
use url::form_urlencoded;
use hyper::HeaderMap;
use http::header::HeaderValue;
use http::header::HeaderName;


pub(crate) const URI_ENV: &'static str = "SHIPLIFT_URI";
pub(crate) const DEFAULT_URI: &'static str = "unix://var/run/docker.sock";

pub(crate) fn build_simple_query<A>(name: &str, value: Option<A>) -> Option<String>
    where
        A: AsRef<str>
{
    let mut query = None;

    if let Some(ref val) = value {
        query = Some(form_urlencoded::serialize(vec![(name, val)]))
    };

    query
}

pub(crate) trait AsSlice {
    fn as_slice(&self) -> Option<&str>;
}

impl AsSlice for Option<String>
{
    fn as_slice(&self) -> Option<&str> {
        match self {
            Some(ref x) => Some(x),
            None => None,
        }
    }
}

#[derive(Default)]
pub(crate) struct RequestArgs<'a,'b> {
    pub path: &'a str,
    pub query: &'b str,
    pub body: Body,
    pub header: HeaderMap,
}

impl <'a,'b> RequestArgs<'a,'b>{
    pub fn set_header<A,B>(&mut self, key: A, value: B)
        where
            A: Into<HeaderName>,
            B: Into<HeaderValue>,
    {
        self.header.insert(key.into(), value.into());
    }
}

pub(crate) trait IntoRequestArgs<'a,'b>
{
    fn into_request_args(self) -> RequestArgs<'a,'b>;
}

impl <'a,'b> IntoRequestArgs<'a,'b> for &'a str
{
    fn into_request_args(self) -> RequestArgs<'a,'b> {
        let mut args = RequestArgs::default();
        args.path = self;

        args
    }
}

impl <'a,'b> IntoRequestArgs<'a,'b> for (&'a str, Option<&'b str>)
{
    fn into_request_args(self) -> RequestArgs<'a,'b> {
        let mut args = RequestArgs::default();

        args.path = self.0;
        args.query = self.1.unwrap_or_default();

        args
    }
}

impl <'a,'b> IntoRequestArgs<'a,'b> for (&'a str, Option<Body>)
{
    fn into_request_args(self) -> RequestArgs<'a,'b> {
        let mut args = RequestArgs::default();
        args.path = self.0;
        args.body = self.1.unwrap_or_default();

        args
    }
}

impl <'a,'b> IntoRequestArgs<'a,'b> for (&'a str, Option<&'b str>, Option<Body>)
{
    fn into_request_args(self) -> RequestArgs<'a,'b> {
        let mut args = RequestArgs::default();

        args.path = self.0;
        args.query = self.1.unwrap_or_default();
        args.body = self.2.unwrap_or_default();

        args
    }
}