Struct TelemetryWorker 

pub struct TelemetryWorker<C: HttpClientCapability + SleepCapability + MaybeSend + Sync + 'static> { /* private fields */ }

C is the capability bundle. Leaf crates pin it to a concrete type (NativeCapabilities on native, WasmCapabilities on wasm).

Trait Implementations

impl<C: HttpClientCapability + SleepCapability + MaybeSend + Sync + 'static> Debug for TelemetryWorker<C>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<C: HttpClientCapability + SleepCapability + MaybeSend + Sync + 'static> Worker for TelemetryWorker<C>

fn reset(&mut self)

Reset the worker state in the child process after a fork.

Discards inherited pending telemetry state and dedupe history without sending anything, and drains the mailbox so that actions queued before the fork are not processed by the child.

fn trigger<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Function called between each run to wait for the next run. This function should be cancellation safe as it can be cancelled at any yield point.

fn run<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Main worker function

fn shutdown<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Hook called when the app is shutting down. Can be used to flush remaining data.

fn initial_trigger<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: Send + 'async_trait,

Alternative trigger called on start to provide custom behavior. Defaults to trigger behavior.