CreateVReplication returns a statement to populate the first value into the _vt.vreplication table.

CreateVReplicationStopped returns a statement to create a stopped vreplication.

CreateVReplicationTable returns the statements required to create the _vt.vreplication table.

DeleteVReplication returns a statement to delete the replication.

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

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

NewDBClient creates a DBClient instance.

NewFakeDBClient returns a fake DBClient.

NewMockDBClient returns a new DBClientMock.

NewStats creates a new Stats structure.

ReadVReplicationPos returns a statement to query the gtid for a given shard from the _vt.vreplication table.

RegisterClientFactory adds a new factory.

StartVReplication returns a statement to start the replication.

StartVReplicationUntil returns a statement to start the replication with a stop position.

StopVReplication returns a statement to stop the replication.

BlpError is for the Error state.

BlplQuery is the key for the stats map.

BlplTransaction is the key for the stats map.

BlpRunning is for the Running state.

BlpStopped is for the Stopped state.

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

BinlogPlayer is for reading a stream of updates from BinlogServer.

MockDBClient mocks a DBClient.

Stats is the internal stats of a player.

StatsHistoryRecord is used to store a Message with timestamp.

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

Client is the interface all clients must satisfy.

DBClient is a high level interface to the database.

ClientFactory is the factory method to create a Client.