Skip to content

Commit 9ae9f11

Browse files
committed
refactor(app/inbound): qualified body metrics imports
see #4180. to make way for the use of request body metrics middleware, we use further qualified paths to `body_data::response::NewRecordBodyData`. to be consistent across the board, we apply this change to the request counting middleware as well. NB: this is based upon #4186. Signed-off-by: katelyn martin <[email protected]>
1 parent 2a2433e commit 9ae9f11

File tree

1 file changed

+11
-11
lines changed

1 file changed

+11
-11
lines changed

linkerd/app/inbound/src/http/router/metrics.rs

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,8 @@ use linkerd_app_core::{
1111
svc,
1212
};
1313
use linkerd_http_prom::{
14-
body_data::{response::NewRecordBodyData, BodyDataMetrics},
15-
count_reqs::{NewCountRequests, RequestCount},
14+
body_data::{self, BodyDataMetrics},
15+
count_reqs::{self, NewCountRequests, RequestCount},
1616
};
1717

1818
pub(super) fn layer<N>(
@@ -25,7 +25,7 @@ pub(super) fn layer<N>(
2525
N,
2626
Service = NewCountRequests<
2727
ExtractRequestCount,
28-
NewRecordBodyData<ExtractRecordBodyDataMetrics, N>,
28+
body_data::response::NewRecordBodyData<ExtractRecordBodyDataMetrics, N>,
2929
>,
3030
> {
3131
use svc::Layer as _;
@@ -37,16 +37,16 @@ pub(super) fn layer<N>(
3737

3838
let body = {
3939
let extract = ExtractRecordBodyDataMetrics(response_body_data.clone());
40-
NewRecordBodyData::layer_via(extract)
40+
body_data::response::NewRecordBodyData::layer_via(extract)
4141
};
4242

4343
svc::layer::mk(move |inner| count.layer(body.layer(inner)))
4444
}
4545

4646
#[derive(Clone, Debug)]
4747
pub struct RequestCountFamilies {
48-
grpc: linkerd_http_prom::count_reqs::RequestCountFamilies<RequestCountLabels>,
49-
http: linkerd_http_prom::count_reqs::RequestCountFamilies<RequestCountLabels>,
48+
grpc: count_reqs::RequestCountFamilies<RequestCountLabels>,
49+
http: count_reqs::RequestCountFamilies<RequestCountLabels>,
5050
}
5151

5252
#[derive(Clone, Debug, Hash, PartialEq, Eq)]
@@ -59,8 +59,8 @@ pub struct ExtractRequestCount(pub RequestCountFamilies);
5959

6060
#[derive(Clone, Debug)]
6161
pub struct ResponseBodyFamilies {
62-
grpc: linkerd_http_prom::body_data::response::ResponseBodyFamilies<ResponseBodyDataLabels>,
63-
http: linkerd_http_prom::body_data::response::ResponseBodyFamilies<ResponseBodyDataLabels>,
62+
grpc: body_data::response::ResponseBodyFamilies<ResponseBodyDataLabels>,
63+
http: body_data::response::ResponseBodyFamilies<ResponseBodyDataLabels>,
6464
}
6565

6666
#[derive(Clone, Debug, Hash, PartialEq, Eq)]
@@ -159,12 +159,12 @@ impl ResponseBodyFamilies {
159159
pub fn register(reg: &mut prom::Registry) -> Self {
160160
let grpc = {
161161
let reg = reg.sub_registry_with_prefix("grpc");
162-
linkerd_http_prom::body_data::response::ResponseBodyFamilies::register(reg)
162+
body_data::response::ResponseBodyFamilies::register(reg)
163163
};
164164

165165
let http = {
166166
let reg = reg.sub_registry_with_prefix("http");
167-
linkerd_http_prom::body_data::response::ResponseBodyFamilies::register(reg)
167+
body_data::response::ResponseBodyFamilies::register(reg)
168168
};
169169

170170
Self { grpc, http }
@@ -174,7 +174,7 @@ impl ResponseBodyFamilies {
174174
fn family(
175175
&self,
176176
variant: PermitVariant,
177-
) -> &linkerd_http_prom::body_data::response::ResponseBodyFamilies<ResponseBodyDataLabels> {
177+
) -> &body_data::response::ResponseBodyFamilies<ResponseBodyDataLabels> {
178178
let Self { grpc, http } = self;
179179
match variant {
180180
PermitVariant::Grpc => grpc,

0 commit comments

Comments
 (0)