| 110 | S: tracing::Subscriber, |
| 111 | { |
| 112 | fn on_event( |
| 113 | &self, |
| 114 | event: &tracing::Event<'_>, |
| 115 | _ctx: tracing_subscriber::layer::Context<'_, S>, |
| 116 | ) { |
| 117 | let mut extractor = LogExtract::default(); |
| 118 | event.record(&mut extractor); |
| 119 | let mut message = match extractor.msg { |
| 120 | Some(m) => m, |
| 121 | None => return, |
| 122 | }; |
| 123 | |
| 124 | // Append any additional fields to the message |
| 125 | if !extractor.fields.is_empty() { |
| 126 | let fields_str: Vec<String> = extractor |
| 127 | .fields |
| 128 | .iter() |
| 129 | .map(|(k, v)| format!("{}=\"{}\"", k, v)) |
| 130 | .collect(); |
| 131 | message = format!("{} [{}]", message, fields_str.join(", ")); |
| 132 | } |
| 133 | |
| 134 | let level = event.metadata().level().into(); |
| 135 | self.sender.send(LogEntry { level, message }).unwrap(); |
| 136 | } |
| 137 | } |
| 138 | |
| 139 | impl From<&Level> for LogLevel { |