Trait StoreAccessorProxyInterface

pub trait StoreAccessorProxyInterface: Send + Sync {
    type GetValueResponseFut: Future<Output = Result<Option<Box<Value>>, Error>> + Send;
    type FlushResponseFut: Future<Output = Result<StoreAccessorFlushResult, Error>> + Send;

    // Required methods
    fn get_value(&self, key: &str) -> Self::GetValueResponseFut;
    fn set_value(&self, key: &str, val: Value) -> Result<(), Error>;
    fn delete_value(&self, key: &str) -> Result<(), Error>;
    fn list_prefix(
        &self,
        prefix: &str,
        it: ServerEnd<ListIteratorMarker>,
    ) -> Result<(), Error>;
    fn get_prefix(
        &self,
        prefix: &str,
        it: ServerEnd<GetIteratorMarker>,
    ) -> Result<(), Error>;
    fn delete_prefix(&self, prefix: &str) -> Result<(), Error>;
    fn commit(&self) -> Result<(), Error>;
    fn flush(&self) -> Self::FlushResponseFut;
}

Required Associated Types

type GetValueResponseFut: Future<Output = Result<Option<Box<Value>>, Error>> + Send

type FlushResponseFut: Future<Output = Result<StoreAccessorFlushResult, Error>> + Send

Required Methods

fn get_value(&self, key: &str) -> Self::GetValueResponseFut

fn set_value(&self, key: &str, val: Value) -> Result<(), Error>

fn delete_value(&self, key: &str) -> Result<(), Error>

fn list_prefix( &self, prefix: &str, it: ServerEnd<ListIteratorMarker>, ) -> Result<(), Error>

fn get_prefix( &self, prefix: &str, it: ServerEnd<GetIteratorMarker>, ) -> Result<(), Error>

fn delete_prefix(&self, prefix: &str) -> Result<(), Error>

fn commit(&self) -> Result<(), Error>

fn flush(&self) -> Self::FlushResponseFut

Implementors

impl StoreAccessorProxyInterface for StoreAccessorProxy

type GetValueResponseFut = QueryResponseFut<Option<Box<Value>>>

type FlushResponseFut = QueryResponseFut<Result<(), FlushError>>