Enum PgOutputMessage 

pub enum PgOutputMessage<'a> {
    Begin(BeginMessage),
    Commit(CommitMessage),
    Relation(RelationMessage<'a>),
    Insert(InsertMessage<'a>),
    Update(UpdateMessage<'a>),
    Delete(DeleteMessage<'a>),
    Truncate(TruncateMessage),
    Origin(OriginMessage<'a>),
    Type(TypeMessage<'a>),
    LogicalDecodingMessage(LogicalDecodingMessage<'a>),
    StreamStart(StreamStartMessage),
    StreamStop,
    StreamCommit(StreamCommitMessage),
    StreamAbort(StreamAbortMessage),
    Unsupported {
        msg_type: u8,
        data: &'a [u8],
    },
}

Variants

Begin(BeginMessage)

Commit(CommitMessage)

Relation(RelationMessage<'a>)

Insert(InsertMessage<'a>)

Update(UpdateMessage<'a>)

Delete(DeleteMessage<'a>)

Truncate(TruncateMessage)

Origin(OriginMessage<'a>)

Type(TypeMessage<'a>)

LogicalDecodingMessage(LogicalDecodingMessage<'a>)

StreamStart(StreamStartMessage)

StreamStop

StreamCommit(StreamCommitMessage)

StreamAbort(StreamAbortMessage)

Unsupported

A pgoutput message type that is part of the protocol but not yet fully supported (e.g., two-phase commit messages from proto_version 3+).

Fields

msg_type: u8

data: &'a [u8]

Trait Implementations

impl<'a> Debug for PgOutputMessage<'a>

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

Formats the value using the given formatter.