Compare commits

...
Author SHA1 Message Date
0a3a592291 V2
Reviewed-on: #2
2026-02-21 10:51:46 +01:00
dzu
b13bbe9408 Merge branch 'main' into dev ? 2026-02-21 09:49:57 +00:00
dzu
2904b795a2 fix: remove client logging 2026-02-21 09:39:30 +00:00
dzu
9940c26771 upd: anyhow and syn 2026-02-20 15:10:04 +00:00
dzu
479d6fe414 ench: use tracing for logging 2026-02-20 13:43:31 +00:00
dzu
03a207d32a fix: 200OK is not an error 2026-02-20 09:44:36 +00:00
dzu
c685a1db3e fix: commit cache 2026-02-20 09:36:14 +00:00
dzu
8be075e61b fix: use correct Uri syntax 2026-02-20 09:12:28 +00:00
dzu
a3c38e595c add: uri logging 2026-02-20 08:49:14 +00:00
dzu
a50d6cb49c fix: getCacheEntry url parameters 2026-02-20 08:44:26 +00:00
dzu
d2e683de28 add: cache downloading 2026-02-20 08:01:37 +00:00
dzu
9de30e2308 move flexible Client input types 2026-02-19 10:11:57 +00:00
dzu
254f547719 initial common version 2026-02-19 10:04:36 +00:00

View file

@ -9,7 +9,7 @@ use isahc::{
http::{Method, StatusCode, header}, http::{Method, StatusCode, header},
}; };
use secrecy::SecretString; use secrecy::SecretString;
use tracing::{Level, debug, error}; use tracing::{Level, debug, error, info};
use tracing_subscriber::fmt::format::FmtSpan; use tracing_subscriber::fmt::format::FmtSpan;
pub fn setup_logger(debug: bool) { pub fn setup_logger(debug: bool) {
@ -105,8 +105,9 @@ impl Client {
}) })
} }
#[tracing::instrument(level = "info", skip(cache))] #[tracing::instrument(level = "debug", skip(cache))]
pub fn save_cache(&self, key: &CacheKey, cache: Vec<u8>) -> Result<()> { pub fn save_cache(&self, key: &CacheKey, cache: Vec<u8>) -> Result<()> {
info!(?key, "save cache");
let cache_len = cache.len(); let cache_len = cache.len();
let cache_id = self.reserve(key, cache_len).context("reserving cache")?; let cache_id = self.reserve(key, cache_len).context("reserving cache")?;
@ -234,8 +235,9 @@ impl Client {
Ok(()) Ok(())
} }
#[tracing::instrument(level = "info")] #[tracing::instrument(level = "debug")]
pub fn load_cache(&self, key: &CacheKey) -> Result<Option<Box<[u8]>>> { pub fn load_cache(&self, key: &CacheKey) -> Result<Option<Box<[u8]>>> {
info!(?key, "load cache");
let Some(cache_location) = self.get_cache_entry(key).context("getting cache entry")? else { let Some(cache_location) = self.get_cache_entry(key).context("getting cache entry")? else {
// cache miss // cache miss
return Ok(None); return Ok(None);