binlog

type DNSTracker struct {
	// contains filtered or unexported fields
}

type EventConsumer struct {
	// contains filtered or unexported fields
}

type GoMysqlLoggerAdapter struct {
	// contains filtered or unexported fields
}

type MysqlBinlogInput struct {
	*core.BaseInput
	Config *MysqlBinlogInputConfig
	// contains filtered or unexported fields
}

type MysqlBinlogInputConfig struct {
	ID              string
	Address         string // the mysql server ip:port address
	BackupAddress   string // the backup server address, if connecting Address fails will try this
	User            string
	Password        string
	ReplicationMode string // gtid or filepos
	SyncDDL         bool   // whether generate events for ddl
	SyncTxInfo      bool   // whether generate events for transaction boundaries
	SwitchByDNS     bool   // if switch mysql master slave by changing dns
}

type ServerInfo struct {
	Host            string
	Port            uint16
	ServerID        uint32
	ServerUUID      string
	GtidEnabled     bool
	File            string
	Pos             uint32
	ExecutedGtidSet string
	PurgedGtidSet   string
}