format

Documentation

Index

• Constants
• type Delete
  • func NewDelete(data []byte, streamedTransaction bool, relation map[uint32]*Relation, ...) (*Delete, error)
• type Insert
  • func NewInsert(data []byte, streamedTransaction bool, relation map[uint32]*Relation, ...) (*Insert, error)
• type Relation
  • func NewRelation(data []byte, streamedTransaction bool) (*Relation, error)
• type Update
  • func NewUpdate(data []byte, streamedTransaction bool, relation map[uint32]*Relation, ...) (*Update, error)

Constants

const (
	UpdateTupleTypeKey = 'K'
	UpdateTupleTypeOld = 'O'
	UpdateTupleTypeNew = 'N'
)

const (
	InsertTupleDataType = 'N'
)

Types

type Delete

type Delete struct {
	MessageTime    time.Time
	OldTupleData   *tuple.Data
	OldDecoded     map[string]any
	TableNamespace string
	TableName      string
	OID            uint32
	XID            uint32
	OldTupleType   uint8
}

func NewDelete

func NewDelete(data []byte, streamedTransaction bool, relation map[uint32]*Relation, serverTime time.Time) (*Delete, error)

type Insert

type Insert struct {
	MessageTime    time.Time
	TupleData      *tuple.Data
	Decoded        map[string]any
	TableNamespace string
	TableName      string
	OID            uint32
	XID            uint32
}

func NewInsert

func NewInsert(data []byte, streamedTransaction bool, relation map[uint32]*Relation, serverTime time.Time) (*Insert, error)

type Relation

type Relation struct {
	Namespace     string
	Name          string
	Columns       []tuple.RelationColumn
	OID           uint32
	XID           uint32
	ColumnNumbers uint16
	ReplicaID     uint8
}

func NewRelation

func NewRelation(data []byte, streamedTransaction bool) (*Relation, error)

type Update

type Update struct {
	MessageTime    time.Time
	NewTupleData   *tuple.Data
	NewDecoded     map[string]any
	OldTupleData   *tuple.Data
	OldDecoded     map[string]any
	TableNamespace string
	TableName      string
	OID            uint32
	XID            uint32
	OldTupleType   uint8
}

func NewUpdate

func NewUpdate(data []byte, streamedTransaction bool, relation map[uint32]*Relation, serverTime time.Time) (*Update, error)