From 67cab4e915fa414c04e192963fa96295f3c1dad1 Mon Sep 17 00:00:00 2001 From: yukun Date: Mon, 6 Dec 2021 19:47:46 +0800 Subject: [PATCH] [skip ci]Fix golint for rocksmq (#12811) Signed-off-by: fishpenguin --- internal/util/rocksmq/server/rocksmq/rocksmq_impl.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index e2529d3e5e..5cf6621b63 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -62,7 +62,7 @@ const ( CurrentIDSuffix = "current_id" ReaderNamePrefix = "reader-" - RmqNotServingErrMsg = "Rocksmq is not serving" + RmqNotServingErrMsg = "rocksmq is not serving" ) const ( @@ -992,7 +992,7 @@ func (rmq *rocksmq) CreateReader(topicName string, startMsgID UniqueID, messageI } nowTs, err := getNowTs(rmq.idAllocator) if err != nil { - return "", errors.New("Can't get current ts from rocksmq idAllocator") + return "", errors.New("can't get current ts from rocksmq idAllocator") } readerName := subscriptionRolePrefix + ReaderNamePrefix + strconv.FormatInt(nowTs, 10)