我正在实现一个时雄/axum HTTP服务器。在我运行服务器的函数中,我配置路由,添加共享应用服务并添加跟踪层。
我的跟踪配置如下所示:
let tracing_layer = TraceLayer::new_for_http()
.make_span_with(|_request: &Request<Body>| {
let request_id = Uuid::new_v4().to_string();
tracing::info_span!("http-request", %request_id)
})
.on_request(|request: &Request<Body>, _span: &Span| {
tracing::info!("request: {} {}", request.method(), request.uri().path())
})
.on_response(
|response: &Response<BoxBody>, latency: Duration, _span: &Span| {
tracing::info!("response: {} {:?}", response.status(), latency)
},
)
.on_failure(
|error: ServerErrorsFailureClass, _latency: Duration, _span: &Span| {
tracing::error!("error: {}", error)
},
);
let app = Router::new()
// routes
.layer(tracing_layer)
// other layers
...
为了组织代码,我将跟踪层配置移到了一个单独的函数中。诀窍是为这个函数提供一个编译返回类型。
第一种方法是按原样移动代码,让IDE生成返回类型:
TraceLayer<SharedClassifier<ServerErrorsAsFailures>, fn(&Request<Body>) -> Span, fn(&Request<Body>, &Span), fn(&Response<BoxBody>, Duration, &Span), DefaultOnBodyChunk, DefaultOnEos, fn(ServerErrorsFailureClass, Duration, &Span)>
这是完全不可读的,但最糟糕的是它不能编译:“需要fn指针,找到闭包”
在第二种方法中,我将fn
改为impl Fn
,这意味着一个闭包类型。再次,我得到一个错误,我的闭包不是Clone
。
第三,我尝试将闭包提取到单独的函数中。但是我得到了“预期的fn指针,找到了fn项”。
我能做什么1)使它编译和2)使它更可读?
1条答案
按热度按时间xriantvc1#
根据经验,由于所有的泛型,像这样分解代码是非常困难的。我建议使用接受并返回
axum::Routers
的函数。这样你就绕过了所有的泛型: