Skip to main content

SinkConfig

kinetic_common::config

Trait SinkConfig 

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

Trait for component configurations that can build a sink task.

Required Methods§

Source

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

Implementors§