Trait erdos::dataflow::deadlines::DeadlineT

source · [−]

pub trait DeadlineT<S>: Send + Sync {
    fn get_constrained_read_stream_ids(&self) -> &HashSet<StreamId>;
    fn get_constrained_write_stream_ids(&self) -> &HashSet<StreamId>;
    fn invoke_start_condition(
        &self, 
        read_stream_ids: &[StreamId], 
        condition_context: &ConditionContext, 
        timestamp: &Timestamp
    ) -> bool;
    fn calculate_deadline(&self, state: &S, timestamp: &Timestamp) -> Duration;
    fn get_end_condition_fn(&self) -> Arc<dyn CondFn>;
    fn id(&self) -> DeadlineId;
    fn invoke_handler(&self, state: &S, timestamp: &Timestamp);
}