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 SetSchemaVersion(ctx context.Context, version int64)
• func WriteBinlog(bin *binlog.Binlog) error

Variables

var ClusterID uint64 = 1

ClusterID is set by command line argument, if not set, use default value 1.

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 a context.

func GetPrewriteValue

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

GetPrewriteValue gets binlog prewrite value in a context.

func GetSchemaVersion

func GetSchemaVersion(ctx context.Context) int64

GetSchemaVersion gets schema version in a context.

func SetSchemaVersion

func SetSchemaVersion(ctx context.Context, version int64)

SetSchemaVersion sets schema version to a context.

func WriteBinlog

func WriteBinlog(bin *binlog.Binlog) error

WriteBinlog writes a binlog to Pump.