messages library

Classes

AuthenticationMessage
BackendKeyMessage
BaseMessage
Either a ServerMessage or a ClientMessage.
BeginMessage
BindCompleteMessage
BindMessage
ClientMessage
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.
CopyFailMessage
Aborta um COPY ... FROM STDIN em andamento; o servidor responde com um erro que contém reason.
CopyInResponseMessage
Início de um COPY ... FROM STDIN: o servidor espera os dados (CopyData) seguidos de CopyDone ou CopyFail.
CopyOutResponseMessage
Início de um COPY ... TO STDOUT: o servidor envia os dados (CopyData) seguidos de CopyDone.
DataRowMessage
DeleteMessage
DescribeMessage
ErrorField
ErrorResponseMessage
ExecuteMessage
HotStandbyFeedbackMessage
InsertMessage
JsonMessage
A non-standrd message for JSON data
LogicalReplicationMessage
A base class for all Logical Replication Message Formats from the server
NoDataMessage
NotificationResponseMessage
OriginMessage
ParameterDescriptionMessage
ParameterStatusMessage
ParseCompleteMessage
ParseMessage
PrimaryKeepAliveMessage
QueryMessage
ReadyForQueryMessage
RelationMessage
RelationMessageColumn
ReplicationMessage
An abstraction for all client and server replication messages
RowDescriptionMessage
ServerMessage
SharedMessages
Messages that are shared between both the server and the client
StandbyStatusUpdateMessage
StartupMessage
SyncMessage
TerminateMessage
TruncateMessage
TupleData
TupleDataColumn
TypeMessage
UnknownLogicalReplicationMessage
A non-stnadard message for unkown messages
UnknownMessage
UpdateMessage
XLogDataLogicalMessage
XLogDataMessage

Constants

pgMaxParameterCount → const int
Número máximo de parâmetros numa mensagem Bind (o protocolo usa 16 bits).

Functions

tooManyParametersException(int count) → PostgreSQLException
Erro lançado antes de enviar uma consulta com parâmetros demais. Sem essa verificação, a contagem estoura os 16 bits do protocolo e o servidor responde com um erro de protocolo difícil de entender.
tryParseLogicalReplicationMessage(Uint8List bytesList, Encoding encoding) → LogicalReplicationMessage?
Tries to check if the bytesList is a LogicalReplicationMessage. If so, LogicalReplicationMessage is returned, otherwise null is returned.