Merge pull request #1380 fix internal name typo

rekby · web-flow · commit 64f418ef3350 · 2024-07-30T19:44:52.000+03:00
diff --git a/internal/topic/topicreadercommon/batch.go b/internal/topic/topicreadercommon/batch.go
@@ -44,17 +44,17 @@ func NewBatch(session *PartitionSession, messages []*PublicMessage) (*PublicBatc
 		}
 	}
 
-	offset := CommitRange{
+	commitRange := CommitRange{
 		PartitionSession: session,
 	}
 	if len(messages) > 0 {
-		offset.CommitOffsetStart = messages[0].commitRange.CommitOffsetStart
-		offset.CommitOffsetEnd = messages[len(messages)-1].commitRange.CommitOffsetEnd
+		commitRange.CommitOffsetStart = messages[0].commitRange.CommitOffsetStart
+		commitRange.CommitOffsetEnd = messages[len(messages)-1].commitRange.CommitOffsetEnd
 	}
 
 	return &PublicBatch{
 		Messages:    messages,
-		commitRange: offset,
+		commitRange: commitRange,
 	}, nil
 }
 

Original file line number	Diff line number	Diff line change
`@@ -44,17 +44,17 @@ func NewBatch(session PartitionSession, messages []PublicMessage) (*PublicBatc`
`44`	`44`	`}`
`45`	`45`	`}`
`46`	`46`
`47`		`- offset := CommitRange{`
	`47`	`+ commitRange := CommitRange{`
`48`	`48`	`PartitionSession: session,`
`49`	`49`	`}`
`50`	`50`	`if len(messages) > 0 {`
`51`		`- offset.CommitOffsetStart = messages[0].commitRange.CommitOffsetStart`
`52`		`- offset.CommitOffsetEnd = messages[len(messages)-1].commitRange.CommitOffsetEnd`
	`51`	`+ commitRange.CommitOffsetStart = messages[0].commitRange.CommitOffsetStart`
	`52`	`+ commitRange.CommitOffsetEnd = messages[len(messages)-1].commitRange.CommitOffsetEnd`
`53`	`53`	`}`
`54`	`54`
`55`	`55`	`return &PublicBatch{`
`56`	`56`	`Messages: messages,`
`57`		`- commitRange: offset,`
	`57`	`+ commitRange: commitRange,`
`58`	`58`	`}, nil`
`59`	`59`	`}`
`60`	`60`