From 271be517c99a34262d61b8c53b9d91cee64b51c4 Mon Sep 17 00:00:00 2001 From: Bel LaPointe Date: Thu, 23 Mar 2023 10:26:12 -0600 Subject: [PATCH] oshit that worked --- src/.main.rs.swp | Bin 12288 -> 0 bytes src/config.rs | 2 +- src/engine.rs | 12 ++++++------ 3 files changed, 7 insertions(+), 7 deletions(-) delete mode 100644 src/.main.rs.swp diff --git a/src/.main.rs.swp b/src/.main.rs.swp deleted file mode 100644 index c52d682620ec9d1cfd43fea2f614127ce80fd088..0000000000000000000000000000000000000000 GIT binary patch literal 0 HcmV?d00001 literal 12288 zcmeI2Ka12r7{+I>KNZDFkZ})=tZ=ipYjb4T%HpuF)5C7bpV>H&%!Fiuh@AHUECd_B zfZ!K7EIe%P18AvM7Ft;PCX-_m&ttJvo`GlIN#>n*-sd;fvK#Im+`G^B#FWvv!q~U3 zH{wSxjtAlE0SgN$)B63Ik(=C<)9GZgChvJuaJ+BEWf6@NlaxZ~$0m~^OoQAgZKa4z zHZH2tKHbSxE=Am=W`WY8DA$z7G6;acMFc9l+}Yb?cczowI%R8ki(k9?@S<$I2LTWO z0T2KI5C8!X009vA4++?Oz>dh*M(gc*8wbC|_7MRDKmY_l00ck)1V8`;KmY_l00cnb zA0!aOj6K+7?3h&l{(tuU|HoywlcPIOPSgAB#^xE;Zqh%sWTgV_QgRi6ipSXV=Yk4IOfsmeLuf z{*p@hex2oQ-|jgZiAp~yg4}c4I#zmV=e+b*`)2-tM=g05VArnDK_>Zp&WF_FaCJkJ iPluivcX#5Ryl&4eDz9OZnYea3WA(&ckDI%VGxiHq!we|^ 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,