Struct OnionPerfRunner

pub struct OnionPerfRunner {
    pub host_name: String,
    pub onionperf_analysis_receiver_stream: Arc<Mutex<UnboundedReceiverStream<OnionPerfAnalysis>>>,
    /* private fields */
}

The client to connect to a OnionPerfRunner Host and get the most recent OnionPerf Analysis file at certain intervals

Fields

host_name: String

Name of the host Eg. “op-de7a”

onionperf_analysis_receiver_stream: Arc<Mutex<UnboundedReceiverStream<OnionPerfAnalysis>>>

The receiver stream to receive the OnionPerfAnalysis files

Implementations

impl OnionPerfRunner

pub fn new<T: AsRef<str>>(host_name: T) -> Self

Create a new client to get data from OnionPerfRunner Host

pub async fn start(&self)

pub async fn stop(&self)

Stop the running loop in start(). If a analysis file has already download, it will stop after the current process has been down. It will stop immediately if you try to start again after stop. The runner will do nothing if you start after stop.