CreateBlpCheckpoint returns the statements required to create the _vt.blp_checkpoint table.

NewBinlogPlayerKeyRange returns a new BinlogPlayer pointing at the server replicating the provided keyrange, starting at the startPosition, and updating _vt.blp_checkpoint with uid=startPosition.Uid.

NewBinlogPlayerTables returns a new BinlogPlayer pointing at the server replicating the provided tables, starting at the startPosition, and updating _vt.blp_checkpoint with uid=startPosition.Uid.

NewDbClient creates a DBClient instance.

NewStats creates a new Stats structure.

NewVtClientMock returns a new VtClientMock.

PopulateBlpCheckpoint returns a statement to populate the first value into the _vt.blp_checkpoint table.

QueryBlpCheckpoint returns a statement to query the gtid and flags for a given shard from the _vt.blp_checkpoint table.

QueryBlpThrottlerSettings returns a statement to query the throttler settings (used by filtered replication) for a given shard from the_vt.blp_checkpoint table.

ReadStartPosition will return the current start position and the flags for the provided binlog player.

RegisterClientFactory adds a new factory.

BinlogPlayerConnTimeout is the flag for binlog player connection timeout.

BlpFlagDontStart means don't start a BinlogPlayer.

BlplQuery is the key for the stats map.

BlplTransaction is the key for the stats map.

SlowQueryThreshold will cause we logging anything that's higher than it.

BinlogPlayer is handling reading a stream of updates from BinlogServer.

DBClient is a real VtClient backed by a mysql connection.

Stats is the internal stats of a player.

VtClientMock is a VtClient that writes to a writer instead of executing anything.

BinlogTransactionStream is the interface of the object returned by StreamTables and StreamKeyRange.

Client is the interface all clients must satisfy.

VtClient is a high level interface to the database.

ClientFactory is the factory method to create a Client.