rflow

Cargo.toml

@@ -45,15 +45,17 @@ metrics = { version = "0.22.3", optional = true }
 snmp = { version = "0.2.2", optional = true }
 rtsc = "0.2"
 rvideo = { version = "0.4", optional = true }
+rflow = { version = "0", optional = true }
 
 [features]
 eapi = ["eva-common", "eva-sdk", "busrt", "tokio", "hostname"]
 pipe = ["tokio/process", "tokio/io-util", "tokio/macros", "tokio/rt", "tokio/time"]
 rvideo = ["dep:rvideo"]
+rflow = ["dep:rflow"]
 modbus = ["rmodbus"]
 openssl-vendored = ["busrt/openssl-vendored", "eva-common/openssl-vendored"]
 metrics = ["dep:metrics", "metrics-exporter-prometheus"]
-full = ["eapi", "modbus", "metrics", "pipe", "rvideo"]
+full = ["eapi", "modbus", "metrics", "pipe", "rvideo", "rflow"]
 #default = ["modbus"]
 
 [dev-dependencies]

src/lib.rs

@@ -215,12 +215,21 @@ pub fn suicide(delay: Duration, warn: bool) {
 #[cfg(feature = "rvideo")]
 pub use rvideo;
 
+#[cfg(feature = "rflow")]
+pub use rflow;
+
 #[cfg(feature = "rvideo")]
 /// Serves the default [`rvideo`] server at TCP port `0.0.0.0:3001`
 pub fn serve_rvideo() -> std::result::Result<(), rvideo::Error> {
     rvideo::serve("0.0.0.0:3001").map_err(Into::into)
 }
 
+#[cfg(feature = "rflow")]
+/// Serves the default [`rflow`] server at TCP port `0.0.0.0:4001`
+pub fn serve_rflow() -> std::result::Result<(), rflow::Error> {
+    rflow::serve("0.0.0.0:4001").map_err(Into::into)
+}
+
 /// Returns [Prometheus metrics exporter
 /// builder](https://docs.rs/metrics-exporter-prometheus/)
 ///