zaphar/durnitisp
1
0
Fork 0
mirror of https://github.com/zaphar/durnitisp.git synced 2025-07-22 18:19:48 -04:00
Code Issues Packages Projects Releases Wiki Activity

On second thought dont store IP as a label

Browse Source
This commit is contained in:
Jeremy Wall 2021-01-05 21:05:35 -05:00
parent d283551bb7
commit 8d30bc61e0
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/icmp.rs
View File

@ -72,10 +72,10 @@ pub fn start_echo_loop(
r.elapsed.as_millis(), r.elapsed.as_millis(),
); );
ping_counter ping_counter
.with(&prometheus::labels! {"result" => "ok", "domain" => domain_name, "ip" => &resolved}) .with(&prometheus::labels! {"result" => "ok", "domain" => domain_name})
.inc(); .inc();
ping_latency_guage ping_latency_guage
.with(&prometheus::labels! {"domain" => domain_name, "ip" => &resolved}) .with(&prometheus::labels! {"domain" => domain_name})
.set(r.elapsed.as_millis() as i64); .set(r.elapsed.as_millis() as i64);
} }
EkkoResponse::UnreachableResponse((_, ref _code)) => { EkkoResponse::UnreachableResponse((_, ref _code)) => {
@ -83,7 +83,7 @@ pub fn start_echo_loop(
error!("{:?}", r); error!("{:?}", r);
info!("Restarting our sender"); info!("Restarting our sender");
ping_counter ping_counter
.with(&prometheus::labels! {"result" => "unreachable", "domain" => domain_name, "ip" => &resolved}) .with(&prometheus::labels! {"result" => "unreachable", "domain" => domain_name})
.inc(); .inc();
let resolved = resolve_host_address(domain_name); let resolved = resolve_host_address(domain_name);
let mut new_sender = Ekko::with_target(&resolved).unwrap(); let mut new_sender = Ekko::with_target(&resolved).unwrap();
@ -92,19 +92,19 @@ pub fn start_echo_loop(
} }
EkkoResponse::ExceededResponse(_) => { EkkoResponse::ExceededResponse(_) => {
ping_counter ping_counter
.with(&prometheus::labels! {"result" => "timeout", "domain" => domain_name, "ip" => &resolved}) .with(&prometheus::labels! {"result" => "timeout", "domain" => domain_name})
.inc(); .inc();
} }
_ => { _ => {
ping_counter ping_counter
.with(&prometheus::labels! {"result" => "err", "domain" => domain_name, "ip" => &resolved}) .with(&prometheus::labels! {"result" => "err", "domain" => domain_name})
.inc(); .inc();
error!("{:?}", r); error!("{:?}", r);
} }
}, },
Err(e) => { Err(e) => {
ping_counter ping_counter
.with(&prometheus::labels! {"result" => "err", "domain" => domain_name, "ip" => &resolved}) .with(&prometheus::labels! {"result" => "err", "domain" => domain_name})
.inc(); .inc();
error!("Ping send to domain: {} address: {} failed: {:?}, Trying again later", domain_name, &resolved, e); error!("Ping send to domain: {} address: {} failed: {:?}, Trying again later", domain_name, &resolved, e);
} }