MCPcopy Create free account
hub / github.com/NVIDIA/OpenShell / telemetry_worker

Function telemetry_worker

crates/openshell-core/src/telemetry.rs:426–431  ·  view source on GitHub ↗
(rx: mpsc::Receiver<TelemetryEvent>)

Source from the content-addressed store, hash-verified

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

Callers 1

telemetry_senderFunction · 0.85

Calls 3

build_payloadFunction · 0.85
timestampFunction · 0.85
publish_payloadFunction · 0.85

Tested by

no test coverage detected