Struct dstore::Local

pub struct Local {
    pub addr: String,
    // some fields omitted
}

Maintain state of Local cache

Fields

addr: String

Using an address as UID

Implementations

impl Local

pub async fn new(
    global_addr: String,
    addr: String
) -> Result<Arc<Mutex<Self>>, Box<dyn Error>>

Generate reference counted pointer to datastructure maintaining Local state

pub async fn update(&mut self)

Remove cached mappings as per directions from Global Invalidation queue

pub async fn insert(
    &mut self,
    key: Bytes,
    value: Bytes
) -> Result<(), Box<dyn Error>>

Insert VALUEs onto Global in either a single packet or as a stream as per it’s size

pub async fn insert_single(
    &mut self,
    key: Bytes,
    value: Bytes
) -> Result<(), Box<dyn Error>>

Insert a single packet sized KEY->VALUE mapping onto Global and store in cache

pub async fn insert_file(
    &mut self,
    key: Bytes,
    value: Bytes
) -> Result<(), Box<dyn Error>>

Insert large KEY -> VALUE mappings on Global and store in cache

pub async fn get(&mut self, key: &Bytes) -> Result<Bytes, Box<dyn Error>>

Get VALUE associated with KEY from system

pub async fn get_single(&mut self, key: &Bytes) -> Result<Bytes, Box<dyn Error>>

Get VALUES that can fit in a single packet

pub async fn get_file(&mut self, key: &Bytes) -> Result<Bytes, Box<dyn Error>>

Get VALUES that don’t fit in a single packet

pub async fn remove(&mut self, key: &Bytes) -> Result<(), Box<dyn Error>>

Remove a KEY from the system