binloginfo

package
v2.0.11+incompatible Latest Latest
Warning

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: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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.

Jump to

Keyboard shortcuts

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