binloginfo

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 SetGRPCTimeout(timeout time.Duration)
• func SetIgnoreError(on bool)
• func SetPumpsClient(client *pumpcli.PumpsClient)
• 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 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 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 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.