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.

StreamEventStream is the interface of the object returned by ServeUpdateStream.

VtClient is a high level interface to the database.

ClientFactory is the factory method to create a Client.