Struct SqliteSourceBuilder 

pub struct SqliteSourceBuilder { /* private fields */ }

Builder for SqliteSource.

Implementations

impl SqliteSourceBuilder

pub fn new(id: impl Into<String>) -> Self

Create a new builder with defaults.

pub fn with_path(self, path: impl Into<String>) -> Self

Use file-backed SQLite.

pub fn in_memory(self) -> Self

Use in-memory SQLite.

pub fn with_tables(self, tables: Vec<String>) -> Self

Set monitored tables.

pub fn with_table_keys(self, table_keys: Vec<TableKeyConfig>) -> Self

Set configured table keys.

pub fn with_rest_api(self, config: RestApiConfig) -> Self

Enable REST API.

pub fn start_from(self, start_from: StartFrom) -> Self

Set initial start behavior.

pub fn with_dispatch_mode(self, mode: DispatchMode) -> Self

Set dispatch mode.

pub fn with_dispatch_buffer_capacity(self, capacity: usize) -> Self

Set dispatch buffer capacity.

pub fn with_bootstrap_provider( self, provider: impl BootstrapProvider + 'static, ) -> Self

Set bootstrap provider.

pub fn auto_start(self, auto_start: bool) -> Self

Set source auto-start.

pub fn build(self) -> Result<SqliteSource>

Build source.