Documentation ¶
Index ¶
- func DisableSkipBinlogFlag()
- func GetPrewriteValue(ctx sessionctx.Context, createIfNotExists bool) *binlog.PrewriteValue
- func GetPumpsClient() *pumpcli.PumpsClient
- func MockPumpsClient(client binlog.PumpClient) *pumpcli.PumpsClient
- func SetDDLBinlog(client *pumpcli.PumpsClient, txn kv.Transaction, jobID int64, ddlQuery string)
- func SetIgnoreError(on bool)
- func SetPumpsClient(client *pumpcli.PumpsClient)
- type BinlogInfo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DisableSkipBinlogFlag ¶
func DisableSkipBinlogFlag()
DisableSkipBinlogFlag disable the skipBinlog flag.
func GetPrewriteValue ¶
func GetPrewriteValue(ctx sessionctx.Context, createIfNotExists bool) *binlog.PrewriteValue
GetPrewriteValue gets binlog prewrite value in the context.
func GetPumpsClient ¶
func GetPumpsClient() *pumpcli.PumpsClient
GetPumpsClient gets the pumps client instance.
func MockPumpsClient ¶
func MockPumpsClient(client binlog.PumpClient) *pumpcli.PumpsClient
MockPumpsClient creates a PumpsClient, used for test.
func SetDDLBinlog ¶
func SetDDLBinlog(client *pumpcli.PumpsClient, txn kv.Transaction, jobID int64, ddlQuery string)
SetDDLBinlog sets DDL binlog in the kv.Transaction.
func SetIgnoreError ¶
func SetIgnoreError(on bool)
SetIgnoreError sets the ignoreError flag, this function called when TiDB start up and find config.Binlog.IgnoreError is true.
func SetPumpsClient ¶
func SetPumpsClient(client *pumpcli.PumpsClient)
SetPumpsClient sets the pumps client instance.
Types ¶
type BinlogInfo ¶
type BinlogInfo struct { Data *binlog.Binlog Client *pumpcli.PumpsClient }
BinlogInfo contains binlog data and binlog client.
func (*BinlogInfo) WriteBinlog ¶
func (info *BinlogInfo) WriteBinlog(clusterID uint64) error
WriteBinlog writes a binlog to Pump.
Click to show internal directories.
Click to hide internal directories.