hotpath 0.29.2

One profiler for CPU, time, memory, SQL, and async code - quickly find and debug performance bottlenecks.
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

use std::time::Duration;

use serde::de::DeserializeOwned;

use crate::common::assert_contains_all;
use crate::common::example::{poll_endpoint, Example};

/// Runs `example` with the metrics server on `port`, waits for `/{route}` to
/// list every `all_expected` needle, then checks that `/{route}/{id}/logs` of
/// the first entry answers 200. Returns the logs body, `None` for an empty list.
#[track_caller]
pub(crate) fn assert_list_and_logs_endpoints<L: DeserializeOwned>(
    example: Example,
    port: u16,
    route: &str,
    all_expected: &[&str],
    first_id: impl Fn(&L) -> Option<u32>,
) -> Option<String> {
    let _running = example
        .env("HOTPATH_METRICS_PORT", port.to_string())
        .env("TEST_SLEEP_SECONDS", "10")
        .spawn();

    let json_text = poll_endpoint(
        &format!("http://localhost:{port}/{route}"),
        12,
        Duration::from_millis(750),
        |body| all_expected.iter().all(|e| body.contains(e)),
    );
    assert_contains_all(&json_text, all_expected);

    let list: L = serde_json::from_str(&json_text)
        .unwrap_or_else(|e| panic!("Failed to parse /{route} JSON: {e}"));
    let id = first_id(&list)?;

    let mut response = ureq::get(&format!("http://localhost:{port}/{route}/{id}/logs"))
        .call()
        .unwrap_or_else(|e| panic!("Failed to call /{route}/{id}/logs endpoint: {e}"));
    assert_eq!(
        response.status(),
        200,
        "Expected status 200 for /{route}/{id}/logs endpoint"
    );
    Some(
        response
            .body_mut()
            .read_to_string()
            .expect("Failed to read logs response"),
    )
}