Function get

chirpstack/src/storage/metrics.rs:178–308

(
    name: &str,
    kind: Kind,
    a: Aggregation,
    start: DateTime<Local>,
    end: DateTime<Local>,
)

}

pub async fn get(
    name: &str,
    kind: Kind,
    a: Aggregation,
    start: DateTime<Local>,
    end: DateTime<Local>,
) -> Result<Vec<Record>> {
    let mut keys: Vec<String> = Vec::new();
    let mut timestamps: Vec<NaiveDateTime> = Vec::new();

    match a {
        Aggregation::MINUTE => {
            let mut ts = NaiveDate::from_ymd_opt(start.year(), start.month(), start.day())
                .ok_or_else(|| anyhow!("Invalid date"))?
                .and_hms_opt(start.hour(), start.minute(), 0)
                .ok_or_else(|| anyhow!("Invalid time"))?;
            let end = NaiveDate::from_ymd_opt(end.year(), end.month(), end.day())
                .ok_or_else(|| anyhow!("Invalid date"))?
                .and_hms_opt(end.hour(), end.minute(), 0)
                .ok_or_else(|| anyhow!("Invalid time"))?;

            while ts.le(&end) {
                timestamps.push(ts);
                keys.push(get_key(name, a, ts));
                ts += ChronoDuration::minutes(1);
            }
        }
        Aggregation::HOUR => {
            let mut ts = NaiveDate::from_ymd_opt(start.year(), start.month(), start.day())
                .ok_or_else(|| anyhow!("Invalid date"))?
                .and_hms_opt(start.hour(), 0, 0)
                .ok_or_else(|| anyhow!("Invalid time"))?;
            let end = NaiveDate::from_ymd_opt(end.year(), end.month(), end.day())
                .ok_or_else(|| anyhow!("Invalid date"))?
                .and_hms_opt(end.hour(), 0, 0)
                .ok_or_else(|| anyhow!("Invalid time"))?;

            while ts.le(&end) {
                timestamps.push(ts);
                keys.push(get_key(name, a, ts));
                ts += ChronoDuration::hours(1);
            }
        }
        Aggregation::DAY => {
            let mut ts = NaiveDate::from_ymd_opt(start.year(), start.month(), start.day())
                .ok_or_else(|| anyhow!("Invalid date"))?
                .and_hms_opt(0, 0, 0)
                .ok_or_else(|| anyhow!("Invalid time"))?;
            let end = NaiveDate::from_ymd_opt(end.year(), end.month(), end.day())
                .ok_or_else(|| anyhow!("Invalid date"))?
                .and_hms_opt(0, 0, 0)
                .ok_or_else(|| anyhow!("Invalid time"))?;

            while ts.le(&end) {
                timestamps.push(ts);
                keys.push(get_key(name, a, ts));
                ts += ChronoDuration::days(1);
            }