Struct PostgresWriterConfig 

pub struct PostgresWriterConfig {
    pub uri: String,
    pub table: String,
    pub mode: PostgresWriteMode,
    pub cdc_op_column: String,
    pub cdc_ts_column: String,
    pub tls: PostgresTlsConfig,
    pub max_records_in_buffer: Option<usize>,
    pub max_buffer_size_bytes: usize,
    pub on_conflict_do_nothing: bool,
    pub threads: usize,
}

Postgres output connector configuration.

Fields

uri: String

Postgres URI. See: https://docs.rs/tokio-postgres/0.7.12/tokio_postgres/config/struct.Config.html

table: String

The table to write the output to.

mode: PostgresWriteMode

Write mode for the connector.

• materialized (default): Perform direct INSERT, UPDATE, and DELETE operations on the table.
• cdc: Write all operations as INSERT operations into an append-only event log with additional metadata columns describing the operation type and timestamp.

cdc_op_column: String

Name of the operation metadata column in CDC mode.

Only used when mode = "cdc". This column will contain:

• "i" for insert operations
• "u" for upsert operations
• "d" for delete operations

Default: "__feldera_op"

cdc_ts_column: String

Name of the timestamp metadata column in CDC mode.

Only used when mode = "cdc". This column will contain the timestamp (in RFC 3339 format) when the batch of updates was output by the pipeline.

Default: "__feldera_ts"

tls: PostgresTlsConfig

TLS/SSL configuration.

max_records_in_buffer: Option<usize>

The maximum number of records in a single buffer.

max_buffer_size_bytes: usize

The maximum buffer size in for a single operation. Note that the buffers of INSERT, UPDATE and DELETE queries are separate. Default: 1 MiB

on_conflict_do_nothing: bool

Specifies how the connector handles conflicts when executing an INSERT into a table with a primary key. By default, an existing row with the same key is overwritten. Setting this flag to true preserves the existing row and ignores the new insert.

This setting does not affect UPDATE statements, which always replace the value associated with the key.

This setting is not supported when mode = "cdc", since all operations are performed as append-only INSERTs into the target table. Any conflict in CDC mode will result in an error.

Default: false

threads: usize

The number of threads to use during encoding.

Default: 1

Implementations

impl PostgresWriterConfig

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

Trait Implementations

impl Clone for PostgresWriterConfig

fn clone(&self) -> PostgresWriterConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresWriterConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PostgresWriterConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for PostgresWriterConfig

fn eq(&self, other: &PostgresWriterConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for PostgresWriterConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<'__s> ToSchema<'__s> for PostgresWriterConfig

fn schema() -> (&'__s str, RefOr<Schema>)

Return a tuple of name and schema or reference to a schema that can be referenced by the name or inlined directly to responses, request bodies or parameters.

fn aliases() -> Vec<(&'__s str, Schema)>

Optional set of alias schemas for the ToSchema::schema.

impl Eq for PostgresWriterConfig

impl StructuralPartialEq for PostgresWriterConfig