summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMatthias Beyer <matthias.beyer@ifm.com>2022-04-21 13:10:00 +0200
committerMatthias Beyer <matthias.beyer@ifm.com>2022-04-21 13:10:13 +0200
commit6ffac814139423ae1560f9a3a8a2ff46e1a191c2 (patch)
tree57cd3bbb97bd8f869073cf1c7b47d22340947035
parent15e9fbef1ad79c12c25964bd6d3293225c82773b (diff)
Integrate moneo mapper plugin in tedge-cli
Signed-off-by: Matthias Beyer <matthias.beyer@ifm.com>
-rw-r--r--Cargo.lock1
-rw-r--r--tedge/Cargo.toml3
-rw-r--r--tedge/example-moneo.toml37
-rw-r--r--tedge/src/main.rs7
4 files changed, 48 insertions, 0 deletions
diff --git a/Cargo.lock b/Cargo.lock
index 5a13076d..7c8019e6 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -3312,6 +3312,7 @@ dependencies = [
"plugin_inotify",
"plugin_log",
"plugin_measurement_filter",
+ "plugin_moneo_mapper",
"plugin_mqtt",
"plugin_mqtt_measurement_bridge",
"plugin_sysstat",
diff --git a/tedge/Cargo.toml b/tedge/Cargo.toml
index c951e7ca..bc6f0064 100644
--- a/tedge/Cargo.toml
+++ b/tedge/Cargo.toml
@@ -30,6 +30,7 @@ plugin_httpstop = { path = "../plugins/plugin_httpstop", optional = true }
plugin_measurement_filter = { path = "../plugins/plugin_measurement_filter", optional = true }
plugin_mqtt = { path = "../plugins/plugin_mqtt", optional = true }
plugin_mqtt_measurement_bridge = { path = "../plugins/plugin_mqtt_measurement_bridge", optional = true }
+plugin_moneo_mapper = { path = "../plugins/plugin_moneo_mapper", optional = true }
[features]
@@ -51,6 +52,8 @@ builtin_plugin_sysstat = ["plugin_sysstat"]
builtin_plugin_inotify = ["plugin_inotify"]
builtin_plugin_httpstop = ["plugin_httpstop"]
builtin_plugin_measurement_filter = ["plugin_measurement_filter"]
+builtin_plugin_moneo_mapper = ["plugin_moneo_mapper"]
mqtt = ["plugin_mqtt", "plugin_mqtt_measurement_bridge"]
+moneo = ["plugin_moneo_mapper"]
diff --git a/tedge/example-moneo.toml b/tedge/example-moneo.toml
new file mode 100644
index 00000000..e4025ccf
--- /dev/null
+++ b/tedge/example-moneo.toml
@@ -0,0 +1,37 @@
+communication_buffer_size = 10
+
+plugin_shutdown_timeout_ms = 10000
+
+[plugins]
+
+
+
+[plugins.logging]
+kind = "log"
+
+[plugins.logging.configuration]
+name = "logging"
+level = "trace"
+acknowledge = false
+setup_logger = false
+
+
+[plugins.plugmqtt]
+kind = "mqtt"
+
+[plugins.plugmqtt.configuration]
+host = "tcp://localhost:1883"
+target = "moneo"
+
+[[plugins.plugmqtt.configuration.subscriptions]]
+topic = "foodebetzma/suitevdevice/0000/80/X80/Timecounter/cds"
+qos = "at_most_once"
+
+
+[plugins.moneo]
+kind = "moneo_mapper"
+
+[plugins.moneo.configuration]
+target = "logging"
+
+
diff --git a/tedge/src/main.rs b/tedge/src/main.rs
index 210f02f0..904c0c43 100644
--- a/tedge/src/main.rs
+++ b/tedge/src/main.rs
@@ -119,6 +119,13 @@ async fn main() -> miette::Result<()> {
plugin_mqtt_measurement_bridge::MqttMeasurementBridgePluginBuilder::new()
);
+ let application = register_plugin!(
+ application,
+ "moneo",
+ plugin_moneo_mapper::MoneoMapperPluginBuilder,
+ plugin_moneo_mapper::MoneoMapperPluginBuilder
+ );
+
let (cancel_sender, application) = application.with_config(config)?;
info!("Application built");