Trait dizhen::sources::Source

source ·
pub trait Source {
    // Required methods
    fn get_latest(&self) -> Result<Vec<Event>>;
    fn run_query(&self, query: &QueryPlan<'_>) -> Result<Vec<Event>>;

    // Provided method
    fn query(&self) -> QueryPlan<'_>
       where Self: Sized { ... }
}

Required Methods§

source

fn get_latest(&self) -> Result<Vec<Event>>

“Latest” here is defined as having data of at least 1 hour from now, usually above M3.0.

source

fn run_query(&self, query: &QueryPlan<'_>) -> Result<Vec<Event>>

Provided Methods§

source

fn query(&self) -> QueryPlan<'_>where Self: Sized,

Implementors§