hotpath 0.25.0

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
51
52
53
54

/// HdrHistogram V2 deflate payload, base64-encoded. Decodable by any HdrHistogram
/// implementation (`hdrhistogram::serialization::Deserializer`, hdr-histogram-js).
#[cfg(feature = "hotpath-cloud")]
pub(crate) fn histogram_base64(hist: &hdrhistogram::Histogram<u64>) -> Option<String> {
    use base64::Engine;
    use hdrhistogram::serialization::{Serializer, V2DeflateSerializer};

    let mut buf = Vec::new();
    V2DeflateSerializer::new().serialize(hist, &mut buf).ok()?;
    Some(base64::engine::general_purpose::STANDARD.encode(&buf))
}

#[cfg(not(feature = "hotpath-cloud"))]
pub(crate) fn histogram_base64(_hist: &hdrhistogram::Histogram<u64>) -> Option<String> {
    None
}

#[cfg(all(test, feature = "hotpath-cloud"))]
pub(crate) fn decode_histogram(b64: &str) -> hdrhistogram::Histogram<u64> {
    use base64::Engine;
    use hdrhistogram::serialization::Deserializer;

    let bytes = base64::engine::general_purpose::STANDARD
        .decode(b64)
        .unwrap();
    Deserializer::new().deserialize(&mut &bytes[..]).unwrap()
}

#[cfg(all(test, feature = "hotpath-cloud"))]
mod tests {
    use base64::Engine;
    use hdrhistogram::serialization::Deserializer;
    use hdrhistogram::Histogram;

    use crate::lib_on::histograms::histogram_base64;

    #[test]
    fn histogram_base64_round_trips() {
        let mut hist = Histogram::<u64>::new_with_bounds(1, 1_000_000_000_000, 3).unwrap();
        for v in [180_000u64, 190_000, 1_400_000, 1_500_000, 9_000_000] {
            hist.record(v).unwrap();
        }

        let b64 = histogram_base64(&hist).unwrap();
        let bytes = base64::engine::general_purpose::STANDARD
            .decode(b64)
            .unwrap();
        let decoded: Histogram<u64> = Deserializer::new().deserialize(&mut &bytes[..]).unwrap();

        assert_eq!(decoded.len(), hist.len());
        assert_eq!(decoded.max(), hist.max());
        assert_eq!(decoded.value_at_quantile(0.5), hist.value_at_quantile(0.5));
    }
}