diff --git a/storage/remote/queue_manager.go b/storage/remote/queue_manager.go index e7aafaf3e..b33230518 100644 --- a/storage/remote/queue_manager.go +++ b/storage/remote/queue_manager.go @@ -670,7 +670,8 @@ func (t *QueueManager) StoreSeries(series []record.RefSeries, index int) { } } -// Update the segment number held against the series, so we can trim older ones in SeriesReset. +// UpdateSeriesSegment updates the segment number held against the series, +// so we can trim older ones in SeriesReset. func (t *QueueManager) UpdateSeriesSegment(series []record.RefSeries, index int) { t.seriesSegmentMtx.Lock() defer t.seriesSegmentMtx.Unlock()