Struct SqliteSink 

pub struct SqliteSink { /* private fields */ }

Event sink that writes to the SQLite store.

Wraps the existing Store and converts ProxyEvent → StoreEvent.

Implementations

impl SqliteSink

pub fn new(store: Store) -> Self

pub fn shutdown(&mut self)

Shutdown the underlying store (flush pending writes).

Trait Implementations

impl EventSink for SqliteSink

fn on_event(&self, event: &ProxyEvent)

Process a single event. Must not block.

fn name(&self) -> &'static str

Human-readable sink name (for logging and debugging).

fn on_batch(&self, events: &[ProxyEvent])

Process a batch of events. Default calls on_event for each.

fn flush(&self)

Flush internal buffers to their destination.