daedalus_core/
policy.rs

1use serde::{Deserialize, Serialize};
2
3/// Backpressure strategy applied to queues.
4///
5/// ```
6/// use daedalus_core::policy::BackpressureStrategy;
7/// let strategy = BackpressureStrategy::BoundedQueues;
8/// assert_eq!(strategy, BackpressureStrategy::BoundedQueues);
9/// ```
10#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize, Default)]
11pub enum BackpressureStrategy {
12    /// No special backpressure; allow defaults.
13    #[default]
14    None,
15    /// Apply bounded queues to edges.
16    BoundedQueues,
17    /// Treat queue overflow as an error.
18    ErrorOnOverflow,
19}