From 75010777df100a0f69ead5258f179a062e8171c0 Mon Sep 17 00:00:00 2001 From: jaime Date: Tue, 21 Dec 2021 21:51:10 +0800 Subject: [PATCH] [skip e2e] Fix golint in mq_msgstream (#13917) Signed-off-by: yun.zhang Co-authored-by: yun.zhang --- internal/msgstream/mq_msgstream.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/msgstream/mq_msgstream.go b/internal/msgstream/mq_msgstream.go index e0a1618047..82abd04cbe 100644 --- a/internal/msgstream/mq_msgstream.go +++ b/internal/msgstream/mq_msgstream.go @@ -131,7 +131,7 @@ func (ms *mqMsgStream) AsConsumer(channels []string, subName string) { ms.AsConsumerWithPosition(channels, subName, mqclient.SubscriptionPositionEarliest) } -// Create consumer to receive message from channels, with initial position +// AsConsumerWithPosition Create consumer to receive message from channels, with initial position // if initial position is set to latest, last message in the channel is exclusive func (ms *mqMsgStream) AsConsumerWithPosition(channels []string, subName string, position mqclient.SubscriptionInitialPosition) { for _, channel := range channels {