Skip to content

Commit c3eaf9f

Browse files
committed
Fix accidental renaming during refactor
1 parent 2d6593a commit c3eaf9f

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

pkg/mimirpb/split.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ func SplitWriteRequestByMaxMarshalSizeRW2(req *WriteRequest, reqSize, maxSize in
9494
// If the next partial request doesn't have any timeseries yet, we add the series anyway, in order to avoid an infinite loop
9595
// if a single timeseries is bigger than the limit.
9696
if nextReqSize+seriesSize+symbolsSize > maxSize && len(nextReq.TimeseriesRW2) > 0 {
97-
// Flush the next partial request.
97+
// Finalize the next partial request.
9898
nextReq.SymbolsRW2 = nextReqSymbols.Symbols()
9999
partialReqs = append(partialReqs, nextReq)
100100

@@ -118,7 +118,7 @@ func SplitWriteRequestByMaxMarshalSizeRW2(req *WriteRequest, reqSize, maxSize in
118118
}
119119

120120
if len(nextReq.TimeseriesRW2) > 0 {
121-
// Flush the last partial request.
121+
// Finalize the next partial request.
122122
nextReq.SymbolsRW2 = nextReqSymbols.Symbols()
123123
partialReqs = append(partialReqs, nextReq)
124124
}
@@ -168,7 +168,7 @@ func splitTimeseriesByMaxMarshalSize(req *WriteRequest, reqSize, maxSize int) []
168168
// If the next partial request doesn't have any timeseries yet, we add the series anyway, in order to avoid an infinite loop
169169
// if a single timeseries is bigger than the limit.
170170
if nextReqSize+seriesSize > maxSize && nextReqTimeseriesLength > 0 {
171-
// Flush the next partial request.
171+
// Finalize the next partial request.
172172
nextReq.Timeseries = req.Timeseries[nextReqTimeseriesStart : nextReqTimeseriesStart+nextReqTimeseriesLength]
173173
partialReqs = append(partialReqs, nextReq)
174174

@@ -184,7 +184,7 @@ func splitTimeseriesByMaxMarshalSize(req *WriteRequest, reqSize, maxSize int) []
184184
}
185185

186186
if nextReqTimeseriesLength > 0 {
187-
// Flush the last partial request.
187+
// Finalize the last partial request.
188188
nextReq.Timeseries = req.Timeseries[nextReqTimeseriesStart : nextReqTimeseriesStart+nextReqTimeseriesLength]
189189
partialReqs = append(partialReqs, nextReq)
190190
}
@@ -234,7 +234,7 @@ func splitMetadataByMaxMarshalSize(req *WriteRequest, reqSize, maxSize int) []*W
234234
// If the next partial request doesn't have any metadata yet, we add the metadata anyway, in order to avoid an infinite loop
235235
// if a single metadata is bigger than the limit.
236236
if nextReqSize+metadataSize > maxSize && nextReqMetadataLength > 0 {
237-
// Flush the next partial request.
237+
// Finalize the next partial request.
238238
nextReq.Metadata = req.Metadata[nextReqMetadataStart : nextReqMetadataStart+nextReqMetadataLength]
239239
partialReqs = append(partialReqs, nextReq)
240240

0 commit comments

Comments
 (0)