From e00a4242df3174a79c33509cdd7cd2a6a6b281ca Mon Sep 17 00:00:00 2001 From: shaoyue Date: Mon, 8 Nov 2021 11:31:00 +0800 Subject: [PATCH] [skip ci] Add comments (#11408) Signed-off-by: shaoyue.chen --- internal/storage/binlog_writer.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/internal/storage/binlog_writer.go b/internal/storage/binlog_writer.go index 043591ede4..73ac64da5c 100644 --- a/internal/storage/binlog_writer.go +++ b/internal/storage/binlog_writer.go @@ -51,10 +51,12 @@ func (writer *baseBinlogWriter) isClosed() bool { return writer.buffer != nil } +// GetEventNums returns the number of event writers func (writer *baseBinlogWriter) GetEventNums() int32 { return int32(len(writer.eventWriters)) } +// GetRowNums returns writer's number of rows func (writer *baseBinlogWriter) GetRowNums() (int32, error) { if writer.isClosed() { return writer.length, nil