liquid_cache_server

Trait StatsCollector

Source 
pub trait StatsCollector: Send + Sync {
    // Required methods
    fn start(&self, partition: usize, plan: &Arc<dyn ExecutionPlan>);
    fn stop(&self, partition: usize, plan: &Arc<dyn ExecutionPlan>);
}
Expand description

A trait to collect stats for the execution plan. The server calls start right before polling the stream, and calls stop right after exhausting the stream.

Required Methods§

Source

fn start(&self, partition: usize, plan: &Arc<dyn ExecutionPlan>)

Start the stats collector.

Source

fn stop(&self, partition: usize, plan: &Arc<dyn ExecutionPlan>)

Stop the stats collector.

Implementors§