1use std::time::Duration;
2
3use futures::pin_mut;
4use futures_util::StreamExt;
5
6use async_traceroute::{dns_lookup_first_ipv4_addr, TracerouteBuilder};
7
8#[tokio::main]
9async fn main() -> Result<(), String> {
10 let ip_addr = match dns_lookup_first_ipv4_addr("google.com").await {
11 None => return Err(String::from("Hostname not resolvable")),
12 Some(ip_addr) => ip_addr,
13 };
14
15 println!("{:?}", ip_addr);
16 let traceroute = TracerouteBuilder::udp()
17 .destination_address(ip_addr)
18 .max_ttl(15)
19 .queries_per_hop(3)
20 .max_wait_probe(Duration::from_secs(3))
21 .simultaneous_queries(16)
22 .active_dns_lookup(true)
23 .initial_destination_port(33434)
24 .network_interface("eth0")
25 .build();
26
27 let traceroute_stream = match traceroute {
28 Ok(traceroute) => traceroute.trace(),
29 Err(error) => return Err(error),
30 };
31
32 pin_mut!(traceroute_stream);
33 while let Some(probe_result) = traceroute_stream.next().await {
34 println!("{:?}", probe_result);
35 }
36
37 Ok(())
38}