Struct rerun::external::re_entity_db::entity_db::IngestionStatistics

pub struct IngestionStatistics {
    store_id: StoreId,
    e2e_latency_sec_history: Mutex<RawMutex, History<f32>>,
}

Fields

store_id: StoreId

e2e_latency_sec_history: Mutex<RawMutex, History<f32>>

Implementations

impl IngestionStatistics

pub fn new(store_id: StoreId) -> IngestionStatistics

pub fn current_e2e_latency_sec(&self) -> Option<f32>

What is the mean latency between the time data was logged in the SDK and the time it was ingested?

This is based on the clocks of the viewer and the SDK being in sync, so if the recording was done on another machine, this is likely very inaccurate.

Trait Implementations

impl ChunkStoreSubscriber for IngestionStatistics

fn name(&self) -> String

Arbitrary name for the subscriber.

fn as_any(&self) -> &(dyn Any + 'static)

Workaround for downcasting support, simply return self:

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

Workaround for downcasting support, simply return self:

fn on_events(&mut self, events: &[ChunkStoreEvent])

The core of this trait: get notified of changes happening in all ChunkStores.