File tree Expand file tree Collapse file tree
quickwit-common/src/tower Expand file tree Collapse file tree Original file line number Diff line number Diff line change 9595///
9696/// If the inner service does not complete within the specified duration,
9797/// the response will be aborted with the error `TimeoutExceeded`.
98+ ///
99+ /// Note that when used in combination with a retry layer, this should be
100+ /// stacked on top of it for the timeout to be retried.
98101#[ derive( Debug , Clone ) ]
99102pub struct TimeoutLayer {
100103 timeout : Duration ,
Original file line number Diff line number Diff line change @@ -463,8 +463,8 @@ pub async fn serve_quickwit(
463463 bail ! ( "could not find any metastore node in the cluster" ) ;
464464 }
465465 MetastoreServiceClient :: tower ( )
466- . stack_layer ( TimeoutLayer :: new ( GRPC_METASTORE_SERVICE_TIMEOUT ) )
467466 . stack_layer ( RetryLayer :: new ( RetryPolicy :: from ( RetryParams :: standard ( ) ) ) )
467+ . stack_layer ( TimeoutLayer :: new ( GRPC_METASTORE_SERVICE_TIMEOUT ) )
468468 . stack_layer ( METASTORE_GRPC_CLIENT_METRICS_LAYER . clone ( ) )
469469 . stack_layer ( tower:: limit:: GlobalConcurrencyLimitLayer :: new (
470470 get_metastore_client_max_concurrency ( ) ,
You can’t perform that action at this time.
0 commit comments