Trait re_space_view::external::re_chunk_store::ChunkStoreSubscriber

pub trait ChunkStoreSubscriber: Any + Send + Sync {
    // Required methods
    fn name(&self) -> String;
    fn as_any(&self) -> &(dyn Any + 'static);
    fn as_any_mut(&mut self) -> &mut (dyn Any + 'static);
    fn on_events(&mut self, events: &[ChunkStoreEvent]);
}

A ChunkStoreSubscriber subscribes to atomic changes from all ChunkStores through ChunkStoreEvents.

ChunkStoreSubscribers can be used to build both secondary indices and trigger systems.

Required Methods

fn name(&self) -> String

Arbitrary name for the subscriber.

Does not need to be unique.

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

Workaround for downcasting support, simply return self:

fn as_any(&self) -> &dyn std::any::Any {
    self
}

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

Workaround for downcasting support, simply return self:

fn as_any_mut(&mut self) -> &mut dyn std::any::Any {
    self
}

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

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

This will be called automatically by the ChunkStore itself if the subscriber has been registered: ChunkStore::register_subscriber. Or you might want to feed it ChunkStoreEvents manually, depending on your use case.

Example

fn on_events(&mut self, events: &[ChunkStoreEvent]) {
    use re_chunk_store::ChunkStoreDiffKind;
    for event in events {
        match event.kind {
            ChunkStoreDiffKind::Addition => println!("Row added: {}", event.row_id),
            ChunkStoreDiffKind::Deletion => println!("Row removed: {}", event.row_id),
        }
    }
}

Implementations on Foreign Types

impl ChunkStoreSubscriber for IngestionStatistics

fn name(&self) -> String

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

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

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

impl ChunkStoreSubscriber for EntityTree

fn name(&self) -> String

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

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

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

impl ChunkStoreSubscriber for TimeHistogramPerTimeline

fn name(&self) -> String

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

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

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

impl ChunkStoreSubscriber for TimesPerTimeline

fn name(&self) -> String

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

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

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

Implementors

impl ChunkStoreSubscriber for QueryCache