Trait arcon_backend::StateBackend

pub trait StateBackend: Send + Sync {
    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<()>;
}

Trait required for all state backend implementations in Arcon

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<()>

Loading content...

Implementors

impl StateBackend for InMemory

fn create(_name: &str) -> InMemory

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

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

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

Loading content...