Trait catapult::processor::OutputProcessor

pub trait OutputProcessor: ConfigurableFilter {
    fn start(&self,
             _rx: Receiver<String>,
             _config: &Option<HashMap<String, String>>)
             -> Result<JoinHandle<()>, String> { ... }
    fn handle_func(rx: Receiver<String>,
                   config: Option<HashMap<String, String>>) { ... }
    fn invoke(&self,
              rx: Receiver<String>,
              config: &Option<HashMap<String, String>>,
              handle_func: fn(_: Receiver<String>, _: Option<HashMap<String, String>>))
              -> Result<JoinHandle<()>, String> { ... }
}

Provided Methods

fn start(&self,
         _rx: Receiver<String>,
         _config: &Option<HashMap<String, String>>)
         -> Result<JoinHandle<()>, String>

fn handle_func(rx: Receiver<String>, config: Option<HashMap<String, String>>)

fn invoke(&self,
          rx: Receiver<String>,
          config: &Option<HashMap<String, String>>,
          handle_func: fn(_: Receiver<String>, _: Option<HashMap<String, String>>))
          -> Result<JoinHandle<()>, String>

Implementors

• impl OutputProcessor for Stdout
• impl OutputProcessor for Elasticsearch
• impl OutputProcessor for RotatingFile
• impl OutputProcessor for Network