Skip to content

Commit 5853fad

Browse files
committed
Import some items from selector
1 parent e657a24 commit 5853fad

File tree

1 file changed

+19
-25
lines changed

1 file changed

+19
-25
lines changed

site/src/request_handlers/graph.rs

Lines changed: 19 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ use crate::api::{graph, ServerResult};
77
use crate::db::{self, ArtifactId, Benchmark, Profile, Scenario};
88
use crate::interpolate::Interpolated;
99
use crate::load::SiteCtxt;
10-
use crate::selector::{self, PathComponent, Tag};
10+
use crate::selector::{Path, PathComponent, Query, Selector, SeriesResponse, Tag};
1111

1212
pub async fn handle_graph(
1313
body: graph::Request,
@@ -95,15 +95,15 @@ async fn handle_graph_impl(
9595
let range = ctxt.data_range(body.start.clone()..=body.end.clone());
9696
let commits: Arc<Vec<_>> = Arc::new(range.iter().map(|c| c.clone().into()).collect());
9797

98-
let metric_selector = selector::Selector::One(body.stat.clone());
98+
let metric_selector = Selector::One(body.stat.clone());
9999

100100
let series = ctxt
101101
.statistic_series(
102-
selector::Query::new()
103-
.set::<String>(selector::Tag::Benchmark, selector::Selector::All)
104-
.set::<String>(selector::Tag::Profile, selector::Selector::All)
105-
.set::<String>(selector::Tag::Scenario, selector::Selector::All)
106-
.set::<String>(selector::Tag::Metric, metric_selector.clone()),
102+
Query::new()
103+
.set::<String>(Tag::Benchmark, Selector::All)
104+
.set::<String>(Tag::Profile, Selector::All)
105+
.set::<String>(Tag::Scenario, Selector::All)
106+
.set::<String>(Tag::Metric, metric_selector.clone()),
107107
commits.clone(),
108108
)
109109
.await?;
@@ -126,11 +126,11 @@ async fn handle_graph_impl(
126126
vec![body.stat.clone()]
127127
)
128128
.map(|(scenario, profile, metric)| {
129-
selector::Query::new()
130-
.set::<String>(selector::Tag::Benchmark, selector::Selector::All)
131-
.set(selector::Tag::Profile, selector::Selector::One(profile))
132-
.set(selector::Tag::Scenario, selector::Selector::One(scenario))
133-
.set::<String>(selector::Tag::Metric, selector::Selector::One(metric))
129+
Query::new()
130+
.set::<String>(Tag::Benchmark, Selector::All)
131+
.set(Tag::Profile, Selector::One(profile))
132+
.set(Tag::Scenario, Selector::One(scenario))
133+
.set::<String>(Tag::Metric, Selector::One(metric))
134134
});
135135

136136
for query in summary_queries {
@@ -148,17 +148,11 @@ async fn handle_graph_impl(
148148
.assert_one()
149149
.parse::<Scenario>()
150150
.unwrap();
151-
let q = selector::Query::new()
152-
.set::<String>(selector::Tag::Benchmark, selector::Selector::All)
153-
.set(selector::Tag::Profile, selector::Selector::One(profile))
154-
.set(
155-
selector::Tag::Scenario,
156-
selector::Selector::One(Scenario::Empty),
157-
)
158-
.set(
159-
selector::Tag::Metric,
160-
query.get(Tag::Metric).unwrap().raw.clone(),
161-
);
151+
let q = Query::new()
152+
.set::<String>(Tag::Benchmark, Selector::All)
153+
.set(Tag::Profile, Selector::One(profile))
154+
.set(Tag::Scenario, Selector::One(Scenario::Empty))
155+
.set(Tag::Metric, query.get(Tag::Metric).unwrap().raw.clone());
162156
let against = match baselines.entry(q.clone()) {
163157
std::collections::hash_map::Entry::Occupied(o) => *o.get(),
164158
std::collections::hash_map::Entry::Vacant(v) => {
@@ -183,8 +177,8 @@ async fn handle_graph_impl(
183177
)
184178
.map(|((c, d), i)| ((c, Some(d.expect("interpolated") / against)), i));
185179
let graph_data = to_graph_points(body.kind, averaged).collect::<Vec<_>>();
186-
series.push(selector::SeriesResponse {
187-
path: selector::Path::new()
180+
series.push(SeriesResponse {
181+
path: Path::new()
188182
.set(PathComponent::Benchmark("Summary".into()))
189183
.set(PathComponent::Profile(profile))
190184
.set(PathComponent::Scenario(scenario))

0 commit comments

Comments
 (0)