decode

package

v0.3.2 Latest Latest Go to latest Published: Sep 10, 2026 License: Apache-2.0 Imports: 1 Imported by: 0

Details

Package decode defines logical-decoding contracts enforcing ST-4 and CO-4.

This section is empty.

This section is empty.

This section is empty.

type ChangeEvent struct {
	Kind    ChangeKind
	LSN     LSN
	Key     int64
	OldKey  *int64
	Columns []Column
}

ChangeEvent is one decoded row change. OldKey is non-nil only when an update moved the key.

func (e ChangeEvent) PresentColumns() []Column

PresentColumns returns only values present in the decoded row image.

type ChangeKind uint8

ChangeKind identifies a decoded row operation.

const (
	// Insert creates a row.
	Insert ChangeKind = iota + 1
	// Update changes a row.
	Update
	// Delete removes a row.
	Delete
)

func (k ChangeKind) String() string

String returns the stable operation name.

type Column struct {
	Name    string
	Value   any
	Present bool
}

Column is one decoded column. Present=false means pgoutput omitted an unchanged TOAST value, so an applier must leave the target column untouched.

type LSN uint64

LSN is a PostgreSQL log sequence number.

func (l LSN) String() string

String renders the PostgreSQL X/Y representation.