eneuber/paramod-rust
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: eneuber:ca43d6b9a562f5119114d62674aecbde057374b3
Branches Tags
eneuber:master
..
compare: eneuber:3ed80f4b687f95d20a88b86efee5b7a71a6105f7
Branches Tags
eneuber:master

No commits in common. "ca43d6b9a562f5119114d62674aecbde057374b3" and "3ed80f4b687f95d20a88b86efee5b7a71a6105f7" have entirely different histories.
ca43d6b9a5 ... 3ed80f4b68

3 changed files with 5 additions and 5 deletions
Show Stats Expand all files Collapse all files

2
Cargo.toml
View File

@ -1,7 +1,7 @@
[package] [package]
name = "paramod" name = "paramod"
version = "__VERSION__" version = "__VERSION__"
edition = "2024" edition = "2021"
[dependencies] [dependencies]
serde_yaml = "0.9" serde_yaml = "0.9"

2
Dockerfile
View File

@ -1,6 +1,6 @@
# Build Stage # Build Stage
FROM rust:1.85 as builder FROM rust:1.81 as builder
WORKDIR /usr/src/app WORKDIR /usr/src/app

6
src/influx.rs
View File

@ -31,7 +31,7 @@ pub fn start_influx_thread(config: Arc<Mutex<AppConfig>>, values: Arc<Mutex<Modb
if should_write(&config, name, "input_register") { if should_write(&config, name, "input_register") {
let point = WriteQuery::new(Timestamp::from(Utc::now()), measurement.clone()) let point = WriteQuery::new(Timestamp::from(Utc::now()), measurement.clone())
.add_field(name, *v) .add_field(name, *v)
// .add_tag("type", "input_register") .add_tag("type", "input_register")
.add_tag("location", location.as_str()) .add_tag("location", location.as_str())
.to_owned(); .to_owned();
points.push(point); points.push(point);
@ -44,7 +44,7 @@ pub fn start_influx_thread(config: Arc<Mutex<AppConfig>>, values: Arc<Mutex<Modb
if should_write(&config, name, "holding_register") { if should_write(&config, name, "holding_register") {
let point = WriteQuery::new(Timestamp::from(Utc::now()), measurement.clone()) let point = WriteQuery::new(Timestamp::from(Utc::now()), measurement.clone())
.add_field(name, *v) .add_field(name, *v)
// .add_tag("type", "holding_register") .add_tag("type", "holding_register")
.add_tag("location", location.as_str()) .add_tag("location", location.as_str())
.to_owned(); .to_owned();
points.push(point); points.push(point);
@ -57,7 +57,7 @@ pub fn start_influx_thread(config: Arc<Mutex<AppConfig>>, values: Arc<Mutex<Modb
if should_write(&config, name, "coils") { if should_write(&config, name, "coils") {
let point = WriteQuery::new(Timestamp::from(Utc::now()), measurement.clone()) let point = WriteQuery::new(Timestamp::from(Utc::now()), measurement.clone())
.add_field(name, *v) .add_field(name, *v)
// .add_tag("type", "coils") .add_tag("type", "coils")
.add_tag("location", location.as_str()) .add_tag("location", location.as_str())
.to_owned(); .to_owned();
points.push(point); points.push(point);