binloginfo

Documentation

Index

• func DisableSkipBinlogFlag()
• func GetPrewriteValue(ctx sessionctx.Context, createIfNotExists bool) *binlog.PrewriteValue
• func GetPumpClient() binlog.PumpClient
• func SetDDLBinlog(client interface{}, txn kv.Transaction, jobID int64, ddlQuery string)
• func SetGRPCTimeout(timeout time.Duration)
• func SetIgnoreError(on bool)
• func SetPumpClient(client binlog.PumpClient)
• type BinlogInfo
  • func (info *BinlogInfo) WriteBinlog(clusterID uint64) error

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

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.