mysqlbinlog

type CheckPoint struct {
	IndexFileDir   string
	BinlogFileName string
	Offset         int
}

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