Struct catapult::inputs::random::Random

pub struct Random { /* fields omitted */ }

Methods

impl Random

Random input

• generate fake input according to column definitions

catapult.conf

input {
    random {
        fieldlist = "id:id,content:str"
        rate = 3
    }
}

Parameters

• rate: Number of messages per second
• fieldList: comma separated list of field name : type

Supported type

• String for now. All other types use string.

fn new(name: String) -> Random

Trait Implementations

impl ConfigurableFilter for Random

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 Random

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>