Method StreamEvents

go/binlog/binlog_reader.go:11–11

(canStopStreaming func() bool, entriesChannel chan<- *BinlogEntry)

// a binary log file and parsing it into binlog entries
type BinlogReader interface {
	StreamEvents(canStopStreaming func() bool, entriesChannel chan<- *BinlogEntry) error
	Reconnect() error
}