hayas1 · hayas1 · Dec 25, 2024 · Dec 20, 2024 · Dec 20, 2024 · Dec 20, 2024
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -44,6 +44,8 @@ jsonptr = { version = "0.6.3", optional = true }
 clap = { version = "4.5.23", features = ["derive"], optional = true }
 console = { version = "0.15.10", optional = true }
 nom = "7.1.3"
+# average = "0.15.1" # Quantile (that use p2 algorithm) do not impl Extend
+hdrhistogram = "7.5.4"
 
 
 [dev-dependencies]

diff --git a/examples/service.rs b/examples/service.rs
@@ -0,0 +1,26 @@
+use std::process::ExitCode;
+
+#[tokio::main]
+#[cfg(all(feature = "yaml", feature = "json", feature = "console-report"))]
+async fn main() -> Result<ExitCode, Box<dyn std::error::Error + Send + Sync>> {
+    use axum::{body::Body, extract::Request};
+    use relentless::{interface::command::Relentless, Error};
+    use relentless_dev_server::route;
+
+    let cmd = Relentless {
+        file: vec!["examples/config/assault.yaml".into(), "examples/config/compare.yaml".into()],
+        ..Default::default()
+    };
+    let configs = cmd.configs().map_err(Error::from)?;
+    let service = route::app_with(Default::default());
+    let report = cmd.assault_with::<_, Request<Body>>(configs, service).await?;
+
+    cmd.report(&report)?;
+    Ok(report.exit_code(&cmd))
+}
+
+#[cfg(not(all(feature = "yaml", feature = "json", feature = "console-report")))]
+fn main() -> ExitCode {
+    eprintln!("Insufficient features for this example");
+    ExitCode::FAILURE
+}
diff --git a/src/assault/error.rs b/src/assault/error.rs
@@ -0,0 +1,26 @@
+use std::time::{Duration, SystemTimeError};
+
+use thiserror::Error;
+
+use super::measure::metrics::MeasuredResponse;
+
+pub type RequestResult<Res> = Result<MeasuredResponse<Res>, RequestError>;
+
+#[derive(Error, Debug)]
+pub enum RequestError {
+    #[error("request timeout: {0:?}")]
+    Timeout(Duration),
+
+    #[error(transparent)]
+    FailToMakeRequest(Box<dyn std::error::Error + Send + Sync>),
+
+    #[error(transparent)]
+    NoReady(Box<dyn std::error::Error + Send + Sync>),
+    #[error(transparent)]
+    InnerServiceError(Box<dyn std::error::Error + Send + Sync>),
+
+    #[error(transparent)]
+    FailToMeasureLatency(SystemTimeError),
+    #[error(transparent)]
+    Unknown(Box<dyn std::error::Error + Send + Sync>),
+}
diff --git a/src/assault/evaluator.rs b/src/assault/evaluator.rs
@@ -1,4 +1,4 @@
-use super::{destinations::Destinations, messages::Messages, metrics::RequestResult};
+use super::{destinations::Destinations, error::RequestResult, messages::Messages};
 
 #[allow(async_fn_in_trait)] // TODO #[warn(async_fn_in_trait)] by default
 pub trait Evaluator<Res> {