mysqlbinlog

Documentation

Index

• type CheckPoint
• type InputMysqlBinlog
  • func (b *InputMysqlBinlog) BinlogEventToLog(event *replication.BinlogEvent) error
  • func (b *InputMysqlBinlog) Collect(collector pipeline.Collector) error
  • func (b *InputMysqlBinlog) Description() string
  • func (b *InputMysqlBinlog) Init(context pipeline.Context) (int, error)

Types

type CheckPoint

type CheckPoint struct {
	IndexFileDir   string
	BinlogFileName string
	Offset         int
}

type InputMysqlBinlog

type InputMysqlBinlog struct {
	IndexFilePath      string
	FromBegining       bool
	AutoMap            bool
	MaxSendEventPerSec int
	IntervalMs         int
	RowMode            bool
	// contains filtered or unexported fields
}

func (*InputMysqlBinlog) BinlogEventToLog

func (b *InputMysqlBinlog) BinlogEventToLog(event *replication.BinlogEvent) error

BinlogEventToLog is a callback for replication.parser.ParseFile to accept bin log events.

func (*InputMysqlBinlog) Collect

func (b *InputMysqlBinlog) Collect(collector pipeline.Collector) error

func (*InputMysqlBinlog) Description

func (b *InputMysqlBinlog) Description() string

func (*InputMysqlBinlog) Init

func (b *InputMysqlBinlog) Init(context pipeline.Context) (int, error)