daedalus-core 0.1.1

Core types and shared utilities for the Daedalus dataflow stack.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use serde::{Deserialize, Serialize};

/// Backpressure strategy applied to queues.
///
/// ```
/// use daedalus_core::policy::BackpressureStrategy;
/// let strategy = BackpressureStrategy::BoundedQueues;
/// assert_eq!(strategy, BackpressureStrategy::BoundedQueues);
/// ```
#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize, Default)]
pub enum BackpressureStrategy {
    /// No special backpressure; allow defaults.
    #[default]
    None,
    /// Apply bounded queues to edges.
    BoundedQueues,
    /// Treat queue overflow as an error.
    ErrorOnOverflow,
}