v2.0.11+incompatible Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Jan 3, 2019 License: Apache-2.0 Imports: 14 Imported by: 928




This section is empty.


This section is empty.


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 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 SetGRPCTimeout

func SetGRPCTimeout(timeout time.Duration)

SetGRPCTimeout sets grpc timeout for writing binlog.

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 SetPumpClient

func SetPumpClient(client binlog.PumpClient)

SetPumpClient sets the pump client instance.


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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL