BinlogSource specifies the source and filter parameters for
Filtered Replication. KeyRange and Tables are legacy. Filter
is the new way to specify the filtering rules.
BinlogTransaction describes a transaction inside the binlogs.
It is streamed by vttablet for filtered replication, used during resharding.
Charset is the per-statement charset info from a QUERY_EVENT binlog entry.
CharsetConversion represent a conversion of text from one charset to another
FieldEvent represents the field info for a table.
Filter represents a list of ordered rules. The first
match wins.
Journal contains the metadata for a journal event.
The commit of a journal event indicates the point of no return
for a migration.
KeyspaceShard represents a keyspace and shard.
RowChange represents one row change.
If Before is set and not After, it’s a delete.
If After is set and not Before, it’s an insert.
If both are set, it’s an update.
RowEvent represent row events for one table.
Rule represents one rule in a Filter.
ShardGtid contains the GTID position for one shard.
It’s used in a request for requesting a starting position.
It’s used in a response to transmit the current position
of a shard. It’s also used in a Journal to indicate the
list of targets and shard positions to migrate to.
StreamKeyRangeRequest is the payload to StreamKeyRange
StreamKeyRangeResponse is the response from StreamKeyRange
StreamTablesRequest is the payload to StreamTables
StreamTablesResponse is the response from StreamTables
VEvent represents a vstream event.
A FieldEvent is sent once for every table, just before
the first event for that table. The client is expected
to cache this information and match it against the RowEvent
which contains the table name.
A GTID event always precedes a commitable event, which can be
COMMIT, DDL or OTHER.
OTHER events are non-material events that have no additional metadata.
A VGtid is a list of ShardGtids.
VStreamRequest is the payload for VStreamer
VStreamResponse is the response from VStreamer
VStreamResultsRequest is the payload for VStreamResults
The ids match VStreamRows, in case we decide to merge the two.
The ids match VStreamRows, in case we decide to merge the two.
VStreamResultsResponse is the response from VStreamResults
The ids match VStreamRows, in case we decide to merge the two.
VStreamRowsRequest is the payload for VStreamRows
VStreamRowsResponse is the response from VStreamRows
VStreamTablesRequest is the payload for VStreamTables
VStreamTablesResponse is the response from VStreamTables