Struct catapult::outputs::elasticsearch::Elasticsearch

pub struct Elasticsearch { /* fields omitted */ }

Methods

impl Elasticsearch

fn new(name: String) -> Elasticsearch

Trait Implementations

impl ConfigurableFilter for Elasticsearch

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 OutputProcessor for Elasticsearch

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

fn handle_func(rx: Receiver<String>, oconfig: 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>