Method samples_widget

src/ui/app.rs:171–242

(&mut self, ui: &mut Ui)

    }

    fn samples_widget(&mut self, ui: &mut Ui) -> (UtcTimestamp, UtcTimestamp) {
        let plot = Plot::new("trace_counts")
            .custom_x_axes(vec![timeaxis::mk_time_axis(Axis::X)])
            .custom_y_axes(vec![AxisHints::new_y().label("Samples")])
            .y_axis_min_width(2.0)
            .x_grid_spacer(timeaxis::mk_time_grid)
            .allow_drag([true, false])
            .height(100.0)
            .label_formatter(|_, val| {
                format!(
                    "Time: {}\nSamples: {:.0}",
                    timeaxis::ts2chrono(val.x as i64),
                    val.y
                )
            });

        let response = plot.show(ui, |pui| {
            let data_start;
            let data_end;

            // If there's a requested time range (from tab action), use it
            if let Some((req_start, req_end)) = self.requested_time_range.take() {
                data_start = req_start;
                data_end = req_end;

                pui.set_plot_bounds(PlotBounds::from_min_max(
                    [data_start as f64, -f64::MIN],
                    [data_end as f64, f64::MAX],
                ));
            } else if let Some(new_lookback) = self.auto_scroll_time {
                let now = chrono::Utc::now();

                data_start = (now - new_lookback).timestamp() as UtcTimestamp;
                data_end = now.timestamp() as UtcTimestamp;

                pui.set_plot_bounds(PlotBounds::from_min_max(
                    [data_start as f64, -f64::MIN],
                    [data_end as f64, f64::MAX],
                ));
            } else {
                let bounds = pui.plot_bounds();
                data_start = bounds.min()[0] as UtcTimestamp;
                data_end = bounds.max()[0] as UtcTimestamp;
            }

            let kind = self.kind.clone();
            let points =
                self.sample_agg_cache
                    .get_or_create((kind, data_start, data_end), move || {
                        DB.trace_events
                            .event_count_buckets(kind, data_start, data_end, 1000)
                            .into_iter()
                            .map(|(time, count)| [time as f64, count as f64])
                            .collect()
                    });

            pui.line(Line::new("", points.clone()));
            pui.set_auto_bounds(egui::Vec2b::new(false, true));