data_pipeline_rs::data_handler

Trait DataObserver

source 
pub trait DataObserver<T> {
    // Required method
    fn observe(&mut self, data: &T);

    // Provided method
    fn get_stats(&self) -> Option<Value> { ... }
}

Required Methods§

source

fn observe(&mut self, data: &T)

Provided Methods§

source

fn get_stats(&self) -> Option<Value>

Implementors§