BinlogReader is a general interface whose implementations can choose their methods of reading a binary log file and parsing it into binlog entries
| 8 | // BinlogReader is a general interface whose implementations can choose their methods of reading |
| 9 | // a binary log file and parsing it into binlog entries |
| 10 | type BinlogReader interface { |
| 11 | StreamEvents(canStopStreaming func() bool, entriesChannel chan<- *BinlogEntry) error |
| 12 | Reconnect() error |
| 13 | } |
no outgoing calls
no test coverage detected
searching dependent graphs…