common_meta::test_util

Trait MockDatanodeHandler

source
pub trait MockDatanodeHandler:
    Sync
    + Send
    + Clone {
    // Required methods
    fn handle<'life0, 'life1, 'async_trait>(
        &'life0 self,
        peer: &'life1 Peer,
        request: RegionRequest,
    ) -> Pin<Box<dyn Future<Output = Result<RegionResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn handle_query<'life0, 'life1, 'async_trait>(
        &'life0 self,
        peer: &'life1 Peer,
        request: QueryRequest,
    ) -> Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}

Required Methods§

source

fn handle<'life0, 'life1, 'async_trait>( &'life0 self, peer: &'life1 Peer, request: RegionRequest, ) -> Pin<Box<dyn Future<Output = Result<RegionResponse>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

source

fn handle_query<'life0, 'life1, 'async_trait>( &'life0 self, peer: &'life1 Peer, request: QueryRequest, ) -> Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types§

source§

impl MockDatanodeHandler for ()

source§

fn handle<'life0, 'life1, 'async_trait>( &'life0 self, _peer: &'life1 Peer, _request: RegionRequest, ) -> Pin<Box<dyn Future<Output = Result<RegionResponse>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

source§

fn handle_query<'life0, 'life1, 'async_trait>( &'life0 self, _peer: &'life1 Peer, _request: QueryRequest, ) -> Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Implementors§