dagger-sdk 0.20.6

A dagger sdk for rust, written in rust
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

use crate::core::logger::DynLogger;
use derive_builder::Builder;
use std::path::PathBuf;

#[derive(Builder)]
#[builder(build_fn(private, name = "fallible_build"))]
#[builder(setter(strip_option))]
pub struct Config {
    #[builder(default = "None")]
    /// The host workdir loaded into dagger.
    pub workdir_path: Option<PathBuf>,
    #[builder(default = "None")]
    /// Project configuration file path.
    pub config_path: Option<PathBuf>,
    #[builder(default = "10000")]
    /// The maximum time in milliseconds for establishing a connection to the server.
    /// Defaults to 10 seconds.
    pub timeout_ms: u64,
    #[builder(default = "false")]
    /// Opt into loading workspace modules for this connection.
    pub load_workspace_modules: bool,
    #[builder(default = "None")]
    /// The maximum time in milliseconds for executing a request.
    /// Defaults to no timeout.
    pub execute_timeout_ms: Option<u64>,
    #[builder(default = "None")]
    /// Logger implementation to handle logs from the engine.
    pub logger: Option<DynLogger>,
}

impl ConfigBuilder {
    pub fn build(&mut self) -> Config {
        self.fallible_build()
            .expect("all fields have default values")
    }
}

impl Default for Config {
    fn default() -> Self {
        Self {
            workdir_path: None,
            config_path: None,
            timeout_ms: 10 * 1000,
            load_workspace_modules: false,
            execute_timeout_ms: None,
            logger: None,
        }
    }
}

impl Config {
    pub fn new(
        workdir_path: Option<PathBuf>,
        config_path: Option<PathBuf>,
        timeout_ms: Option<u64>,
        execute_timeout_ms: Option<u64>,
        logger: Option<DynLogger>,
    ) -> Self {
        Self {
            workdir_path,
            config_path,
            timeout_ms: timeout_ms.unwrap_or(10 * 1000),
            load_workspace_modules: false,
            execute_timeout_ms,
            logger,
        }
    }

    /// Returns a new config builder instance
    pub fn builder() -> ConfigBuilder {
        ConfigBuilder::default()
    }
}

#[cfg(test)]
mod tests {
    use super::Config;

    #[test]
    fn default_timeout_is_10s() {
        let cfg = Config::default();
        assert_eq!(cfg.timeout_ms, 10 * 1000);
        assert!(cfg.execute_timeout_ms.is_none());
    }
}