diff options
| author | Matthias Beyer <matthias.beyer@ifm.com> | 2022-05-12 09:24:16 +0200 |
|---|---|---|
| committer | Matthias Beyer <matthias.beyer@ifm.com> | 2022-05-13 09:31:49 +0200 |
| commit | d53019d882cc0af2abab5bea4eaa50d38efbbe27 (patch) | |
| tree | cd9c3b5fd30646b73b787f0749715740bf520828 /plugins/plugin_measurement_filter/src | |
| parent | 0391990aaaf01303b9d1c60b6e8dc55bde90bb3c (diff) | |
plugin_measurement_filter: Add tracing information
This patch adds detailed tracing information to the
plugin_measurement_filter plugin implementation.
Signed-off-by: Matthias Beyer <matthias.beyer@ifm.com>
Diffstat (limited to 'plugins/plugin_measurement_filter/src')
| -rw-r--r-- | plugins/plugin_measurement_filter/src/plugin.rs | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/plugins/plugin_measurement_filter/src/plugin.rs b/plugins/plugin_measurement_filter/src/plugin.rs index dedb0880..d03f0f02 100644 --- a/plugins/plugin_measurement_filter/src/plugin.rs +++ b/plugins/plugin_measurement_filter/src/plugin.rs @@ -13,6 +13,7 @@ use crate::builder::MeasurementReceiver; use crate::extractor::Extractable; use crate::filter::Filterable; +#[derive(Debug)] pub struct MeasurementFilterPlugin { target: Address<MeasurementReceiver>, filtered_target: Option<Address<MeasurementReceiver>>, @@ -56,14 +57,15 @@ impl Plugin for MeasurementFilterPlugin { #[async_trait] impl Handle<Measurement> for MeasurementFilterPlugin { + #[tracing::instrument(name = "plugin.measurement_filter.handle_message", level = "trace")] async fn handle_message( &self, message: Measurement, _sender: ReplySenderFor<Measurement>, ) -> Result<(), PluginError> { - trace!("Extracting with {:?} from {:?}", self.extractor, message); + trace!(plugin.extractor = ?self.extractor, ?message, "Extracting from message"); if let Some(value) = message.extract(&self.extractor.0) { - trace!("Applying filter {:?} to value {:?}", self.filter, value); + trace!(plugin.filter = ?self.filter, ?value, "Applying filter"); if value.apply_filter(&self.filter) { let _ = self.target.send_and_wait(message).await; } else { |