gogs
/
rusty-pipe
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

oshit that worked

master
Bel LaPointe 2023-03-23 10:26:12 -06:00
parent 5d65aa5b42
commit 271be517c9
3 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

BIN
src/.main.rs.swp
View File

Binary file not shown.

2
src/config.rs
View File

@ -76,7 +76,7 @@ fn build_config_std() -> Config {
}, },
output: Stream { output: Stream {
engine: Engine{ engine: Engine{
name: String::from("gui"), name: String::from("stdout"),
kafka: None, kafka: None,
device: None, device: None,
udp: None, udp: None,

12
src/engine.rs
View File

@ -24,7 +24,7 @@ pub fn build_input_engine(cfg: &Engine) -> Box<dyn InputEngine> {
Box::new(InputEngineStdin{}) Box::new(InputEngineStdin{})
} }
struct InputEngineDevice { pub struct InputEngineDevice {
} }
pub fn build_input_engine_device(cfg: &Engine) -> Result<InputEngineDevice, String> { pub fn build_input_engine_device(cfg: &Engine) -> Result<InputEngineDevice, String> {
@ -106,7 +106,7 @@ impl InputEngine for InputEngineDevice {
} }
} }
struct InputEngineUDP { pub struct InputEngineUDP {
last_socket: Option<std::net::UdpSocket>, last_socket: Option<std::net::UdpSocket>,
port: i32, port: i32,
} }
@ -140,7 +140,7 @@ impl InputEngine for InputEngineUDP {
} }
} }
struct InputEngineKafka { pub struct InputEngineKafka {
} }
pub fn build_input_engine_kafka(cfg: &Engine) -> Result<InputEngineKafka, String> { pub fn build_input_engine_kafka(cfg: &Engine) -> Result<InputEngineKafka, String> {
@ -154,7 +154,7 @@ impl InputEngine for InputEngineKafka {
} }
} }
struct InputEngineStdin {} pub struct InputEngineStdin {}
impl InputEngine for InputEngineStdin { impl InputEngine for InputEngineStdin {
fn get(&mut self) -> Vec<char> { fn get(&mut self) -> Vec<char> {
@ -201,7 +201,7 @@ pub fn build_output_engine(cfg: &Engine) -> Box<dyn OutputEngine> {
Box::new(OutputEngineStdout{}) Box::new(OutputEngineStdout{})
} }
struct OutputEngineStdout {} pub struct OutputEngineStdout {}
impl OutputEngine for OutputEngineStdout { impl OutputEngine for OutputEngineStdout {
fn put(&mut self, v: Vec<char>) { fn put(&mut self, v: Vec<char>) {
@ -230,7 +230,7 @@ mod test_output {
} }
} }
struct OutputEngineUDP { pub struct OutputEngineUDP {
last_socket: Option<std::net::UdpSocket>, last_socket: Option<std::net::UdpSocket>,
host: String, host: String,
port: i32, port: i32,