mirror of
https://github.com/tokio-rs/axum.git
synced 2024-12-29 07:48:39 +01:00
Show how to configure TraceLayer
(#314)
This isn't very obvious so makes sense to include in the example
This commit is contained in:
parent
36665793c3
commit
4e088b40f6
1 changed files with 39 additions and 4 deletions
|
@ -4,9 +4,16 @@
|
||||||
//! cargo run -p example-tracing-aka-logging
|
//! cargo run -p example-tracing-aka-logging
|
||||||
//! ```
|
//! ```
|
||||||
|
|
||||||
use axum::{handler::get, response::Html, Router};
|
use axum::{
|
||||||
use std::net::SocketAddr;
|
body::Bytes,
|
||||||
use tower_http::trace::TraceLayer;
|
handler::get,
|
||||||
|
http::{HeaderMap, Request, Response},
|
||||||
|
response::Html,
|
||||||
|
Router,
|
||||||
|
};
|
||||||
|
use std::{net::SocketAddr, time::Duration};
|
||||||
|
use tower_http::{classify::ServerErrorsFailureClass, trace::TraceLayer};
|
||||||
|
use tracing::Span;
|
||||||
|
|
||||||
#[tokio::main]
|
#[tokio::main]
|
||||||
async fn main() {
|
async fn main() {
|
||||||
|
@ -24,8 +31,36 @@ async fn main() {
|
||||||
.route("/", get(handler))
|
.route("/", get(handler))
|
||||||
// `TraceLayer` is provided by tower-http so you have to add that as a dependency.
|
// `TraceLayer` is provided by tower-http so you have to add that as a dependency.
|
||||||
// It provides good defaults but is also very customizable.
|
// It provides good defaults but is also very customizable.
|
||||||
|
//
|
||||||
// See https://docs.rs/tower-http/0.1.1/tower_http/trace/index.html for more details.
|
// See https://docs.rs/tower-http/0.1.1/tower_http/trace/index.html for more details.
|
||||||
.layer(TraceLayer::new_for_http());
|
.layer(TraceLayer::new_for_http())
|
||||||
|
// If you want to customize the behavior using closures here is how
|
||||||
|
//
|
||||||
|
// This is just for demonstration, you don't need to add this middleware twice
|
||||||
|
.layer(
|
||||||
|
TraceLayer::new_for_http()
|
||||||
|
.on_request(|_request: &Request<_>, _span: &Span| {
|
||||||
|
// ...
|
||||||
|
})
|
||||||
|
.on_response(
|
||||||
|
|_response: &Response<_>, _latency: Duration, _span: &Span| {
|
||||||
|
// ...
|
||||||
|
},
|
||||||
|
)
|
||||||
|
.on_body_chunk(|_chunk: &Bytes, _latency: Duration, _span: &Span| {
|
||||||
|
// ..
|
||||||
|
})
|
||||||
|
.on_eos(
|
||||||
|
|_trailers: Option<&HeaderMap>, _stream_duration: Duration, _span: &Span| {
|
||||||
|
// ...
|
||||||
|
},
|
||||||
|
)
|
||||||
|
.on_failure(
|
||||||
|
|_error: ServerErrorsFailureClass, _latency: Duration, _span: &Span| {
|
||||||
|
// ...
|
||||||
|
},
|
||||||
|
),
|
||||||
|
);
|
||||||
|
|
||||||
// run it
|
// run it
|
||||||
let addr = SocketAddr::from(([127, 0, 0, 1], 3000));
|
let addr = SocketAddr::from(([127, 0, 0, 1], 3000));
|
||||||
|
|
Loading…
Reference in a new issue