From bba471c2bbcc478e3fbf833b2e47a7dddc06bb6d Mon Sep 17 00:00:00 2001 From: Bel LaPointe Date: Thu, 16 Mar 2023 14:12:08 -0600 Subject: [PATCH] stub --- src/config.rs | 33 +++++++++++++++++++++++ src/main.rs | 5 +++- src/testdata/config-kinesis-to-kafka.json | 4 +-- src/testdata/config-stdin-to-stdout.yaml | 4 +-- 4 files changed, 41 insertions(+), 5 deletions(-) create mode 100644 src/config.rs diff --git a/src/config.rs b/src/config.rs new file mode 100644 index 0000000..67be1d0 --- /dev/null +++ b/src/config.rs @@ -0,0 +1,33 @@ +#[derive(Debug)] +pub struct Config { + streams: Streams, +} + +#[derive(Debug)] +struct Streams { + input: Stream, + output: Stream, +} + +#[derive(Debug)] +struct Stream { + engine: Engine, +} + +#[derive(Debug)] +struct Engine { + name: String, +} + +pub fn build_config() -> Config { + return Config { + streams: Streams{ + input: Stream { + engine: Engine{ name: String::from("stdin") }, + }, + output: Stream { + engine: Engine{ name: String::from("stdout") }, + }, + }, + } +} diff --git a/src/main.rs b/src/main.rs index e7a11a9..1d8a9b5 100644 --- a/src/main.rs +++ b/src/main.rs @@ -1,3 +1,6 @@ +pub mod config; + fn main() { - println!("Hello, world!"); + let cfg = config::build_config(); + println!("{:?}", cfg); } diff --git a/src/testdata/config-kinesis-to-kafka.json b/src/testdata/config-kinesis-to-kafka.json index 3a3e669..8fc0e02 100644 --- a/src/testdata/config-kinesis-to-kafka.json +++ b/src/testdata/config-kinesis-to-kafka.json @@ -2,7 +2,7 @@ "streams": { "input": { "engine": { - "type": "kinesis", + "name": "kinesis", "kinesis": { "aws-region": "us-east-2", "aws-arn": "arn:aws:::us-east-2" @@ -11,7 +11,7 @@ }, "output": { "engine": { - "type": "kafka", + "name": "kafka", "kafka": { "topic": "topic-name" } diff --git a/src/testdata/config-stdin-to-stdout.yaml b/src/testdata/config-stdin-to-stdout.yaml index 9645d31..1ec2163 100644 --- a/src/testdata/config-stdin-to-stdout.yaml +++ b/src/testdata/config-stdin-to-stdout.yaml @@ -1,7 +1,7 @@ streams: input: engine: - type: stdin + name: stdin output: engine: - type: stdout + name: stdout