Struct PostgresSinkConfig 

pub struct PostgresSinkConfig {

    pub hostname: String,
    pub port: u16,
    pub database: String,
    pub username: String,
    pub password: String,
    pub schema_name: String,
    pub table_name: String,
    pub write_mode: WriteMode,
    pub primary_key_columns: Vec<String>,
    pub batch_size: usize,
    pub flush_interval: Duration,
    pub pool_size: usize,
    pub connect_timeout: Duration,
    pub ssl_mode: SslMode,
    pub auto_create_table: bool,
    pub changelog_mode: bool,
    pub delivery_guarantee: DeliveryGuarantee,
    pub sink_id: String,
}

Configuration for the PostgreSQL sink connector.

Parsed from SQL WITH (...) clause options via from_config.

Fields

hostname: String

PostgreSQL hostname.

port: u16

PostgreSQL port (default: 5432).

database: String

Database name.

username: String

Username for authentication.

password: String

Password for authentication.

schema_name: String

Target schema name (default: "public").

table_name: String

Target table name.

write_mode: WriteMode

Write mode: append (COPY BINARY) or upsert (ON CONFLICT).

primary_key_columns: Vec<String>

Primary key columns (required for upsert mode).

batch_size: usize

Maximum records to buffer before flushing.

flush_interval: Duration

Maximum time to buffer before flushing.

pool_size: usize

Connection pool size.

connect_timeout: Duration

Connection timeout.

ssl_mode: SslMode

SSL mode for connections.

auto_create_table: bool

Whether to create the target table if it doesn’t exist.

changelog_mode: bool

Whether to handle changelog/retraction records.

delivery_guarantee: DeliveryGuarantee

Delivery guarantee level.

sink_id: String

Sink ID for offset tracking (auto-generated if empty).

Implementations

impl PostgresSinkConfig

pub fn new(hostname: &str, database: &str, table_name: &str) -> Self

Creates a minimal config for testing.

pub fn from_config(config: &ConnectorConfig) -> Result<Self, ConnectorError>

Parses a sink config from a ConnectorConfig (SQL WITH clause).

Required keys

• hostname - PostgreSQL server hostname
• database - Target database name
• username - Authentication username
• table.name - Target table name

Errors

Returns ConnectorError::MissingConfig if required keys are absent, or ConnectorError::ConfigurationError on invalid values.

pub fn validate(&self) -> Result<(), ConnectorError>

Validates the configuration for consistency.

Errors

Returns ConnectorError::ConfigurationError on invalid combinations.

pub fn qualified_table_name(&self) -> String

Returns the fully qualified table name (schema.table).

pub fn effective_sink_id(&self) -> String

Returns the effective sink ID, auto-generating from table name if empty.

Trait Implementations

impl Clone for PostgresSinkConfig

fn clone(&self) -> PostgresSinkConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresSinkConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PostgresSinkConfig

fn default() -> Self

Returns the “default value” for a type.