decoder

Documentation

Index

• Constants
• func Parse(src []byte) (message.Message, error)

Constants

const (
	InsertMsgType   = 'I'
	DeleteMsgType   = 'D'
	UpdateMsgType   = 'U'
	TruncateMsgType = 'T'
	BeginMsgType    = 'B'
	CommitMsgType   = 'C'
	TypeMsgType     = 'Y'
	OriginMsgType   = 'O'
	RelationMsgType = 'R'
)

Functions

func Parse

func Parse(src []byte) (message.Message, error)

Parse a logical replication message. See https://www.postgresql.org/docs/current/static/protocol-logicalrep-message-formats.html