Struct Daemon 

pub struct Daemon<K, V, S> {

    pub hasher: S,
    pub arena: Arena,
    pub t1: Arc<T1<K, V>>,
    pub t2: Arc<T2<K, V>>,
    pub cache: Arc<Cache<K, V>>,
    pub cmd_rx: Receiver<Command<K, V>>,
    pub hit_rx: Receiver<[usize; 64]>,
    pub epoch: Arc<AtomicU32>,
    pub duration: u32,
    pub admission: Arc<AdmissionFilter>,
    pub hit_accumulator: Vec<usize>,
    pub last_decay_epoch: u32,
    pub garbage_queue: Vec<(*mut Node<K, V>, usize)>,
    pub worker_states: Arc<[WorkerState]>,
}

Fields

hasher: S

arena: Arena

t1: Arc<T1<K, V>>

t2: Arc<T2<K, V>>

cache: Arc<Cache<K, V>>

cmd_rx: Receiver<Command<K, V>>

hit_rx: Receiver<[usize; 64]>

epoch: Arc<AtomicU32>

duration: u32

admission: Arc<AdmissionFilter>

hit_accumulator: Vec<usize>

last_decay_epoch: u32

garbage_queue: Vec<(*mut Node<K, V>, usize)>

worker_states: Arc<[WorkerState]>

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: Receiver<Command<K, V>>, hit_rx: Receiver<[usize; 64]>, epoch: Arc<AtomicU32>, duration: u32, worker_states: Arc<[WorkerState]>, ) -> Self

pub fn run(self)

Trait Implementations

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