azure_functions/timer/
schedule_status.rs

1use crate::util::deserialize_datetime;
2use chrono::{DateTime, Utc};
3use serde::Deserialize;
4
5/// Represents a timer binding schedule status.
6#[derive(Debug, Deserialize)]
7#[serde(rename_all = "PascalCase")]
8pub struct ScheduleStatus {
9    /// The last recorded schedule occurrence.
10    #[serde(deserialize_with = "deserialize_datetime")]
11    pub last: DateTime<Utc>,
12    /// The expected next schedule occurrence.
13    #[serde(deserialize_with = "deserialize_datetime")]
14    pub next: DateTime<Utc>,
15    /// The last time the timer record was updated.
16    ///
17    /// This is used to re-calculate `next` with the current schedule after a host restart.
18    #[serde(deserialize_with = "deserialize_datetime")]
19    pub last_updated: DateTime<Utc>,
20}
21
22#[cfg(test)]
23mod tests {
24    use super::*;
25    use serde_json::from_str;
26
27    #[test]
28    fn it_deserializes_from_json() {
29        const JSON: &'static str = r#"{"Last":"0001-01-01T00:00:00","Next":"2018-07-24T23:24:00-07:00","LastUpdated":"2018-07-28T02:00:32+00:00"}"#;
30
31        let status: ScheduleStatus =
32            from_str(JSON).expect("failed to parse schedule status JSON data");
33        assert_eq!(status.last.to_rfc3339(), "0001-01-01T00:00:00+00:00");
34        assert_eq!(status.next.to_rfc3339(), "2018-07-25T06:24:00+00:00");
35        assert_eq!(
36            status.last_updated.to_rfc3339(),
37            "2018-07-28T02:00:32+00:00"
38        );
39    }
40}
azure_functions/timer/schedule_status.rs

azure_functions/timer/
schedule_status.rs
