(rx: mpsc::Receiver<TelemetryEvent>)
| 424 | |
| 425 | #[cfg(feature = "telemetry")] |
| 426 | fn telemetry_worker(rx: mpsc::Receiver<TelemetryEvent>) { |
| 427 | for event in rx { |
| 428 | let payload = build_payload(event.name, event.event, &event.event_ts, ×tamp()); |
| 429 | let _ = publish_payload(&event.endpoint, payload); |
| 430 | } |
| 431 | } |
| 432 | |
| 433 | #[cfg(feature = "telemetry")] |
| 434 | fn publish_payload(endpoint: &str, payload: Value) -> Result<(), reqwest::Error> { |
no test coverage detected