From cf5d07dc661b9df35caba900ce8245a952919f35 Mon Sep 17 00:00:00 2001 From: yukun Date: Wed, 15 Dec 2021 18:29:26 +0800 Subject: [PATCH] [skip ci]Add comment for rocksmq reader_impl (#13442) Signed-off-by: fishpenguin --- internal/util/rocksmq/client/rocksmq/reader_impl.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/rocksmq/client/rocksmq/reader_impl.go b/internal/util/rocksmq/client/rocksmq/reader_impl.go index fecf20d2af..18ad4748e3 100644 --- a/internal/util/rocksmq/client/rocksmq/reader_impl.go +++ b/internal/util/rocksmq/client/rocksmq/reader_impl.go @@ -24,6 +24,7 @@ type reader struct { subscriptionRolePrefix string } +// newReader create a rocksmq reader from reader options func newReader(c *client, readerOptions *ReaderOptions) (*reader, error) { if c == nil { return nil, newError(InvalidConfiguration, "client is nil")