binlog

type Event struct {
	// Data is the original binlog data
	Data    []byte
	Header  EventHeader
	Payload EventSet
}

type EventHeader struct {
	// Timestamp seconds since unix epoch
	Timestamp uint32
	// EventType https://dev.mysql.com/doc/internals/en/binlog-event-type.html
	EventType uint8
	// ServerID
	// server-id of the originating mysql-server. Used to filter out events in circular replication.
	ServerID uint32
	// EventSize size of the event (header, post-header, body)
	EventSize uint32
	// LogPos  position of the next event
	LogPos uint32
	// Flags
	// https://dev.mysql.com/doc/internals/en/binlog-event-flag.html
	Flags uint16
}

type EventSet struct {
	// Parsed is true when the event is parsed
	Parsed bool
	// FormatDescription event
	FormatDescription *FormatDescriptionEvent
	// Rotate event
	Rotate *RotateEvent
	// Query event
	Query *QueryEvent
	// Xid event
	Xid *XidEvent
	// Table map event
	TableMap *TableMapEvent
	// Rows event
	Rows *RowsEvent
	// Rows query event
	RowsQuery *RowsQueryEvent
	// Gtid event
	GTID *GTIDEvent
	// Mariadb gtid event
	MariadbGTID *MariadbGTIDEvent
	// Heartbeat event
	Heartbeat *HeartbeatEvent
}

type FormatDescriptionEvent struct {
	BinlogVersion          uint16
	MysqlServerVersion     [50]byte
	CreateTimestamp        uint32
	EventHeaderLength      uint8
	EventTypeHeaderLengths []byte
}

type GTIDEvent struct {
	CommitFlag uint8
	SID        []byte
	GNO        int64
}

type HeartbeatEvent struct {
	LogIdent string
}

type IPayload interface {
	Decode([]byte) error
}

type MariadbGTIDEvent struct {
	DomainID       uint32
	ServerID       uint32
	SequenceNumber uint64
}

type Parser struct {
	// contains filtered or unexported fields
}

type QueryEvent struct {
	// Post header
	SlaveProxyID     uint32
	ExecutionTime    uint32
	SchemaLength     uint8
	ErrorCode        uint16
	StatusVarsLength uint16
	// Payload
	StatusVars string
	Schema     string

	Query string
	// contains filtered or unexported fields
}

type RotateEvent struct {
	Position uint64
	NextName string
}

type Row struct {
	ColumnDatas []interface{}
}

type RowsEvent struct {
	Action      int
	TableID     uint64
	Table       *TableMapEvent
	Flags       uint16
	ExtraData   []byte
	ColumnCount uint64
	Bitmap1     []byte
	Bitmap2     []byte
	Rows        []*Row
	// Sync desc
	Rule *rule.SyncDesc
	// contains filtered or unexported fields
}

type RowsQueryEvent struct {
	QueryText string
}

type TableMapEvent struct {
	TableID      uint64
	Flags        uint16
	SchemaName   string
	TableName    string
	ColumnCount  uint64
	ColumnDefine []byte
	ColumnMeta   []uint16
	NullBitmask  []byte
	// contains filtered or unexported fields
}

type XidEvent struct {
	Xid uint64
}