messages library

Classes

AuthenticationMessage
AuthenticationMessageType
BackendKeyMessage
BeginMessage
BindCompleteMessage
BindMessage
CancelRequestMessage
ClientMessage
ClientMessageFormat
ClientMessageId
CloseCompleteMessage
CloseMessage
CommandCompleteMessage
CommitMessage
CopyBothResponseMessage
Identifies the message as a Start Copy Both response. This message is used only for Streaming Replication.
CopyDataMessage
A COPY data message.
CopyDoneMessage
A COPY-complete indicator.
DataRowMessage
DeleteMessage
DescribeMessage
EmptyQueryResponseMessage
ErrorField
ErrorFieldId
ErrorOrNoticeMessage
ErrorResponseMessage
ExecuteMessage
FieldDescription
HotStandbyFeedbackMessage
InsertMessage
JsonMessage
A non-standrd message for JSON data
LogicalReplicationMessage
A base class for all Logical Replication Message Formats from the server
Message
Either a ServerMessage or a ClientMessage.
NoDataMessage
NoticeMessage
NotificationResponseMessage
OriginMessage
ParameterDescriptionMessage
ParameterStatusMessage
ParseCompleteMessage
ParseMessage
PgByteDataWriter
PrimaryKeepAliveMessage
QueryMessage
ReadyForQueryMessage
ReadyForQueryMessageState
RelationMessage
RelationMessageColumn
ReplicationMessage
An abstraction for all client and server replication messages
ReplicationMessageId
RowDescriptionMessage
ServerMessage
SharedMessage
Messages that are shared between both the server and the client
SharedMessageId
StandbyStatusUpdateMessage
StartupMessage
SyncMessage
TerminateMessage
TruncateMessage
TupleData
TupleDataColumn
TypeMessage
UnknownLogicalReplicationMessage
A non-stnadard message for unkown messages
UnknownMessage
UpdateMessage
XLogDataLogicalMessage
XLogDataMessage

Functions

tryParseLogicalReplicationMessage(PgByteDataReader reader, int length) → LogicalReplicationMessage?
Tries to check if the bytesList is a LogicalReplicationMessage. If so, LogicalReplicationMessage is returned, otherwise null is returned.