xfr 0.7.1

Modern network bandwidth testing with TUI
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

//! JSON output

use std::fs;
use std::path::Path;

use serde::Serialize;

use crate::protocol::TestResult;

pub fn output_json(result: &TestResult) -> String {
    serde_json::to_string_pretty(result).unwrap_or_else(|_| "{}".to_string())
}

pub fn save_json(result: &TestResult, path: &Path) -> anyhow::Result<()> {
    let json = output_json(result);
    fs::write(path, json)?;
    Ok(())
}

/// JSON streaming interval output (one JSON object per line)
#[derive(Serialize)]
pub struct StreamInterval {
    pub timestamp: String,
    pub elapsed_secs: f64,
    pub bytes: u64,
    pub throughput_mbps: f64,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub retransmits: Option<u64>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub jitter_ms: Option<f64>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub lost: Option<u64>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub rtt_us: Option<u32>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub cwnd: Option<u32>,
}

/// Output interval as JSON line (for --json-stream)
#[allow(clippy::too_many_arguments)]
pub fn output_interval_json(
    timestamp: &str,
    elapsed_secs: f64,
    throughput_mbps: f64,
    bytes: u64,
    retransmits: Option<u64>,
    jitter_ms: Option<f64>,
    lost: Option<u64>,
    rtt_us: Option<u32>,
    cwnd: Option<u32>,
) -> String {
    let interval = StreamInterval {
        timestamp: timestamp.to_string(),
        elapsed_secs,
        bytes,
        throughput_mbps,
        retransmits,
        jitter_ms,
        lost,
        rtt_us,
        cwnd,
    };
    serde_json::to_string(&interval).unwrap_or_else(|_| "{}".to_string())
}