naming

grafana · Jan 22, 2025 · be09cfb · be09cfb
1 parent 213344a
commit be09cfb
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 5 deletions.
diff --git a/pkg/dataobj/consumer/partition_processor.go b/pkg/dataobj/consumer/partition_processor.go
@@ -239,7 +239,7 @@ func (p *partitionProcessor) writeMetastores(backoff *backoff.Backoff, dataobjPa
 
 				if len(buf) > 0 {
 					replayStart := time.Now()
-					err = metastoreBuilder.FromObject(bytes.NewReader(buf))
+					err = metastoreBuilder.FromExisting(bytes.NewReader(buf))
 					if err != nil {
 						return nil, err
 					}

diff --git a/pkg/dataobj/reader.go b/pkg/dataobj/reader.go
@@ -25,9 +25,7 @@ type reader struct {
 }
 
 func newReader(bucket objstore.Bucket) *reader {
-	return &reader{
-		bucket: bucket,
-	}
+	return &reader{bucket: bucket}
 }
 
 // Objects returns an iterator over all data objects for the provided tenant.

diff --git a/pkg/loki/loki.go b/pkg/loki/loki.go
@@ -754,7 +754,7 @@ func (t *Loki) setupModuleManager() error {
 		Write:   {Ingester, Distributor, PatternIngester},
 		Backend: {QueryScheduler, Ruler, Compactor, IndexGateway, BloomPlanner, BloomBuilder, BloomGateway},
 
-		All: {QueryScheduler, QueryFrontend, Querier, Ingester, PatternIngester, Distributor, Ruler, Compactor, DataObjConsumer},
+		All: {QueryScheduler, QueryFrontend, Querier, Ingester, PatternIngester, Distributor, Ruler, Compactor},
 	}
 
 	if t.Cfg.Querier.PerRequestLimitsEnabled {