diff --git a/src/.main.rs.swp b/src/.main.rs.swp deleted file mode 100644 index c52d682..0000000 Binary files a/src/.main.rs.swp and /dev/null differ diff --git a/src/config.rs b/src/config.rs index 7bca115..36dc7d1 100644 --- a/src/config.rs +++ b/src/config.rs @@ -76,7 +76,7 @@ fn build_config_std() -> Config { }, output: Stream { engine: Engine{ - name: String::from("gui"), + name: String::from("stdout"), kafka: None, device: None, udp: None, diff --git a/src/engine.rs b/src/engine.rs index a854edf..d51e3e8 100644 --- a/src/engine.rs +++ b/src/engine.rs @@ -24,7 +24,7 @@ pub fn build_input_engine(cfg: &Engine) -> Box { Box::new(InputEngineStdin{}) } -struct InputEngineDevice { +pub struct InputEngineDevice { } pub fn build_input_engine_device(cfg: &Engine) -> Result { @@ -106,7 +106,7 @@ impl InputEngine for InputEngineDevice { } } -struct InputEngineUDP { +pub struct InputEngineUDP { last_socket: Option, port: i32, } @@ -140,7 +140,7 @@ impl InputEngine for InputEngineUDP { } } -struct InputEngineKafka { +pub struct InputEngineKafka { } pub fn build_input_engine_kafka(cfg: &Engine) -> Result { @@ -154,7 +154,7 @@ impl InputEngine for InputEngineKafka { } } -struct InputEngineStdin {} +pub struct InputEngineStdin {} impl InputEngine for InputEngineStdin { fn get(&mut self) -> Vec { @@ -201,7 +201,7 @@ pub fn build_output_engine(cfg: &Engine) -> Box { Box::new(OutputEngineStdout{}) } -struct OutputEngineStdout {} +pub struct OutputEngineStdout {} impl OutputEngine for OutputEngineStdout { fn put(&mut self, v: Vec) { @@ -230,7 +230,7 @@ mod test_output { } } -struct OutputEngineUDP { +pub struct OutputEngineUDP { last_socket: Option, host: String, port: i32,