()
| 1612 | } |
| 1613 | |
| 1614 | func (b *BinlogReader) GetQueueSize() int { |
| 1615 | if b != nil && b.binlogStreamer0 != nil { |
| 1616 | return b.binlogStreamer0.QueueSize() |
| 1617 | } else { |
| 1618 | return 0 |
| 1619 | } |
| 1620 | } |
| 1621 | |
| 1622 | func (b *BinlogReader) GetExtractedTxCount() uint32 { |
| 1623 | if b != nil { |