Struct Daemon 

pub struct Daemon<K, V, S> {
    pub hasher: S,
    pub core: CoreCache<K, V>,
    pub cmd_rx: Arc<LossyQueue<Command<K, V>>>,
    pub hit_rx: Arc<LossyQueue<[usize; 64]>>,
    pub poll_us: u64,
    pub daemon_tick: Arc<AtomicU64>,
}

Fields

hasher: S

core: CoreCache<K, V>

cmd_rx: Arc<LossyQueue<Command<K, V>>>

hit_rx: Arc<LossyQueue<[usize; 64]>>

poll_us: u64

Configurable poll interval in microseconds (1 000–10 000 µs).

daemon_tick: Arc<AtomicU64>

Monotonically increasing tick counter — incremented on every poll loop.

Implementations

impl<K, V, S> Daemon<K, V, S>

where K: Hash + Eq + Send + Sync + Clone + 'static, V: Send + Sync + Clone + 'static, S: BuildHasher + Clone + Send + 'static,

pub fn new( hasher: S, capacity: usize, t1: Arc<T1<K, V>>, t2: Arc<T2<K, V>>, cache: Arc<Cache<K, V>>, cmd_rx: Arc<LossyQueue<Command<K, V>>>, hit_rx: Arc<LossyQueue<[usize; 64]>>, epoch: Arc<AtomicU32>, duration: u32, poll_us: u64, worker_states: Arc<[WorkerState]>, daemon_tick: Arc<AtomicU64>, is_cold_start: Arc<AtomicBool>, ) -> Self

pub fn run(self)

Main Daemon event loop.

Trait Implementations

impl<K: Send, V: Send, S: Send> Send for Daemon<K, V, S>