Replicant.Decoder.Messages.Message (Replicant v0.3.1)

Copy Markdown View Source

M — a logical-decoding message emitted by pg_logical_emit_message. A TRANSACTIONAL message (flags = 1) arrives bracketed by Begin/Commit (or inside a streamed txn's S/E/c) and rides %Transaction.messages; a NON-TRANSACTIONAL message (flags = 0) arrives standalone and delivers via Replicant.Sink.handle_message/2. xid is set only for a streamed message. ordinal is set by the assembler for a transactional message (spec §7.1).

Summary

Types

t()

Types

t()

@type t() :: %Replicant.Decoder.Messages.Message{
  content: binary() | nil,
  lsn: Replicant.lsn() | nil,
  ordinal: non_neg_integer() | nil,
  prefix: String.t() | nil,
  transactional?: boolean() | nil,
  xid: non_neg_integer() | nil
}