diff --git a/pkg/logql/log/pipeline.go b/pkg/logql/log/pipeline.go index a205039dd7715..181947fc07435 100644 --- 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 {