addtl linting

Signed-off-by: Owen Diehl <[email protected]>

Author: owen-d

pkg/bloomcompactor/spec.go

@@ -115,7 +115,7 @@ func (s *SimpleBloomGenerator) populator(ctx context.Context) v1.BloomPopulatorF
 			Chunks:      toAdd,
 		})
 
-		s.tokenizer.Populate(series, srcBlooms, chunkItersWithFP.itr, ch)
+		s.tokenizer.Populate(srcBlooms, chunkItersWithFP.itr, ch)
 
 		if s.reporter != nil {
 			s.reporter(series.Fingerprint)

pkg/storage/bloom/v1/bloom_tokenizer.go

@@ -5,11 +5,12 @@ import (
 
 	"github.com/go-kit/log/level"
 
-	"github.com/grafana/loki/pkg/push"
 	"github.com/grafana/loki/v3/pkg/iter"
 	"github.com/grafana/loki/v3/pkg/logproto"
 	"github.com/grafana/loki/v3/pkg/storage/bloom/v1/filter"
 
+	"github.com/grafana/loki/pkg/push"
+
 	"github.com/grafana/loki/v3/pkg/util/encoding"
 	util_log "github.com/grafana/loki/v3/pkg/util/log"
 )
@@ -97,7 +98,6 @@ func (bt *BloomTokenizer) newBloom() *Bloom {
 }
 
 func (bt *BloomTokenizer) Populate(
-	series *Series,
 	blooms SizedIterator[*Bloom],
 	chks Iterator[ChunkRefWithIter],
 	ch chan *BloomCreation,
@@ -163,8 +163,6 @@ func (bt *BloomTokenizer) Populate(
 		SourceBytesAdded: bytesAdded,
 	}
 	close(ch)
-	return
-
 }
 
 // addChunkToBloom adds the tokens from the given chunk to the given bloom.

pkg/storage/bloom/v1/bloom_tokenizer_test.go

@@ -121,13 +121,9 @@ func TestTokenizerPopulate(t *testing.T) {
 	bloom := Bloom{
 		ScalableBloomFilter: *sbf,
 	}
-	series := Series{
-		Fingerprint: model.Fingerprint(lbsList[0].Hash()),
-	}
 
 	blooms, err := populateAndConsumeBloom(
 		bt,
-		series,
 		NewSliceIter([]*Bloom{&bloom}),
 		NewSliceIter([]ChunkRefWithIter{{Ref: ChunkRef{},
 			Itr: itr}}),
@@ -164,13 +160,8 @@ func TestBloomTokenizerPopulateWithoutPreexistingBloom(t *testing.T) {
 	)
 	require.Nil(t, err)
 
-	series := Series{
-		Fingerprint: model.Fingerprint(lbsList[0].Hash()),
-	}
-
 	blooms, err := populateAndConsumeBloom(
 		bt,
-		series,
 		NewEmptyIter[*Bloom](),
 		NewSliceIter([]ChunkRefWithIter{{Ref: ChunkRef{},
 			Itr: itr}}),
@@ -227,11 +218,6 @@ func TestTokenizerPopulateWontExceedMaxSize(t *testing.T) {
 	itr, err := chunkRefItrFromLines(line)
 	require.NoError(t, err)
 	go bt.Populate(
-		&Series{
-			Chunks: ChunkRefs{
-				{},
-			},
-		},
 		NewSliceIter([]*Bloom{
 			{
 				*filter.NewScalableBloomFilter(1024, 0.01, 0.8),
@@ -258,13 +244,12 @@ func TestTokenizerPopulateWontExceedMaxSize(t *testing.T) {
 
 func populateAndConsumeBloom(
 	bt *BloomTokenizer,
-	s Series,
 	blooms SizedIterator[*Bloom],
 	chks Iterator[ChunkRefWithIter],
 ) (res []*Bloom, err error) {
 	var e multierror.MultiError
 	ch := make(chan *BloomCreation)
-	go bt.Populate(&s, blooms, chks, ch)
+	go bt.Populate(blooms, chks, ch)
 	for x := range ch {
 		if x.Err != nil {
 			e = append(e, x.Err)
@@ -301,12 +286,9 @@ func BenchmarkPopulateSeriesWithBloom(b *testing.B) {
 		bloom := Bloom{
 			ScalableBloomFilter: *sbf,
 		}
-		series := Series{
-			Fingerprint: model.Fingerprint(lbsList[0].Hash()),
-		}
+
 		_, err = populateAndConsumeBloom(
 			bt,
-			series,
 			NewSliceIter([]*Bloom{&bloom}),
 			NewSliceIter([]ChunkRefWithIter{{Ref: ChunkRef{},
 				Itr: itr}}),

pkg/storage/bloom/v1/index.go

@@ -421,7 +421,7 @@ func (s *SeriesWithOffsets) Decode(
 	var (
 		err        error
 		lastEnd    model.Time
-		lastOffset BloomOffset = previousOffset
+		lastOffset = previousOffset
 	)
 	for i := range s.Offsets {
 		err = s.Offsets[i].Decode(dec, lastOffset)

pkg/storage/bloom/v1/util.go

@@ -16,8 +16,8 @@ const (
 	magicNumber = uint32(0xCA7CAFE5)
 	// Add new versions below
 	V1 Version = iota
-	// V2 supports single series blooms encoded over multipe pages
-	// to accomodate larger single series
+	// V2 supports single series blooms encoded over multiple pages
+	// to accommodate larger single series
 	V2
 )
 

pkg/storage/bloom/v1/versioned_builder.go

@@ -129,6 +129,7 @@ type SeriesWithBloom struct {
 	Bloom  *Bloom
 }
 
+//nolint:revive
 type V1Builder struct {
 	opts BlockOptions