Versions in this module Expand all Collapse all v1 v1.0.9 Apr 20, 2018 Changes in this version + func GetPrewriteValue(ctx context.Context, createIfNotExists bool) *binlog.PrewriteValue + func GetPumpClient() binlog.PumpClient + func SetDDLBinlog(client interface{}, txn kv.Transaction, jobID int64, ddlQuery string) + func SetPumpClient(client binlog.PumpClient) + type BinlogInfo struct + Client binlog.PumpClient + Data *binlog.Binlog + func (info *BinlogInfo) WriteBinlog(clusterID uint64) error