rs-zero 0.2.8

Rust-first microservice framework inspired by go-zero engineering practices
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::time::Duration;

use axum::{Router, error_handling::HandleErrorLayer, response::IntoResponse};
use tower::{ServiceBuilder, timeout::TimeoutLayer};

use crate::rest::{RestError, response::ApiResponse};

/// Applies a timeout layer and maps elapsed requests into uniform responses.
pub fn apply_timeout(router: Router, duration: Duration) -> Router {
    router.layer(
        ServiceBuilder::new()
            .layer(HandleErrorLayer::new(|error: tower::BoxError| async move {
                if error.is::<tower::timeout::error::Elapsed>() {
                    RestError::Timeout.into_response()
                } else {
                    ApiResponse::<()>::fail("INTERNAL", error.to_string()).into_response()
                }
            }))
            .layer(TimeoutLayer::new(duration)),
    )
}