Struct PostgresSourceConfig 

pub struct PostgresSourceConfig {

    pub hostname: String,
    pub port: u16,
    pub database: String,
    pub username: String,
    pub password: String,
    pub publication: String,
    pub publication_autocreate_mode: PublicationAutoCreateMode,
    pub replica_identity_autoset_values: Vec<PostgresReplicaIdentityRule>,
    pub publish_via_partition_root: bool,
    pub slot_name: String,
    pub drop_slot_on_stop: bool,
    pub slot_failover: bool,
    pub slot_ownership: SlotOwnership,
    pub offset_mismatch_strategy: PostgresOffsetMismatchStrategy,
    pub lsn_flush_mode: PostgresLsnFlushMode,
    pub lsn_flush_timeout: Duration,
    pub lsn_flush_timeout_action: PostgresLsnFlushTimeoutAction,
    pub slot_stream_params: BTreeMap<String, String>,
    pub database_initial_statements: Vec<String>,
    pub snapshot_locking_mode: PostgresSnapshotLockingMode,
    pub snapshot_lock_timeout: Duration,
    pub snapshot_isolation_mode: PostgresSnapshotIsolationMode,
    pub xmin_fetch_interval: Duration,
    pub tables: TableSelection,
    pub ssl_mode: String,
    pub ssl_root_cert: Option<String>,
    pub ssl_cert: Option<String>,
    pub ssl_key: Option<String>,
    pub ssl_key_password: Option<String>,
    pub connect_timeout: Duration,
    pub status_update_interval: Duration,
    pub tcp_keepalive: bool,
    pub heartbeat_interval: Duration,
    pub heartbeat_action_query: Option<String>,
    pub heartbeat_topics_prefix: String,
    pub heartbeat_topic_name: Option<String>,
    pub signal_data_collection: Option<String>,
    pub signal_enabled_channels: Vec<String>,
    pub signal_file: String,
    pub signal_poll_interval: Duration,
    pub signal_kafka_topic: Option<String>,
    pub signal_kafka_bootstrap_servers: Vec<String>,
    pub signal_kafka_group_id: String,
    pub signal_kafka_poll_timeout: Duration,
    pub signal_kafka_consumer_properties: BTreeMap<String, String>,
    pub incremental_snapshot_chunk_size: usize,
    pub incremental_snapshot_watermarking_strategy: String,
    pub read_only: bool,
    pub hstore_handling_mode: String,
    pub interval_handling_mode: String,
    pub include_unknown_datatypes: bool,
    pub money_fraction_digits: i16,
    pub schema_refresh_mode: PostgresSchemaRefreshMode,
    pub logical_decoding_messages: bool,
    pub message_prefix_include_list: Vec<String>,
    pub message_prefix_exclude_list: Vec<String>,
    pub column_transformations: Vec<ColumnTransformRule>,
}

Fields

hostname: String

port: u16

database: String

username: String

password: String

publication: String

publication_autocreate_mode: PublicationAutoCreateMode

replica_identity_autoset_values: Vec<PostgresReplicaIdentityRule>

publish_via_partition_root: bool

slot_name: String

drop_slot_on_stop: bool

slot_failover: bool

slot_ownership: SlotOwnership

offset_mismatch_strategy: PostgresOffsetMismatchStrategy

lsn_flush_mode: PostgresLsnFlushMode

lsn_flush_timeout: Duration

lsn_flush_timeout_action: PostgresLsnFlushTimeoutAction

slot_stream_params: BTreeMap<String, String>

database_initial_statements: Vec<String>

snapshot_locking_mode: PostgresSnapshotLockingMode

snapshot_lock_timeout: Duration

snapshot_isolation_mode: PostgresSnapshotIsolationMode

xmin_fetch_interval: Duration

tables: TableSelection

ssl_mode: String

ssl_root_cert: Option<String>

ssl_cert: Option<String>

ssl_key: Option<String>

ssl_key_password: Option<String>

connect_timeout: Duration

status_update_interval: Duration

tcp_keepalive: bool

heartbeat_interval: Duration

heartbeat_action_query: Option<String>

heartbeat_topics_prefix: String

heartbeat_topic_name: Option<String>

signal_data_collection: Option<String>

signal_enabled_channels: Vec<String>

signal_file: String

signal_poll_interval: Duration

signal_kafka_topic: Option<String>

signal_kafka_bootstrap_servers: Vec<String>

signal_kafka_group_id: String

signal_kafka_poll_timeout: Duration

signal_kafka_consumer_properties: BTreeMap<String, String>

incremental_snapshot_chunk_size: usize

incremental_snapshot_watermarking_strategy: String

read_only: bool

hstore_handling_mode: String

interval_handling_mode: String

include_unknown_datatypes: bool

money_fraction_digits: i16

schema_refresh_mode: PostgresSchemaRefreshMode

logical_decoding_messages: bool

message_prefix_include_list: Vec<String>

message_prefix_exclude_list: Vec<String>

column_transformations: Vec<ColumnTransformRule>

Implementations

impl PostgresSourceConfig

pub fn captures_logical_decoding_messages(&self) -> bool

pub fn includes_message_prefix(&self, prefix: &str) -> bool

pub fn connection_url(&self, replication: bool) -> Result<String>

Trait Implementations

impl Clone for PostgresSourceConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresSourceConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PostgresSourceConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PostgresSourceConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.