pub struct Backend<S: Adapter> { /* private fields */ }
Expand description
Backend of kv service.
Implementations§
Trait Implementations§
source§impl<S: Adapter> Accessor for Backend<S>
impl<S: Adapter> Accessor for Backend<S>
§type BlockingReader = Cursor
type BlockingReader = Cursor
BlockingReader is the associated reader that could return in
blocking_read
operation.§type BlockingWriter = KvWriter<S>
type BlockingWriter = KvWriter<S>
BlockingWriter is the associated writer the could return in
blocking_write
operation.§type BlockingPager = KvPager
type BlockingPager = KvPager
BlockingPager is the associated pager that could return in
blocking_list
or scan
operation.source§fn info(&self) -> AccessorInfo
fn info(&self) -> AccessorInfo
Invoke the
info
operation to get metadata of accessor. Read moresource§fn create<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
__arg2: OpCreate
) -> Pin<Box<dyn Future<Output = Result<RpCreate>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn create<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, __arg2: OpCreate ) -> Pin<Box<dyn Future<Output = Result<RpCreate>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,
Invoke the
create
operation on the specified path Read moresource§fn blocking_create(&self, path: &str, _: OpCreate) -> Result<RpCreate>
fn blocking_create(&self, path: &str, _: OpCreate) -> Result<RpCreate>
Invoke the
blocking_create
operation on the specified path. Read moresource§fn read<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
args: OpRead
) -> Pin<Box<dyn Future<Output = Result<(RpRead, Self::Reader)>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn read<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, args: OpRead ) -> Pin<Box<dyn Future<Output = Result<(RpRead, Self::Reader)>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,
source§fn blocking_read(
&self,
path: &str,
args: OpRead
) -> Result<(RpRead, Self::BlockingReader)>
fn blocking_read( &self, path: &str, args: OpRead ) -> Result<(RpRead, Self::BlockingReader)>
Invoke the
blocking_read
operation on the specified path. Read moresource§fn write<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
__arg2: OpWrite
) -> Pin<Box<dyn Future<Output = Result<(RpWrite, Self::Writer)>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn write<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, __arg2: OpWrite ) -> Pin<Box<dyn Future<Output = Result<(RpWrite, Self::Writer)>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,
Invoke the
write
operation on the specified path, returns a
written size if operate successful. Read moresource§fn blocking_write(
&self,
path: &str,
_: OpWrite
) -> Result<(RpWrite, Self::BlockingWriter)>
fn blocking_write( &self, path: &str, _: OpWrite ) -> Result<(RpWrite, Self::BlockingWriter)>
Invoke the
blocking_write
operation on the specified path. Read moresource§fn stat<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
__arg2: OpStat
) -> Pin<Box<dyn Future<Output = Result<RpStat>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn stat<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, __arg2: OpStat ) -> Pin<Box<dyn Future<Output = Result<RpStat>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,
Invoke the
stat
operation on the specified path. Read moresource§fn blocking_stat(&self, path: &str, _: OpStat) -> Result<RpStat>
fn blocking_stat(&self, path: &str, _: OpStat) -> Result<RpStat>
Invoke the
blocking_stat
operation on the specified path. Read moresource§fn delete<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
__arg2: OpDelete
) -> Pin<Box<dyn Future<Output = Result<RpDelete>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn delete<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, __arg2: OpDelete ) -> Pin<Box<dyn Future<Output = Result<RpDelete>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,
Invoke the
delete
operation on the specified path. Read moresource§fn blocking_delete(&self, path: &str, _: OpDelete) -> Result<RpDelete>
fn blocking_delete(&self, path: &str, _: OpDelete) -> Result<RpDelete>
Invoke the
blocking_delete
operation on the specified path. Read moresource§fn scan<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
__arg2: OpScan
) -> Pin<Box<dyn Future<Output = Result<(RpScan, Self::Pager)>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn scan<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, __arg2: OpScan ) -> Pin<Box<dyn Future<Output = Result<(RpScan, Self::Pager)>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,
Invoke the
scan
operation on the specified path. Read moresource§fn blocking_scan(
&self,
path: &str,
_: OpScan
) -> Result<(RpScan, Self::BlockingPager)>
fn blocking_scan( &self, path: &str, _: OpScan ) -> Result<(RpScan, Self::BlockingPager)>
Invoke the
blocking_scan
operation on the specified path. Read moresource§fn list<'life0, 'life1, 'async_trait>(
&'life0 self,
path: &'life1 str,
args: OpList
) -> Pin<Box<dyn Future<Output = Result<(RpList, Self::Pager)>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn list<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, args: OpList ) -> Pin<Box<dyn Future<Output = Result<(RpList, Self::Pager)>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,
Invoke the
list
operation on the specified path. Read moresource§fn presign(&self, path: &str, args: OpPresign) -> Result<RpPresign>
fn presign(&self, path: &str, args: OpPresign) -> Result<RpPresign>
Invoke the
presign
operation on the specified path. Read moresource§fn batch<'life0, 'async_trait>(
&'life0 self,
args: OpBatch
) -> Pin<Box<dyn Future<Output = Result<RpBatch>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn batch<'life0, 'async_trait>( &'life0 self, args: OpBatch ) -> Pin<Box<dyn Future<Output = Result<RpBatch>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,
Invoke the
batch
operations.source§fn blocking_list(
&self,
path: &str,
args: OpList
) -> Result<(RpList, Self::BlockingPager)>
fn blocking_list( &self, path: &str, args: OpList ) -> Result<(RpList, Self::BlockingPager)>
Invoke the
blocking_list
operation on the specified path. Read more