Merge pull request #3 from Overmuse/SR/update_address

only read address from settings
Overmuse · Jun 21, 2021 · 3aaeced · 3aaeced
2 parents dac0397 + 08467cb
commit 3aaeced
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 15 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "reporting"
-version = "0.1.3"
+version = "0.1.4"
 authors = ["Sebastian Rollen <[email protected]>"]
 edition = "2018"
 

diff --git a/src/main.rs b/src/main.rs
@@ -23,9 +23,12 @@ async fn main() -> Result<()> {
     let settings = settings::Settings::new().context("Failed to load settings")?;
     let consumer = consumer(&settings.kafka).context("Failed to create kafka consumer")?;
     debug!("Creating dogstatsd client");
-    let client = Client::new("127.0.0.1:0", &settings.app.target_address)
-        .await
-        .context("Failed to create dogstatsd client")?;
+    let client = Client::new(
+        "127.0.0.1:0",
+        &format!("{}:8125", settings.app.target_address),
+    )
+    .await
+    .context("Failed to create dogstatsd client")?;
     while let Some(message) = consumer.stream().next().await {
         let message = message.context("Error from kafka")?;
         if let Some(payload) = message.payload() {