lmn-core 0.3.0

Core engine for the lmn HTTP load testing CLI
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

use tokio::task::JoinError;

/// Errors that can occur during a load test run.
#[derive(Debug)]
pub enum RunError {
    /// Failed to build the HTTP client for this run.
    HttpClientBuild(reqwest::Error),
    /// The internal drain task terminated unexpectedly.
    DrainTaskFailed(JoinError),
}

impl std::fmt::Display for RunError {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            Self::HttpClientBuild(e) => write!(f, "failed to build HTTP client: {e}"),
            Self::DrainTaskFailed(e) => write!(f, "drain task failed unexpectedly: {e}"),
        }
    }
}

impl std::error::Error for RunError {
    fn source(&self) -> Option<&(dyn std::error::Error + 'static)> {
        match self {
            Self::HttpClientBuild(e) => Some(e),
            Self::DrainTaskFailed(e) => Some(e),
        }
    }
}

impl From<reqwest::Error> for RunError {
    fn from(e: reqwest::Error) -> Self {
        Self::HttpClientBuild(e)
    }
}

impl From<JoinError> for RunError {
    fn from(e: JoinError) -> Self {
        Self::DrainTaskFailed(e)
    }
}

// ── Tests ─────────────────────────────────────────────────────────────────────

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

    fn make_reqwest_error() -> reqwest::Error {
        // reqwest::get on an unparseable URL fails immediately without a network
        // call, giving us a real reqwest::Error without async overhead.
        tokio::runtime::Runtime::new()
            .unwrap()
            .block_on(reqwest::get("not-a-valid-url"))
            .unwrap_err()
    }

    fn make_join_error() -> JoinError {
        tokio::runtime::Runtime::new().unwrap().block_on(async {
            tokio::spawn(async { panic!("test panic") })
                .await
                .unwrap_err()
        })
    }

    #[test]
    fn display_http_client_build() {
        let run_err = RunError::HttpClientBuild(make_reqwest_error());
        assert!(
            run_err
                .to_string()
                .starts_with("failed to build HTTP client:"),
            "unexpected: {run_err}"
        );
    }

    #[test]
    fn display_drain_task_failed() {
        let run_err = RunError::DrainTaskFailed(make_join_error());
        assert!(
            run_err
                .to_string()
                .starts_with("drain task failed unexpectedly:"),
            "unexpected: {run_err}"
        );
    }

    #[test]
    fn source_is_set() {
        let run_err = RunError::HttpClientBuild(make_reqwest_error());
        assert!(
            std::error::Error::source(&run_err).is_some(),
            "source must be set"
        );
    }

    #[test]
    fn from_reqwest_error_produces_http_client_build_variant() {
        let run_err = RunError::from(make_reqwest_error());
        assert!(matches!(run_err, RunError::HttpClientBuild(_)));
    }

    #[test]
    fn from_join_error_produces_drain_task_failed_variant() {
        let run_err = RunError::from(make_join_error());
        assert!(matches!(run_err, RunError::DrainTaskFailed(_)));
    }
}