Struct PostgresWriterConfig 

pub struct PostgresWriterConfig {
    pub uri: String,
    pub table: String,
    pub ssl_ca_pem: Option<String>,
    pub ssl_client_pem: Option<String>,
    pub ssl_client_key: Option<String>,
    pub verify_hostname: Option<bool>,
    pub max_records_in_buffer: Option<usize>,
    pub max_buffer_size_bytes: usize,
    pub on_conflict_do_nothing: bool,
}

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.

ssl_ca_pem: Option<String>

The CA certificate in PEM format.

ssl_client_pem: Option<String>

The client certificate in PEM format.

ssl_client_key: Option<String>

The client certificate key in PEM format.

verify_hostname: Option<bool>

True to enable hostname verification when using TLS. True by default.

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.

Default: false

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