message

type Begin struct {
	RawMessage
	FinalLSN  dbutils.LSN // LSN of the record that lead to this xact to be committed
	Timestamp time.Time   // Commit timestamp of the transaction
	XID       int32       // Xid of the transaction.
}

type Column struct {
	IsKey   bool        `yaml:"IsKey"` // column as part of the key.
	Name    string      `yaml:"Name"`  // Name of the column.
	TypeOID dbutils.OID `yaml:"OID"`   // OID of the column's data type.
	Mode    int32       `yaml:"Mode"`  // OID modifier of the column (atttypmod).
}

type Commit struct {
	RawMessage
	Flags          uint8       // Flags; currently unused (must be 0)
	LSN            dbutils.LSN // The LastLSN of the commit.
	TransactionLSN dbutils.LSN // LSN pointing to the end of the commit record + 1
	Timestamp      time.Time   // Commit timestamp of the transaction
}

type Delete struct {
	RawMessage
	RelationOID dbutils.OID // OID of the relation corresponding to the OID in the relation message.

	Ident      []TupleData // Key or old row values
	IdentIsKey bool        // Whether Ident is key
}

type DumpInfo struct {
	StartLSN       dbutils.LSN   `yaml:"StartLSN"`
	CreateDate     time.Time     `yaml:"CreateDate"`
	Relation       Relation      `yaml:"Relation"`
	BackupDuration time.Duration `yaml:"BackupDuration"`
}

type Insert struct {
	RawMessage
	RelationOID dbutils.OID // OID of the relation corresponding to the OID in the relation message.

	NewRow []TupleData
}

type MType int

type Message interface {
	fmt.Stringer

	MsgType() MType
	RawData() []byte
}

type NamespacedName struct {
	Namespace string `yaml:"Namespace"`
	Name      string `yaml:"Name"`
}

type Origin struct {
	RawMessage
	LSN  dbutils.LSN // The last LSN of the commit on the origin server.
	Name string
}

type RawMessage struct {
	Message
	Data []byte
}

type Relation struct {
	RawMessage
	NamespacedName `yaml:"NamespacedName"`

	OID             dbutils.OID     `yaml:"OID"`             // OID of the relation.
	ReplicaIdentity ReplicaIdentity `yaml:"ReplicaIdentity"` // Replica identity
	Columns         []Column        `yaml:"Columns"`         // Columns
}

type ReplicaIdentity uint8

type Truncate struct {
	RawMessage
	Cascade         bool
	RestartIdentity bool
	RelationOIDs    []dbutils.OID
}

type TupleData struct {
	Kind  TupleKind
	Value []byte
}

type TupleKind uint8

type Type struct {
	RawMessage
	NamespacedName

	OID dbutils.OID // OID of the data type
}

type Update struct {
	RawMessage
	RelationOID dbutils.OID // OID of the relation corresponding to the OID in the relation message.

	NewRow     []TupleData
	Ident      []TupleData // Key or old row values
	IdentIsKey bool        // Whether Ident is key
}