()
| 1620 | } |
| 1621 | |
| 1622 | func (b *BinlogReader) GetExtractedTxCount() uint32 { |
| 1623 | if b != nil { |
| 1624 | return b.extractedTxCount |
| 1625 | } else { |
| 1626 | return 0 |
| 1627 | } |
| 1628 | } |
| 1629 | |
| 1630 | func (b *BinlogReader) GetQueueMem() int64 { |
| 1631 | if b != nil && b.binlogStreamer0 != nil { |