From 08467cb0e9c3c1cb26a88990b456700f637e43e7 Mon Sep 17 00:00:00 2001 From: Sebastian Rollen Date: Mon, 21 Jun 2021 12:44:40 -0400 Subject: [PATCH] only read address from settings --- Cargo.lock | 22 +++++++++++----------- Cargo.toml | 2 +- src/main.rs | 9 ++++++--- 3 files changed, 18 insertions(+), 15 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index 1ab4a70..e50bbcc 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -730,9 +730,9 @@ checksum = "624a8340c38c1b80fd549087862da4ba43e08858af025b236e509b6649fc13d5" [[package]] name = "openssl" -version = "0.10.34" +version = "0.10.35" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "6d7830286ad6a3973c0f1d9b73738f69c76b739301d0229c4b96501695cbe4c8" +checksum = "549430950c79ae24e6d02e0b7404534ecf311d94cc9f861e9e4020187d13d885" dependencies = [ "bitflags", "cfg-if", @@ -759,9 +759,9 @@ dependencies = [ [[package]] name = "openssl-sys" -version = "0.9.63" +version = "0.9.65" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "b6b0d6fb7d80f877617dfcb014e605e2b5ab2fb0afdf27935219bb6bd984cb98" +checksum = "7a7907e3bfa08bb85105209cdfcb6c63d109f8f6c1ed6ca318fff5c1853fbc1d" dependencies = [ "autocfg", "cc", @@ -976,7 +976,7 @@ dependencies = [ [[package]] name = "reporting" -version = "0.1.3" +version = "0.1.4" dependencies = [ "alpaca", "anyhow", @@ -1037,9 +1037,9 @@ checksum = "3e52c148ef37f8c375d49d5a73aa70713125b7f19095948a923f80afdeb22ec2" [[package]] name = "rust_decimal" -version = "1.14.2" +version = "1.14.3" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "9787e62372fc0c5a0f3af64c392652db72d3ec1cc0cff1becc175d2c11e6fbcc" +checksum = "01127cb8617e5e21bcf2e19b5eb48317735ca677f1d0a94833c21c331c446582" dependencies = [ "arrayvec", "num-traits 0.2.14", @@ -1286,9 +1286,9 @@ checksum = "cda74da7e1a664f795bb1f8a87ec406fb89a02522cf6e50620d016add6dbbf5c" [[package]] name = "tokio" -version = "1.7.0" +version = "1.7.1" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "c79ba603c337335df6ba6dd6afc38c38a7d5e1b0c871678439ea973cd62a118e" +checksum = "5fb2ed024293bb19f7a5dc54fe83bf86532a44c12a2bb8ba40d64a4509395ca2" dependencies = [ "autocfg", "bytes", @@ -1527,9 +1527,9 @@ dependencies = [ [[package]] name = "vcpkg" -version = "0.2.14" +version = "0.2.15" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "70455df2fdf4e9bf580a92e443f1eb0303c390d682e2ea817312c9e81f8c3399" +checksum = "accd4ea62f7bb7a82fe23066fb0957d48ef677f6eeb8215f372f52e48bb32426" [[package]] name = "version_check" diff --git a/Cargo.toml b/Cargo.toml index 35f29b1..724677f 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "reporting" -version = "0.1.3" +version = "0.1.4" authors = ["Sebastian Rollen "] edition = "2018" diff --git a/src/main.rs b/src/main.rs index bee1a04..29b999a 100644 --- 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() {