chore: remove minor dead code that was missed in a PR review (#15094)

Signed-off-by: Callum Styan <callumstyan@gmail.com>
grafana · Nov 25, 2024 · 1ea49e3 · 1ea49e3
1 parent 10b7478
commit 1ea49e3
Showing 1 changed file with 5 additions and 7 deletions.
diff --git a/pkg/logql/log/pipeline.go b/pkg/logql/log/pipeline.go
@@ -68,7 +68,7 @@ func (n *noopPipeline) ForStream(labels labels.Labels) StreamPipeline {
 	}
 	n.mu.RUnlock()
 
-	sp := &noopStreamPipeline{n.baseBuilder.ForLabels(labels, h), make([]int, 0, 10)}
+	sp := &noopStreamPipeline{n.baseBuilder.ForLabels(labels, h)}
 
 	n.mu.Lock()
 	defer n.mu.Unlock()
@@ -93,8 +93,7 @@ func IsNoopPipeline(p Pipeline) bool {
 }
 
 type noopStreamPipeline struct {
-	builder    *LabelsBuilder
-	offsetsBuf []int
+	builder *LabelsBuilder
 }
 
 func (n noopStreamPipeline) ReferencedStructuredMetadata() bool {
@@ -181,13 +180,12 @@ func NewPipeline(stages []Stage) Pipeline {
 }
 
 type streamPipeline struct {
-	stages     []Stage
-	builder    *LabelsBuilder
-	offsetsBuf []int
+	stages  []Stage
+	builder *LabelsBuilder
 }
 
 func NewStreamPipeline(stages []Stage, labelsBuilder *LabelsBuilder) StreamPipeline {
-	return &streamPipeline{stages, labelsBuilder, make([]int, 0, 10)}
+	return &streamPipeline{stages, labelsBuilder}
 }
 
 func (p *pipeline) ForStream(labels labels.Labels) StreamPipeline {