message

type Begin struct {
	FinalLSN  dbtypes.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 dbtypes.OID `yaml:"OID"`   // OID of the column's data type.
	Mode    int32       `yaml:"Mode"`  // OID modifier of the column (atttypmod).
}

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

type Delete struct {
	RelationOID dbtypes.OID // OID of the relation corresponding to the OID in the relation message.
	IsKey       bool        // OldRow contains columns which are part of REPLICA IDENTITY index.
	IsOld       bool        // OldRow contains old tuple in case of REPLICA IDENTITY set to FULL

	OldRow Row
}

type Insert struct {
	RelationOID dbtypes.OID // OID of the relation corresponding to the OID in the relation message.
	IsNew       bool        // Identifies tuple as a new tuple.

	NewRow Row
}

type MType int

type Message interface {
	fmt.Stringer
}

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

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

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

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

type ReplicaIdentity uint8

type Row []*Tuple // set of columns

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

type Tuple struct {
	Kind  TupleKind
	Value []byte
}

type TupleKind uint8

type Type struct {
	NamespacedName

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

type Update struct {
	RelationOID dbtypes.OID // OID of the relation corresponding to the OID in the relation message.
	IsKey       bool        // OldRow contains columns which are part of REPLICA IDENTITY index.
	IsOld       bool        // OldRow contains old tuple in case of REPLICA IDENTITY set to FULL
	IsNew       bool        // Identifies tuple as a new tuple.

	OldRow Row
	NewRow Row
}