Struct catapult::inputs::stdin::Stdin

pub struct Stdin { /* fields omitted */ }

Stdin input

• reads stdin

catapult.conf

input {
  stdin
}

Parameters

• none

Methods

impl Stdin

fn new(name: String) -> Stdin

Trait Implementations

impl ConfigurableFilter for Stdin

fn human_name(&self) -> &str

fn mandatory_fields(&self) -> Vec<&str>

fn requires_fields(&self,
                   optional_config: &Option<HashMap<String, String>>,
                   required_fields: Vec<&str>)

impl InputProcessor for Stdin

fn start(&self, config: &Option<HashMap<String, String>>) -> Receiver<String>

fn handle_func(tx: SyncSender<String>, _config: Option<HashMap<String, String>>)

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