Struct SqliteSink 

pub struct SqliteSink { /* private fields */ }

SQLite sink that batches events and writes them in transactions. Reuses the exact same table schema and insertion logic from SqliteLayer.

Implementations

impl SqliteSink

pub fn new(batch_size: usize) -> Result<Self>

Create a new SQLite sink with an in-memory database. Matches the API of SqliteLayer::new()

Arguments

• batch_size - Number of events to batch before flushing to disk

pub fn new_with_file( db_path: impl AsRef<Path>, batch_size: usize, ) -> Result<Self>

Create a new SQLite sink with a file-based database. Matches the API of SqliteLayer::new_with_file()

Arguments

• db_path - Path to SQLite database file
• batch_size - Number of events to batch before flushing to disk