Trait RequestProcessor 

pub trait RequestProcessor: Send + Sync {
    // Required method
    fn process<'life0, 'life1, 'async_trait>(
        &'life0 self,
        request: &'life1 [u8],
    ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}

Request processor trait

Required Methods

fn process<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Process a request

Implementors

impl RequestProcessor for BrokerHeartbeatProcessor

impl RequestProcessor for ElectMasterProcessor

impl RequestProcessor for RegisterBrokerProcessor

impl RequestProcessor for UnregisterBrokerProcessor

impl RequestProcessor for GetMetadataProcessor

impl RequestProcessor for CreateTopicProcessor

impl RequestProcessor for DeleteTopicProcessor

impl RequestProcessor for UpdateTopicProcessor