Trait StateBackend

Source
pub trait StateBackend: Send + Sync {
    // Required methods
    fn create(name: &str) -> Self
       where Self: Sized;
    fn put(&mut self, key: &[u8], value: &[u8]) -> ArconResult<()>;
    fn get(&self, key: &[u8]) -> ArconResult<Vec<u8>>;
    fn checkpoint(&self, id: String) -> ArconResult<()>;
}
Expand description

Trait required for all state backend implementations in Arcon

Required Methods§

Source

fn create(name: &str) -> Self
where Self: Sized,

Source

fn put(&mut self, key: &[u8], value: &[u8]) -> ArconResult<()>

Source

fn get(&self, key: &[u8]) -> ArconResult<Vec<u8>>

Source

fn checkpoint(&self, id: String) -> ArconResult<()>

Implementors§