From e6962683acaaa28de91d6645334088d049a97d8f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Gr=C3=A9goire=20Roussel?= Date: Thu, 29 Jan 2026 13:08:05 +0100 Subject: [PATCH] mooore histograms --- lading/src/generator/http.rs | 3 ++- lading_capture/src/formats/multi.rs | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/lading/src/generator/http.rs b/lading/src/generator/http.rs index efdf068bf..0726593cc 100644 --- a/lading/src/generator/http.rs +++ b/lading/src/generator/http.rs @@ -19,7 +19,7 @@ use std::{ use hyper::{HeaderMap, Request, Uri, header::CONTENT_LENGTH}; use hyper_util::{client::legacy::Client, rt::TokioExecutor}; -use metrics::counter; +use metrics::{counter, histogram}; use once_cell::sync::OnceCell; use rand::{SeedableRng, prelude::StdRng}; use serde::{Deserialize, Serialize}; @@ -258,6 +258,7 @@ impl Http { match client.request(request).await { Ok(response) => { counter!("bytes_written", &labels).increment(block_length as u64); + histogram!("bytes_written_histogram", &labels).record(block_length as f64); if let Some(dp) = data_points { counter!("data_points_transmitted", &labels).increment(dp); diff --git a/lading_capture/src/formats/multi.rs b/lading_capture/src/formats/multi.rs index a1a0414f8..432719b33 100644 --- a/lading_capture/src/formats/multi.rs +++ b/lading_capture/src/formats/multi.rs @@ -20,7 +20,7 @@ pub enum Error { /// Multi-format writer /// -/// Writes metrics to both JSONL and Parquet formats, uses fail-fast sematics on +/// Writes metrics to both JSONL and Parquet formats, uses fail-fast semantics on /// errors from either format. #[derive(Debug)] pub struct Format {