Struct PostgresSourceBuilder 

pub struct PostgresSourceBuilder { /* private fields */ }

Builder for PostgreSQL source configuration.

Provides a fluent API for constructing PostgreSQL source configurations with sensible defaults.

Example

use drasi_source_postgres::PostgresReplicationSource;

let source = PostgresReplicationSource::builder("pg-source")
    .with_host("db.example.com")
    .with_database("production")
    .with_user("replication_user")
    .with_password("secret")
    .with_tables(vec!["users".to_string(), "orders".to_string()])
    .with_slot_name("my_slot")
    .build()?;

Implementations

impl PostgresSourceBuilder

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

Create a new PostgreSQL source builder with the given ID and default values

pub fn with_host(self, host: impl Into<String>) -> Self

Set the PostgreSQL host

pub fn with_port(self, port: u16) -> Self

Set the PostgreSQL port

pub fn with_database(self, database: impl Into<String>) -> Self

Set the database name

pub fn with_user(self, user: impl Into<String>) -> Self

Set the database user

pub fn with_password(self, password: impl Into<String>) -> Self

Set the database password

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

Set the tables to replicate

pub fn add_table(self, table: impl Into<String>) -> Self

Add a table to replicate

pub fn with_slot_name(self, slot_name: impl Into<String>) -> Self

Set the replication slot name

pub fn with_publication_name(self, publication_name: impl Into<String>) -> Self

Set the publication name

pub fn with_ssl_mode(self, ssl_mode: SslMode) -> Self

Set the SSL mode

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

Set the table key configurations

pub fn add_table_key(self, table_key: TableKeyConfig) -> Self

Add a table key configuration

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

Set the dispatch mode for this source

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

Set the dispatch buffer capacity for this source

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

Set the bootstrap provider for this source

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

Set whether this source should auto-start when DrasiLib starts.

Default is true. Set to false if this source should only be started manually via start_source().

pub fn with_config(self, config: PostgresSourceConfig) -> Self

Set the full configuration at once

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

Build the PostgreSQL replication source

Errors

Returns an error if the source cannot be constructed.