Struct TelemetryPipeline 

pub struct TelemetryPipeline { /* private fields */ }

The full pipeline — owns the buffer, an uploader, and a background flush task.

Callers get a cheap TelemetryBuffer clone via TelemetryPipeline::buffer so hot paths do not need to pay for the uploader machinery.

Implementations

impl TelemetryPipeline

pub fn new(config: ProxyTelemetryConfig) -> Self

pub fn buffer(&self) -> TelemetryBuffer

pub fn config(&self) -> &ProxyTelemetryConfig

pub fn start(&mut self, auth: TelemetryAuth) -> Result<()>

Wire up the uploader and start the flush task. No-op when telemetry is disabled or when endpoint is not set.

pub async fn flush(&self) -> Result<usize>

Force an immediate flush. Returns the number of events uploaded.

pub async fn shutdown(&mut self)

Gracefully stop the background task, doing one final flush attempt.