feldera-buffer-cache 0.287.0

Weighted in-memory buffer caches with LRU and S3-FIFO eviction
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use enum_map::Enum;
use serde::Serialize;
use std::fmt::{Display, Formatter, Result as FmtResult};

/// Type of a DBSP worker thread that owns a buffer-cache slot.
#[derive(Copy, Clone, Debug, Eq, PartialEq, Hash, Enum, Serialize)]
#[serde(rename_all = "snake_case")]
pub enum ThreadType {
    /// Circuit thread.
    Foreground,

    /// Merger thread.
    Background,
}

impl Display for ThreadType {
    fn fmt(&self, f: &mut Formatter<'_>) -> FmtResult {
        match self {
            ThreadType::Foreground => write!(f, "foreground"),
            ThreadType::Background => write!(f, "background"),
        }
    }
}