fix linter

ydb-platform · Dec 15, 2023 · 7fd9756 · 7fd9756
1 parent a620003
commit 7fd9756
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 6 deletions.
diff --git a/internal/grpcwrapper/rawtopic/rawtopicwriter/messages.go b/internal/grpcwrapper/rawtopic/rawtopicwriter/messages.go
@@ -187,10 +187,10 @@ func (d *MessageData) ToProto() (*Ydb_Topic.StreamWriteMessage_WriteRequest_Mess
 		return nil, err
 	}
 
-	for _, item := range d.MetadataItems {
+	for i := range d.MetadataItems {
 		res.MetadataItems = append(res.MetadataItems, &Ydb_Topic.MetadataItem{
-			Key:   item.Key,
-			Value: item.Value,
+			Key:   d.MetadataItems[i].Key,
+			Value: d.MetadataItems[i].Value,
 		})
 	}
 

diff --git a/internal/topic/topicreaderinternal/batch.go b/internal/topic/topicreaderinternal/batch.go
@@ -88,8 +88,8 @@ func newBatchFromStream(
 
 		if len(sMess.MetadataItems) > 0 {
 			dstMess.Metadata = make(map[string][]byte, len(sMess.MetadataItems))
-			for _, item := range sMess.MetadataItems {
-				dstMess.Metadata[item.Key] = item.Value
+			for metadataIndex := range sMess.MetadataItems {
+				dstMess.Metadata[sMess.MetadataItems[metadataIndex].Key] = sMess.MetadataItems[metadataIndex].Value
 			}
 		}
 

diff --git a/internal/topic/topicwriterinternal/writer_reconnector_test.go b/internal/topic/topicwriterinternal/writer_reconnector_test.go
@@ -108,7 +108,6 @@ func TestWriterImpl_Write(t *testing.T) {
 			require.NoError(t, err)
 			mess.metadataCached = true
 			expectedMap[k] = mess
-
 		}
 
 		require.Equal(t, expectedMap, w.queue.messagesByOrder)