binloginfo

Documentation

Index

• Variables
• func GetPrewriteValue(ctx context.Context, createIfNotExists bool) *binlog.PrewriteValue
• func SetDDLBinlog(txn kv.Transaction, jobID int64, ddlQuery string)
• func WriteBinlog(bin *binlog.Binlog, clusterID uint64) error

Variables

var PumpClient binlog.PumpClient

PumpClient is the gRPC client to write binlog, it is opened on server start and never close, shared by all sessions.

Functions

func GetPrewriteValue

func GetPrewriteValue(ctx context.Context, createIfNotExists bool) *binlog.PrewriteValue

GetPrewriteValue gets binlog prewrite value in the context.

func SetDDLBinlog

func SetDDLBinlog(txn kv.Transaction, jobID int64, ddlQuery string)

SetDDLBinlog sets DDL binlog in the kv.Transaction.

func WriteBinlog

func WriteBinlog(bin *binlog.Binlog, clusterID uint64) error

WriteBinlog writes a binlog to Pump.