Documentation
¶
Index ¶
- func DisableSkipBinlogFlag()
- func GetPrewriteValue(ctx sessionctx.Context, createIfNotExists bool) *binlog.PrewriteValue
- func GetPumpClient() binlog.PumpClient
- func SetDDLBinlog(client interface{}, txn kv.Transaction, jobID int64, ddlQuery string)
- func SetGRPCTimeout(timeout time.Duration)
- func SetIgnoreError(on bool)
- func SetPumpClient(client binlog.PumpClient)
- type BinlogInfo
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 ¶
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.
Source Files
Click to show internal directories.
Click to hide internal directories.