1
0
Fork 0
mirror of https://codeberg.org/icewind/prometheus-mdns-rs.git synced 2026-06-03 18:04:11 +02:00

Add trace logs

This commit is contained in:
Mike Kusold 2025-06-20 06:56:59 -06:00
commit 0d080ca339
3 changed files with 102 additions and 1 deletions

96
Cargo.lock generated
View file

@ -2,6 +2,15 @@
# It is not intended for manual editing. # It is not intended for manual editing.
version = 3 version = 3
[[package]]
name = "aho-corasick"
version = "1.1.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "8e60d3430d3a69478ad0993f19238d2df97c507009a52b3c10addcd7f6bcb916"
dependencies = [
"memchr",
]
[[package]] [[package]]
name = "async-attributes" name = "async-attributes"
version = "1.1.2" version = "1.1.2"
@ -276,6 +285,19 @@ dependencies = [
"quick-error", "quick-error",
] ]
[[package]]
name = "env_logger"
version = "0.10.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "4cd405aab171cb85d6735e5c8d9db038c17d3ca007a4d2c25f337935c3d90580"
dependencies = [
"humantime",
"is-terminal",
"log",
"regex",
"termcolor",
]
[[package]] [[package]]
name = "err-derive" name = "err-derive"
version = "0.2.4" version = "0.2.4"
@ -416,6 +438,29 @@ version = "0.4.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "fbf6a919d6cf397374f7dfeeea91d974c7c0a7221d0d0f4f20d859d329e53fcc" checksum = "fbf6a919d6cf397374f7dfeeea91d974c7c0a7221d0d0f4f20d859d329e53fcc"
[[package]]
name = "hermit-abi"
version = "0.5.2"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "fc0fef456e4baa96da950455cd02c081ca953b141298e41db3fc7e36b1da849c"
[[package]]
name = "humantime"
version = "2.2.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9b112acc8b3adf4b107a8ec20977da0273a8c386765a3ec0229bd500a1443f9f"
[[package]]
name = "is-terminal"
version = "0.4.16"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "e04d7f318608d35d4b61ddd75cbdaee86b023ebe2bd5a66ee0915f0bf93095a9"
dependencies = [
"hermit-abi 0.5.2",
"libc",
"windows-sys 0.59.0",
]
[[package]] [[package]]
name = "itoa" name = "itoa"
version = "1.0.14" version = "1.0.14"
@ -544,7 +589,7 @@ checksum = "a604568c3202727d1507653cb121dbd627a58684eb09a820fd746bee38b4442f"
dependencies = [ dependencies = [
"cfg-if 1.0.0", "cfg-if 1.0.0",
"concurrent-queue", "concurrent-queue",
"hermit-abi", "hermit-abi 0.4.0",
"pin-project-lite", "pin-project-lite",
"rustix", "rustix",
"tracing", "tracing",
@ -590,7 +635,9 @@ version = "0.1.0"
dependencies = [ dependencies = [
"async-std", "async-std",
"atomicwrites", "atomicwrites",
"env_logger",
"futures-util", "futures-util",
"log",
"main_error", "main_error",
"mdns", "mdns",
"serde", "serde",
@ -612,6 +659,35 @@ dependencies = [
"proc-macro2", "proc-macro2",
] ]
[[package]]
name = "regex"
version = "1.11.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b544ef1b4eac5dc2db33ea63606ae9ffcfac26c1416a2806ae0bf5f56b201191"
dependencies = [
"aho-corasick",
"memchr",
"regex-automata",
"regex-syntax",
]
[[package]]
name = "regex-automata"
version = "0.4.9"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "809e8dc61f6de73b46c85f4c96486310fe304c434cfa43669d7b40f711150908"
dependencies = [
"aho-corasick",
"memchr",
"regex-syntax",
]
[[package]]
name = "regex-syntax"
version = "0.8.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "2b15c43186be67a4fd63bee50d0303afffcef381492ebe2c5d87f324e1b8815c"
[[package]] [[package]]
name = "rustix" name = "rustix"
version = "0.38.42" version = "0.38.42"
@ -734,6 +810,15 @@ dependencies = [
"windows-sys 0.59.0", "windows-sys 0.59.0",
] ]
[[package]]
name = "termcolor"
version = "1.4.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "06794f8f6c5c898b3275aebefa6b8a1cb24cd2c6c79397ab15774837a0bc5755"
dependencies = [
"winapi-util",
]
[[package]] [[package]]
name = "tracing" name = "tracing"
version = "0.1.41" version = "0.1.41"
@ -867,6 +952,15 @@ version = "0.4.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "ac3b87c63620426dd9b991e5ce0329eff545bccbbb34f3be09ff6fb6ab51b7b6" checksum = "ac3b87c63620426dd9b991e5ce0329eff545bccbbb34f3be09ff6fb6ab51b7b6"
[[package]]
name = "winapi-util"
version = "0.1.9"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "cf221c93e13a30d793f7645a0e7762c55d169dbb0a49671918a2319d289b10bb"
dependencies = [
"windows-sys 0.59.0",
]
[[package]] [[package]]
name = "winapi-x86_64-pc-windows-gnu" name = "winapi-x86_64-pc-windows-gnu"
version = "0.4.0" version = "0.4.0"

View file

@ -18,6 +18,8 @@ serde_json = "1.0.133"
atomicwrites = "0.4.4" atomicwrites = "0.4.4"
main_error = "0.1.2" main_error = "0.1.2"
futures-util = "0.3.31" futures-util = "0.3.31"
log = "0.4"
env_logger = "0.10"
[profile.release] [profile.release]
lto = true lto = true

View file

@ -8,6 +8,8 @@ use std::io::Write;
use std::net::SocketAddr; use std::net::SocketAddr;
use std::time::Duration; use std::time::Duration;
use std::time::Instant; use std::time::Instant;
use log::{debug, error, log_enabled, info, Level};
/// The hostname of the devices we are searching for. /// The hostname of the devices we are searching for.
const SERVICE_NAME: &str = "_prometheus-http._tcp.local"; const SERVICE_NAME: &str = "_prometheus-http._tcp.local";
@ -38,6 +40,7 @@ const INTERVAL: Duration = Duration::from_secs(15);
#[async_std::main] #[async_std::main]
async fn main() -> Result<(), main_error::MainError> { async fn main() -> Result<(), main_error::MainError> {
env_logger::init();
let out = env::args() let out = env::args()
.nth(1) .nth(1)
.map(|path| AtomicFile::new(path, AllowOverwrite)); .map(|path| AtomicFile::new(path, AllowOverwrite));
@ -49,6 +52,7 @@ async fn main() -> Result<(), main_error::MainError> {
while let Some(Ok(response)) = stream.next().await { while let Some(Ok(response)) = stream.next().await {
let response: Response = response; let response: Response = response;
log::trace!("Received Response: {:?}", response);
let addr = response.socket_address(); let addr = response.socket_address();
let mut labels: HashMap<String, String> = response let mut labels: HashMap<String, String> = response
.txt_records() .txt_records()
@ -74,6 +78,7 @@ async fn main() -> Result<(), main_error::MainError> {
}; };
let start_count = services.len(); let start_count = services.len();
log::trace!("Adding service: {}", service.addr);
services.insert(service.addr, service); services.insert(service.addr, service);
let added_count = services.len(); let added_count = services.len();