Trait OutputChannel
dashpipe
pub trait OutputChannel { fn send(&self, msg: String); }
fn send(&self, msg: String)
impl OutputChannel for KafkaOutput
impl OutputChannel for NatsOutput
impl OutputChannel for StdoutOutput