binloginfo

package
v2.0.11-binlog+incompa... Latest Latest
Warning

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

Go to latest
Published: Jan 4, 2019 License: Apache-2.0 Imports: 16 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 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.

Jump to

Keyboard shortcuts

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