feldera_buffer_cache/
thread_type.rs

1use enum_map::Enum;
2use serde::Serialize;
3use std::fmt::{Display, Formatter, Result as FmtResult};
4
5/// Type of a DBSP worker thread that owns a buffer-cache slot.
6#[derive(Copy, Clone, Debug, Eq, PartialEq, Hash, Enum, Serialize)]
7#[serde(rename_all = "snake_case")]
8pub enum ThreadType {
9    /// Circuit thread.
10    Foreground,
11
12    /// Merger thread.
13    Background,
14}
15
16impl Display for ThreadType {
17    fn fmt(&self, f: &mut Formatter<'_>) -> FmtResult {
18        match self {
19            ThreadType::Foreground => write!(f, "foreground"),
20            ThreadType::Background => write!(f, "background"),
21        }
22    }
23}

feldera_buffer_cache/thread_type.rs

feldera_buffer_cache/
thread_type.rs