Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetPrewriteValue

func GetPrewriteValue(ctx context.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 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