Enum postgres_replication::protocol::LogicalReplicationMessage

#[non_exhaustive]
pub enum LogicalReplicationMessage {
    Begin(BeginBody),
    Commit(CommitBody),
    Origin(OriginBody),
    Relation(RelationBody),
    Type(TypeBody),
    Insert(InsertBody),
    Update(UpdateBody),
    Delete(DeleteBody),
    Truncate(TruncateBody),
}

A message of the logical replication stream

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Begin(BeginBody)

A BEGIN statement

Commit(CommitBody)

A BEGIN statement

Origin(OriginBody)

An Origin replication message Note that there can be multiple Origin messages inside a single transaction.

Relation(RelationBody)

A Relation replication message

Type(TypeBody)

A Type replication message

Insert(InsertBody)

An INSERT statement

Update(UpdateBody)

An UPDATE statement

Delete(DeleteBody)

A DELETE statement

Truncate(TruncateBody)

A TRUNCATE statement

Implementations

impl LogicalReplicationMessage

pub fn parse(buf: &Bytes) -> Result<Self>

Trait Implementations

impl Debug for LogicalReplicationMessage

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

Formats the value using the given formatter.