message

Documentation

Index

• Constants
• Variables
• func New(data []byte, serverTime time.Time, relation map[uint32]*format.Relation) (any, error)
• type Type

Constants

const (
	XLogDataByteID                = 'w'
	PrimaryKeepaliveMessageByteID = 'k'
)

Variables

var ErrorByteNotSupported = errors.New("message byte not supported")

Functions

func New

func New(data []byte, serverTime time.Time, relation map[uint32]*format.Relation) (any, error)

Types

type Type

type Type uint8

const (
	StreamAbortByte  Type = 'A'
	BeginByte        Type = 'B'
	CommitByte       Type = 'C'
	DeleteByte       Type = 'D'
	StreamStopByte   Type = 'E'
	InsertByte       Type = 'I'
	LogicalByte      Type = 'M'
	OriginByte       Type = 'O'
	RelationByte     Type = 'R'
	StreamStartByte  Type = 'S'
	TruncateByte     Type = 'T'
	UpdateByte       Type = 'U'
	TypeByte         Type = 'Y'
	StreamCommitByte Type = 'c'
)