pong-rs 0.3.3

A network monitoring tool that performs ICMP, TCP, and HTTP pings
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

use crate::executor::Executor;
use crate::ping_error::PingError;
use crate::task::http::http_ping::HttpPing;
use async_trait::async_trait;
use log::trace;
use std::time::Duration;

#[derive(Clone)]
pub struct HttpExecutor {
    urn: String,
    http_ping: HttpPing,
    timeout: Duration,
}

impl HttpExecutor {
    /// 构造函数
    /// # 参数
    /// * `urn` - 要请求的URN地址，格式为 `<method>:<url>`，例如: `GET:http://127.0.0.1:8080`
    /// * `timeout` - 一个 `Duration`，表示超时时间
    pub fn new(urn: String, timeout: Duration) -> Self {
        let http_ping = HttpPing::new(urn.clone());

        Self {
            http_ping,
            urn,
            timeout,
        }
    }
}

#[async_trait]
impl Executor for HttpExecutor {
    fn get_name(&self) -> String {
        String::from("HTTP")
    }

    async fn exec(&self) -> Result<(), PingError> {
        trace!("开始执行 HTTP 任务: ping {}", self.urn);
        self.http_ping.ping(self.timeout).await
    }
}