Method start

src/instruments/mongo_tracer.rs:120–167

(&mut self)

    }

    pub async fn start(&mut self) -> Result<()> {
        let mut command = Command::new("cs-mongo-tracer");
        let (server_address, proxy_host_port, destination_host_port) = self
            .get_host_port_from_uris()
            .context("Failed to parse the uris")?;

        let mut envs = vec![
            ("RUST_LOG", "debug"),
            (
                "CODSPEED_MONGO_INSTR_SERVER_ADDRESS",
                server_address.as_str(),
            ),
            ("CODSPEED_MONGO_PROXY_HOST_PORT", proxy_host_port.as_str()),
        ];
        if let Some(destination_host_port) = destination_host_port.as_ref() {
            envs.push((
                "CODSPEED_MONGO_DEST_HOST_PORT",
                destination_host_port.as_str(),
            ));
        }
        command.envs(envs);

        debug!("Start the MongoDB tracer: {command:?}");
        if let Some(destination_host_port) = destination_host_port {
            debug!("Proxy MongoDB from {proxy_host_port} to {destination_host_port}");
        } else {
            info!(
                "No MongoDB URI provided, user will have to provide it dynamically through the CodSpeed integration"
            );
        }
        let mut process = command
            .stdout(Stdio::piped())
            .stderr(Stdio::piped())
            .spawn()?;

        let process_stdout = process.stdout.take().expect("error taking child stdout");
        let process_stderr = process.stderr.take().expect("error taking child stderr");
        thread::spawn(move || {
            dump_tracer_log(process_stdout).expect("error communicating with child stdout")
        });
        thread::spawn(move || {
            dump_tracer_log(process_stderr).expect("error communicating with child stderr")
        });

        self.process = Some(process);

        Ok(())
    }

    pub async fn stop(&mut self) -> Result<()> {
        let response = Client::new()