From e19708566f9c94e8bbb1baf268bc8d58261eeedb Mon Sep 17 00:00:00 2001 From: yukun Date: Fri, 24 Dec 2021 10:51:55 +0800 Subject: [PATCH] [skip e2e]Add comment for pulsar reader (#14114) Signed-off-by: fishpenguin --- internal/util/mqclient/pulsar_reader.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/util/mqclient/pulsar_reader.go b/internal/util/mqclient/pulsar_reader.go index fe5b0a1c93..85a8029772 100644 --- a/internal/util/mqclient/pulsar_reader.go +++ b/internal/util/mqclient/pulsar_reader.go @@ -6,6 +6,7 @@ import ( "github.com/apache/pulsar-client-go/pulsar" ) +// pulsarReader contains a pulsar reader type pulsarReader struct { r pulsar.Reader }