crdb-cache 0.0.1-alpha.0

Concurrently Replicated DataBase
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

use crdb_core::BinPtr;
use std::{
    collections::HashMap,
    sync::{Arc, Weak},
};

pub struct BinariesCache {
    data: HashMap<BinPtr, Weak<[u8]>>,
}

impl BinariesCache {
    pub fn new() -> BinariesCache {
        BinariesCache {
            data: HashMap::new(),
        }
    }

    pub fn insert(&mut self, id: BinPtr, value: Weak<[u8]>) {
        self.data.insert(id, value);
    }

    pub fn get(&self, binary_id: &BinPtr) -> Option<Arc<[u8]>> {
        self.data.get(binary_id).and_then(|b| b.upgrade())
    }
}

impl Default for BinariesCache {
    fn default() -> BinariesCache {
        BinariesCache::new()
    }
}