arcon 0.2.1

A runtime for writing streaming applications
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use super::{ArconResult, Error};
use snafu::Snafu;
use std::fmt::Debug;

/// TimerResult type utilised while scheduling timers
pub type TimerResult<A> = ArconResult<std::result::Result<(), TimerExpiredError<A>>>;

#[derive(Debug, Snafu)]
#[snafu(display(
    "Attempted to schedule timer entry {:?} at {} when time is {}",
    entry,
    scheduled_time,
    current_time
))]
pub struct TimerExpiredError<A: Debug> {
    /// Current event time
    pub current_time: u64,
    /// The scheduled time
    pub scheduled_time: u64,
    /// Timer Entry
    pub entry: A,
}

impl<A: Debug> From<Error> for TimerResult<A> {
    fn from(error: Error) -> Self {
        Err(error)
    }
}