Enum PostgresWriteMode 

pub enum PostgresWriteMode {
    Materialized,
    Cdc,
}

PostgreSQL write mode.

Determines how the PostgreSQL output connector writes data to the target table.

Variants

Materialized

Materialized mode: perform direct INSERT, UPDATE, and DELETE operations on the table. This is the default behavior and maintains the postgres table as a materialized snapshot of the output view.

Cdc

CDC (Change Data Capture) mode: write all operations as INSERT operations into a Postgres table that serves as an append-only event log. In this mode, inserts, updates, and deletes are all represented as new rows with metadata columns describing the operation type and timestamp.

Trait Implementations

impl Clone for PostgresWriteMode

fn clone(&self) -> PostgresWriteMode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresWriteMode

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

Formats the value using the given formatter.

impl Default for PostgresWriteMode

fn default() -> PostgresWriteMode

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PostgresWriteMode

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for PostgresWriteMode

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

Formats the value using the given formatter.

impl PartialEq for PostgresWriteMode

fn eq(&self, other: &PostgresWriteMode) -> 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 PostgresWriteMode

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 PostgresWriteMode

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 PostgresWriteMode

impl StructuralPartialEq for PostgresWriteMode