Struct OpenedTelemetry 

pub struct OpenedTelemetry {
    pub consent: ConsentStore,
    pub install_id: Option<InstallId>,
    pub reporter: Rc<DynamicReporter>,
    pub recent_log: Arc<InMemoryEventQueue>,
    pub policy: PrivacyPolicy,
    pub event_schema_version: u32,
}

Outcome of TelemetryBundle::open. Cheap to clone (every contained service is Rc/Arc-shaped). Registered into app_state by TeksiloAppBuilder::install_telemetry.

Fields

consent: ConsentStore

install_id: Option<InstallId>

reporter: Rc<DynamicReporter>

recent_log: Arc<InMemoryEventQueue>

Ring buffer of recently-emitted events. DynamicReporter::record tees every consent-gated event into this log in addition to forwarding to the active adapter. Bounded by TelemetryBundle::with_recent_log_capacity (default 200). Read by the PrivacySettings “Inspect data sent” accordion; independent of the adapter’s outbound queue (events stay in the recent log even after the adapter has flushed them).

policy: PrivacyPolicy

event_schema_version: u32

Implementations

impl OpenedTelemetry

pub fn flush_all(&self) -> Result<(), TelemetryBundleError>

Synchronous flush of consent + install_id files (the queue flush is the adapter’s responsibility — see UsageReporter::flush).

pub fn discard_pending(&self) -> Result<(), TelemetryError>

Wipe the recent-log ring buffer and ask each adapter to drop its outbound buffer. Called on consent revocation and on the “Erase my data” flow.

The recent-log discard happens inside DynamicReporter:: discard_pending() (so the revision signal is bumped from the same place it’s bumped on record()), not here.

Trait Implementations

impl Clone for OpenedTelemetry

fn clone(&self) -> OpenedTelemetry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for OpenedTelemetry

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

Formats the value using the given formatter.