Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetPrewriteValue ¶
func GetPrewriteValue(ctx sessionctx.Context, createIfNotExists bool) *binlog.PrewriteValue
GetPrewriteValue gets binlog prewrite value in the context.
func GetPumpClient ¶
func GetPumpClient() binlog.PumpClient
GetPumpClient gets the pump client instance.
func SetDDLBinlog ¶
func SetDDLBinlog(client interface{}, txn kv.Transaction, jobID int64, ddlQuery string)
SetDDLBinlog sets DDL binlog in the kv.Transaction.
func SetPumpClient ¶
func SetPumpClient(client binlog.PumpClient)
SetPumpClient sets the pump client instance.
Types ¶
type BinlogInfo ¶
type BinlogInfo struct { Data *binlog.Binlog Client binlog.PumpClient }
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.