Struct PostgresWriterConfig 

pub struct PostgresWriterConfig {

    pub max_buffer_size_bytes: u64,
    pub max_records_in_buffer: Option<u64>,
    pub on_conflict_do_nothing: Option<bool>,
    pub ssl_ca_location: Option<String>,
    pub ssl_ca_pem: Option<String>,
    pub ssl_certificate_chain_location: Option<String>,
    pub ssl_client_key: Option<String>,
    pub ssl_client_key_location: Option<String>,
    pub ssl_client_location: Option<String>,
    pub ssl_client_pem: Option<String>,
    pub table: String,
    pub uri: String,
    pub verify_hostname: Option<bool>,
}

Postgres output connector configuration.

JSON schema

{
 "description": "Postgres output connector configuration.",
 "type": "object",
 "required": [
   "table",
   "uri"
 ],
 "properties": {
   "max_buffer_size_bytes": {
     "description": "The maximum buffer size in for a single operation.\nNote that the buffers of `INSERT`, `UPDATE` and `DELETE` queries are\nseparate.\nDefault: 1 MiB",
     "default": 1048576,
     "type": "integer",
     "minimum": 0.0
   },
   "max_records_in_buffer": {
     "description": "The maximum number of records in a single buffer.",
     "type": [
       "integer",
       "null"
     ],
     "minimum": 0.0
   },
   "on_conflict_do_nothing": {
     "description": "Specifies how the connector handles conflicts when executing an `INSERT`\ninto a table with a primary key. By default, an existing row with the same\nkey is overwritten. Setting this flag to `true` preserves the existing row\nand ignores the new insert.\n\nThis setting does not affect `UPDATE` statements, which always replace the\nvalue associated with the key.\n\nDefault: `false`",
     "type": "boolean"
   },
   "ssl_ca_location": {
     "description": "Path to a file containing a sequence of CA certificates in PEM format.",
     "type": [
       "string",
       "null"
     ]
   },
   "ssl_ca_pem": {
     "description": "A sequence of CA certificates in PEM format.",
     "type": [
       "string",
       "null"
     ]
   },
   "ssl_certificate_chain_location": {
     "description": "The path to the certificate chain file.\nThe file must contain a sequence of PEM-formatted certificates,\nthe first being the leaf certificate, and the remainder forming\nthe chain of certificates up to and including the trusted root certificate.",
     "type": [
       "string",
       "null"
     ]
   },
   "ssl_client_key": {
     "description": "The client certificate key in PEM format.",
     "type": [
       "string",
       "null"
     ]
   },
   "ssl_client_key_location": {
     "description": "Path to the client certificate key.",
     "type": [
       "string",
       "null"
     ]
   },
   "ssl_client_location": {
     "description": "Path to the client certificate.",
     "type": [
       "string",
       "null"
     ]
   },
   "ssl_client_pem": {
     "description": "The client certificate in PEM format.",
     "type": [
       "string",
       "null"
     ]
   },
   "table": {
     "description": "The table to write the output to.",
     "type": "string"
   },
   "uri": {
     "description": "Postgres URI.\nSee: <https://docs.rs/tokio-postgres/0.7.12/tokio_postgres/config/struct.Config.html>",
     "type": "string"
   },
   "verify_hostname": {
     "description": "True to enable hostname verification when using TLS. True by default.",
     "type": [
       "boolean",
       "null"
     ]
   }
 }
}

Fields

max_buffer_size_bytes: u64

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

max_records_in_buffer: Option<u64>

The maximum number of records in a single buffer.

on_conflict_do_nothing: Option<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

ssl_ca_location: Option<String>

Path to a file containing a sequence of CA certificates in PEM format.

ssl_ca_pem: Option<String>

A sequence of CA certificates in PEM format.

ssl_certificate_chain_location: Option<String>

The path to the certificate chain file. The file must contain a sequence of PEM-formatted certificates, the first being the leaf certificate, and the remainder forming the chain of certificates up to and including the trusted root certificate.

ssl_client_key: Option<String>

The client certificate key in PEM format.

ssl_client_key_location: Option<String>

Path to the client certificate key.

ssl_client_location: Option<String>

Path to the client certificate.

ssl_client_pem: Option<String>

The client certificate in PEM format.

table: String

The table to write the output to.

uri: String

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

verify_hostname: Option<bool>

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

Implementations

impl PostgresWriterConfig

pub fn builder() -> PostgresWriterConfig

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 From<&PostgresWriterConfig> for PostgresWriterConfig

fn from(value: &PostgresWriterConfig) -> Self

Converts to this type from the input type.

impl From<PostgresWriterConfig> for PostgresWriterConfig

fn from(value: PostgresWriterConfig) -> Self

Converts to this type from the input type.

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 TryFrom<PostgresWriterConfig> for PostgresWriterConfig

type Error = ConversionError

The type returned in the event of a conversion error.

fn try_from(value: PostgresWriterConfig) -> Result<Self, ConversionError>

Performs the conversion.