Trait Processor

pub trait Processor {
    // Required methods
    fn apply<'life0, 'life1, 'async_trait>(
        &'life0 self,
        payload: &'life1 Payload,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn prepare<'life0, 'life1, 'async_trait>(
        &'life0 self,
        config: &'life1 LoadTestConfig,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<Payload>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn dump_cache_to_file(&self, config: &LoadTestConfig);
}

Required Methods

fn apply<'life0, 'life1, 'async_trait>( &'life0 self, payload: &'life1 Payload, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

process commands in order

fn prepare<'life0, 'life1, 'async_trait>( &'life0 self, config: &'life1 LoadTestConfig, ) -> Pin<Box<dyn Future<Output = Result<Vec<Payload>>> + Send + 'async_trait>>

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

prepare payload for each thread according to LoadTestConfig

fn dump_cache_to_file(&self, config: &LoadTestConfig)

write results to file based on LoadTestConfig

Implementors

impl Processor for RpcCommandProcessor