rifts 0.2.0

Rift Realtime Protocol / 1.0 — server-side implementation
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
29
30
31

//! Retention policy (spec §9.3).

use std::time::Duration;

/// How long messages on a topic are kept.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Default)]
pub enum RetentionPolicy {
    /// No retention — messages are not kept after fanout.
    None,
    /// Retain for at most this duration.
    Ttl(Duration),
    /// Retain at most this many messages.
    Count(usize),
    /// Retain at most this many bytes.
    Size(usize),
    /// External durable storage controls retention.
    Durable,
    /// Only the latest value per state key is kept.
    #[default]
    Latest,
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn default_is_latest() {
        assert_eq!(RetentionPolicy::default(), RetentionPolicy::Latest);
    }
}