Struct catapult::inputs::network::Network

pub struct Network { /* fields omitted */ }

Network input

• listens on an UDP port for data, forward upstream

catapult.conf

input {
  network {
    listenPort = 6667
  }
}

Parameters

• listenPort: UDP port to listen to

Methods

impl Network

fn new(name: String) -> Network

Trait Implementations

impl ConfigurableFilter for Network

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 Network

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

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

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