/// Runs the prober in an infinite loop. Never returns.
Runs the prober in an infinite loop. Never returns.
Runs the prober in an infinite loop . Never returns .
pub fn run(&self) {
        info!(
            self.log,
            "IC Prober listening on {}",
            self.server.server_addr()
        );
        let base_url =
            Arc::new(Url::parse(&format!("http://{}/", self.server.server_addr())).unwrap());
        loop {
            match self.server.recv() {
                Ok(request) => {
                    let handle_http_request_future = handle_http_request(
                        request,
                        base_url.clone(),
                        self.metrics.clone(),
                        self.registry.clone(),
                        self.log.clone(),
                    );
                    tokio::task::spawn(handle_http_request_future);
                }
                Err(e) => warn!(self.log, "server.recv() returned error: {}", e),
            }
        }
    }
pub fn run ( & self ) { info ! ( self log " " self server server_addr ( ) ) ; let base_url = Arc :: new ( Url :: parse ( & format ! ( " " self server server_addr ( ) ) ) . unwrap ( ) ) ; loop { match self . server . recv ( ) { Ok ( request ) => { let handle_http_request_future = handle_http_request ( request , base_url . clone ( ) , self . metrics . clone ( ) , self . registry . clone ( ) , self . log . clone ( ) , ) ; tokio :: task :: spawn ( handle_http_request_future ) ; } Err ( e ) => warn ! ( self log " " e ) , } } }
Runs the prober in an infinite loop.
Runs the prober in an infinite loop .
&self