binloginfo

Documentation

Index

• Variables
• func ClearBinlog(ctx context.Context)
• func GetPrewriteValue(ctx context.Context, createIfNotExists bool) *binlog.PrewriteValue
• func GetSchemaVersion(ctx context.Context) int64
• func SetDDLBinlog(txn kv.Transaction, jobID int64, ddlQuery string)
• func SetSchemaVersion(ctx context.Context, version int64)
• 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 ClearBinlog

func ClearBinlog(ctx context.Context)

ClearBinlog clears binlog in the Context.

func GetPrewriteValue

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

GetPrewriteValue gets binlog prewrite value in the context.

func GetSchemaVersion

func GetSchemaVersion(ctx context.Context) int64

GetSchemaVersion gets schema version in the context.

func SetDDLBinlog

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

SetDDLBinlog sets DDL binlog in the kv.Transaction.

func SetSchemaVersion

func SetSchemaVersion(ctx context.Context, version int64)

SetSchemaVersion sets schema version to the context.

func WriteBinlog

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

WriteBinlog writes a binlog to Pump.