common_meta::kv_backend::rds

Trait KvQueryExecutor

Source 
pub trait KvQueryExecutor<T: Executor> {
    // Required methods
    fn range_with_query_executor<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        query_executor: &'life1 mut ExecutorImpl<'life2, T>,
        req: RangeRequest,
    ) -> Pin<Box<dyn Future<Output = Result<RangeResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn batch_put_with_query_executor<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        query_executor: &'life1 mut ExecutorImpl<'life2, T>,
        req: BatchPutRequest,
    ) -> Pin<Box<dyn Future<Output = Result<BatchPutResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn batch_get_with_query_executor<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        query_executor: &'life1 mut ExecutorImpl<'life2, T>,
        req: BatchGetRequest,
    ) -> Pin<Box<dyn Future<Output = Result<BatchGetResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn delete_range_with_query_executor<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        query_executor: &'life1 mut ExecutorImpl<'life2, T>,
        req: DeleteRangeRequest,
    ) -> Pin<Box<dyn Future<Output = Result<DeleteRangeResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn batch_delete_with_query_executor<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        query_executor: &'life1 mut ExecutorImpl<'life2, T>,
        req: BatchDeleteRequest,
    ) -> Pin<Box<dyn Future<Output = Result<BatchDeleteResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;

    // Provided method
    fn put_with_query_executor<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        query_executor: &'life1 mut ExecutorImpl<'life2, T>,
        req: PutRequest,
    ) -> Pin<Box<dyn Future<Output = Result<PutResponse>> + Send + 'async_trait>>
       where Self: Sync + 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait { ... }
}

Required Methods§

Source

fn range_with_query_executor<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query_executor: &'life1 mut ExecutorImpl<'life2, T>, req: RangeRequest, ) -> Pin<Box<dyn Future<Output = Result<RangeResponse>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Source

fn batch_put_with_query_executor<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query_executor: &'life1 mut ExecutorImpl<'life2, T>, req: BatchPutRequest, ) -> Pin<Box<dyn Future<Output = Result<BatchPutResponse>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Source

fn batch_get_with_query_executor<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query_executor: &'life1 mut ExecutorImpl<'life2, T>, req: BatchGetRequest, ) -> Pin<Box<dyn Future<Output = Result<BatchGetResponse>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Batch get with certain client. It’s needed for a client with transaction.

Source

fn delete_range_with_query_executor<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query_executor: &'life1 mut ExecutorImpl<'life2, T>, req: DeleteRangeRequest, ) -> Pin<Box<dyn Future<Output = Result<DeleteRangeResponse>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Source

fn batch_delete_with_query_executor<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query_executor: &'life1 mut ExecutorImpl<'life2, T>, req: BatchDeleteRequest, ) -> Pin<Box<dyn Future<Output = Result<BatchDeleteResponse>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Provided Methods§

Source

fn put_with_query_executor<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query_executor: &'life1 mut ExecutorImpl<'life2, T>, req: PutRequest, ) -> Pin<Box<dyn Future<Output = Result<PutResponse>> + Send + 'async_trait>>
where Self: Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Implementors§