Struct EntityDispatcher 

pub struct EntityDispatcher { /* private fields */ }

Dispatches entity lifecycle events to Arrow RecordBatches.

This is separate from RecordBatchSink which handles tracing events (spans, events). Both use the same FlushCallback pattern to push batches to the database scanner’s tables.

Implementations

impl EntityDispatcher

pub fn new(batch_size: usize, flush_callback: FlushCallback) -> Self

Create a new EntityDispatcher with the specified batch size and flush callback.

The callback receives (table_name, record_batch) when a batch is ready. The callback should handle empty batches by creating the table with the schema but not appending the empty data.

Arguments

• batch_size - Number of rows to buffer before flushing each table
• flush_callback - Called with (table_name, record_batch) when a batch is ready

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

Flush all buffers, emitting batches for actors and meshes tables.

This always emits batches for both tables, even if they are empty. The callback is expected to handle empty batches by creating the table with the correct schema but not appending empty data.

Trait Implementations

impl Clone for EntityDispatcher

fn clone(&self) -> EntityDispatcher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl EntityEventDispatcher for EntityDispatcher

fn dispatch(&self, event: EntityEvent) -> Result<(), Error>

Dispatch an entity event to the appropriate handler.