Skip to main content

SourceConfig

kinetic_common::config

Trait SourceConfig 

Source 
pub trait SourceConfig: Send + Sync {
    // Required method
    fn build(&self, cx: SourceContext) -> Result<JoinHandle<()>>;
}
Expand description

Trait for component configurations that can build a source task.

Required Methods§

Source

fn build(&self, cx: SourceContext) -> Result<JoinHandle<()>>

Implementors§